changeset 888:ebe90be297a4

run
author anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
date Mon, 25 Jan 2021 20:12:04 +0900
parents b1a6d44426cb
children ece1428e8a27
files src/parallel_execution/ModelChecking/MCWorker.cbc
diffstat 1 files changed, 6 insertions(+), 3 deletions(-) [+]
line wrap: on
line diff
--- a/src/parallel_execution/ModelChecking/MCWorker.cbc	Mon Jan 25 18:09:21 2021 +0900
+++ b/src/parallel_execution/ModelChecking/MCWorker.cbc	Mon Jan 25 20:12:04 2021 +0900
@@ -37,14 +37,17 @@
 }
 
 __code startModelChecker(struct MCWorker* worker) {
-    struct Queue* mcQueue =  worker->mcQueue;
-    goto takeSingleLinkedQueue(mcQueue, taskReceiveMCWorker);
+    struct SingleLinkedQueue* mcQueue =  (struct SingleLinkedQueue*)worker->mcQueue->queue;
+    struct Element* elem = mcQueue->top;
+    elem = elem->next;
+    struct Context* ncontext = (struct Context*)elem->data;
+    goto meta(ncontext, ncontext->next);
 }
 
 __code getTaskMCWorker(struct MCWorker* mcWorker, struct Context* task, struct Worker* worker) {
     if (!task) {
         printf("mc worker take end\n");
-        goto worker->shutdown(); // end thread
+        goto startModelChecker(); // end thread
     }
     printf("mc worker take\n");
     task->worker = worker;