diff TaskManager/kernel/ppe/TaskManagerImpl.cc @ 475:e083c4ff91c1

BufferManager removed.
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Sun, 04 Oct 2009 11:29:50 +0900
parents eab18aa0c7f6
children 5bda98b0b56d
line wrap: on
line diff
--- a/TaskManager/kernel/ppe/TaskManagerImpl.cc	Sat Oct 03 10:50:16 2009 +0900
+++ b/TaskManager/kernel/ppe/TaskManagerImpl.cc	Sun Oct 04 11:29:50 2009 +0900
@@ -42,7 +42,7 @@
 {
     HTaskPtr new_task;
 
-    new_task = bufferManager->create_task(cmd);
+    new_task = htaskImpl->create(cmd);
     new_task->post_func = noaction;
     new_task->mimpl = this;
 
@@ -59,8 +59,8 @@
 {
     TaskQueuePtr m, s;
 
-    m = bufferManager->create_taskQueue(master);
-    s = bufferManager->create_taskQueue(slave);
+    m = taskQueueImpl->create(master);
+    s = taskQueueImpl->create(slave);
 
     master->wait_me = TaskQueue::append(master->wait_me, s);
     slave->wait_i   = TaskQueue::append(slave->wait_i, m);
@@ -93,7 +93,7 @@
 {
     TaskQueuePtr q;
 
-    q = bufferManager->create_taskQueue(task);
+    q = taskQueueImpl->create(task);
     activeTaskQueue = TaskQueue::append(activeTaskQueue, q);
 }
 
@@ -121,7 +121,7 @@
 {
     notify_wait_taskQueue(task, task->wait_me);
     task->post_func(task->post_arg);
-    bufferManager->free_task(task);
+    htaskImpl->free(task);
 }
 
 /**
@@ -150,7 +150,7 @@
 {
     TaskQueuePtr q;
 
-    q = bufferManager->create_taskQueue(task);
+    q = taskQueueImpl->create(task);
     waitTaskQueue = TaskQueue::append(waitTaskQueue, q);
 }
 
@@ -183,7 +183,7 @@
 
     while (p != NULL) {
         p1 = p->next;
-        bufferManager->free_taskQueue(p);
+        taskQueueImpl->free(p);
         p = p1;
     }
 }
@@ -203,7 +203,7 @@
 
     if (p->task == task) {
         list = list->next;
-        bufferManager->free_taskQueue(p);
+        taskQueueImpl->free(p);
     } else {
         p1 = p->next;
         while (p1 && p1->task && p1->task != task) {
@@ -212,7 +212,7 @@
         }
         if (p1) {
             p->next = p1->next;
-            bufferManager->free_taskQueue(p1);
+            taskQueueImpl->free(p1);
         }
     }
 
@@ -229,7 +229,7 @@
 
     if (p == q) {
         list = list->next;
-        bufferManager->free_taskQueue(p);
+        taskQueueImpl->free(p);
     } else {
         p1 = p->next;
         while (p1 && p1 != q) {
@@ -238,7 +238,7 @@
         }
         if (p1) {
             p->next = p1->next;
-            bufferManager->free_taskQueue(p1);
+            taskQueueImpl->free(p1);
         }
     }