comparison TaskManager/Cell/CellTaskManagerImpl.cc @ 66:1034077dd217

*** empty log message ***
author gongo
date Sun, 17 Feb 2008 18:29:08 +0900
parents 519d24aa7ac8
children 7d2874fb0671
comparison
equal deleted inserted replaced
65:519d24aa7ac8 66:1034077dd217
25 MailQueuePtr 25 MailQueuePtr
26 CellTaskManagerImpl::mail_check(MailQueuePtr mail_list) 26 CellTaskManagerImpl::mail_check(MailQueuePtr mail_list)
27 { 27 {
28 int id; 28 int id;
29 int data; 29 int data;
30 unsigned int send;
30 31
31 for (id = 0; id < machineNum; id++) { 32 for (id = 0; id < machineNum; id++) {
32 while (1) { 33 while (1) {
33 data = speThreads->get_mail(id); 34 data = speThreads->get_mail(id);
34 if (data < 0) break; 35 if (data < 0) break;
38 __debug_ppe("[SPE %d] finish\n", id); 39 __debug_ppe("[SPE %d] finish\n", id);
39 } else { 40 } else {
40 __debug_ppe("[PPE] recv from [SPE %d] : 0x%x\n", data, id); 41 __debug_ppe("[PPE] recv from [SPE %d] : 0x%x\n", data, id);
41 bufferManager->check_task_finish((HTaskPtr)data); 42 bufferManager->check_task_finish((HTaskPtr)data);
42 } 43 }
44
45 send = (unsigned int)id;
46 //¥ئ¥¹¥بحر
47 speThreads->send_mail(id, &send);
43 } 48 }
44 } 49 }
50
45 return TaskManagerImpl::mail_check(mail_list); 51 return TaskManagerImpl::mail_check(mail_list);
46 } 52 }
47 53
48 54
49 TaskManagerImpl* 55 TaskManagerImpl*