Mercurial > hg > Game > Cerium
annotate TaskManager/kernel/ppe/HTask.cc @ 970:1a4849b2acad draft
change pipeline and TaskArray fast
| author | Yutaka Kinjyo <yutaka@cr.ie.u-ryukyu.ac.jp> |
|---|---|
| date | Thu, 26 Aug 2010 20:38:06 +0900 |
| parents | 774eba654643 |
| children | 5393bebe0956 |
| rev | line source |
|---|---|
| 109 | 1 #include "HTask.h" |
| 2 #include "ListData.h" | |
| 3 #include "TaskManagerImpl.h" | |
|
704
ec6c897448ca
Compatibility mode works.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
700
diff
changeset
|
4 #include "strings.h" |
| 109 | 5 |
| 6 | |
| 293 | 7 /*! |
| 297 | 8 manager->set_task_depend(task1, task2); // task2 は task1 の終了を待つ |
| 293 | 9 |
| 297 | 10 ってやるより |
| 293 | 11 |
| 12 task2->set_depend(task1); | |
| 13 | |
| 297 | 14 ってやったほうがわかりやすいよねー的な話し合いで |
| 15 下のようなAPIを作りました | |
| 293 | 16 */ |
| 17 | |
| 109 | 18 void |
| 19 HTask::spawn(void) | |
| 20 { | |
| 836 | 21 mimpl->spawn_task(this); |
| 109 | 22 } |
| 23 | |
| 293 | 24 /*! |
| 297 | 25 @brief この Task が待ち合わせする Task を指定する |
| 26 @param[in] master この Task が終了待ち合わせをする相手の Task | |
| 293 | 27 |
| 297 | 28 繰り返し使用する事で複数の Task を待ち合わせする事ができる。 |
| 293 | 29 |
| 297 | 30 wait_for している Task の入力バッファにこの Task から書き込みできる機能があると良い |
| 293 | 31 */ |
| 109 | 32 void |
| 293 | 33 HTask::wait_for(HTaskPtr master) |
| 109 | 34 { |
| 35 mimpl->set_task_depend(master, this); | |
| 36 } | |
| 37 | |
| 814 | 38 /** |
| 39 * タスクが実行する CPU を選択する | |
| 40 * | |
| 41 * 現在は CPU_PPE, CPU_SPE, SPE_ANY, SPE_0, SPE_1, ..., SPE_5 | |
| 42 * types.h に書いてます。 | |
| 43 * | |
| 44 * mimpl によって使えるCPUが異なるので、mimpl に任せる必要がある | |
| 45 */ | |
| 547 | 46 void |
| 47 HTask::set_cpu(CPU_TYPE type) | |
| 48 { | |
| 109 | 49 mimpl->set_task_cpu(this, type); |
| 547 | 50 } |
| 51 | |
| 814 | 52 /*! |
| 53 @brief このTaskが終了した時に実行する関数 | |
| 54 @param arg1, arg2 の二つの引数を持つ (Task に合わせてある) | |
| 55 */ | |
| 547 | 56 void |
| 550 | 57 HTask::set_post(PostFunction func,void *arg1, void *arg2) |
| 547 | 58 { |
| 109 | 59 this->post_func = func; |
| 550 | 60 this->post_arg1 = arg1; |
| 61 this->post_arg2 = arg2; | |
| 547 | 62 } |
| 63 | |
|
687
25afcd4ae380
test code for TaskArray
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
567
diff
changeset
|
64 |
| 814 | 65 /*! |
| 66 @brief まとまって実行されるTask である Task Array の作成 | |
| 67 @param id Task ID | |
| 68 @param num_task 実行する Task の数 | |
| 69 @param num_param 一つのTaskがset_paramする数 | |
| 70 @param num_inData 一つのTaskが読み込む Data の数、set_inData の数 | |
| 71 @param num_outData 一つのTaskが書き出す Data の数、set_outData の数 | |
| 72 @return Task Array へのポインタ | |
| 73 */ | |
|
687
25afcd4ae380
test code for TaskArray
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
567
diff
changeset
|
74 Task * |
| 700 | 75 HTask::create_task_array(int id, int num_task, int num_param, int num_inData, int num_outData) |
|
687
25afcd4ae380
test code for TaskArray
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
567
diff
changeset
|
76 { |
| 700 | 77 r_size = Task::calc_size(num_param, num_inData, num_outData)*num_task; |
| 78 rbuf = (memaddr) mimpl->allocate(r_size); | |
|
970
1a4849b2acad
change pipeline and TaskArray fast
Yutaka Kinjyo <yutaka@cr.ie.u-ryukyu.ac.jp>
parents:
954
diff
changeset
|
79 //printf("r_size %d\n",r_size); |
|
704
ec6c897448ca
Compatibility mode works.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
700
diff
changeset
|
80 bzero(rbuf,r_size); |
| 700 | 81 Task *task = (Task*)rbuf; |
| 82 task->init(id, num_param,num_inData,num_outData); | |
| 83 // task->print(); | |
| 84 return task; // first task | |
| 85 } | |
|
689
ecf63089f5bb
Task Array generation worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
688
diff
changeset
|
86 |
| 814 | 87 /*! |
| 88 @brief Task Array の次のTask | |
| 89 @param t 今のTaskのポインタ | |
| 90 0 の場合は最初のTask | |
| 91 @return 次のTaskへのポインタ | |
| 92 */ | |
| 700 | 93 Task * |
| 94 HTask::next_task_array(int id, Task *t) | |
| 95 { | |
| 96 Task *first = (Task*)rbuf; | |
| 97 if (t==0) { | |
| 98 // first->print(); | |
| 99 return first; | |
| 100 } | |
| 101 | |
| 102 Task *next = t->next(); | |
| 103 next->init(id, first->param_count, first->inData_count, first->outData_count); | |
| 104 if ((memaddr)next - (memaddr)rbuf > r_size) | |
| 736 | 105 mimpl->get_scheduler()->printf("too many task array used.\n"); |
| 700 | 106 return next; |
|
687
25afcd4ae380
test code for TaskArray
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
567
diff
changeset
|
107 } |
|
25afcd4ae380
test code for TaskArray
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
567
diff
changeset
|
108 |
| 814 | 109 /*! |
| 110 @brief Task Array の中のすべてのTaskが書き込まれたかどうかをチェックする | |
| 111 TaskArray 自体の spawn() は別に必要 | |
| 112 @param last 今のTaskのポインタ (最後である必要がある) | |
| 113 */ | |
|
689
ecf63089f5bb
Task Array generation worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
688
diff
changeset
|
114 void |
| 700 | 115 HTask::spawn_task_array(Task * last) |
|
689
ecf63089f5bb
Task Array generation worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
688
diff
changeset
|
116 { |
| 700 | 117 int size = (memaddr)last - rbuf; |
| 118 if (size!= r_size) { | |
| 736 | 119 mimpl->get_scheduler()->printf("spawn task array size differ size 0x%x r_size 0x%x\n", |
| 700 | 120 size, r_size); |
|
689
ecf63089f5bb
Task Array generation worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
688
diff
changeset
|
121 } |
|
ecf63089f5bb
Task Array generation worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
688
diff
changeset
|
122 } |
|
ecf63089f5bb
Task Array generation worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
688
diff
changeset
|
123 |
|
ecf63089f5bb
Task Array generation worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
688
diff
changeset
|
124 |
|
687
25afcd4ae380
test code for TaskArray
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
567
diff
changeset
|
125 |
| 954 | 126 |
| 547 | 127 /* end */ |