Mercurial > hg > Members > kono > Cerium
annotate TaskManager/kernel/ppe/TaskManagerImpl.cc @ 567:47b61865ea8c
merge
| author | Shinji KONO <kono@ie.u-ryukyu.ac.jp> |
|---|---|
| date | Thu, 22 Oct 2009 23:54:58 +0900 |
| parents | 2659376067e8 5c76db2a07fa |
| children | 0decff4e867b |
| 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" |
| 6 #include "SchedTaskManager.h" | |
| 109 | 7 #include "../sys_task/SysTask.h" |
| 8 | |
| 220 | 9 static HTaskPtr systask_start; |
| 109 | 10 static HTaskPtr systask_finish; |
| 42 | 11 |
| 514 | 12 static void |
| 13 noaction(SchedTask *s, void *read, void *write) | |
| 3 | 14 { |
| 15 } | |
| 16 | |
| 109 | 17 TaskManagerImpl::TaskManagerImpl(int num) |
|
480
46464727d825
TaskQueueInfo initiaization...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
479
diff
changeset
|
18 : machineNum(num) { |
|
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
19 activeTaskQueue = new HTaskInfo(); |
|
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
20 waitTaskQueue = new HTaskInfo(); |
|
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
21 htaskImpl = waitTaskQueue ; // any HTaskInfo |
|
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
22 taskQueueImpl = new TaskQueueInfo(); |
|
480
46464727d825
TaskQueueInfo initiaization...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
479
diff
changeset
|
23 } |
| 50 | 24 |
| 220 | 25 /** |
| 298 | 26 * 一番最初に PPE で実行される systask_start |
| 27 * 一番最後に、全てのタスクの終了を待つ systask_finish | |
| 28 * 番兵的な意味で実装 | |
| 220 | 29 */ |
| 42 | 30 void |
| 499 | 31 TaskManagerImpl::systask_init() |
| 42 | 32 { |
| 109 | 33 systask_register(); |
| 42 | 34 |
| 507 | 35 schedTaskManager = new SchedTaskManager(this); |
| 36 | |
| 220 | 37 systask_start = create_task(SYSTASK_START); |
| 109 | 38 systask_finish = create_task(SYSTASK_FINISH); |
| 220 | 39 |
| 40 systask_start->spawn(); | |
| 41 | |
| 298 | 42 // systask_finish で spawn すると |
| 220 | 43 // systask_finish->wait_for(systask_finish); |
| 298 | 44 // とかなって無限ループになるので、 |
| 45 // これだけは明示的に append_waitTask() で | |
| 499 | 46 append_waitTask(systask_finish); |
| 42 | 47 } |
| 48 | |
| 3 | 49 HTaskPtr |
| 109 | 50 TaskManagerImpl::create_task(int cmd) |
| 3 | 51 { |
| 52 HTaskPtr new_task; | |
| 53 | |
|
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
54 new_task = htaskImpl->create(cmd); |
| 109 | 55 new_task->post_func = noaction; |
| 63 | 56 new_task->mimpl = this; |
| 57 | |
| 3 | 58 return new_task; |
| 59 } | |
| 60 | |
| 61 /** | |
| 298 | 62 * task の依存関係を設定 |
| 63 * master task が終わってから、slave task を実行するように | |
| 109 | 64 * master->wait_for(slave); |
| 3 | 65 */ |
| 66 void | |
| 67 TaskManagerImpl::set_task_depend(HTaskPtr master, HTaskPtr slave) | |
| 519 | 68 { |
| 3 | 69 TaskQueuePtr m, s; |
| 519 | 70 |
|
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
71 m = taskQueueImpl->create(master); |
|
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
72 s = taskQueueImpl->create(slave); |
| 519 | 73 |
|
479
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
74 master->wait_me->addLast(s); |
|
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
75 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
|
76 s->waiter = m; |
| 519 | 77 } |
| 78 | |
| 3 | 79 /** |
| 298 | 80 * タスクを実行可能キューまたは待機キューへ追加する。 |
| 81 * 依存関係が満たされていれば active, まだだったら wait へ。 | |
| 109 | 82 * task->spawn(); |
| 83 */ | |
| 3 | 84 void |
| 18 | 85 TaskManagerImpl::spawn_task(HTaskPtr task) |
| 3 | 86 { |
| 109 | 87 // waiter // master |
| 88 // waitee // slave | |
|
480
46464727d825
TaskQueueInfo initiaization...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
479
diff
changeset
|
89 if (task->wait_i->empty()) { |
|
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
90 append_activeTask(task); |
| 3 | 91 } else { |
|
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
92 append_waitTask(task); |
| 3 | 93 } |
| 109 | 94 |
| 95 systask_finish->wait_for(task); | |
| 3 | 96 } |
| 42 | 97 |
| 109 | 98 /** |
| 298 | 99 * Task を実行可能キューに追加する |
| 109 | 100 */ |
| 101 void | |
|
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
102 TaskManagerImpl::append_activeTask(HTaskPtr q) |
| 109 | 103 { |
|
479
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
104 activeTaskQueue->addLast(q); |
| 109 | 105 } |
| 106 | |
| 107 /** | |
| 298 | 108 * タスクが実行する CPU を選択する |
| 109 | 109 * |
| 298 | 110 * 現在は CPU_PPE, CPU_SPE, SPE_ANY, SPE_0, SPE_1, ..., SPE_5 |
| 111 * types.h に書いてます。 | |
| 109 | 112 */ |
| 65 | 113 void |
| 114 TaskManagerImpl::set_task_cpu(HTaskPtr task, CPU_TYPE type) | |
| 115 { | |
| 116 task->cpu_type = type; | |
| 117 } | |
| 118 | |
| 109 | 119 /** |
| 298 | 120 * 終了したタスクから依存の処理とか |
| 121 * post_func() はこのタスクが終了したら実行する関数。 | |
| 109 | 122 * |
| 298 | 123 * @param [task] 終了したタスク |
| 109 | 124 */ |
| 125 void | |
| 497 | 126 TaskManagerImpl::check_task_finish(HTaskPtr me) |
| 42 | 127 { |
| 499 | 128 // post_func を先に実行しないと、systask_finish が active_queue |
| 129 // 移されてから、wait_for されるという事態が起きることがある。 | |
| 130 | |
| 507 | 131 me->post_func(schedTaskManager, me->post_arg1,me->post_arg2); |
| 499 | 132 |
| 497 | 133 while(TaskQueue *p = me->wait_me->poll()) { |
| 499 | 134 HTaskPtr you = p->task; |
| 497 | 135 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
|
136 // 相手の wait queue から自分(を指しているTaskQueue)を削除 |
|
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
137 wait_i->remove(p->waiter); |
|
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
138 // queue を free する |
| 493 | 139 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
|
140 |
| 497 | 141 if (wait_i->empty()) { |
| 499 | 142 waitTaskQueue->remove(you); |
| 143 append_activeTask(you); | |
| 497 | 144 } |
| 145 | |
| 493 | 146 wait_i->free_(p); |
|
479
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
147 } |
|
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
148 |
|
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
149 htaskImpl->free_(me); |
| 109 | 150 } |
| 42 | 151 |
| 109 | 152 |
| 153 void | |
|
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
154 TaskManagerImpl::append_waitTask(HTaskPtr q) |
| 109 | 155 { |
|
479
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
156 waitTaskQueue ->addLast(q); |
| 109 | 157 } |
| 158 | |
| 159 /** | |
| 298 | 160 * waitQueue の中で依存関係を満たしたタスクは |
| 161 * activeQueue へ移す | |
| 109 | 162 */ |
| 163 void | |
| 499 | 164 TaskManagerImpl::wakeup_waitTask() |
| 109 | 165 { |
| 497 | 166 // done in check_task_finish |
| 109 | 167 } |
| 54 | 168 |
|
479
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
169 /* end */ |