Mercurial > hg > Game > Cerium
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()