Mercurial > hg > Gears > Gears
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;