Mercurial > hg > Game > Cerium

changeset 1606:b09f44c7c052 draft

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
indent
author Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
date Tue, 16 Apr 2013 12:12:27 +0900
parents 5b99bcc6bdb0
children 5deb318564ec 8841d97c37e5
files TaskManager/Cell/CellTaskManagerImpl.cc TaskManager/Fifo/FifoTaskManagerImpl.cc TaskManager/kernel/ppe/HTask.cc TaskManager/kernel/ppe/HTask.h TaskManager/kernel/schedule/SchedTask.cc
diffstat 5 files changed, 66 insertions(+), 66 deletions(-) [+]
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()
--- a/TaskManager/Fifo/FifoTaskManagerImpl.cc	Sun Apr 14 22:48:43 2013 +0900
+++ b/TaskManager/Fifo/FifoTaskManagerImpl.cc	Tue Apr 16 12:12:27 2013 +0900
@@ -97,14 +97,14 @@
     // printf("active task queue length = %d\n",activeTaskQueue->length());
     HTaskPtr htask = activeTaskQueue->getFirst();
     while (htask != NULL) {
-      if (htask->cpu_type == CPU_PPE) {
-	set_taskList(htask, taskListInfo );
-	HTaskPtr next = activeTaskQueue->getNext(htask);
-	activeTaskQueue->remove(htask);
-	htask = next;
-      } else {
-	htask = activeTaskQueue->getNext(htask);
-      }
+        if (htask->cpu_type == CPU_PPE) {
+            set_taskList(htask, taskListInfo );
+            HTaskPtr next = activeTaskQueue->getNext(htask);
+            activeTaskQueue->remove(htask);
+            htask = next;
+        } else {
+            htask = activeTaskQueue->getNext(htask);
+        }
     }
 }
 
@@ -117,10 +117,10 @@
     // printf("active task queue length = %d\n",activeTaskQueue->length());
     HTaskPtr htask = activeTaskQueue->getFirst();
     while (htask != NULL) {
-	set_taskList(htask, taskListInfo );
-	HTaskPtr next = activeTaskQueue->getNext(htask);
-	activeTaskQueue->remove(htask);
-	htask = next;
+        set_taskList(htask, taskListInfo );
+        HTaskPtr next = activeTaskQueue->getNext(htask);
+        activeTaskQueue->remove(htask);
+        htask = next;
     }
 }
 
@@ -157,7 +157,7 @@
 FifoTaskManagerImpl::run()
 {
     do {
-	poll1();
+        poll1();
     } while(!activeTaskQueue->empty()) ;
 
     if (!waitTaskQueue->empty()) {
@@ -218,11 +218,11 @@
 FifoTaskManagerImpl::mail_check()
 {
     while (mainScheduler->has_mail_from_host()) {
-	memaddr data = mainScheduler->mail_read_from_host();
-
+        memaddr data = mainScheduler->mail_read_from_host();
+        
         if (data == (memaddr)MY_SPE_STATUS_READY) {
             __debug_ppe("mail_check(): Task List finish\n");
-	    ppeTaskList->freeAll(); 
+            ppeTaskList->freeAll(); 
         } else if (data == (memaddr)MY_SPE_COMMAND_EXIT) {
             __debug_ppe("mail_check(): Task List finish COMMAND\n");
         } else if (data == (memaddr)MY_SPE_COMMAND_MALLOC) {
@@ -248,17 +248,17 @@
 #endif
 #ifndef NOT_CHECK
 	    
-	    if (task != NULL) {
-	      //PPE で処理された Task が返ってくるはず。
-	      if (task->cpu_type != CPU_PPE) {
-		printf("attention : SPE task run on PPE\n");
-		printf("Task id : %d\n", task->command);
-		const char *name = get_task_name(task);
-		if (name != NULL) {	       
-		  printf("Task name : %s\n", name);
-		}
-	      }
-	    }
+            if (task != NULL) {
+                //PPE で処理された Task が返ってくるはず。
+                if (task->cpu_type != CPU_PPE) {
+                    printf("attention : SPE task run on PPE\n");
+                    printf("Task id : %d\n", task->command);
+                    const char *name = get_task_name(task);
+                    if (name != NULL) {	       
+                        printf("Task name : %s\n", name);
+                    }
+                }
+            }
 	    
 #endif
 
@@ -273,7 +273,7 @@
 FifoTaskManagerImpl::polling()
 {
     if (others!=0)
-	others->polling();
+        others->polling();
 }
 
 static void
--- a/TaskManager/kernel/ppe/HTask.cc	Sun Apr 14 22:48:43 2013 +0900
+++ b/TaskManager/kernel/ppe/HTask.cc	Tue Apr 16 12:12:27 2013 +0900
@@ -70,7 +70,7 @@
   繰り返し使用する事で複数の Task を待ち合わせする事ができる。
 
   wait_for している Task の入力バッファにこの Task から書き込みできる機能があると良い
- */
+*/
 void
 HTask::wait_for(HTaskPtr master)
 {
@@ -101,7 +101,7 @@
 /*!
   @brief このTaskが終了した時に実行する関数
   @param arg1, arg2 の二つの引数を持つ (Task に合わせてある)
- */
+*/
 void
 HTask::set_post(PostFunction func,void *arg1, void *arg2)
 {
@@ -119,7 +119,7 @@
   @param num_inData   一つのTaskが読み込む Data の数、set_inData の数
   @param num_outData  一つのTaskが書き出す Data の数、set_outData の数
   @return  Task Array へのポインタ
- */ 
+*/ 
 
 Task *
 HTask::create_task_array(int id, int num_task, int num_param, int num_inData, int num_outData)
@@ -140,9 +140,9 @@
 /*!
   @brief Task Array の次のTask
   @param t            今のTaskのポインタ
-                      0 の場合は最初のTask
+  0 の場合は最初のTask
   @return  次のTaskへのポインタ
- */
+*/
 Task *
 HTask::next_task_array(int id, Task *t)
 {
@@ -157,9 +157,9 @@
 /*!
   @brief Task Array の次のTask
   @param t            今のTaskのポインタ
-                      0 の場合は最初のTask
+  0 の場合は最初のTask
   @return  次のTaskへのポインタ
- */
+*/
 Task *
 HTask::next_task_array(int id, Task *t, int param_count, int inData_count, int outData_count)
 {
@@ -194,9 +194,9 @@
 }
 /*!
   @brief Task Array の中のすべてのTaskが書き込まれたかどうかをチェックする
-         TaskArray 自体の spawn() は別に必要
+  TaskArray 自体の spawn() は別に必要
   @param last            今のTaskのポインタ (最後である必要がある)
- */
+*/
 void
 HTask::spawn_task_array(Task * last)
 {
--- a/TaskManager/kernel/ppe/HTask.h	Sun Apr 14 22:48:43 2013 +0900
+++ b/TaskManager/kernel/ppe/HTask.h	Tue Apr 16 12:12:27 2013 +0900
@@ -26,12 +26,12 @@
   cpu の指定があれば並列に実行される。
   特定の Task を待ち合わせる事が可能。
   Task の入出力は dma などで copy される。
- */
+*/
 
 #include "SimpleTask.h"
 
 class HTask : public SimpleTask {
-public:
+ public:
     BASE_NEW_DELETE(HTask);
 
     QueueInfo<TaskQueue> *wait_me;  // List of task waiting for me
@@ -78,24 +78,24 @@
     }
 
     void initOnce() {
-       wait_me = new QueueInfo<TaskQueue>(taskQueuePool);
-       wait_i = new QueueInfo<TaskQueue>(taskQueuePool);
+        wait_me = new QueueInfo<TaskQueue>(taskQueuePool);
+        wait_i = new QueueInfo<TaskQueue>(taskQueuePool);
     }
 
     void freeOnce() {
-       delete wait_me;
-       delete wait_i;
+        delete wait_me;
+        delete wait_i;
     }
 
-    private:
+ private:
 
-// compatibility
-    public: // functions
+    // compatibility
+ public: // functions
     void set_inData_t(int index, memaddr addr, int size) {
 #ifdef EARLY_TOUCH
         if ((unsigned long)addr&0xf) {
-          printf("inData is not aligned. command = %d, index = %d, addr = 0x%lx, size = %d\n",
-                 command, index, (unsigned long)addr, size);
+            printf("inData is not aligned. command = %d, index = %d, addr = 0x%lx, size = %d\n",
+                   command, index, (unsigned long)addr, size);
         }
         char *p = (char *)addr; char b = *p;
         p = (char *)(addr+size-1); b += *p;
@@ -106,8 +106,8 @@
     void set_outData_t(int index, memaddr addr, int size) {
 #ifdef EARLY_TOUCH
         if ((unsigned long)addr&0xf) {
-          printf("inData is not aligned. command = %d, index = %d, addr = 0x%lx, size = %d\n",
-                 command, index, (unsigned long)addr, size);
+            printf("inData is not aligned. command = %d, index = %d, addr = 0x%lx, size = %d\n",
+                   command, index, (unsigned long)addr, size);
         }
         char *p = (char *)addr; char b = *p;
         p = (char *)(addr+size-1); b += *p;
--- a/TaskManager/kernel/schedule/SchedTask.cc	Sun Apr 14 22:48:43 2013 +0900
+++ b/TaskManager/kernel/schedule/SchedTask.cc	Tue Apr 16 12:12:27 2013 +0900
@@ -57,10 +57,10 @@
 
 #ifdef TASK_LIST_MAIL
     if (list)
-       waiter = (memaddr) list->waiter;
+        waiter = (memaddr) list->waiter;
 #else
     if (task)
-       waiter = (memaddr) task->self;
+        waiter = (memaddr) task->self;
 #endif
 
 }
@@ -426,7 +426,7 @@
 HTaskPtr
 SchedTask::create_task_array(int id, int num_task, int num_param, int num_inData, int num_outData)
 {
-  return manager->create_task_array(id, num_task, num_param, num_inData, num_outData, __builtin_return_address(0));
+    return manager->create_task_array(id, num_task, num_param, num_inData, num_outData, __builtin_return_address(0));
 }
 
 void SchedTask::free_htask(HTask *p) {