diff src/synchronizedQueue/synchronizedQueue.c @ 38:ce9fde200f3e

Add code segment sender & receiver to synchronizedQueue
author Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
date Sat, 16 May 2015 02:45:31 +0900
parents 240c045ebab2
children 754c90e96e3d
line wrap: on
line diff
--- a/src/synchronizedQueue/synchronizedQueue.c	Fri May 15 19:19:31 2015 +0900
+++ b/src/synchronizedQueue/synchronizedQueue.c	Sat May 16 02:45:31 2015 +0900
@@ -18,30 +18,41 @@
     goto (context->code[next])(context);
 }
 
-__code meta_code2(struct Context* context, enum Code next) {
-    context->data[Queue]->queue.head = context->data[context->dataNum];
-    context->data[Queue]->queue.tail = context->data[Queue]->queue.head;
-    context->data[context->dataNum]->element.next = 0;
+__code code2(struct Context* context) {
+    context->data[Allocate]->allocate.after_put = Code3;
+    context->data[context->dataNum] -> element.value = 1024;
+    goto meta(context, Sender);
+}
+
+__code meta_sender(struct Context* context, enum Code next) {
     goto (context->code[next])(context);
 }
 
-__code code2(struct Context* context) {
-    context->data[context->dataNum] -> element.value = 1024;
-    context->data[Allocate]->allocate.size = sizeof(struct Element);
-    context->data[Allocate]->allocate.next = Code3;
-    goto meta_code2(context, Allocator);
+__code sender(struct Context* context) {
+    goto meta(context, Put);
 }
 
 __code code3(struct Context* context) {
-    context->data[Allocate]->allocate.after_put = Code4;
+    context->data[Allocate]->allocate.size = sizeof(struct Element);
+    context->data[Allocate]->allocate.next = Code4;
+    goto meta(context, Allocator);
+}
+
+__code code4(struct Context* context) {
+    context->data[Allocate]->allocate.after_put = Code5;
     context->data[context->dataNum] -> element.value = 10;
-    goto meta(context, Put);
+    goto meta(context, Sender);
 }
 
 __code meta_put(struct Context* context, enum Code next) {
-    context->data[Queue]->queue.tail->element.next = context->data[context->dataNum];
-    context->data[Queue]->queue.tail               = context->data[Queue]->queue.tail->element.next;
-    context->data[Queue]->queue.tail->element.next = 0;
+    if(context->data[Queue]->queue.first) {
+        context->data[Queue]->queue.last->element.next = context->data[context->dataNum];
+        context->data[Queue]->queue.last               = context->data[Queue]->queue.last->element.next;
+    } else {
+        context->data[Queue]->queue.first = context->data[context->dataNum];
+        context->data[Queue]->queue.last  = context->data[Queue]->queue.first;
+    }
+    context->data[Queue]->queue.last->element.next = 0;
     goto (context->code[next])(context);
 }
 
@@ -50,37 +61,25 @@
 }
 
 
-__code meta_traverse(struct Context* context, enum Code next) {
-    printf("current value in queue is %d\n", context->data[Queue]->queue.current->element.value);
-    if (context->data[Queue]->queue.current->element.next) {
-        context->data[Queue]->queue.current = context->data[Queue]->queue.current->element.next;
-        goto meta_traverse(context, next);
-    }
-    goto (context->code[next])(context);
+__code code5(struct Context* context) {
+    context->data[Allocate]->allocate.after_get = Code6;
+    goto meta(context, Receiver);
 }
 
-__code traverse(struct Context* context) {
-    context->data[Queue]->queue.current = context->data[Queue]->queue.head;
-    goto meta_traverse(context, context->data[Allocate]->allocate.after_traverse);
+__code meta_receiver(struct Context* context, enum Code next) {
 }
 
-__code code4(struct Context* context) {
-    context->data[Allocate]->allocate.after_traverse = Code5;
-    goto meta(context, Traverse);
-}
-
-
-__code code5(struct Context* context) {
-    context->data[Allocate]->allocate.after_get = Code6;
+__code receiver(struct Context* context, enum Code next) {
     goto meta(context, Get);
 }
 
 __code meta_get(struct Context* context, enum Code next) {
-    if (context->data[Queue]->queue.head == context->data[Queue]->queue.tail) {
+    if (context->data[Queue]->queue.first == context->data[Queue]->queue.last) {
         printf("queue is empty\n");
         goto (context->code[Exit])(context);
     }
-    context->data[Queue]->queue.head = (context->data[Queue]->queue.head->element.next) ? context->data[Queue]->queue.head->element.next : 0;
+    printf("Get %d\n", context->data[Queue]->queue.first->element.value);
+    context->data[Queue]->queue.first = (context->data[Queue]->queue.first->element.next) ? context->data[Queue]->queue.first->element.next : 0;
     goto (context->code[next])(context);
 }
 
@@ -89,14 +88,15 @@
 }
 
 __code code6(struct Context* context) {
-    printf("after delete\n");
-    context->data[Allocate]->allocate.after_traverse = Exit;
-    goto meta(context, Traverse);
+    goto meta(context, Exit);
 }
 
 
 int main() {
-    struct Context* context = (struct Context*)malloc(sizeof(struct Context));
-    initSynchronizedQueueContext(context);
-    goto start_code(context, Code1);
+    struct Context* context1 = (struct Context*)malloc(sizeof(struct Context));
+    initSynchronizedQueueContext(context1);
+    struct Context* context2 = (struct Context*)malloc(sizeof(struct Context));
+    initSynchronizedQueueContext(context2);
+    context2->data[Queue] = context1->data[Queue];
+    goto start_code(context1, Code1);
 }