Mercurial > hg > Members > kono > Cerium

annotate TaskManager/kernel/ppe/TaskManagerImpl.cc @ 479:5bda98b0b56d

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Double Linked List base TaskQueue
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Mon, 05 Oct 2009 10:36:37 +0900
parents e083c4ff91c1
children 46464727d825
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
5
75f184d16fa5 *** empty log message ***
gongo
parents: 3
diff changeset
1 #include <stdio.h>
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
2 #include "TaskManagerImpl.h"
46
f154d9d07a42 *** empty log message ***
gongo
parents: 42
diff changeset
3 #include "types.h"
f154d9d07a42 *** empty log message ***
gongo
parents: 42
diff changeset
4 #include "error.h"
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
5 #include "../sys_task/SysTask.h"
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
6
220
gongo@localhost.localdomain
parents: 115
diff changeset
7 static HTaskPtr systask_start;
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
8 static HTaskPtr systask_finish;
42
aa11038dbdc1 *** empty log message ***
gongo
parents: 18
diff changeset
9
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
10 void
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
11 noaction(void *p)
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
12 {
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
13 }
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
14
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
15 TaskManagerImpl::TaskManagerImpl(int num)
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
16 : machineNum(num), activeTaskQueue(NULL), waitTaskQueue(NULL) {}
50
7927e00fb8e2 *** empty log message ***
gongo
parents: 48
diff changeset
17
220
gongo@localhost.localdomain
parents: 115
diff changeset
18 /**
298
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
19 * 一番最初に PPE で実行される systask_start
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
20 * 一番最後に、全てのタスクの終了を待つ systask_finish
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
21 * 番兵的な意味で実装
220
gongo@localhost.localdomain
parents: 115
diff changeset
22 */
42
aa11038dbdc1 *** empty log message ***
gongo
parents: 18
diff changeset
23 void
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
24 TaskManagerImpl::systask_init(void)
42
aa11038dbdc1 *** empty log message ***
gongo
parents: 18
diff changeset
25 {
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
26 systask_register();
42
aa11038dbdc1 *** empty log message ***
gongo
parents: 18
diff changeset
27
220
gongo@localhost.localdomain
parents: 115
diff changeset
28 systask_start = create_task(SYSTASK_START);
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
29 systask_finish = create_task(SYSTASK_FINISH);
220
gongo@localhost.localdomain
parents: 115
diff changeset
30
gongo@localhost.localdomain
parents: 115
diff changeset
31 systask_start->spawn();
gongo@localhost.localdomain
parents: 115
diff changeset
32
298
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
33 // systask_finish で spawn すると
220
gongo@localhost.localdomain
parents: 115
diff changeset
34 // systask_finish->wait_for(systask_finish);
298
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
35 // とかなって無限ループになるので、
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
36 // これだけは明示的に append_waitTask() で
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
37 append_waitTask(systask_finish);
42
aa11038dbdc1 *** empty log message ***
gongo
parents: 18
diff changeset
38 }
aa11038dbdc1 *** empty log message ***
gongo
parents: 18
diff changeset
39
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
40 HTaskPtr
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
41 TaskManagerImpl::create_task(int cmd)
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
42 {
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
43 HTaskPtr new_task;
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
44
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
45 new_task = htaskImpl->create(cmd);
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
46 new_task->post_func = noaction;
63
54355e641172 *** empty log message ***
gongo
parents: 58
diff changeset
47 new_task->mimpl = this;
54355e641172 *** empty log message ***
gongo
parents: 58
diff changeset
48
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
49 return new_task;
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
50 }
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
51
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
52 /**
298
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
53 * task の依存関係を設定
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
54 * master task が終わってから、slave task を実行するように
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
55 * master->wait_for(slave);
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
56 */
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
57 void
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
58 TaskManagerImpl::set_task_depend(HTaskPtr master, HTaskPtr slave)
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
59 {
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
60 TaskQueuePtr m, s;
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
61
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
62 m = taskQueueImpl->create(master);
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
63 s = taskQueueImpl->create(slave);
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
64
479
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
65 master->wait_me->addLast(s);
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
66 slave->wait_i->addLast(m);
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
67 m->waiter = s;
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
68 }
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
69
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
70 /**
298
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
71 * タスクを実行可能キューまたは待機キューへ追加する。
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
72 * 依存関係が満たされていれば active, まだだったら wait へ。
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
73 * task->spawn();
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
74 */
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
75 void
18
0c9341da4522 *** empty log message ***
gongo
parents: 5
diff changeset
76 TaskManagerImpl::spawn_task(HTaskPtr task)
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
77 {
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
78 // waiter // master
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
79 // waitee // slave
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
80 if (task->wait_i == NULL) {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 298
diff changeset
81 append_activeTask(task);
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
82 } else {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 298
diff changeset
83 append_waitTask(task);
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
84 }
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
85
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
86 systask_finish->wait_for(task);
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
87 }
42
aa11038dbdc1 *** empty log message ***
gongo
parents: 18
diff changeset
88
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
89 /**
298
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
90 * Task を実行可能キューに追加する
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
91 */
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
92 void
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
93 TaskManagerImpl::append_activeTask(HTaskPtr task)
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
94 {
479
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
95 TaskQueuePtr q = taskQueueImpl->create(task);
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
96 activeTaskQueue->addLast(q);
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
97 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
98
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
99 /**
298
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
100 * タスクが実行する CPU を選択する
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
101 *
298
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
102 * 現在は CPU_PPE, CPU_SPE, SPE_ANY, SPE_0, SPE_1, ..., SPE_5
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
103 * types.h に書いてます。
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
104 */
65
519d24aa7ac8 *** empty log message ***
gongo
parents: 63
diff changeset
105 void
519d24aa7ac8 *** empty log message ***
gongo
parents: 63
diff changeset
106 TaskManagerImpl::set_task_cpu(HTaskPtr task, CPU_TYPE type)
519d24aa7ac8 *** empty log message ***
gongo
parents: 63
diff changeset
107 {
519d24aa7ac8 *** empty log message ***
gongo
parents: 63
diff changeset
108 task->cpu_type = type;
519d24aa7ac8 *** empty log message ***
gongo
parents: 63
diff changeset
109 }
519d24aa7ac8 *** empty log message ***
gongo
parents: 63
diff changeset
110
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
111 /**
298
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
112 * 終了したタスクから依存の処理とか
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
113 * post_func() はこのタスクが終了したら実行する関数。
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
114 *
298
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
115 * @param [task] 終了したタスク
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
116 */
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
117 void
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
118 TaskManagerImpl::check_task_finish(HTaskPtr task)
42
aa11038dbdc1 *** empty log message ***
gongo
parents: 18
diff changeset
119 {
479
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
120 TaskQueue *p = task->wait_me->getFirst();
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
121 while(p) {
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
122 TaskQueue *next = p->next;
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
123 HTaskPtr htask = (HTaskPtr)p->task;
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
124 TaskQueueInfo *wait_i = htask->wait_i;
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
125 // 相手の wait queue から自分(を指しているTaskQueue)を削除
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
126 wait_i->remove(p->waiter);
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
127
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
128 // queue を free する
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
129 wait_i->free(p->waiter);
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
130 wait_i->free(p);
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
131 p = next;
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
132 }
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
133
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
134 task->post_func(task->post_arg);
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
135 htaskImpl->free(task);
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
136 }
42
aa11038dbdc1 *** empty log message ***
gongo
parents: 18
diff changeset
137
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
138
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
139 void
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
140 TaskManagerImpl::append_waitTask(HTaskPtr task)
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
141 {
479
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
142 TaskQueuePtr q = taskQueueImpl->create(task);
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
143 waitTaskQueue ->addLast(q);
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
144 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
145
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
146 /**
298
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
147 * waitQueue の中で依存関係を満たしたタスクは
58fd16298954 from EUC to UTF-8
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
148 * activeQueue へ移す
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
149 */
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
150 void
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
151 TaskManagerImpl::wakeup_waitTask(void)
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
152 {
479
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
153 TaskQueuePtr p = waitTaskQueue->getFirst();
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
154 while (p) {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 298
diff changeset
155 HTaskPtr task = (HTaskPtr)p->task;
479
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
156 TaskQueue *next = p->next;
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 298
diff changeset
157 if (task->wait_i == NULL) {
479
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
158 waitTaskQueue->remove(p);
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
159 activeTaskQueue->addLast(p);
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 298
diff changeset
160 }
479
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
161 p = next;
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
162 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 94
diff changeset
163 }
54
90523ccc4dff *** empty log message ***
gongo
parents: 50
diff changeset
164
479
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
165 /* end */