diff TaskManager/kernel/ppe/TaskManagerImpl.cc @ 58:7492eb28b577

*** empty log message ***
author gongo
date Sat, 16 Feb 2008 19:40:20 +0900
parents 90523ccc4dff
children 54355e641172
line wrap: on
line diff
--- a/TaskManager/kernel/ppe/TaskManagerImpl.cc	Sat Feb 16 19:40:20 2008 +0900
+++ b/TaskManager/kernel/ppe/TaskManagerImpl.cc	Sat Feb 16 19:40:20 2008 +0900
@@ -14,7 +14,7 @@
 {
     delete mailManager;
     delete scheduler;
-    delete taskInfo;
+    delete bufferManager;
 }
 
 void
@@ -34,7 +34,7 @@
 {
     HTaskPtr new_task;
 
-    new_task = taskInfo->create_task(cmd, size, in_addr, out_addr);
+    new_task = bufferManager->create_task(cmd, size, in_addr, out_addr);
 
     if (func == NULL) {
 	new_task->post_func = noaction;
@@ -54,8 +54,8 @@
 {
     TaskQueuePtr m, s;
 
-    m = taskInfo->create_taskQueue(master);
-    s = taskInfo->create_taskQueue(slave);
+    m = bufferManager->create_taskQueue(master);
+    s = bufferManager->create_taskQueue(slave);
 
     master->wait_me = TaskQueueInfo::append(master->wait_me, s);
     slave->wait_i = TaskQueueInfo::append(slave->wait_i, m);
@@ -65,9 +65,9 @@
 TaskManagerImpl::spawn_task(HTaskPtr task)
 {
     if (task->wait_i == NULL) {
-	taskInfo->append_activeTask(task);
+	bufferManager->append_activeTask(task);
     } else {
-	taskInfo->append_waitTask(task);	
+	bufferManager->append_waitTask(task);	
     }
 }
 
@@ -81,15 +81,15 @@
     HTaskPtr htask;
     TaskPtr task;
 
-    queue = taskInfo->activeTaskQueue;
+    queue = bufferManager->activeTaskQueue;
     if (queue == NULL) {
 	return NULL;
     }
 
-    taskInfo->clear_taskList();
+    bufferManager->clear_taskList();
  
     while (queue) {
-	list = taskInfo->get_available_taskList();
+	list = bufferManager->get_available_taskList();
 	htask = queue->task;
 	d = queue;
 	queue = queue->next;
@@ -116,10 +116,10 @@
 	task->in_size  = htask->in_size;
 	task->self = htask;
 
-	taskInfo->free_taskQueue(d);
+	bufferManager->free_taskQueue(d);
     }
 
-    taskInfo->activeTaskQueue = NULL;
+    bufferManager->activeTaskQueue = NULL;
 
     return list;
 }
@@ -176,7 +176,7 @@
 	    }
 	} else {
 	    __debug_ppe("[PPE] recv from : 0x%x\n", data);
-	    taskInfo->check_task_finish((HTaskPtr)data);
+	    bufferManager->check_task_finish((HTaskPtr)data);
 	}
 
 	d = q;