# HG changeset patch # User Shinji KONO # Date 1280909257 -32400 # Node ID 559d041313dc6114a0f86e1613310aab32e84cbd # Parent 15026ebf7a174023c858f20addeeeab29a3db198 quue info working on Cell. diff -r 15026ebf7a17 -r 559d041313dc TaskManager/Cell/CellTaskManagerImpl.cc --- a/TaskManager/Cell/CellTaskManagerImpl.cc Wed Aug 04 17:02:26 2010 +0900 +++ b/TaskManager/Cell/CellTaskManagerImpl.cc Wed Aug 04 17:07:37 2010 +0900 @@ -35,8 +35,8 @@ speThreads->init(); // 実行される Task 用の パイプライン用のダブルバッファ - speTaskList = new *QueueInfo[machineNum]; // spe上の走っている Task の配列 - taskListInfo = new *QueueInfo[machineNum]; // 次に走る Task の配列 + speTaskList = new QueueInfo*[machineNum]; // spe上の走っている Task の配列 + taskListInfo = new QueueInfo*[machineNum]; // 次に走る Task の配列 for (int i = 0; i < machineNum; i++) { taskListInfo[i] = new QueueInfo(taskListPool); @@ -148,7 +148,7 @@ { if (p==me) printf("*%lx ",(long)p); // loop if (depth==0) return; - TaskQueueInfo *w = p->wait_i; + QueueInfo *w = p->wait_i; if (w) { for( TaskQueue *q = w->getFirst(); q; q = w->getNext(q)) { loop_check(q->task,me, depth-1); @@ -166,7 +166,7 @@ get_scheduler()-> printf(" wait queue %d\n",waitTaskQueue->length()); for( HTask *p = waitTaskQueue->getFirst(); p; p = waitTaskQueue->getNext(p)) { printf(" Waiting task%d %lx",p->command, (long)p); - TaskQueueInfo *w = p->wait_i; + QueueInfo *w = p->wait_i; if (w) { for( TaskQueue *q = w->getFirst(); q; q = w->getNext(q)) { printf(" waiting task%d %lx",q->task->command, (long)q->task); @@ -272,7 +272,7 @@ // speTaskList は走り終わった ppe の Task の List. // taskListInfo はこれから走る Task の List. // 交換して実行する - TaskListInfoPtr tmp = taskListInfo[id]; + QueueInfo *tmp = taskListInfo[id]; taskListInfo[id] = speTaskList[id]; speTaskList[id] = tmp; diff -r 15026ebf7a17 -r 559d041313dc TaskManager/Cell/CellTaskManagerImpl.h --- a/TaskManager/Cell/CellTaskManagerImpl.h Wed Aug 04 17:02:26 2010 +0900 +++ b/TaskManager/Cell/CellTaskManagerImpl.h Wed Aug 04 17:07:37 2010 +0900 @@ -12,8 +12,8 @@ ~CellTaskManagerImpl(); /* variables */ - QueueInfo *taskListInfo; - QueueInfo *speTaskList; // running task + QueueInfo **taskListInfo; + QueueInfo **speTaskList; // running task SpeThreads *speThreads; FifoTaskManagerImpl *ppeManager;