Mercurial > hg > Members > kono > Cerium
annotate TaskManager/kernel/ppe/TaskManagerImpl.cc @ 801:974cd68383b3
TaslListInfo
author | Shinji KONO <kono@ie.u-ryukyu.ac.jp> |
---|---|
date | Sat, 22 May 2010 18:20:16 +0900 |
parents | 2708c4a7bade |
children | 3763d29f41a3 |
rev | line source |
---|---|
5 | 1 #include <stdio.h> |
3 | 2 #include "TaskManagerImpl.h" |
46 | 3 #include "types.h" |
4 #include "error.h" | |
518 | 5 #include "SchedTask.h" |
619 | 6 #include "Scheduler.h" |
634 | 7 #include "SysTask.h" |
8 #include "SysFunc.h" | |
801 | 9 #include <string.h> |
10 | |
619 | 11 |
220 | 12 static HTaskPtr systask_start; |
109 | 13 static HTaskPtr systask_finish; |
42 | 14 |
514 | 15 static void |
16 noaction(SchedTask *s, void *read, void *write) | |
3 | 17 { |
18 } | |
19 | |
109 | 20 TaskManagerImpl::TaskManagerImpl(int num) |
480
46464727d825
TaskQueueInfo initiaization...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
479
diff
changeset
|
21 : machineNum(num) { |
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
22 activeTaskQueue = new HTaskInfo(); |
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
23 waitTaskQueue = new HTaskInfo(); |
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
24 htaskImpl = waitTaskQueue ; // any HTaskInfo |
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
25 taskQueueImpl = new TaskQueueInfo(); |
480
46464727d825
TaskQueueInfo initiaization...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
479
diff
changeset
|
26 } |
50 | 27 |
220 | 28 /** |
298 | 29 * 一番最初に PPE で実行される systask_start |
220 | 30 */ |
42 | 31 void |
499 | 32 TaskManagerImpl::systask_init() |
42 | 33 { |
109 | 34 systask_register(); |
639 | 35 systask_start = create_task(StartTask,0,0,0,0); |
36 systask_finish = create_task(FinishTask,0,0,0,0); | |
220 | 37 |
38 systask_start->spawn(); | |
39 | |
634 | 40 // すべての Task が FinishTask を wait_for すると、 |
41 // あらゆる Task が FinishTask の waiting task queue を操作する | |
42 // ことになる。それは、重すぎる。PPE/SPE Task が終了した時点で、 | |
43 // TaskManager が実行する方が安い。 | |
44 // append_waitTask(systask_finish); | |
45 } | |
46 | |
47 HTaskPtr | |
636
d433fc37587d
Cell Simple Task compiled. but not worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
635
diff
changeset
|
48 TaskManagerImpl::create_task(int cmd,memaddr rbuf, long r_size, memaddr wbuf, long w_size) |
634 | 49 { |
50 HTaskPtr new_task; | |
51 | |
52 new_task = htaskImpl->create(cmd, rbuf, r_size, wbuf, w_size); | |
53 new_task->post_func = noaction; | |
54 new_task->mimpl = this; | |
55 | |
56 return new_task; | |
42 | 57 } |
58 | |
3 | 59 HTaskPtr |
109 | 60 TaskManagerImpl::create_task(int cmd) |
3 | 61 { |
62 HTaskPtr new_task; | |
63 | |
703 | 64 // for compatibility |
65 new_task = htaskImpl->create(TaskArray1); | |
66 new_task->post_func = noaction; | |
67 new_task->mimpl = this; | |
736 | 68 new_task->create_task_array(cmd,1,8,8,8); |
713
f725c6455d19
remove SIMPLE_TASK conditional
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
704
diff
changeset
|
69 // rbuf, r_size were set |
704
6d497c098455
Compatibility mode works.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
703
diff
changeset
|
70 new_task->command = TaskArray1; |
63 | 71 |
3 | 72 return new_task; |
73 } | |
74 | |
800
2708c4a7bade
run16 word count ( not yet worked. )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
736
diff
changeset
|
75 HTaskPtr |
2708c4a7bade
run16 word count ( not yet worked. )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
736
diff
changeset
|
76 TaskManagerImpl::create_task_array(int id, int num_task, int num_param, int num_inData, int num_outData) |
2708c4a7bade
run16 word count ( not yet worked. )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
736
diff
changeset
|
77 { |
2708c4a7bade
run16 word count ( not yet worked. )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
736
diff
changeset
|
78 HTaskPtr ta = create_task(TaskArray,0,0,0,0); |
2708c4a7bade
run16 word count ( not yet worked. )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
736
diff
changeset
|
79 ta->create_task_array(id, num_task, num_param, num_inData, num_outData) ; |
2708c4a7bade
run16 word count ( not yet worked. )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
736
diff
changeset
|
80 return ta; |
2708c4a7bade
run16 word count ( not yet worked. )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
736
diff
changeset
|
81 } |
2708c4a7bade
run16 word count ( not yet worked. )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
736
diff
changeset
|
82 |
3 | 83 /** |
298 | 84 * task の依存関係を設定 |
85 * master task が終わってから、slave task を実行するように | |
109 | 86 * master->wait_for(slave); |
3 | 87 */ |
88 void | |
89 TaskManagerImpl::set_task_depend(HTaskPtr master, HTaskPtr slave) | |
519 | 90 { |
3 | 91 TaskQueuePtr m, s; |
519 | 92 |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
93 m = taskQueueImpl->create(master); |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
94 s = taskQueueImpl->create(slave); |
519 | 95 |
479
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
96 master->wait_me->addLast(s); |
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
97 slave->wait_i->addLast(m); |
481
4896dffad67c
Double linked list modification done (tested on Mac OS X)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
480
diff
changeset
|
98 s->waiter = m; |
519 | 99 } |
100 | |
3 | 101 /** |
298 | 102 * タスクを実行可能キューまたは待機キューへ追加する。 |
103 * 依存関係が満たされていれば active, まだだったら wait へ。 | |
109 | 104 * task->spawn(); |
105 */ | |
3 | 106 void |
18 | 107 TaskManagerImpl::spawn_task(HTaskPtr task) |
3 | 108 { |
109 | 109 // waiter // master |
110 // waitee // slave | |
480
46464727d825
TaskQueueInfo initiaization...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
479
diff
changeset
|
111 if (task->wait_i->empty()) { |
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
112 append_activeTask(task); |
3 | 113 } else { |
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
114 append_waitTask(task); |
3 | 115 } |
109 | 116 |
635
8cc609285bbe
SimpleTask worked on Mac OS X
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
634
diff
changeset
|
117 // systask_finish->wait_for(task); |
3 | 118 } |
42 | 119 |
800
2708c4a7bade
run16 word count ( not yet worked. )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
736
diff
changeset
|
120 |
109 | 121 /** |
298 | 122 * Task を実行可能キューに追加する |
109 | 123 */ |
124 void | |
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
125 TaskManagerImpl::append_activeTask(HTaskPtr q) |
109 | 126 { |
479
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
127 activeTaskQueue->addLast(q); |
109 | 128 } |
129 | |
130 /** | |
298 | 131 * タスクが実行する CPU を選択する |
109 | 132 * |
298 | 133 * 現在は CPU_PPE, CPU_SPE, SPE_ANY, SPE_0, SPE_1, ..., SPE_5 |
134 * types.h に書いてます。 | |
109 | 135 */ |
65 | 136 void |
137 TaskManagerImpl::set_task_cpu(HTaskPtr task, CPU_TYPE type) | |
138 { | |
664 | 139 if (machineNum==0) |
140 task->cpu_type = CPU_PPE ; | |
141 else | |
142 task->cpu_type = type; | |
65 | 143 } |
144 | |
109 | 145 /** |
298 | 146 * 終了したタスクから依存の処理とか |
147 * post_func() はこのタスクが終了したら実行する関数。 | |
109 | 148 * |
298 | 149 * @param [task] 終了したタスク |
109 | 150 */ |
151 void | |
647
7c9ded1ea750
MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
639
diff
changeset
|
152 TaskManagerImpl::check_task_finish(HTaskPtr me, HTaskInfo *wait_queue) |
42 | 153 { |
499 | 154 |
497 | 155 while(TaskQueue *p = me->wait_me->poll()) { |
499 | 156 HTaskPtr you = p->task; |
497 | 157 TaskQueueInfo *wait_i = you->wait_i; |
479
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
158 // 相手の wait queue から自分(を指しているTaskQueue)を削除 |
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
159 wait_i->remove(p->waiter); |
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
160 // queue を free する |
493 | 161 wait_i->free_(p->waiter); |
483
0b933bef0328
renew task worked. but not test_nogl...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
481
diff
changeset
|
162 |
497 | 163 if (wait_i->empty()) { |
647
7c9ded1ea750
MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
639
diff
changeset
|
164 wait_queue->remove(you); |
499 | 165 append_activeTask(you); |
497 | 166 } |
167 | |
493 | 168 wait_i->free_(p); |
479
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
169 } |
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
170 |
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
171 htaskImpl->free_(me); |
109 | 172 } |
42 | 173 |
109 | 174 |
175 void | |
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
176 TaskManagerImpl::append_waitTask(HTaskPtr q) |
109 | 177 { |
479
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
178 waitTaskQueue ->addLast(q); |
109 | 179 } |
180 | |
801 | 181 void |
182 TaskManagerImpl::set_taskList(HTaskPtr htask, TaskListInfoPtr taskList) { | |
183 TaskListPtr list = taskList->getLast(); | |
184 SimpleTaskPtr task = &list->tasks[list->length++]; | |
185 if (htask->command==TaskArray1) { | |
186 // compatibility | |
187 int next = ((htask->r_size)/sizeof(SimpleTask))+1; | |
188 if (list->length+next>=TASK_MAX_SIZE) { | |
189 list->length--; | |
190 TaskListPtr newList = taskListImpl->create(); | |
191 taskList->addLast(newList); | |
192 list = newList; | |
193 task = &list->tasks[list->length++]; | |
194 } | |
195 Task *array = (Task*)&list->tasks[list->length]; | |
196 list->length += next; | |
197 if (list->length>=TASK_MAX_SIZE) { | |
198 perror("task array1 overflow\n"); | |
199 } | |
200 memcpy(array, htask->rbuf, htask->r_size); | |
201 free(htask->rbuf); | |
202 htask->rbuf = 0; htask->r_size = 0; | |
203 *task = *(SimpleTask*)htask; | |
204 } else { | |
205 *task = *(SimpleTask*)htask; | |
206 } | |
207 if (list->length >= TASK_MAX_SIZE) { | |
208 TaskListPtr newList = taskListImpl->create(); | |
209 taskList->addLast(newList); | |
210 list = newList; | |
211 } | |
212 } | |
213 | |
54 | 214 |
619 | 215 |
479
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
216 /* end */ |