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