# HG changeset patch # User Yuhi TOMARI # Date 1366081947 -32400 # Node ID b09f44c7c05230e6908633bd17115dfb5fd62d15 # Parent 5b99bcc6bdb0aa65aacd5844aff340b8a129b29f indent diff -r 5b99bcc6bdb0 -r b09f44c7c052 TaskManager/Cell/CellTaskManagerImpl.cc --- 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 * activeTaskQueue, int spe_running_) { + QueueInfo * 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() diff -r 5b99bcc6bdb0 -r b09f44c7c052 TaskManager/Fifo/FifoTaskManagerImpl.cc --- 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 diff -r 5b99bcc6bdb0 -r b09f44c7c052 TaskManager/kernel/ppe/HTask.cc --- 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) { diff -r 5b99bcc6bdb0 -r b09f44c7c052 TaskManager/kernel/ppe/HTask.h --- 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 *wait_me; // List of task waiting for me @@ -78,24 +78,24 @@ } void initOnce() { - wait_me = new QueueInfo(taskQueuePool); - wait_i = new QueueInfo(taskQueuePool); + wait_me = new QueueInfo(taskQueuePool); + wait_i = new QueueInfo(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; diff -r 5b99bcc6bdb0 -r b09f44c7c052 TaskManager/kernel/schedule/SchedTask.cc --- 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) {