Mercurial > hg > Members > kono > Cerium
annotate TaskManager/Fifo/FifoTaskManagerImpl.cc @ 486:bfbad00ed9be
activeTaskQueue on Fifo is necessary on Cell
author | Shinji KONO <kono@ie.u-ryukyu.ac.jp> |
---|---|
date | Tue, 06 Oct 2009 10:12:37 +0900 |
parents | 9745d08e2f25 |
children | 7cd207691af1 |
rev | line source |
---|---|
3 | 1 #include <stdio.h> |
2 #include <stdlib.h> | |
3 #include <string.h> | |
4 #include "FifoTaskManagerImpl.h" | |
373 | 5 #include "Scheduler.h" |
47 | 6 #include "types.h" |
109 | 7 #include "error.h" |
3 | 8 |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
9 FifoTaskManagerImpl::~FifoTaskManagerImpl() |
109 | 10 { |
11 delete mailManager; | |
12 delete scheduler; | |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
13 |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
14 delete taskListImpl ; |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
15 delete taskQueueImpl ; |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
16 delete htaskImpl ; |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
17 |
109 | 18 } |
19 | |
20 /** | |
321 | 21 * MailManager は PPE スケジューラとのメール交換、 |
22 * FifoScheduler は PPE 側のスケジューラ | |
23 * BufferManager は Task、TaskList などのメモリ管理(大層なことしてないが | |
109 | 24 */ |
3 | 25 void |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
26 FifoTaskManagerImpl::init() |
3 | 27 { |
109 | 28 mailManager = new MailManager(); |
29 mailManager->init(20); | |
30 | |
31 scheduler = new MainScheduler(); | |
32 scheduler->init(); | |
33 scheduler->set_mailManager(mailManager); | |
194 | 34 scheduler->id = 0; |
42 | 35 |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
36 taskListImpl = new TaskListInfo; |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
37 taskQueueImpl = new TaskQueueInfo; |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
38 htaskImpl = new HTaskInfo; |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
39 |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
40 taskQueueImpl->init(TASK_MAX_SIZE*4); |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
41 htaskImpl->init(TASK_MAX_SIZE*2); |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
42 |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
43 mainTaskList = taskListImpl->create(); |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
44 |
109 | 45 } |
46 | |
47 /** | |
321 | 48 * これは CellTaskManagerImpl から呼ばれる。 |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
49 * TaskList等 は共用で使うので引数に。 |
321 | 50 * CellTaskManagerImpl と FifoTaskManagerImpl が同時に |
373 | 51 * 上のデータにアクセスする事は(今は)ないのでこれでおk |
109 | 52 */ |
53 void | |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
54 FifoTaskManagerImpl::init(MainScheduler *_sched, TaskManagerImpl *tm) |
109 | 55 { |
56 mailManager = new MailManager(); | |
57 mailManager->init(20); | |
58 | |
59 //scheduler = new MainScheduler(); | |
60 scheduler = _sched; | |
61 scheduler->init(); | |
62 scheduler->set_mailManager(mailManager); | |
63 | |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
64 taskListImpl = tm-> taskListImpl ; |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
65 taskQueueImpl = tm-> taskQueueImpl ; |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
66 htaskImpl = tm-> htaskImpl ; |
485 | 67 waitTaskQueue = NULL; // mail_check で外から設定される |
486
bfbad00ed9be
activeTaskQueue on Fifo is necessary on Cell
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
485
diff
changeset
|
68 // waitTaskQueue = tm->waitTaskQueue; |
bfbad00ed9be
activeTaskQueue on Fifo is necessary on Cell
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
485
diff
changeset
|
69 // activeTaskQueue = NULL; // CellTaskManagerImple 側を使う |
485 | 70 |
71 // waitTaskQueue = tm->waitTaskQueue; | |
479
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
72 // activeQueue は? |
109 | 73 |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
74 mainTaskList = taskListImpl->create(); |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
75 |
479
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
76 |
109 | 77 } |
78 | |
79 /** | |
321 | 80 * スケジューラに渡す TaskList を取得する。 |
109 | 81 * |
321 | 82 * @return 実行タスクリスト |
109 | 83 * |
321 | 84 * ActiveTaskQueue (依存条件は満たし済み) のタスクを |
85 * 実行タスクリストに入れる | |
109 | 86 */ |
87 TaskListPtr | |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
88 FifoTaskManagerImpl::get_runTaskList() |
109 | 89 { |
90 TaskListPtr list, list_top; | |
321 | 91 HTaskPtr htask; // HTask (PPE にある) |
92 TaskPtr task; // Task (SPE に送る Task) | |
109 | 93 |
480
46464727d825
TaskQueueInfo initiaization...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
479
diff
changeset
|
94 if (activeTaskQueue->empty()) { |
373 | 95 return NULL; |
109 | 96 } |
97 | |
321 | 98 // PPE 側で実行される TaskList |
109 | 99 list_top = mainTaskList; |
100 | |
321 | 101 // list_top->clear() とかの方がいいかもしれん。 |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
102 list_top = taskListImpl->clear_taskList(list_top); |
109 | 103 list = list_top; |
104 | |
480
46464727d825
TaskQueueInfo initiaization...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
479
diff
changeset
|
105 while (TaskQueuePtr queue = activeTaskQueue->poll()) { |
373 | 106 htask = (HTaskPtr)queue->task; |
109 | 107 |
373 | 108 task = &list->tasks[list->length++]; |
109 | 109 |
481
4896dffad67c
Double linked list modification done (tested on Mac OS X)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
480
diff
changeset
|
110 memcpy(task, (Task*)htask, sizeof(Task)); |
109 | 111 |
373 | 112 if (list->length >= TASK_MAX_SIZE) { |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
113 TaskListPtr newList = taskListImpl->create(); |
373 | 114 list_top = TaskListInfo::append(list_top, newList); |
115 list = newList; | |
116 } | |
109 | 117 |
481
4896dffad67c
Double linked list modification done (tested on Mac OS X)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
480
diff
changeset
|
118 activeTaskQueue->free(queue); |
109 | 119 } |
120 | |
121 mainTaskList = list_top; | |
122 | |
123 return list_top; | |
124 } | |
125 | |
126 | |
127 void | |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
128 FifoTaskManagerImpl::run() |
109 | 129 { |
130 TaskListPtr list; | |
131 MailQueuePtr mail; | |
132 | |
133 list = get_runTaskList(); | |
134 | |
135 do { | |
373 | 136 // list を実行する |
137 mail = schedule(list); | |
109 | 138 |
373 | 139 // mail には、ppe scheduler からの mail がある |
140 mail_check(mail); | |
109 | 141 |
373 | 142 // 依存関係を満たしたものは実行可能キューへ |
143 wakeup_waitTask(); | |
144 list = get_runTaskList(); | |
109 | 145 } while (list); |
146 } | |
147 | |
148 /** | |
321 | 149 * @param [list] 実行タスクリスト |
150 * @return FifoScheduler からのメール | |
109 | 151 * |
321 | 152 * [Tasklist] -> [番兵] -> scheduler->run を抜ける |
109 | 153 */ |
154 MailQueuePtr | |
155 FifoTaskManagerImpl::schedule(TaskListPtr list) | |
156 { | |
157 MailQueuePtr list_mail; // task list | |
321 | 158 MailQueuePtr sentinel; // 番兵 |
109 | 159 MailQueuePtr in_mail_list = NULL; |
160 MailQueuePtr out_mail_list = NULL; | |
161 | |
321 | 162 // TaskList のアドレス |
373 | 163 list_mail = mailManager->create((unsigned int)list); |
109 | 164 in_mail_list = MailManager::append_mailQueue(in_mail_list, list_mail); |
165 | |
321 | 166 // EXIT_COMMAND (番兵的な意味で) |
109 | 167 sentinel = mailManager->create(MY_SPE_COMMAND_EXIT); |
168 in_mail_list = MailManager::append_mailQueue(in_mail_list, sentinel); | |
373 | 169 |
321 | 170 // scheduler は受け取ったメールを元に実行する |
109 | 171 scheduler->send_mailList(in_mail_list); |
172 scheduler->run(); | |
373 | 173 out_mail_list = scheduler->recv_mailList(); |
109 | 174 |
175 return out_mail_list; | |
176 } | |
177 | |
178 /** | |
321 | 179 * PPE Scheduler からのメールをチェックする |
109 | 180 * |
181 * @param [mail_list] | |
321 | 182 * PPE 側で動く Scheduler からのメールリスト |
183 * 終了した Task や、その他(今はまだ実装してないけど)の情報が入ってる | |
109 | 184 * |
373 | 185 * @return Scheduler が次に実行する Task List |
321 | 186 * NULL なら全てのタスクが実行終了したということ |
109 | 187 */ |
188 void | |
485 | 189 FifoTaskManagerImpl::mail_check(MailQueuePtr mail_list, TaskQueueInfo *waitQueue) |
190 { | |
191 waitTaskQueue = waitQueue; | |
192 mail_check(mail_list); | |
193 } | |
194 | |
195 void | |
109 | 196 FifoTaskManagerImpl::mail_check(MailQueuePtr mail_list) |
197 { | |
198 MailQueuePtr q = mail_list; | |
199 MailQueuePtr d; | |
200 unsigned int data; | |
201 | |
202 while (q) { | |
373 | 203 data = q->data; |
109 | 204 |
373 | 205 /** |
206 * MY_SPE_STATUS_READY: SPE が持ってた Task 全て終了 | |
207 * MY_SPE_NOP: 特に意味のないコマンド | |
208 * それ以外:終了したタスク(PPEにあるのでアドレス | |
209 * | |
210 * MY_SPE_NOP が 0 なので、 | |
211 * 下のように data > MY_SPE_NOP とかしています。 | |
212 * 一目でよくわからない書き方なんで、直したいところですが。。。 | |
213 */ | |
214 if (data == MY_SPE_STATUS_READY) { | |
215 __debug_ppe("mail_check(): Task List finish\n"); | |
216 } else if (data > MY_SPE_NOP) { | |
217 __debug_ppe("mail_check(): recv from 0x%x\n", data); | |
218 check_task_finish((HTaskPtr)data); | |
219 } | |
109 | 220 |
373 | 221 d = q; |
222 q = q->next; | |
109 | 223 |
373 | 224 mailManager->free(d); |
109 | 225 } |
3 | 226 } |
227 | |
109 | 228 void* |
229 FifoTaskManagerImpl::allocate(int size) | |
230 { | |
231 return malloc(size); | |
232 } | |
233 | |
373 | 234 Scheduler* |
235 FifoTaskManagerImpl::get_scheduler() { | |
236 return scheduler; | |
237 } | |
238 | |
109 | 239 /** |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
240 * # # # # # # # # |
109 | 241 * Abstract Factory Pattern |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
242 * # # # # # # # |
109 | 243 */ |
244 #ifdef __CERIUM_FIFO__ | |
373 | 245 TaskManagerImpl* |
3 | 246 create_impl(int num) |
247 { | |
248 return new FifoTaskManagerImpl(); | |
249 } | |
109 | 250 #endif // __CERIUM_FIFO__ |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
251 |