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