Game/Cerium: TaskManager/kernel/ppe/TaskManagerImpl.cc annotate

annotate TaskManager/kernel/ppe/TaskManagerImpl.cc @ 1887:94a824cde2e4 draft

remove some old code

author	Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date	Fri, 03 Jan 2014 17:04:46 +0900
parents	b49aaf88eae6
children	f4c16bdddee0

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 2356238ebea7 * empty log message * gongo parents: diff changeset	2 #include "TaskManagerImpl.h"
46 f154d9d07a42 * empty log message * gongo parents: 42 diff changeset	3 #include "types.h"
f154d9d07a42 * empty log message * gongo parents: 42 diff changeset	4 #include "error.h"
546 d6ba5ede4fe7 .... Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 539 diff changeset	5 #include "SchedTask.h"
619 278db3ca751d RenewTask removal Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 567 diff changeset	6 #include "Scheduler.h"
634 62e570ac5db2 SimpleTask start Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 619 diff changeset	7 #include "SysTask.h"
62e570ac5db2 SimpleTask start Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 619 diff changeset	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 fb49e881f2ed TaslListInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 800 diff changeset	10 #include <string.h>
fb49e881f2ed TaslListInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 800 diff changeset	11
955 6ffeb543e8d4 unify all QueueInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 949 diff changeset	12 // singleton
6ffeb543e8d4 unify all QueueInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 949 diff changeset	13 QueueInfo<TaskQueue> *taskQueuePool = new QueueInfo<TaskQueue>() ;
6ffeb543e8d4 unify all QueueInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 949 diff changeset	14 QueueInfo<HTask> *htaskPool = new QueueInfo<HTask>() ;
6ffeb543e8d4 unify all QueueInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 949 diff changeset	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 6ffeb543e8d4 unify all QueueInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 949 diff changeset	17
220 305ac1897c50 fix gongo@localhost.localdomain parents: 115 diff changeset	18 static HTaskPtr systask_start;
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	19 static HTaskPtr systask_finish;
42 aa11038dbdc1 * empty log message * gongo parents: 18 diff changeset	20
550 a9f27334963a old ball_bound fix... Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 539 diff changeset	21 static void
a9f27334963a old ball_bound fix... Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 539 diff changeset	22 noaction(SchedTask s, void read, void *write)
3 2356238ebea7 * empty log message * gongo parents: diff changeset	23 {
2356238ebea7 * empty log message * gongo parents: diff changeset	24 }
2356238ebea7 * empty log message * gongo parents: diff changeset	25
835 beccb8a8bc69 fix yutaka@localhost.localdomain parents: 833 diff changeset	26 TaskManagerImpl::TaskManagerImpl(int num)
1605 5b99bcc6bdb0 fix mail_check and init dim_count and init _export_task_log. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1588 diff changeset	27 : machineNum(num) ,_export_task_log(0){
853 0718a4e40450 fix game@zeus.cr.ie.u-ryukyu.ac.jp parents: 835 diff changeset	28 // 実行可能なHTaskのリスト
955 6ffeb543e8d4 unify all QueueInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 949 diff changeset	29 activeTaskQueue = new QueueInfo<HTask>(htaskPool);
853 0718a4e40450 fix game@zeus.cr.ie.u-ryukyu.ac.jp parents: 835 diff changeset	30 // wait_forで止まっているHTaskのリスト。必要ないが、Dead lock detection に使う
955 6ffeb543e8d4 unify all QueueInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 949 diff changeset	31 waitTaskQueue = new QueueInfo<HTask>(htaskPool);
6ffeb543e8d4 unify all QueueInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 949 diff changeset	32 // HTask の factory. QueueInfo<HTask> ならなんでもいい。
6ffeb543e8d4 unify all QueueInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 949 diff changeset	33 htaskImpl = waitTaskQueue ; // any QueueInfo<HTask>
6ffeb543e8d4 unify all QueueInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 949 diff changeset	34 // Task の dependency を表現する double linked list. QueueInfo<HTask> とは別に必要。
1542 9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	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 7927e00fb8e2 * empty log message * gongo parents: 48 diff changeset	38
220 305ac1897c50 fix gongo@localhost.localdomain parents: 115 diff changeset	39 /**
298 768452fab95e from EUC to UTF-8 Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 220 diff changeset	40 * 一番最初に PPE で実行される systask_start
220 305ac1897c50 fix gongo@localhost.localdomain parents: 115 diff changeset	41 */
42 aa11038dbdc1 * empty log message * gongo parents: 18 diff changeset	42 void
499 981aa2f89a80 still fixing... Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 498 diff changeset	43 TaskManagerImpl::systask_init()
42 aa11038dbdc1 * empty log message * gongo parents: 18 diff changeset	44 {
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	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 305ac1897c50 fix gongo@localhost.localdomain parents: 115 diff changeset	48
305ac1897c50 fix gongo@localhost.localdomain parents: 115 diff changeset	49 systask_start->spawn();
305ac1897c50 fix gongo@localhost.localdomain parents: 115 diff changeset	50
634 62e570ac5db2 SimpleTask start Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 619 diff changeset	51 // すべての Task が FinishTask を wait_for すると、
62e570ac5db2 SimpleTask start Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 619 diff changeset	52 // あらゆる Task が FinishTask の waiting task queue を操作する
62e570ac5db2 SimpleTask start Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 619 diff changeset	53 // ことになる。それは、重すぎる。PPE/SPE Task が終了した時点で、
62e570ac5db2 SimpleTask start Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 619 diff changeset	54 // TaskManager が実行する方が安い。
62e570ac5db2 SimpleTask start Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 619 diff changeset	55 // append_waitTask(systask_finish);
62e570ac5db2 SimpleTask start Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 619 diff changeset	56 }
62e570ac5db2 SimpleTask start Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 619 diff changeset	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 62e570ac5db2 SimpleTask start Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 619 diff changeset	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 fc5b23108608 TaskList on going... Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1464 diff changeset	63 HTaskPtr new_task = htaskImpl->create();
1474 b158873485f6 fix simple task Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1468 diff changeset	64 new_task->init(cmd, rbuf, r_size, wbuf, w_size); // この引数はもう意味がない
1465 fc5b23108608 TaskList on going... Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1464 diff changeset	65 new_task->mimpl = this;
1474 b158873485f6 fix simple task Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1468 diff changeset	66 new_task->command = TaskArray1;
b158873485f6 fix simple task Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1468 diff changeset	67 new_task->create_task_array(cmd, 1, 8, 8, 8) ; // この引数はもう意味がない
634 62e570ac5db2 SimpleTask start Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 619 diff changeset	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 b158873485f6 fix simple task Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1468 diff changeset	71 Task *t = new_task->next_task_array(cmd,0,8,1,1);
b158873485f6 fix simple task Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1468 diff changeset	72 t->set_inData(0,rbuf,r_size);
b158873485f6 fix simple task Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1468 diff changeset	73 t->set_outData(0,wbuf,w_size);
b158873485f6 fix simple task Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1468 diff changeset	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 5f0135ca75ee word count size fix Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 945 diff changeset	83 #ifdef EARLY_TOUCH
5f0135ca75ee word count size fix Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 945 diff changeset	84 if (rbuf) {
1542 9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	85 if ((unsigned long)rbuf&0xf) {
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	86 printf("Data is not aligned. command = %d, addr = 0x%lx, size = %ld\n",
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	87 cmd, (unsigned long)rbuf, r_size);
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	88 }
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	89 char p = (char )rbuf; char b = *p; // これはコンパイラが落としてしまうのではないか...
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	90 p = (char )(rbuf+r_size-1); b += p;
949 5f0135ca75ee word count size fix Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 945 diff changeset	91 }
5f0135ca75ee word count size fix Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 945 diff changeset	92 if (wbuf) {
1542 9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	93 if ((unsigned long)wbuf&0xf) {
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	94 printf("Data is not aligned. command = %d, addr = 0x%lx, size = %ld\n",
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	95 cmd, (unsigned long)wbuf, w_size);
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	96 }
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	97 char p = (char )wbuf; char b = *p;
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	98 p = (char )(wbuf+w_size-1); b += p;
949 5f0135ca75ee word count size fix Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 945 diff changeset	99 }
5f0135ca75ee word count size fix Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 945 diff changeset	100 #endif
634 62e570ac5db2 SimpleTask start Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 619 diff changeset	101
62e570ac5db2 SimpleTask start Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 619 diff changeset	102 return new_task;
42 aa11038dbdc1 * empty log message * gongo parents: 18 diff changeset	103 }
aa11038dbdc1 * empty log message * gongo parents: 18 diff changeset	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 2356238ebea7 * empty log message * gongo parents: diff changeset	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 2356238ebea7 * empty log message * gongo parents: diff changeset	110 {
2356238ebea7 * empty log message * gongo parents: diff changeset	111
1465 fc5b23108608 TaskList on going... Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1464 diff changeset	112 HTaskPtr new_task = create_task(TaskArray,0,0,0,0, from);
703 0c8ad8d99656 compatibility Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 664 diff changeset	113 new_task->post_func = noaction;
0c8ad8d99656 compatibility Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 664 diff changeset	114 new_task->mimpl = this;
736 1b225972ae88 cut printf hiroki@localhost.localdomain parents: 719 diff changeset	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;
1551 57317332f6ef create fft example Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1543 diff changeset	119 new_task->next_task_array(cmd,0,8,8,8);
63 54355e641172 * empty log message * gongo parents: 58 diff changeset	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 2356238ebea7 * empty log message * gongo parents: diff changeset	129 return new_task;
2356238ebea7 * empty log message * gongo parents: diff changeset	130 }
2356238ebea7 * empty log message * gongo parents: diff changeset	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 b77f32eb137c make available Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp> parents: 1428 diff changeset	143 TaskListPtr
b77f32eb137c make available Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp> parents: 1428 diff changeset	144 TaskManagerImpl::createTaskList()
b77f32eb137c make available Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp> parents: 1428 diff changeset	145 {
b77f32eb137c make available Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp> parents: 1428 diff changeset	146 return NULL;
b77f32eb137c make available Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp> parents: 1428 diff changeset	147 }
b77f32eb137c make available Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp> parents: 1428 diff changeset	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 279b41354753 add check code. Yutaka_Kinjyo parents: 1142 diff changeset	152 if (0 <= cmd && cmd < MAX_TASK_OBJECT) {
1542 9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	153 return task_list[cmd].name;
1887 94a824cde2e4 remove some old code Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1666 diff changeset	154 } else {
1147 279b41354753 add check code. Yutaka_Kinjyo parents: 1142 diff changeset	155 return NULL;
279b41354753 add check code. Yutaka_Kinjyo parents: 1142 diff changeset	156 }
1062 f994f5032299 add TaskManagerImpl::get_task_name() kazz <kazz@cr.ie.u-ryukyu.ac.jp> parents: 955 diff changeset	157 }
f994f5032299 add TaskManagerImpl::get_task_name() kazz <kazz@cr.ie.u-ryukyu.ac.jp> parents: 955 diff changeset	158 const char *
f994f5032299 add TaskManagerImpl::get_task_name() kazz <kazz@cr.ie.u-ryukyu.ac.jp> parents: 955 diff changeset	159 TaskManagerImpl::get_task_name(TaskPtr task) {
1542 9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	160 return task != NULL ? get_task_name(task->command) : NULL;
1062 f994f5032299 add TaskManagerImpl::get_task_name() kazz <kazz@cr.ie.u-ryukyu.ac.jp> parents: 955 diff changeset	161 }
f994f5032299 add TaskManagerImpl::get_task_name() kazz <kazz@cr.ie.u-ryukyu.ac.jp> parents: 955 diff changeset	162 const char *
f994f5032299 add TaskManagerImpl::get_task_name() kazz <kazz@cr.ie.u-ryukyu.ac.jp> parents: 955 diff changeset	163 TaskManagerImpl::get_task_name(SimpleTaskPtr simple_task) {
1542 9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	164 return simple_task != NULL ? get_task_name(simple_task->command) : NULL;
1062 f994f5032299 add TaskManagerImpl::get_task_name() kazz <kazz@cr.ie.u-ryukyu.ac.jp> parents: 955 diff changeset	165 }
f994f5032299 add TaskManagerImpl::get_task_name() kazz <kazz@cr.ie.u-ryukyu.ac.jp> parents: 955 diff changeset	166 const char *
f994f5032299 add TaskManagerImpl::get_task_name() kazz <kazz@cr.ie.u-ryukyu.ac.jp> parents: 955 diff changeset	167 TaskManagerImpl::get_task_name(SchedTaskBase *sched_task) {
1542 9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	168 if (sched_task == NULL) return NULL;
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	169 if (sched_task->atask != NULL) {
1464 3f2230d79eba TaskList no compile errors Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1462 diff changeset	170 return get_task_name(sched_task->atask->command);
1542 9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	171 }
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	172 return NULL;
1062 f994f5032299 add TaskManagerImpl::get_task_name() kazz <kazz@cr.ie.u-ryukyu.ac.jp> parents: 955 diff changeset	173 }
f994f5032299 add TaskManagerImpl::get_task_name() kazz <kazz@cr.ie.u-ryukyu.ac.jp> parents: 955 diff changeset	174 const char *
f994f5032299 add TaskManagerImpl::get_task_name() kazz <kazz@cr.ie.u-ryukyu.ac.jp> parents: 955 diff changeset	175 TaskManagerImpl::get_task_name(HTaskPtr htask) {
1147 279b41354753 add check code. Yutaka_Kinjyo parents: 1142 diff changeset	176
279b41354753 add check code. Yutaka_Kinjyo parents: 1142 diff changeset	177 return get_task_name(htask, 0);
279b41354753 add check code. Yutaka_Kinjyo parents: 1142 diff changeset	178
1561 e8c9a7099bcc add set NDRange param Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1551 diff changeset	179 }
1062 f994f5032299 add TaskManagerImpl::get_task_name() kazz <kazz@cr.ie.u-ryukyu.ac.jp> parents: 955 diff changeset	180 const char *
f994f5032299 add TaskManagerImpl::get_task_name() kazz <kazz@cr.ie.u-ryukyu.ac.jp> parents: 955 diff changeset	181 TaskManagerImpl::get_task_name(HTaskPtr htask, int index) {
1542 9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	182 if (!htask) return NULL;
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	183 switch (htask->command) {
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	184 case TaskArray1:
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	185 return get_task_name((TaskPtr)htask->rbuf);
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	186 break;
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	187 case TaskArray: {
1147 279b41354753 add check code. Yutaka_Kinjyo parents: 1142 diff changeset	188
1542 9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	189 TaskPtr tmp = (TaskPtr)htask->rbuf;
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	190 return get_task_name(tmp[0].command);
1147 279b41354753 add check code. Yutaka_Kinjyo parents: 1142 diff changeset	191
1542 9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	192 }
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	193 default:
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	194 return get_task_name(htask->command);
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	195 }
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	196 return NULL;
1062 f994f5032299 add TaskManagerImpl::get_task_name() kazz <kazz@cr.ie.u-ryukyu.ac.jp> parents: 955 diff changeset	197 }
f994f5032299 add TaskManagerImpl::get_task_name() kazz <kazz@cr.ie.u-ryukyu.ac.jp> parents: 955 diff changeset	198
3 2356238ebea7 * empty log message * gongo parents: diff changeset	199 /**
298 768452fab95e from EUC to UTF-8 Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 220 diff changeset	200 * task の依存関係を設定
768452fab95e from EUC to UTF-8 Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 220 diff changeset	201 * master task が終わってから、slave task を実行するように
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	202 * master->wait_for(slave);
3 2356238ebea7 * empty log message * gongo parents: diff changeset	203 */
2356238ebea7 * empty log message * gongo parents: diff changeset	204 void
2356238ebea7 * empty log message * gongo parents: diff changeset	205 TaskManagerImpl::set_task_depend(HTaskPtr master, HTaskPtr slave)
547 e5431e658038 continue.. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 546 diff changeset	206 {
3 2356238ebea7 * empty log message * gongo parents: diff changeset	207 TaskQueuePtr m, s;
941 fc6cfaae6de7 add no_auto_free flag on HTask Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 940 diff changeset	208 if (!master->self) return;
547 e5431e658038 continue.. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 546 diff changeset	209
955 6ffeb543e8d4 unify all QueueInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 949 diff changeset	210 m = taskQueueImpl->create(); m->init(master);
6ffeb543e8d4 unify all QueueInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 949 diff changeset	211 s = taskQueueImpl->create(); s->init(slave);
547 e5431e658038 continue.. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 546 diff changeset	212
479 bf2d2625485e Double Linked List base TaskQueue Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 475 diff changeset	213 master->wait_me->addLast(s);
bf2d2625485e Double Linked List base TaskQueue Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 475 diff changeset	214 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	215 s->waiter = m;
547 e5431e658038 continue.. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 546 diff changeset	216 }
e5431e658038 continue.. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 546 diff changeset	217
3 2356238ebea7 * empty log message * gongo parents: diff changeset	218 /**
298 768452fab95e from EUC to UTF-8 Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 220 diff changeset	219 * タスクを実行可能キューまたは待機キューへ追加する。
768452fab95e from EUC to UTF-8 Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 220 diff changeset	220 * 依存関係が満たされていれば active, まだだったら wait へ。
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	221 * task->spawn();
028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	222 */
3 2356238ebea7 * empty log message * gongo parents: diff changeset	223 void
18 0c9341da4522 * empty log message * gongo parents: 5 diff changeset	224 TaskManagerImpl::spawn_task(HTaskPtr task)
3 2356238ebea7 * empty log message * gongo parents: diff changeset	225 {
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	226 // waiter // master
028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	227 // waitee // slave
480 75e4afa40da2 TaskQueueInfo initiaization... Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 479 diff changeset	228 if (task->wait_i->empty()) {
498 bce667ff20b9 double linked HTaskInfo/HTask Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 497 diff changeset	229 append_activeTask(task);
3 2356238ebea7 * empty log message * gongo parents: diff changeset	230 } else {
498 bce667ff20b9 double linked HTaskInfo/HTask Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 497 diff changeset	231 append_waitTask(task);
3 2356238ebea7 * empty log message * gongo parents: diff changeset	232 }
2356238ebea7 * empty log message * gongo parents: diff changeset	233 }
42 aa11038dbdc1 * empty log message * gongo parents: 18 diff changeset	234
800 54f0180cea0f run16 word count ( not yet worked. ) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 736 diff changeset	235
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	236 /**
298 768452fab95e from EUC to UTF-8 Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 220 diff changeset	237 * Task を実行可能キューに追加する
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	238 */
028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	239 void
498 bce667ff20b9 double linked HTaskInfo/HTask Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 497 diff changeset	240 TaskManagerImpl::append_activeTask(HTaskPtr q)
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	241 {
479 bf2d2625485e Double Linked List base TaskQueue Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 475 diff changeset	242 activeTaskQueue->addLast(q);
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	243 }
028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	244
028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	245 /**
298 768452fab95e from EUC to UTF-8 Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 220 diff changeset	246 * タスクが実行する CPU を選択する
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	247 *
298 768452fab95e from EUC to UTF-8 Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 220 diff changeset	248 * 現在は CPU_PPE, CPU_SPE, SPE_ANY, SPE_0, SPE_1, ..., SPE_5
768452fab95e from EUC to UTF-8 Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 220 diff changeset	249 * types.h に書いてます。
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	250 */
65 519d24aa7ac8 * empty log message * gongo parents: 63 diff changeset	251 void
519d24aa7ac8 * empty log message * gongo parents: 63 diff changeset	252 TaskManagerImpl::set_task_cpu(HTaskPtr task, CPU_TYPE type)
519d24aa7ac8 * empty log message * gongo parents: 63 diff changeset	253 {
1492 73f4bfaeaf99 fix select cpu type Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1482 diff changeset	254 task_list->cpu_type = type;
664 beb0f17c19f9 word count Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 647 diff changeset	255 if (machineNum==0)
1588 f7d35318ea76 fix min_cpu() anc max_cpu() Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp> parents: 1561 diff changeset	256 task->cpu_type = CPU_PPE ;
664 beb0f17c19f9 word count Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 647 diff changeset	257 else
1588 f7d35318ea76 fix min_cpu() anc max_cpu() Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp> parents: 1561 diff changeset	258 task->cpu_type = type;
65 519d24aa7ac8 * empty log message * gongo parents: 63 diff changeset	259 }
519d24aa7ac8 * empty log message * gongo parents: 63 diff changeset	260
940 e01b551f25d6 unknown dead lock still... Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 939 diff changeset	261 #if 0
1542 9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	262 static void
955 6ffeb543e8d4 unify all QueueInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 949 diff changeset	263 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	264 for(TaskQueue *t = wait_i->getFirst(); t; t = wait_i->getNext(t)) {
1542 9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	265 if (!tm->waitTaskQueue->find(t->task)) {
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	266 //this->printf("stray waiting task%d %lx\n",t->task->command, (long)t->task);
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	267 printf("stray waiting task%d %lx\n",t->task->command, (long)t->task);
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	268 } else if (tm->activeTaskQueue->find(t->task)) {
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	269 //this->printf(" active task%d in waiting queue %lx\n",t->task->command, (long)t->task);
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	270 printf(" active task%d in waiting queue %lx\n",t->task->command, (long)t->task);
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	271 } else
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	272 printf(".");
940 e01b551f25d6 unknown dead lock still... Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 939 diff changeset	273 }
e01b551f25d6 unknown dead lock still... Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 939 diff changeset	274 }
e01b551f25d6 unknown dead lock still... Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 939 diff changeset	275 #endif
e01b551f25d6 unknown dead lock still... Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 939 diff changeset	276
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	277 /**
830 af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	278 * @brief 終了したタスクから依存の処理とか
298 768452fab95e from EUC to UTF-8 Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 220 diff changeset	279 * post_func() はこのタスクが終了したら実行する関数。
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	280 *
298 768452fab95e from EUC to UTF-8 Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 220 diff changeset	281 * @param [task] 終了したタスク
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	282 */
028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	283 void
955 6ffeb543e8d4 unify all QueueInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 949 diff changeset	284 TaskManagerImpl::check_task_finish(HTaskPtr me, QueueInfo<HTask> *wait_queue)
42 aa11038dbdc1 * empty log message * gongo parents: 18 diff changeset	285 {
1479 163220e54cc0 remove hard code for TaskLog Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp> parents: 1474 diff changeset	286 if (_export_task_log)
163220e54cc0 remove hard code for TaskLog Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp> parents: 1474 diff changeset	287 me->tasklog->finish_time = rdtsc();
1423 515a0f15b5d2 add to log taskdependency Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp> parents: 1230 diff changeset	288
497 3429986b8a28 no wakeup loop Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 496 diff changeset	289 while(TaskQueue *p = me->wait_me->poll()) {
1666 b49aaf88eae6 fix dim_count init Masa parents: 1605 diff changeset	290 HTaskPtr you = p->task;
b49aaf88eae6 fix dim_count init Masa parents: 1605 diff changeset	291 QueueInfo<TaskQueue> *wait_i = you->wait_i;
b49aaf88eae6 fix dim_count init Masa parents: 1605 diff changeset	292 // 相手の wait queue から自分(を指しているTaskQueue)を削除
b49aaf88eae6 fix dim_count init Masa parents: 1605 diff changeset	293 wait_i->remove(p->waiter);
b49aaf88eae6 fix dim_count init Masa parents: 1605 diff changeset	294 // queue を free する
b49aaf88eae6 fix dim_count init Masa parents: 1605 diff changeset	295 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	296
1666 b49aaf88eae6 fix dim_count init Masa parents: 1605 diff changeset	297 if (wait_i->empty()) {
b49aaf88eae6 fix dim_count init Masa parents: 1605 diff changeset	298 wait_queue->remove(you);
b49aaf88eae6 fix dim_count init Masa parents: 1605 diff changeset	299 append_activeTask(you);
b49aaf88eae6 fix dim_count init Masa parents: 1605 diff changeset	300 }
497 3429986b8a28 no wakeup loop Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 496 diff changeset	301
1666 b49aaf88eae6 fix dim_count init Masa parents: 1605 diff changeset	302 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	303 }
bf2d2625485e Double Linked List base TaskQueue Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 475 diff changeset	304
1466 cb57420a8219 TaskList on going... Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1465 diff changeset	305 // このTaskList は終わったので、今 free して良いが、TaskListInfo に入っているので、
cb57420a8219 TaskList on going... Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1465 diff changeset	306 // MY_SPE_STATUS_READY 時に、まとめてfree する。FifoTaskManager/CellTaskManager
1542 9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	307
939 aafa99c856a3 loop detection. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 897 diff changeset	308 // me を誰かが持っていて、me が finish した後に、
aafa99c856a3 loop detection. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 897 diff changeset	309 // me->wait_for(i) とか、やられると気まずい。
aafa99c856a3 loop detection. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 897 diff changeset	310 // 特に、me が他人に再利用されていると。そういう時には、
aafa99c856a3 loop detection. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 897 diff changeset	311 // このfreeをコメントアウトしてみる。
aafa99c856a3 loop detection. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 897 diff changeset	312
aafa99c856a3 loop detection. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 897 diff changeset	313 // id かななんかでチェックした方が良いが...
aafa99c856a3 loop detection. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 897 diff changeset	314
aafa99c856a3 loop detection. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 897 diff changeset	315 me->self = 0;
941 fc6cfaae6de7 add no_auto_free flag on HTask Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 940 diff changeset	316 if (!me->flag.no_auto_free)
1666 b49aaf88eae6 fix dim_count init Masa parents: 1605 diff changeset	317 htaskImpl->free_(me);
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	318 }
42 aa11038dbdc1 * empty log message * gongo parents: 18 diff changeset	319
830 af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	320 /**
af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	321 * @brief 終了したタスクリストの依存の処理
af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	322 * @param [task] 終了したタスク
af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	323 */
af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	324 void
955 6ffeb543e8d4 unify all QueueInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 949 diff changeset	325 TaskManagerImpl::check_task_list_finish(SchedTask s, TaskListPtr list, QueueInfo<HTask> wait_queue)
830 af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	326 {
1462 8cf62aea798f HTask/TaskList fix (on going) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1424 diff changeset	327 HTask *me = list->self;
8cf62aea798f HTask/TaskList fix (on going) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1424 diff changeset	328 if (me) {
8cf62aea798f HTask/TaskList fix (on going) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1424 diff changeset	329 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	330 check_task_finish(me, wait_queue);
830 af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	331 }
af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	332 }
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	333
830 af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	334 /**
af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	335 * @brief waitTaskqueue への挿入。必須ではない。
af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	336 * 現状では、dead lock 検出にしか使ってない
af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	337 *
af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	338 * @param [task] 終了したタスク
af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	339 */
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	340 void
498 bce667ff20b9 double linked HTaskInfo/HTask Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 497 diff changeset	341 TaskManagerImpl::append_waitTask(HTaskPtr q)
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	342 {
479 bf2d2625485e Double Linked List base TaskQueue Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 475 diff changeset	343 waitTaskQueue ->addLast(q);
109 028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	344 }
028ffc9c0375 Cerium cvs version gongo@gendarme.local parents: 94 diff changeset	345
830 af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	346 /**
1542 9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	347 @brief htask のTaskListを DMA でCPUに渡すための TaskListQueue に入れる
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	348 @param htask
9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	349 @param taskList
830 af2fb2e641eb return TaskList->self Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 809 diff changeset	350 */
806 fb49e881f2ed TaslListInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 800 diff changeset	351 void
1423 515a0f15b5d2 add to log taskdependency Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp> parents: 1230 diff changeset	352 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	353 {
1479 163220e54cc0 remove hard code for TaskLog Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp> parents: 1474 diff changeset	354 if (_export_task_log)
163220e54cc0 remove hard code for TaskLog Daichi TOMA <toma@cr.ie.u-ryukyu.ac.jp> parents: 1474 diff changeset	355 htask->tasklog->execute_time = rdtsc();
1542 9ccfdc408d51 fix gpu word count.but not count line num. Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1492 diff changeset	356
1462 8cf62aea798f HTask/TaskList fix (on going) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1424 diff changeset	357 TaskListPtr tl = (TaskList*)htask->rbuf;
8cf62aea798f HTask/TaskList fix (on going) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1424 diff changeset	358 while(tl->prev) tl=tl->prev;
8cf62aea798f HTask/TaskList fix (on going) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1424 diff changeset	359 while(tl) {
8cf62aea798f HTask/TaskList fix (on going) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1424 diff changeset	360 TaskListPtr next = tl->next;
8cf62aea798f HTask/TaskList fix (on going) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1424 diff changeset	361 taskList->addLast(tl);
8cf62aea798f HTask/TaskList fix (on going) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 1424 diff changeset	362 tl = next;
806 fb49e881f2ed TaslListInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 800 diff changeset	363 }
fb49e881f2ed TaslListInfo Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 800 diff changeset	364 }
1561 e8c9a7099bcc add set NDRange param Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1551 diff changeset	365
1543 890cb39418ca add error routine Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1542 diff changeset	366 void
890cb39418ca add error routine Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1542 diff changeset	367 error(const char *error_message)
890cb39418ca add error routine Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1542 diff changeset	368 {
890cb39418ca add error routine Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1542 diff changeset	369 fprintf(stderr,"%s \n",error_message);
890cb39418ca add error routine Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1542 diff changeset	370 exit(1);
890cb39418ca add error routine Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp> parents: 1542 diff changeset	371 }
54 90523ccc4dff * empty log message * gongo parents: 50 diff changeset	372
479 bf2d2625485e Double Linked List base TaskQueue Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 475 diff changeset	373 /* end */

Mercurial > hg > Game > Cerium

annotate TaskManager/kernel/ppe/TaskManagerImpl.cc @ 1887:94a824cde2e4 draft