Mercurial > hg > Members > Moririn

diff src/parallel_execution/taskManager.c @ 222:77faa28128b4

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Add taskSend for TaskManager
author Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
date Wed, 11 Jan 2017 16:52:27 +0900
parents 2454f4392316
children 8d2519c3a36e
line wrap: on
line diff
--- a/src/parallel_execution/taskManager.c	Mon Jan 09 21:39:33 2017 +0900
+++ b/src/parallel_execution/taskManager.c	Wed Jan 11 16:52:27 2017 +0900
@@ -38,6 +38,15 @@
             );
 }
 
+__code taskSend(struct Context* context) {
+    if(loopCounter->i < taskManager->numWorker) {
+        taskManager->workers[i]->taskSend;
+        loopCounter->i++;
+        goto meta(context, C_taskSend);
+    }
+    goto meta(context, TaskManager->next);
+}
+
 __code shutdownTaskManager(struct Context* context, struct LoopCounter* loopCounter, struct Worker* worker) {
     int i = loopCounter->i;