Mercurial > hg > Game > Cerium
annotate TaskManager/kernel/ppe/TaskManagerImpl.cc @ 1479:163220e54cc0 draft
remove hard code for TaskLog
| author | Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp> |
|---|---|
| date | Tue, 24 Jul 2012 17:15:15 +0900 |
| parents | b158873485f6 |
| children | 85a848d7f181 |
| rev | line source |
|---|---|
|
1142
801d57ae1e29
cut compile CreatePolygonTask on spe side because not enough spe memory. We have to use code loading.
yutaka@localhost.localdomain
parents:
1064
diff
changeset
|
1 //#include <stdio.h> |
| 3 | 2 #include "TaskManagerImpl.h" |
| 46 | 3 #include "types.h" |
| 4 #include "error.h" | |
| 546 | 5 #include "SchedTask.h" |
| 619 | 6 #include "Scheduler.h" |
| 634 | 7 #include "SysTask.h" |
| 8 #include "SysFunc.h" | |
|
1423
515a0f15b5d2
add to log taskdependency
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1230
diff
changeset
|
9 #include "rdtsc.h" |
| 806 | 10 #include <string.h> |
| 11 | |
| 955 | 12 // singleton |
| 13 QueueInfo<TaskQueue> *taskQueuePool = new QueueInfo<TaskQueue>() ; | |
| 14 QueueInfo<HTask> *htaskPool = new QueueInfo<HTask>() ; | |
| 15 QueueInfo<TaskList> *taskListPool = new QueueInfo<TaskList>() ; | |
|
1428
af2adce9752e
add to export TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1424
diff
changeset
|
16 QueueInfo<TaskLog> *taskLogQueue = new QueueInfo<TaskLog>(); |
| 955 | 17 |
| 220 | 18 static HTaskPtr systask_start; |
| 109 | 19 static HTaskPtr systask_finish; |
| 42 | 20 |
| 550 | 21 static void |
| 22 noaction(SchedTask *s, void *read, void *write) | |
| 3 | 23 { |
| 24 } | |
| 25 | |
| 835 | 26 TaskManagerImpl::TaskManagerImpl(int num) |
| 27 : machineNum(num){ | |
| 853 | 28 // 実行可能なHTaskのリスト |
| 955 | 29 activeTaskQueue = new QueueInfo<HTask>(htaskPool); |
| 853 | 30 // wait_forで止まっているHTaskのリスト。必要ないが、Dead lock detection に使う |
| 955 | 31 waitTaskQueue = new QueueInfo<HTask>(htaskPool); |
| 32 // HTask の factory. QueueInfo<HTask> ならなんでもいい。 | |
| 33 htaskImpl = waitTaskQueue ; // any QueueInfo<HTask> | |
| 34 // Task の dependency を表現する double linked list. QueueInfo<HTask> とは別に必要。 | |
| 35 taskQueueImpl = new QueueInfo<TaskQueue>(taskQueuePool); | |
|
1423
515a0f15b5d2
add to log taskdependency
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1230
diff
changeset
|
36 |
|
480
75e4afa40da2
TaskQueueInfo initiaization...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
479
diff
changeset
|
37 } |
| 50 | 38 |
| 220 | 39 /** |
| 298 | 40 * 一番最初に PPE で実行される systask_start |
| 220 | 41 */ |
| 42 | 42 void |
| 499 | 43 TaskManagerImpl::systask_init() |
| 42 | 44 { |
| 109 | 45 systask_register(); |
|
897
6bd218d3f643
add return address in SimpleTask for debugging.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
855
diff
changeset
|
46 systask_start = create_task(StartTask,0,0,0,0,__builtin_return_address(0)); |
|
6bd218d3f643
add return address in SimpleTask for debugging.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
855
diff
changeset
|
47 systask_finish = create_task(FinishTask,0,0,0,0,__builtin_return_address(0)); |
| 220 | 48 |
| 49 systask_start->spawn(); | |
| 50 | |
| 634 | 51 // すべての Task が FinishTask を wait_for すると、 |
| 52 // あらゆる Task が FinishTask の waiting task queue を操作する | |
| 53 // ことになる。それは、重すぎる。PPE/SPE Task が終了した時点で、 | |
| 54 // TaskManager が実行する方が安い。 | |
| 55 // append_waitTask(systask_finish); | |
| 56 } | |
| 57 | |
|
945
9ed1c4a877ca
sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
941
diff
changeset
|
58 /** |
|
9ed1c4a877ca
sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
941
diff
changeset
|
59 * Create Simple Task |
|
9ed1c4a877ca
sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
941
diff
changeset
|
60 */ |
| 634 | 61 HTaskPtr |
|
897
6bd218d3f643
add return address in SimpleTask for debugging.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
855
diff
changeset
|
62 TaskManagerImpl::create_task(int cmd,memaddr rbuf, long r_size, memaddr wbuf, long w_size, void *from) { |
| 1465 | 63 HTaskPtr new_task = htaskImpl->create(); |
| 1474 | 64 new_task->init(cmd, rbuf, r_size, wbuf, w_size); // この引数はもう意味がない |
| 1465 | 65 new_task->mimpl = this; |
| 1474 | 66 new_task->command = TaskArray1; |
| 67 new_task->create_task_array(cmd, 1, 8, 8, 8) ; // この引数はもう意味がない | |
| 634 | 68 new_task->post_func = noaction; |
|
897
6bd218d3f643
add return address in SimpleTask for debugging.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
855
diff
changeset
|
69 new_task->from = (memaddr)from; |
|
1423
515a0f15b5d2
add to log taskdependency
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1230
diff
changeset
|
70 |
| 1474 | 71 Task *t = new_task->next_task_array(cmd,0,8,1,1); |
| 72 t->set_inData(0,rbuf,r_size); | |
| 73 t->set_outData(0,wbuf,w_size); | |
| 74 | |
|
1479
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
75 new_task->export_task_log = _export_task_log; |
|
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
76 if (_export_task_log) { |
|
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
77 TaskLog *tasklog = new TaskLog(); |
|
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
78 tasklog->set_cmd(cmd); |
|
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
79 taskLogQueue->addLast(tasklog); |
|
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
80 new_task->tasklog = tasklog; |
|
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
81 } |
|
1423
515a0f15b5d2
add to log taskdependency
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1230
diff
changeset
|
82 |
| 949 | 83 #ifdef EARLY_TOUCH |
| 84 if (rbuf) { | |
| 85 if ((unsigned long)rbuf&0xf) { | |
| 1152 | 86 printf("Data is not aligned. command = %d, addr = 0x%lx, size = %ld\n", |
| 949 | 87 cmd, (unsigned long)rbuf, r_size); |
| 88 } | |
| 1474 | 89 char *p = (char *)rbuf; char b = *p; // これはコンパイラが落としてしまうのではないか... |
| 949 | 90 p = (char *)(rbuf+r_size-1); b += *p; |
| 91 } | |
| 92 if (wbuf) { | |
| 93 if ((unsigned long)wbuf&0xf) { | |
| 1152 | 94 printf("Data is not aligned. command = %d, addr = 0x%lx, size = %ld\n", |
| 949 | 95 cmd, (unsigned long)wbuf, w_size); |
| 96 } | |
| 97 char *p = (char *)wbuf; char b = *p; | |
| 98 p = (char *)(wbuf+w_size-1); b += *p; | |
| 99 } | |
| 100 #endif | |
| 634 | 101 |
| 102 return new_task; | |
| 42 | 103 } |
| 104 | |
|
945
9ed1c4a877ca
sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
941
diff
changeset
|
105 /** |
|
9ed1c4a877ca
sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
941
diff
changeset
|
106 * Create Compatible Task (TaskArray1) |
|
9ed1c4a877ca
sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
941
diff
changeset
|
107 */ |
| 3 | 108 HTaskPtr |
|
897
6bd218d3f643
add return address in SimpleTask for debugging.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
855
diff
changeset
|
109 TaskManagerImpl::create_task(int cmd,void *from) |
| 3 | 110 { |
| 111 | |
| 1465 | 112 HTaskPtr new_task = create_task(TaskArray,0,0,0,0, from); |
| 703 | 113 new_task->post_func = noaction; |
| 114 new_task->mimpl = this; | |
| 736 | 115 new_task->create_task_array(cmd,1,8,8,8); |
|
713
97adb3fe85c6
remove SIMPLE_TASK conditional
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
704
diff
changeset
|
116 // rbuf, r_size were set |
|
704
ec6c897448ca
Compatibility mode works.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
703
diff
changeset
|
117 new_task->command = TaskArray1; |
|
897
6bd218d3f643
add return address in SimpleTask for debugging.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
855
diff
changeset
|
118 new_task->from = (memaddr)from; |
| 1474 | 119 new_task->next_task_array(cmd,0,8,1,1); |
| 63 | 120 |
|
1479
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
121 new_task->export_task_log = _export_task_log; |
|
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
122 if (_export_task_log) { |
|
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
123 TaskLog *tasklog = new TaskLog(); |
|
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
124 tasklog->set_cmd(cmd); |
|
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
125 taskLogQueue->addLast(tasklog); |
|
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
126 new_task->tasklog = tasklog; |
|
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
127 } |
|
1428
af2adce9752e
add to export TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1424
diff
changeset
|
128 |
| 3 | 129 return new_task; |
| 130 } | |
| 131 | |
|
945
9ed1c4a877ca
sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
941
diff
changeset
|
132 /** |
|
9ed1c4a877ca
sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
941
diff
changeset
|
133 * Create Task Array |
|
9ed1c4a877ca
sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
941
diff
changeset
|
134 */ |
|
800
54f0180cea0f
run16 word count ( not yet worked. )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
736
diff
changeset
|
135 HTaskPtr |
|
897
6bd218d3f643
add return address in SimpleTask for debugging.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
855
diff
changeset
|
136 TaskManagerImpl::create_task_array(int id, int num_task, int num_param, int num_inData, int num_outData, void *from) |
|
800
54f0180cea0f
run16 word count ( not yet worked. )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
736
diff
changeset
|
137 { |
|
897
6bd218d3f643
add return address in SimpleTask for debugging.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
855
diff
changeset
|
138 HTaskPtr ta = create_task(TaskArray,0,0,0,0, from); |
|
800
54f0180cea0f
run16 word count ( not yet worked. )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
736
diff
changeset
|
139 ta->create_task_array(id, num_task, num_param, num_inData, num_outData) ; |
|
54f0180cea0f
run16 word count ( not yet worked. )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
736
diff
changeset
|
140 return ta; |
|
54f0180cea0f
run16 word count ( not yet worked. )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
736
diff
changeset
|
141 } |
|
54f0180cea0f
run16 word count ( not yet worked. )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
736
diff
changeset
|
142 |
| 1432 | 143 TaskListPtr |
| 144 TaskManagerImpl::createTaskList() | |
| 145 { | |
| 146 return NULL; | |
| 147 } | |
| 148 | |
|
1062
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
149 /* call get_task_name from ppu only */ |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
150 const char * |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
151 TaskManagerImpl::get_task_name(int cmd) { |
| 1147 | 152 |
| 153 if (0 <= cmd && cmd < MAX_TASK_OBJECT) { | |
| 154 | |
| 155 #ifndef NOT_CHECK | |
| 156 | |
| 157 int flag = 0; | |
| 158 | |
| 159 for (int i = 0; i < MAX_TASK_OBJECT; i++) { | |
| 160 if (entry_cmd[i] == cmd) { | |
| 161 flag = 1; | |
| 162 break; | |
| 163 } | |
| 164 } | |
| 165 | |
| 166 if (flag == 0) { | |
| 167 printf("cmd %d is not registered on task_list\n", cmd); | |
| 168 return NULL; | |
| 169 } | |
| 170 | |
| 171 #endif | |
| 172 return task_list[cmd].name; | |
| 173 } | |
| 174 else { | |
| 175 return NULL; | |
| 176 } | |
|
1062
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
177 } |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
178 const char * |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
179 TaskManagerImpl::get_task_name(TaskPtr task) { |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
180 return task != NULL ? get_task_name(task->command) : NULL; |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
181 } |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
182 const char * |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
183 TaskManagerImpl::get_task_name(SimpleTaskPtr simple_task) { |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
184 return simple_task != NULL ? get_task_name(simple_task->command) : NULL; |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
185 } |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
186 const char * |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
187 TaskManagerImpl::get_task_name(SchedTaskBase *sched_task) { |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
188 if (sched_task == NULL) return NULL; |
|
1464
3f2230d79eba
TaskList no compile errors
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1462
diff
changeset
|
189 if (sched_task->atask != NULL) { |
|
3f2230d79eba
TaskList no compile errors
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1462
diff
changeset
|
190 return get_task_name(sched_task->atask->command); |
|
1062
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
191 } |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
192 return NULL; |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
193 } |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
194 const char * |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
195 TaskManagerImpl::get_task_name(HTaskPtr htask) { |
| 1147 | 196 |
| 197 return get_task_name(htask, 0); | |
| 198 | |
|
1062
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
199 } |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
200 const char * |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
201 TaskManagerImpl::get_task_name(HTaskPtr htask, int index) { |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
202 if (!htask) return NULL; |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
203 switch (htask->command) { |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
204 case TaskArray1: |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
205 return get_task_name((TaskPtr)htask->rbuf); |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
206 break; |
|
1064
23dab670c5aa
TaskManagerImpl::get_task_name() fix in header file...
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
1062
diff
changeset
|
207 case TaskArray: { |
| 1147 | 208 |
| 209 TaskPtr tmp = (TaskPtr)htask->rbuf; | |
| 210 return get_task_name(tmp[0].command); | |
| 211 | |
|
1064
23dab670c5aa
TaskManagerImpl::get_task_name() fix in header file...
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
1062
diff
changeset
|
212 } |
|
1062
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
213 default: |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
214 return get_task_name(htask->command); |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
215 } |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
216 return NULL; |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
217 } |
|
f994f5032299
add TaskManagerImpl::get_task_name()
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
955
diff
changeset
|
218 |
| 3 | 219 /** |
| 298 | 220 * task の依存関係を設定 |
| 221 * master task が終わってから、slave task を実行するように | |
| 109 | 222 * master->wait_for(slave); |
| 3 | 223 */ |
| 224 void | |
| 225 TaskManagerImpl::set_task_depend(HTaskPtr master, HTaskPtr slave) | |
| 547 | 226 { |
| 3 | 227 TaskQueuePtr m, s; |
|
941
fc6cfaae6de7
add no_auto_free flag on HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
940
diff
changeset
|
228 if (!master->self) return; |
| 547 | 229 |
| 955 | 230 m = taskQueueImpl->create(); m->init(master); |
| 231 s = taskQueueImpl->create(); s->init(slave); | |
| 547 | 232 |
|
479
bf2d2625485e
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
233 master->wait_me->addLast(s); |
|
bf2d2625485e
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
234 slave->wait_i->addLast(m); |
|
481
f9ffcffb6d09
Double linked list modification done (tested on Mac OS X)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
480
diff
changeset
|
235 s->waiter = m; |
| 547 | 236 } |
| 237 | |
| 3 | 238 /** |
| 298 | 239 * タスクを実行可能キューまたは待機キューへ追加する。 |
| 240 * 依存関係が満たされていれば active, まだだったら wait へ。 | |
| 109 | 241 * task->spawn(); |
| 242 */ | |
| 3 | 243 void |
| 18 | 244 TaskManagerImpl::spawn_task(HTaskPtr task) |
| 3 | 245 { |
| 109 | 246 // waiter // master |
| 247 // waitee // slave | |
|
480
75e4afa40da2
TaskQueueInfo initiaization...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
479
diff
changeset
|
248 if (task->wait_i->empty()) { |
|
498
bce667ff20b9
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
249 append_activeTask(task); |
| 3 | 250 } else { |
|
498
bce667ff20b9
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
251 append_waitTask(task); |
| 3 | 252 } |
| 253 } | |
| 42 | 254 |
|
800
54f0180cea0f
run16 word count ( not yet worked. )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
736
diff
changeset
|
255 |
| 109 | 256 /** |
| 298 | 257 * Task を実行可能キューに追加する |
| 109 | 258 */ |
| 259 void | |
|
498
bce667ff20b9
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
260 TaskManagerImpl::append_activeTask(HTaskPtr q) |
| 109 | 261 { |
|
479
bf2d2625485e
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
262 activeTaskQueue->addLast(q); |
| 109 | 263 } |
| 264 | |
| 265 /** | |
| 298 | 266 * タスクが実行する CPU を選択する |
| 109 | 267 * |
| 298 | 268 * 現在は CPU_PPE, CPU_SPE, SPE_ANY, SPE_0, SPE_1, ..., SPE_5 |
| 269 * types.h に書いてます。 | |
| 109 | 270 */ |
| 65 | 271 void |
| 272 TaskManagerImpl::set_task_cpu(HTaskPtr task, CPU_TYPE type) | |
| 273 { | |
| 664 | 274 if (machineNum==0) |
| 275 task->cpu_type = CPU_PPE ; | |
| 276 else | |
| 277 task->cpu_type = type; | |
| 65 | 278 } |
| 279 | |
|
940
e01b551f25d6
unknown dead lock still...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
939
diff
changeset
|
280 #if 0 |
|
e01b551f25d6
unknown dead lock still...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
939
diff
changeset
|
281 static void |
| 955 | 282 check_wait(TaskManagerImpl *tm, QueueInfo<TaskQueue> *wait_i) { |
|
940
e01b551f25d6
unknown dead lock still...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
939
diff
changeset
|
283 for(TaskQueue *t = wait_i->getFirst(); t; t = wait_i->getNext(t)) { |
|
e01b551f25d6
unknown dead lock still...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
939
diff
changeset
|
284 if (!tm->waitTaskQueue->find(t->task)) { |
| 1152 | 285 //this->printf("stray waiting task%d %lx\n",t->task->command, (long)t->task); |
| 286 printf("stray waiting task%d %lx\n",t->task->command, (long)t->task); | |
|
940
e01b551f25d6
unknown dead lock still...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
939
diff
changeset
|
287 } else if (tm->activeTaskQueue->find(t->task)) { |
| 1152 | 288 //this->printf(" active task%d in waiting queue %lx\n",t->task->command, (long)t->task); |
| 289 printf(" active task%d in waiting queue %lx\n",t->task->command, (long)t->task); | |
|
940
e01b551f25d6
unknown dead lock still...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
939
diff
changeset
|
290 } else |
| 1152 | 291 printf("."); |
|
940
e01b551f25d6
unknown dead lock still...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
939
diff
changeset
|
292 } |
|
e01b551f25d6
unknown dead lock still...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
939
diff
changeset
|
293 } |
|
e01b551f25d6
unknown dead lock still...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
939
diff
changeset
|
294 #endif |
|
e01b551f25d6
unknown dead lock still...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
939
diff
changeset
|
295 |
| 109 | 296 /** |
| 830 | 297 * @brief 終了したタスクから依存の処理とか |
| 298 | 298 * post_func() はこのタスクが終了したら実行する関数。 |
| 109 | 299 * |
| 298 | 300 * @param [task] 終了したタスク |
| 109 | 301 */ |
| 302 void | |
| 955 | 303 TaskManagerImpl::check_task_finish(HTaskPtr me, QueueInfo<HTask> *wait_queue) |
| 42 | 304 { |
|
1479
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
305 if (_export_task_log) |
|
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
306 me->tasklog->finish_time = rdtsc(); |
|
1423
515a0f15b5d2
add to log taskdependency
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1230
diff
changeset
|
307 |
| 497 | 308 while(TaskQueue *p = me->wait_me->poll()) { |
| 499 | 309 HTaskPtr you = p->task; |
| 955 | 310 QueueInfo<TaskQueue> *wait_i = you->wait_i; |
|
479
bf2d2625485e
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
311 // 相手の wait queue から自分(を指しているTaskQueue)を削除 |
|
bf2d2625485e
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
312 wait_i->remove(p->waiter); |
|
bf2d2625485e
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
313 // queue を free する |
| 493 | 314 wait_i->free_(p->waiter); |
|
483
5f4ffff2c2aa
renew task worked. but not test_nogl...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
481
diff
changeset
|
315 |
| 497 | 316 if (wait_i->empty()) { |
|
647
7ba4ad4538b1
MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
639
diff
changeset
|
317 wait_queue->remove(you); |
| 499 | 318 append_activeTask(you); |
| 497 | 319 } |
| 320 | |
|
940
e01b551f25d6
unknown dead lock still...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
939
diff
changeset
|
321 wait_i->free_(p); // p->wait_i, p->wait_me は再利用される |
|
479
bf2d2625485e
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
322 } |
|
bf2d2625485e
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
323 |
| 1466 | 324 // このTaskList は終わったので、今 free して良いが、TaskListInfo に入っているので、 |
| 325 // MY_SPE_STATUS_READY 時に、まとめてfree する。FifoTaskManager/CellTaskManager | |
| 326 | |
| 939 | 327 // me を誰かが持っていて、me が finish した後に、 |
| 328 // me->wait_for(i) とか、やられると気まずい。 | |
| 329 // 特に、me が他人に再利用されていると。そういう時には、 | |
| 330 // このfreeをコメントアウトしてみる。 | |
| 331 | |
| 332 // id かななんかでチェックした方が良いが... | |
| 333 | |
| 334 me->self = 0; | |
|
941
fc6cfaae6de7
add no_auto_free flag on HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
940
diff
changeset
|
335 if (!me->flag.no_auto_free) |
|
fc6cfaae6de7
add no_auto_free flag on HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
940
diff
changeset
|
336 htaskImpl->free_(me); |
| 109 | 337 } |
| 42 | 338 |
| 830 | 339 /** |
| 340 * @brief 終了したタスクリストの依存の処理 | |
| 341 * @param [task] 終了したタスク | |
| 342 */ | |
| 343 void | |
| 955 | 344 TaskManagerImpl::check_task_list_finish(SchedTask *s, TaskListPtr list, QueueInfo<HTask> *wait_queue) |
| 830 | 345 { |
|
1462
8cf62aea798f
HTask/TaskList fix (on going)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1424
diff
changeset
|
346 HTask *me = list->self; |
|
8cf62aea798f
HTask/TaskList fix (on going)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1424
diff
changeset
|
347 if (me) { |
|
8cf62aea798f
HTask/TaskList fix (on going)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1424
diff
changeset
|
348 me->post_func(s, me->post_arg1, me->post_arg2); |
|
8cf62aea798f
HTask/TaskList fix (on going)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1424
diff
changeset
|
349 check_task_finish(me, wait_queue); |
| 830 | 350 } |
| 351 } | |
| 109 | 352 |
| 830 | 353 /** |
| 354 * @brief waitTaskqueue への挿入 。必須ではない。 | |
| 355 * 現状では、dead lock 検出にしか使ってない | |
| 356 * | |
| 357 * @param [task] 終了したタスク | |
| 358 */ | |
| 109 | 359 void |
|
498
bce667ff20b9
double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
497
diff
changeset
|
360 TaskManagerImpl::append_waitTask(HTaskPtr q) |
| 109 | 361 { |
|
479
bf2d2625485e
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
362 waitTaskQueue ->addLast(q); |
| 109 | 363 } |
| 364 | |
| 830 | 365 /** |
|
1462
8cf62aea798f
HTask/TaskList fix (on going)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1424
diff
changeset
|
366 @brief htask のTaskListを DMA でCPUに渡すための TaskListQueue に入れる |
| 830 | 367 @param htask |
| 368 @param taskList | |
| 369 */ | |
| 806 | 370 void |
|
1423
515a0f15b5d2
add to log taskdependency
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1230
diff
changeset
|
371 TaskManagerImpl::set_taskList(HTaskPtr htask, QueueInfo<TaskList> * taskList) |
|
515a0f15b5d2
add to log taskdependency
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1230
diff
changeset
|
372 { |
|
1479
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
373 if (_export_task_log) |
|
163220e54cc0
remove hard code for TaskLog
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1474
diff
changeset
|
374 htask->tasklog->execute_time = rdtsc(); |
|
1423
515a0f15b5d2
add to log taskdependency
Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp>
parents:
1230
diff
changeset
|
375 |
|
1462
8cf62aea798f
HTask/TaskList fix (on going)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1424
diff
changeset
|
376 TaskListPtr tl = (TaskList*)htask->rbuf; |
|
8cf62aea798f
HTask/TaskList fix (on going)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1424
diff
changeset
|
377 while(tl->prev) tl=tl->prev; |
|
8cf62aea798f
HTask/TaskList fix (on going)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1424
diff
changeset
|
378 while(tl) { |
|
8cf62aea798f
HTask/TaskList fix (on going)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1424
diff
changeset
|
379 TaskListPtr next = tl->next; |
|
8cf62aea798f
HTask/TaskList fix (on going)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1424
diff
changeset
|
380 taskList->addLast(tl); |
|
8cf62aea798f
HTask/TaskList fix (on going)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1424
diff
changeset
|
381 tl = next; |
| 806 | 382 } |
| 383 } | |
| 384 | |
| 54 | 385 |
| 619 | 386 |
|
479
bf2d2625485e
Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
475
diff
changeset
|
387 /* end */ |