diff TaskManager/Cell/CellTaskManagerImpl.cc @ 1606:b09f44c7c052 draft

indent
author Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
date Tue, 16 Apr 2013 12:12:27 +0900
parents 5b99bcc6bdb0
children 8841d97c37e5
line wrap: on
line diff
--- a/TaskManager/Cell/CellTaskManagerImpl.cc	Sun Apr 14 22:48:43 2013 +0900
+++ b/TaskManager/Cell/CellTaskManagerImpl.cc	Tue Apr 16 12:12:27 2013 +0900
@@ -15,7 +15,7 @@
 #include "GpuThreads.h"
 #endif
 static void send_alloc_reply(CellTaskManagerImpl *tm, int id,
-                Threads *speThreads);
+                             Threads *speThreads);
 
 CellTaskManagerImpl::~CellTaskManagerImpl() {
     delete speThreads;
@@ -119,7 +119,7 @@
     for (int id = 0; id < machineNum; id++) {
         mail_check(id);
         if (!speTaskList[id]->empty()) {
-                continue; // まだ、走ってる
+            continue; // まだ、走ってる
         }
         if (!taskListInfo[id]->empty()) {
             // SPE に送る TaskList の準備
@@ -136,9 +136,9 @@
 }
 
 void CellTaskManagerImpl::debug_check_spe_idle(
-                QueueInfo<HTask> * activeTaskQueue, int spe_running_) {
+                                               QueueInfo<HTask> * activeTaskQueue, int spe_running_) {
     printf("spu_idle! spe_running = %d : activeTaskQueue->length = %d \n",
-                        spe_running_, activeTaskQueue->length());
+           spe_running_, activeTaskQueue->length());
     HTaskPtr task = activeTaskQueue->getFirst();
     int tmp_i = 0;
     do {
@@ -195,7 +195,7 @@
 
 void CellTaskManagerImpl::show_dead_lock_info() {
     get_scheduler()-> printf("Dead lock detected\n   ppe queue %d\n",
-                    ppeManager->activeTaskQueue->length());
+                             ppeManager->activeTaskQueue->length());
     // 確か waitQueue は共通...
     // get_scheduler()-> printf("   wait queue %d\n",ppeManager->waitTaskQueue->length());
     get_scheduler()-> printf("   wait queue %d\n", waitTaskQueue->length());
@@ -205,7 +205,7 @@
         if (w) {
             for (TaskQueue *q = w->getFirst(); q; q = w->getNext(q)) {
                 printf("    waiting task%d %lx", q->task->command,
-                                (long) q->task);
+                       (long) q->task);
                 if (!waitTaskQueue->find(q->task)) {
                     printf("!"); // stray task
                 }
@@ -217,7 +217,7 @@
     get_scheduler()-> printf("   spe queue %d\n", activeTaskQueue->length());
     for (int i = 0; i < machineNum; i++) {
         get_scheduler()-> printf("   spe %d send %d wait %d\n", i,
-                            speTaskList[i]->length(), taskListInfo[i]->length());
+                                 speTaskList[i]->length(), taskListInfo[i]->length());
     }
 }
 
@@ -244,10 +244,10 @@
             continue;
         } else {
 #ifdef TASK_LIST_MAIL
-  	    // multi dimensionだったらカウントする 
+            // multi dimensionだったらカウントする 
             TaskListPtr list = (TaskListPtr)data;
-	    if (list->self->flag.dim_count-- == 0)
-	        check_task_list_finish(schedTaskManager, list, waitTaskQueue);
+            if (list->self->flag.dim_count-- == 0)
+                check_task_list_finish(schedTaskManager, list, waitTaskQueue);
 #else
             // 終了したタスク(PPEにあるのでアドレス)
             HTaskPtr task = (HTaskPtr) data;
@@ -281,7 +281,7 @@
             check_task_finish(task, waitTaskQueue);
 #endif
         }
-            // MY_SPE_NOP: 特に意味のないコマンド
+        // MY_SPE_NOP: 特に意味のないコマンド
     }
 }
 
@@ -294,7 +294,7 @@
 }
 
 static void send_alloc_reply(CellTaskManagerImpl *tm, int id,
-                Threads *speThreads) {
+                             Threads *speThreads) {
 
     /**
      * info[0] = alloc_id; (CellScheduler::mainMem_alloc 参照)
@@ -365,7 +365,7 @@
 }
 
 void CellTaskManagerImpl::print_arch() {
-        printf("CellTaskManager\n");
+    printf("CellTaskManager\n");
 }
 
 TaskListPtr CellTaskManagerImpl::createTaskList()