changeset 903:c9bd13e2ac59

...
author anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
date Wed, 27 Jan 2021 17:06:14 +0900
parents 58037271d763
children 4ca02394a09c
files src/parallel_execution/SingleLinkedQueue.cbc
diffstat 1 files changed, 4 insertions(+), 5 deletions(-) [+]
line wrap: on
line diff
--- a/src/parallel_execution/SingleLinkedQueue.cbc	Wed Jan 27 16:52:11 2021 +0900
+++ b/src/parallel_execution/SingleLinkedQueue.cbc	Wed Jan 27 17:06:14 2021 +0900
@@ -103,17 +103,17 @@
 } TaskIterator, *TaskIteratorPtr;
 
 
-TaskIteratorPtr createQueueIterator(struct SingleLinkedQueue* queue, struct Element* prev) {
+TaskIteratorPtr createQueueIterator(struct SingleLinkedQueue* queue, StateDB s, struct Element* prev) {
     TaskIteratorPtr new = (TaskIteratorPtr)calloc(1, sizeof(TaskIterator));
     if (!new) exit(1);
     new->prev  = prev;
-    new->state = NULL;
+    new->state = s; //
     new->list  = queue->top;
     new->last  = queue->last;
     return new;
 }
 
-TaskIteratorPtr takeNextIterator(struct SingleLinkedQueue* queue, TaskIteratorPtr iterator) {
+Element* takeNextIterator(struct SingleLinkedQueue* queue, TaskIteratorPtr iterator) {
   struct Element* elem = iterator->list;
   if (!elem) {
     return NULL;
@@ -128,7 +128,6 @@
     return NULL;
   }
 
-  iterator->prev = elem;
   iterator->list = next;
-  return iterator;
+  return next;
 }