Members/kono/Cerium: TaskManager/Cell/CellTaskManagerImpl.cc comparison

cleanups..

author	Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date	Sat, 19 Dec 2009 12:12:09 +0900
parents	dac59b74e02a
children	abad59c7e3ac

comparison

equal deleted inserted replaced

-:dac59b74e02a
+:2b167196cb27
 }
 }
 void
+CellTaskManager::sednTaskList()
+{
+for (int i = 0; i < machineNum; i++)  {
+	if (flag_sendTaskList[i] == 1 && speTaskList_bg[i]->length >= 1 ) {
+	    send_taskList(i);
+	    spe_running++;
+	}
+}
+}
+void
 CellTaskManagerImpl::run()
 {
 TaskListPtr ppeTaskList = NULL;
 do {
 // PPE side
 	ppeTaskList =  ppeManager->get_runTaskList();
-	ppeManager->schedule(ppeTaskList);
+	if (ppeTaskList)
+	    ppeManager->sendTaskList(ppeTaskList);
 	ppeManager->mail_check();
 // SPE side
 	do {
 	    mail_check();
 	    // SPE に送る TaskList の準備
 	    set_runTaskList();
 	    // TaskList 待ちの SPE に TaskList を送る
-	    for (int i = 0; i < machineNum; i++)  {
+	    sednTaskList();
-		if (flag_sendTaskList[i] == 1 && speTaskList_bg[i]->length >= 1 ) {
+	} while (ppeManager->activeTaskQueue->empty());
-		    send_taskList(i);
+} while (ppeTaskList || spe_running >0);
-		    spe_running++;
+if (!waitTaskQueue->empty()) {
-		}
+	fprintf(stderr,"Dead lock detected\n");
-	    }
+}
-	} while (ppeManager->activeTaskQueue->empty() && !waitTaskQueue->empty());
-} while (ppeTaskList || spe_running >0);
 }
 /**
 * SPE からのメールをチェックする
 */

Mercurial > hg > Members > kono > Cerium