Mercurial > hg > Members > kono > Cerium

comparison TaskManager/Cell/CellTaskManagerImpl.cc @ 621:5b178db5988a

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Cell fix
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Sun, 15 Nov 2009 03:34:18 +0900
parents 55ed910d13c2
children 8843edf37c0e
comparison
equal deleted inserted replaced
620:55ed910d13c2 621:5b178db5988a
4 #include <stdlib.h> 4 #include <stdlib.h>
5 #include <string.h> 5 #include <string.h>
6 #include "CellTaskManagerImpl.h" 6 #include "CellTaskManagerImpl.h"
7 #include "CellTaskListInfo.h" 7 #include "CellTaskListInfo.h"
8 #include "HTaskInfo.h" 8 #include "HTaskInfo.h"
9 #include "SchedTask.h"
9 #include "PpeScheduler.h" 10 #include "PpeScheduler.h"
10 #include "types.h" 11 #include "types.h"
11 12
12 CellTaskManagerImpl::~CellTaskManagerImpl() 13 CellTaskManagerImpl::~CellTaskManagerImpl()
13 { 14 {
219 */ 220 */
220 221
221 //__debug_ppe("[PPE] MALLOCED 0x%x from [SPE %d]\n", alloc_info[1],id); 222 //__debug_ppe("[PPE] MALLOCED 0x%x from [SPE %d]\n", alloc_info[1],id);
222 speThreads->add_output_tasklist(command, alloc_info[1], alloc_size); 223 speThreads->add_output_tasklist(command, alloc_info[1], alloc_size);
223 224
224 speThreads->send_mail(id, 2, (memaddr *)alloc_info); 225 speThreads->send_mail(id, 2, alloc_info);
225 } else if (data > MY_SPE_NOP) { 226 } else if (data > MY_SPE_NOP) {
226 //__debug_ppe("[PPE] recv from [SPE %d] : 0x%x\n", id, data); 227 //__debug_ppe("[PPE] recv from [SPE %d] : 0x%x\n", id, data);
227 HTaskPtr task = (HTaskPtr)data; 228 HTaskPtr task = (HTaskPtr)data;
228 task->post_func(schedTaskManager, task->post_arg1, task->post_arg2); 229 task->post_func(schedTaskManager, task->post_arg1, task->post_arg2);
229 check_task_finish(task); 230 check_task_finish(task);
273 speTaskList_bg[id] = tmp; 274 speTaskList_bg[id] = tmp;
274 275
275 taskListImpl->clear_taskList(speTaskList_bg[id]); 276 taskListImpl->clear_taskList(speTaskList_bg[id]);
276 277
277 //speThreads->send_mail(id, 1, (unsigned int *)&speTaskList[id]); 278 //speThreads->send_mail(id, 1, (unsigned int *)&speTaskList[id]);
278 speThreads->send_mail(id, 1, (memaddr *)&speTaskList[id]); 279 speThreads->send_mail(id, 1, (unsigned int *)&speTaskList[id]);
279 flag_sendTaskList[id] = 0; 280 flag_sendTaskList[id] = 0;
280 } 281 }
281 282
282 283
283 void* 284 void*