Mercurial > hg > Members > kono > Cerium

changeset 957:559d041313dc

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
quue info working on Cell.
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Wed, 04 Aug 2010 17:07:37 +0900
parents 15026ebf7a17
children 58ff7b6fdbce
files TaskManager/Cell/CellTaskManagerImpl.cc TaskManager/Cell/CellTaskManagerImpl.h
diffstat 2 files changed, 7 insertions(+), 7 deletions(-) [+]
line wrap: on
line diff
--- 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<TaskList>[machineNum]; // spe上の走っている Task の配列
-    taskListInfo  = new *QueueInfo<TaskList>[machineNum]; // 次に走る Task の配列
+    speTaskList   = new QueueInfo<TaskList>*[machineNum]; // spe上の走っている Task の配列
+    taskListInfo  = new QueueInfo<TaskList>*[machineNum]; // 次に走る Task の配列
 
     for (int i = 0; i < machineNum; i++) {
 	taskListInfo[i] = new QueueInfo<TaskList>(taskListPool);
@@ -148,7 +148,7 @@
 {
     if (p==me) printf("*%lx ",(long)p); // loop
     if (depth==0) return;
-    TaskQueueInfo *w = p->wait_i;
+    QueueInfo<TaskQueue> *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<TaskQueue> *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<TaskList> *tmp = taskListInfo[id];
     taskListInfo[id] = speTaskList[id];
     speTaskList[id] = tmp;
 
--- 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<TaskList> *taskListInfo;
-    QueueInfo<TaskList> *speTaskList;  // running task
+    QueueInfo<TaskList> **taskListInfo;
+    QueueInfo<TaskList> **speTaskList;  // running task
 
     SpeThreads *speThreads;
     FifoTaskManagerImpl *ppeManager;