Mercurial > hg > Members > kono > Cerium
annotate TaskManager/Fifo/FifoTaskManagerImpl.cc @ 634:0558abba673c
SimpleTask start
author | Shinji KONO <kono@ie.u-ryukyu.ac.jp> |
---|---|
date | Wed, 18 Nov 2009 17:29:14 +0900 |
parents | 60aa3f241b10 |
children | 8cc609285bbe |
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" |
619 | 6 #include "SchedTask.h" |
47 | 7 #include "types.h" |
109 | 8 #include "error.h" |
3 | 9 |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
10 FifoTaskManagerImpl::~FifoTaskManagerImpl() |
109 | 11 { |
12 delete mailManager; | |
13 delete scheduler; | |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
14 |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
15 delete taskListImpl ; |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
16 delete taskQueueImpl ; |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
17 delete htaskImpl ; |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
18 |
109 | 19 } |
20 | |
21 /** | |
321 | 22 * MailManager は PPE スケジューラとのメール交換、 |
23 * FifoScheduler は PPE 側のスケジューラ | |
24 * BufferManager は Task、TaskList などのメモリ管理(大層なことしてないが | |
109 | 25 */ |
3 | 26 void |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
27 FifoTaskManagerImpl::init() |
3 | 28 { |
109 | 29 mailManager = new MailManager(); |
30 mailManager->init(20); | |
31 | |
32 scheduler = new MainScheduler(); | |
33 scheduler->init(); | |
34 scheduler->set_mailManager(mailManager); | |
194 | 35 scheduler->id = 0; |
619 | 36 scheduler->set_manager(this); |
42 | 37 |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
38 taskListImpl = new TaskListInfo; |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
39 taskQueueImpl = new TaskQueueInfo; |
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
494
diff
changeset
|
40 htaskImpl = new HTaskInfo(); |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
41 |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
42 mainTaskList = taskListImpl->create(); |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
43 |
619 | 44 schedTaskManager = new SchedTask(); |
45 schedTaskManager->init(0,0,0,scheduler); | |
46 | |
109 | 47 } |
48 | |
49 /** | |
321 | 50 * これは CellTaskManagerImpl から呼ばれる。 |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
51 * TaskList等 は共用で使うので引数に。 |
321 | 52 * CellTaskManagerImpl と FifoTaskManagerImpl が同時に |
373 | 53 * 上のデータにアクセスする事は(今は)ないのでこれでおk |
109 | 54 */ |
55 void | |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
56 FifoTaskManagerImpl::init(MainScheduler *_sched, TaskManagerImpl *tm) |
109 | 57 { |
58 mailManager = new MailManager(); | |
59 mailManager->init(20); | |
60 | |
61 //scheduler = new MainScheduler(); | |
62 scheduler = _sched; | |
63 scheduler->init(); | |
64 scheduler->set_mailManager(mailManager); | |
65 | |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
66 taskListImpl = tm-> taskListImpl ; |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
67 taskQueueImpl = tm-> taskQueueImpl ; |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
68 htaskImpl = tm-> htaskImpl ; |
485 | 69 waitTaskQueue = NULL; // mail_check で外から設定される |
109 | 70 |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
71 mainTaskList = taskListImpl->create(); |
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
72 |
479
5bda98b0b56d
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
73 |
109 | 74 } |
75 | |
76 /** | |
321 | 77 * スケジューラに渡す TaskList を取得する。 |
109 | 78 * |
321 | 79 * @return 実行タスクリスト |
109 | 80 * |
321 | 81 * ActiveTaskQueue (依存条件は満たし済み) のタスクを |
82 * 実行タスクリストに入れる | |
109 | 83 */ |
84 TaskListPtr | |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
85 FifoTaskManagerImpl::get_runTaskList() |
109 | 86 { |
87 TaskListPtr list, list_top; | |
634 | 88 #ifdef SIMPLE_TASK |
321 | 89 TaskPtr task; // Task (SPE に送る Task) |
634 | 90 #else |
91 SimpleTaskPtr task; // Task (SPE に送る Task) | |
92 #endif | |
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 | |
499 | 105 // printf("active task queue length = %d\n",activeTaskQueue->length()); |
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
494
diff
changeset
|
106 while (HTaskPtr htask = activeTaskQueue->poll()) { |
373 | 107 task = &list->tasks[list->length++]; |
634 | 108 #ifdef SIMPLE_TASK |
109 *task = *(SimpleTask*)htask; | |
110 #else | |
491 | 111 memcpy(task, (Task*)htask, sizeof(Task)); |
634 | 112 #endif |
373 | 113 if (list->length >= TASK_MAX_SIZE) { |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
114 TaskListPtr newList = taskListImpl->create(); |
373 | 115 list_top = TaskListInfo::append(list_top, newList); |
116 list = newList; | |
117 } | |
499 | 118 // activeTaskQueue->free_(htask); ここで free しないで、 |
119 // mail を待つ | |
109 | 120 } |
121 | |
122 mainTaskList = list_top; | |
123 | |
124 return list_top; | |
125 } | |
126 | |
127 | |
128 void | |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
129 FifoTaskManagerImpl::run() |
109 | 130 { |
131 TaskListPtr list; | |
132 MailQueuePtr mail; | |
133 | |
134 list = get_runTaskList(); | |
135 | |
136 do { | |
373 | 137 // list を実行する |
138 mail = schedule(list); | |
109 | 139 |
373 | 140 // mail には、ppe scheduler からの mail がある |
141 mail_check(mail); | |
109 | 142 |
373 | 143 // 依存関係を満たしたものは実行可能キューへ |
144 wakeup_waitTask(); | |
145 list = get_runTaskList(); | |
109 | 146 } while (list); |
147 } | |
148 | |
149 /** | |
321 | 150 * @param [list] 実行タスクリスト |
151 * @return FifoScheduler からのメール | |
109 | 152 * |
321 | 153 * [Tasklist] -> [番兵] -> scheduler->run を抜ける |
109 | 154 */ |
155 MailQueuePtr | |
156 FifoTaskManagerImpl::schedule(TaskListPtr list) | |
157 { | |
158 MailQueuePtr list_mail; // task list | |
321 | 159 MailQueuePtr sentinel; // 番兵 |
109 | 160 MailQueuePtr in_mail_list = NULL; |
161 MailQueuePtr out_mail_list = NULL; | |
162 | |
321 | 163 // TaskList のアドレス |
603
42c94f85c779
long -> memaddr (64 or 32)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
602
diff
changeset
|
164 list_mail = mailManager->create((memaddr)list); |
109 | 165 in_mail_list = MailManager::append_mailQueue(in_mail_list, list_mail); |
166 | |
321 | 167 // EXIT_COMMAND (番兵的な意味で) |
625
60aa3f241b10
64bit mode worked on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
619
diff
changeset
|
168 sentinel = mailManager->create((memaddr)MY_SPE_COMMAND_EXIT); |
109 | 169 in_mail_list = MailManager::append_mailQueue(in_mail_list, sentinel); |
373 | 170 |
321 | 171 // scheduler は受け取ったメールを元に実行する |
109 | 172 scheduler->send_mailList(in_mail_list); |
173 scheduler->run(); | |
373 | 174 out_mail_list = scheduler->recv_mailList(); |
109 | 175 |
176 return out_mail_list; | |
177 } | |
178 | |
179 /** | |
321 | 180 * PPE Scheduler からのメールをチェックする |
109 | 181 * |
182 * @param [mail_list] | |
321 | 183 * PPE 側で動く Scheduler からのメールリスト |
184 * 終了した Task や、その他(今はまだ実装してないけど)の情報が入ってる | |
109 | 185 * |
373 | 186 * @return Scheduler が次に実行する Task List |
321 | 187 * NULL なら全てのタスクが実行終了したということ |
109 | 188 */ |
189 void | |
498
cb5ecfc5aaa3
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
494
diff
changeset
|
190 FifoTaskManagerImpl::mail_check(MailQueuePtr mail_list, HTaskInfo *waitQueue) |
485 | 191 { |
192 waitTaskQueue = waitQueue; | |
193 mail_check(mail_list); | |
194 } | |
195 | |
196 void | |
109 | 197 FifoTaskManagerImpl::mail_check(MailQueuePtr mail_list) |
198 { | |
199 MailQueuePtr q = mail_list; | |
200 MailQueuePtr d; | |
625
60aa3f241b10
64bit mode worked on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
619
diff
changeset
|
201 memaddr data; |
109 | 202 |
203 while (q) { | |
373 | 204 data = q->data; |
109 | 205 |
625
60aa3f241b10
64bit mode worked on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
619
diff
changeset
|
206 if (data == (memaddr)MY_SPE_STATUS_READY) { |
373 | 207 __debug_ppe("mail_check(): Task List finish\n"); |
625
60aa3f241b10
64bit mode worked on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
619
diff
changeset
|
208 } else if (data != (memaddr)MY_SPE_NOP) { |
373 | 209 __debug_ppe("mail_check(): recv from 0x%x\n", data); |
619 | 210 // post_func を先に実行しないと、systask_finish が active_queue |
211 // 移されてから、wait_for されるという事態が起きることがある。 | |
212 HTaskPtr task = (HTaskPtr)data; | |
213 task->post_func(schedTaskManager, task->post_arg1, task->post_arg2); | |
214 check_task_finish(task); | |
373 | 215 } |
109 | 216 |
373 | 217 d = q; |
218 q = q->next; | |
109 | 219 |
373 | 220 mailManager->free(d); |
109 | 221 } |
3 | 222 } |
223 | |
109 | 224 void* |
506 | 225 FifoTaskManagerImpl::allocate(int size, int alignment) |
226 { | |
227 #ifdef __APPLE__ | |
228 return malloc(size); | |
229 #else | |
230 void *buff; | |
231 posix_memalign(&buff, alignment, size); | |
232 return buff; | |
233 #endif | |
234 } | |
235 | |
236 void* | |
109 | 237 FifoTaskManagerImpl::allocate(int size) |
238 { | |
506 | 239 #ifdef __APPLE__ |
109 | 240 return malloc(size); |
506 | 241 #else |
242 void *buff; | |
243 posix_memalign(&buff, DEFAULT_ALIGNMENT, size); | |
244 return buff; | |
245 #endif | |
109 | 246 } |
247 | |
373 | 248 Scheduler* |
249 FifoTaskManagerImpl::get_scheduler() { | |
250 return scheduler; | |
251 } | |
252 | |
109 | 253 /** |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
254 * # # # # # # # # |
109 | 255 * Abstract Factory Pattern |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
256 * # # # # # # # |
109 | 257 */ |
258 #ifdef __CERIUM_FIFO__ | |
373 | 259 TaskManagerImpl* |
3 | 260 create_impl(int num) |
261 { | |
262 return new FifoTaskManagerImpl(); | |
263 } | |
109 | 264 #endif // __CERIUM_FIFO__ |
475
e083c4ff91c1
BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
373
diff
changeset
|
265 |