Mercurial > hg > Game > Cerium
annotate TaskManager/Cell/CellTaskManagerImpl.cc @ 620:51d2ce7946e3 draft
merge
author | Shinji KONO <kono@ie.u-ryukyu.ac.jp> |
---|---|
date | Sun, 15 Nov 2009 02:05:33 +0900 |
parents | 278db3ca751d 0cc2e76d9cf4 |
children | 64e05530e333 |
rev | line source |
---|---|
321 | 1 #define DEBUG |
2 #include "error.h" | |
57 | 3 #include <stdio.h> |
4 #include <stdlib.h> | |
5 #include <string.h> | |
6 #include "CellTaskManagerImpl.h" | |
476
5fc79ff9c257
CellBufferManager removed
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
380
diff
changeset
|
7 #include "CellTaskListInfo.h" |
501
7ddbe22d4cdb
Cell inData/outData DMA removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
496
diff
changeset
|
8 #include "HTaskInfo.h" |
109 | 9 #include "PpeScheduler.h" |
57 | 10 #include "types.h" |
11 | |
501
7ddbe22d4cdb
Cell inData/outData DMA removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
496
diff
changeset
|
12 CellTaskManagerImpl::~CellTaskManagerImpl() |
67 | 13 { |
109 | 14 delete speThreads; |
15 delete [] speTaskList; | |
16 delete [] speTaskList_bg; | |
17 /** | |
321 | 18 * bufferManager は |
19 * ppeManager のなかで delete してもらう | |
109 | 20 */ |
21 // delete bufferManager; | |
22 delete [] flag_sendTaskList; | |
23 | |
24 delete ppeManager; | |
67 | 25 } |
26 | |
57 | 27 void |
501
7ddbe22d4cdb
Cell inData/outData DMA removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
496
diff
changeset
|
28 CellTaskManagerImpl::init() |
57 | 29 { |
476
5fc79ff9c257
CellBufferManager removed
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
380
diff
changeset
|
30 taskListImpl = new CellTaskListInfo; |
5fc79ff9c257
CellBufferManager removed
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
380
diff
changeset
|
31 taskListImpl->init(machineNum*2); |
5fc79ff9c257
CellBufferManager removed
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
380
diff
changeset
|
32 |
501
7ddbe22d4cdb
Cell inData/outData DMA removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
496
diff
changeset
|
33 activeTaskQueue = new HTaskInfo(); |
481
f9ffcffb6d09
Double linked list modification done (tested on Mac OS X)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
479
diff
changeset
|
34 |
501
7ddbe22d4cdb
Cell inData/outData DMA removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
496
diff
changeset
|
35 htaskImpl = activeTaskQueue ; // any HTaskInfo |
65 | 36 |
37 speThreads = new SpeThreads(machineNum); | |
38 speThreads->init(); | |
109 | 39 |
40 speTaskList = new TaskListPtr[machineNum]; | |
41 speTaskList_bg = new TaskListPtr[machineNum]; | |
476
5fc79ff9c257
CellBufferManager removed
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
380
diff
changeset
|
42 |
109 | 43 for (int i = 0; i < machineNum; i++) { |
476
5fc79ff9c257
CellBufferManager removed
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
380
diff
changeset
|
44 speTaskList[i] = taskListImpl->create(); |
5fc79ff9c257
CellBufferManager removed
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
380
diff
changeset
|
45 speTaskList_bg[i] = taskListImpl->create(); |
109 | 46 } |
47 | |
48 flag_sendTaskList = new int[machineNum]; | |
49 for (int i = 0; i < machineNum; i++) { | |
50 flag_sendTaskList[i] = 1; | |
476
5fc79ff9c257
CellBufferManager removed
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
380
diff
changeset
|
51 } |
321 | 52 // PPE 側の管理をする Manager |
109 | 53 ppeManager = new FifoTaskManagerImpl(machineNum); |
479
bf2d2625485e
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
476
diff
changeset
|
54 // 大半のTaskQueueInfoは、共有される |
476
5fc79ff9c257
CellBufferManager removed
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
380
diff
changeset
|
55 ppeManager->init(new PpeScheduler, this); |
619 | 56 |
57 ppeManager->get_scheduler()->set_manager(this); | |
58 schedTaskManager = new SchedTask(); | |
59 schedTaskManager->init(0,0,0,ppeManager->get_scheduler()); | |
57 | 60 } |
61 | |
109 | 62 void |
501
7ddbe22d4cdb
Cell inData/outData DMA removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
496
diff
changeset
|
63 CellTaskManagerImpl::append_activeTask(HTaskPtr task) |
109 | 64 { |
65 if (task->cpu_type == CPU_PPE) { | |
501
7ddbe22d4cdb
Cell inData/outData DMA removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
496
diff
changeset
|
66 ppeManager->append_activeTask(task); |
109 | 67 } else { |
501
7ddbe22d4cdb
Cell inData/outData DMA removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
496
diff
changeset
|
68 activeTaskQueue->addLast(task); |
109 | 69 } |
70 } | |
71 | |
321 | 72 // SPE_ANY が指定されていた時に |
73 // これをインクリメントしつつ呼ぶことにする。 | |
74 // 乱数使ってもいいけどさ。 | |
109 | 75 int cur_anySpeid = 0; |
76 | |
77 /** | |
321 | 78 * ActiveTaskQueue から Task を |
79 * 各 SPE に渡す TaskList に入れる | |
109 | 80 * |
321 | 81 * ここの activeTaskQueue は FifoTaskManagerImpl のと意味が違い、 |
82 * spe に渡される Task だけ入っている | |
109 | 83 */ |
84 void | |
501
7ddbe22d4cdb
Cell inData/outData DMA removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
496
diff
changeset
|
85 CellTaskManagerImpl::set_runTaskList() |
70 | 86 { |
321 | 87 // ここ...直すかな |
70 | 88 TaskListPtr list; |
481
f9ffcffb6d09
Double linked list modification done (tested on Mac OS X)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
479
diff
changeset
|
89 |
70 | 90 TaskPtr task; |
109 | 91 int speid; |
70 | 92 |
501
7ddbe22d4cdb
Cell inData/outData DMA removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
496
diff
changeset
|
93 while (HTaskPtr htask = activeTaskQueue->poll()) { |
70 | 94 |
109 | 95 if (htask->cpu_type == SPE_ANY) { |
96 speid = cur_anySpeid++; | |
97 cur_anySpeid = (cur_anySpeid < machineNum) | |
98 ? cur_anySpeid : 0; | |
70 | 99 } else { |
321 | 100 // -1 してるのは |
101 // htask->cpu_type - CPU_SPE で | |
102 // SPE0 = 1, SPE1 = 2, ... SPE5 = 6 ってなってるので | |
103 // 配列的 (SPE0 = arr[0], SPE1 = arr[1]) にするため | |
109 | 104 speid = htask->cpu_type - CPU_SPE - 1; |
105 | |
321 | 106 // SPU の数以上が指定されていれば |
107 // とりあえず MAX_USE_SPE_NUM (実際に動く SPE の最大数) で | |
108 // あまり求めてそれを使うことにする。 | |
109 // ここで判定するもんでもないか? | |
109 | 110 if (speid >= machineNum) { |
111 speid %= machineNum; | |
112 } | |
70 | 113 } |
109 | 114 |
115 list = speTaskList_bg[speid]; | |
116 | |
117 if (list->length >= TASK_MAX_SIZE) { | |
476
5fc79ff9c257
CellBufferManager removed
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
380
diff
changeset
|
118 TaskListPtr newList = taskListImpl->create(); |
109 | 119 newList = TaskListInfo::append(newList, speTaskList_bg[speid]); |
120 speTaskList_bg[speid] = newList; | |
121 list = newList; | |
122 } | |
123 | |
124 task = &list->tasks[list->length++]; | |
492 | 125 #if 0 |
109 | 126 task->command = htask->command; |
127 task->inData = htask->inData; | |
128 task->outData = htask->outData; | |
129 task->self = (unsigned int)htask; | |
79 | 130 #else |
481
f9ffcffb6d09
Double linked list modification done (tested on Mac OS X)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
479
diff
changeset
|
131 memcpy(task, (Task*)htask, sizeof(Task)); |
79 | 132 #endif |
70 | 133 |
501
7ddbe22d4cdb
Cell inData/outData DMA removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
496
diff
changeset
|
134 // activeTaskQueue->free_(queue); |
70 | 135 } |
136 | |
109 | 137 } |
138 | |
139 void | |
501
7ddbe22d4cdb
Cell inData/outData DMA removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
496
diff
changeset
|
140 CellTaskManagerImpl::run() |
109 | 141 { |
142 TaskListPtr ppeTaskList = NULL; | |
143 MailQueuePtr ppeMail = NULL; | |
70 | 144 |
321 | 145 // PPE 側で動く TaskList です |
146 // FifoTaskManagerImpl::run と上手く合うように | |
147 // こんなことやってますよ | |
109 | 148 ppeTaskList = ppeManager->get_runTaskList(); |
149 if (!ppeTaskList) { | |
150 goto cont; | |
151 } | |
70 | 152 |
321 | 153 // SPE からの Mailbox Check は |
154 // PPE 側の schedule から抜けて来たときに行う | |
155 // (speThreads で Blocking Mailbox read と | |
156 // セマフォとか使ってやってもいいが、今はこの方式で) | |
109 | 157 do { |
158 ppeMail = ppeManager->schedule(ppeTaskList); | |
159 cont: | |
160 ppeTaskList = mail_check(ppeMail); | |
161 } while (ppeTaskList); | |
70 | 162 } |
163 | |
65 | 164 /** |
321 | 165 * SPE からのメールをチェックする |
109 | 166 * |
167 * @param [mail_list] | |
321 | 168 * PPE 側で動く Scheduler からのメールリスト |
169 * この中で PPE 側の mail check も行う | |
109 | 170 * |
321 | 171 * @return PPE Scheduler に対してのメール。 |
172 * 次に実行する TaskList のアドレスや、終了コマンドを送る | |
109 | 173 */TaskListPtr |
65 | 174 CellTaskManagerImpl::mail_check(MailQueuePtr mail_list) |
57 | 175 { |
321 | 176 // PPE Scheduler からの mail check |
485 | 177 ppeManager->mail_check(mail_list, waitTaskQueue); |
65 | 178 |
70 | 179 do { |
244 | 180 unsigned int data; |
109 | 181 |
321 | 182 // SPE Scheduler からの mail check |
244 | 183 for (int id = 0; id < machineNum; id++) { |
184 while (speThreads->check_mail(id, 1, &data)) { | |
70 | 185 |
109 | 186 /** |
321 | 187 * MY_SPE_STATUS_READY: SPE が持ってた Task 全て終了 |
188 * MY_SPE_NOP: 特に意味のないコマンド | |
189 * それ以外:終了したタスク(PPEにあるのでアドレス | |
109 | 190 * |
321 | 191 * MY_SPE_NOP が 0 なので、 |
192 * 下のように data > MY_SPE_NOP とかしています。 | |
193 * 一目でよくわからない書き方なんで、直したいところですが。。。 | |
109 | 194 */ |
321 | 195 // 名前あとでちゃんと決めよう => MY_SPE_... とかじゃなくて |
70 | 196 if (data == MY_SPE_STATUS_READY) { |
334
7bc5cbc5fe04
[in test_render] push L key , call show_dma_wait, but incomplete.
e065746@localhost.localdomain
parents:
321
diff
changeset
|
197 //__debug_ppe("[SPE %d] finish\n", id); |
109 | 198 flag_sendTaskList[id] = 1; |
199 } else if (data == MY_SPE_COMMAND_MALLOC) { | |
334
7bc5cbc5fe04
[in test_render] push L key , call show_dma_wait, but incomplete.
e065746@localhost.localdomain
parents:
321
diff
changeset
|
200 //__debug_ppe("[PPE] MALLOC COMMAND from [SPE %d]\n", id); |
109 | 201 |
202 /** | |
321 | 203 * info[0] = alloc_id; (CellScheduler::mainMem_alloc 参照) |
109 | 204 * info[1] = alloc_addr; |
205 */ | |
244 | 206 unsigned int alloc_info[3]; |
109 | 207 int alloc_size; |
244 | 208 int command; |
109 | 209 |
244 | 210 speThreads->get_mail(id, 2, alloc_info); |
211 command = alloc_info[0]; | |
253
0c9c9906d777
usr_help_str is nessesary for example
tkaito@localhost.localdomain
parents:
244
diff
changeset
|
212 alloc_size = alloc_info[1]; |
244 | 213 |
109 | 214 |
215 alloc_info[1] = (unsigned int)allocate(alloc_size); | |
244 | 216 /* |
321 | 217 * allocate された領域は今の SPE buffer にリンクとして接続する |
218 * ここでは TaskList を allocate(new) して登録してやろうか | |
244 | 219 */ |
109 | 220 |
334
7bc5cbc5fe04
[in test_render] push L key , call show_dma_wait, but incomplete.
e065746@localhost.localdomain
parents:
321
diff
changeset
|
221 //__debug_ppe("[PPE] MALLOCED 0x%x from [SPE %d]\n", alloc_info[1],id); |
300
68d4267cb4a4
remove TaskManager/Fifo/MainScheduler.o TaskManeger/Test/test_render/test_nogl
tkaito@localhost.localdomain
parents:
298
diff
changeset
|
222 speThreads->add_output_tasklist(command, alloc_info[1], alloc_size); |
275 | 223 |
614 | 224 speThreads->send_mail(id, 2, (memaddr *)alloc_info); |
109 | 225 } else if (data > MY_SPE_NOP) { |
334
7bc5cbc5fe04
[in test_render] push L key , call show_dma_wait, but incomplete.
e065746@localhost.localdomain
parents:
321
diff
changeset
|
226 //__debug_ppe("[PPE] recv from [SPE %d] : 0x%x\n", id, data); |
619 | 227 HTaskPtr task = (HTaskPtr)data; |
228 task->post_func(schedTaskManager, task->post_arg1, task->post_arg2); | |
229 check_task_finish(task); | |
70 | 230 } |
65 | 231 } |
232 } | |
109 | 233 |
321 | 234 // 依存関係を満たしたタスクをアクティブに |
109 | 235 wakeup_waitTask(); |
236 | |
321 | 237 // SPE に送る TaskList の準備 |
109 | 238 set_runTaskList(); |
239 | |
321 | 240 // TaskList 待ちの SPE に TaskList を送る |
109 | 241 for (int i = 0; i < machineNum; i++) { |
242 if (flag_sendTaskList[i] == 1 && speTaskList_bg[i]->length >= 1 ) { | |
243 send_taskList(i); | |
244 } | |
245 } | |
70 | 246 |
321 | 247 // 現在の FifoTaskManager の仕様では |
248 // ・PPE で実行するタスクが無くなれば終了する | |
249 // であり、この場合もし SPE にタスクが残っていても | |
250 // メインループから抜けてプログラム終了となってしまうので | |
251 // ここでストップかけてます。 | |
481
f9ffcffb6d09
Double linked list modification done (tested on Mac OS X)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
479
diff
changeset
|
252 } while (ppeManager->activeTaskQueue->empty() && !waitTaskQueue->empty()); |
109 | 253 |
254 return ppeManager->get_runTaskList(); | |
255 } | |
66 | 256 |
109 | 257 /** |
321 | 258 * 条件を満たしたら SPE に TaskList を送信する |
259 * 条件1. SPE が持ってた TaskList を終了して、次の TaskList を待ってる | |
260 * 条件2. SPE に送る TaskList に Task がある | |
109 | 261 * |
321 | 262 * SPE で実行終了した TaskList [speTaskList] と |
263 * これから実行する TaskList [speTaskList_bg] のバッファを入れ替える | |
264 * ついでに実行終了したやつは clear しておく。 | |
109 | 265 */ |
266 void | |
267 CellTaskManagerImpl::send_taskList(int id) | |
268 { | |
269 TaskListPtr tmp; | |
270 | |
271 tmp = speTaskList[id]; | |
272 speTaskList[id] = speTaskList_bg[id]; | |
273 speTaskList_bg[id] = tmp; | |
274 | |
476
5fc79ff9c257
CellBufferManager removed
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
380
diff
changeset
|
275 taskListImpl->clear_taskList(speTaskList_bg[id]); |
109 | 276 |
614 | 277 //speThreads->send_mail(id, 1, (unsigned int *)&speTaskList[id]); |
278 speThreads->send_mail(id, 1, (memaddr *)&speTaskList[id]); | |
109 | 279 flag_sendTaskList[id] = 0; |
57 | 280 } |
281 | |
65 | 282 |
109 | 283 void* |
538 | 284 CellTaskManagerImpl::allocate(int size, int alignment) |
285 { | |
286 void *buff; | |
287 posix_memalign(&buff, alignment, size); | |
288 return buff; | |
289 } | |
290 | |
291 void* | |
109 | 292 CellTaskManagerImpl::allocate(int size) |
293 { | |
294 void *buff; | |
295 | |
296 posix_memalign(&buff, DEFAULT_ALIGNMENT, size); | |
244 | 297 |
321 | 298 // bzero はコストが高いのでやりたくない |
538 | 299 // bzero(buff, size); |
109 | 300 |
301 return buff; | |
302 } | |
303 | |
380 | 304 Scheduler* |
305 CellTaskManagerImpl::get_scheduler() | |
306 { | |
307 return ppeManager->get_scheduler(); | |
308 } | |
309 | |
109 | 310 #ifdef __CERIUM_CELL__ |
57 | 311 TaskManagerImpl* |
312 create_impl(int num) | |
313 { | |
67 | 314 return new CellTaskManagerImpl(num); |
57 | 315 } |
109 | 316 #endif // __CERIUM_CELL |