changeset 1:4a172166e6c3

add meta connector script
author Kaito Tokumori <e105711@ie.u-ryukyu.ac.jp>
date Wed, 29 Jul 2015 00:13:12 +0900
parents d66cc78ae824
children 81da5b2c3382
files meta_connector/meta_connect_test.c meta_connector/meta_connector.py
diffstat 2 files changed, 320 insertions(+), 0 deletions(-) [+]
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/meta_connector/meta_connect_test.c	Wed Jul 29 00:13:12 2015 +0900
@@ -0,0 +1,232 @@
+#include <stdlib.h>
+#include <stdio.h>
+
+#include "synchronizedQueueContext.h"
+
+#include "allocate.h"
+#include "origin_cs.h"
+
+#ifdef CLANG
+#define _CbC_retrun __return
+#define _CbC_environment __environment
+#endif
+
+#define NUM 100
+
+meta_connect(
+             meta_sender:sender
+             meta_receiver: receiver
+             )
+
+extern __code initSynchronizedQueueContext(struct Context* context);
+
+//__code code1(struct Context* context) {
+//    context->data[Allocate]->allocate.size = sizeof(struct Element);
+//    context->data[Allocate]->allocate.next = Code2;
+//    goto meta(context, Allocator);
+//}
+
+__code meta(struct Context* context, enum Code next) {
+    goto (context->code[next])(context);
+}
+
+//__code code2(struct Context* context) {
+//    context->data[Allocate]->allocate.after_put = Code3;
+//    context->data[context->dataNum] -> element.value = 1024;
+//    goto meta(context, Sender);
+//}
+
+__code code1(struct Context* context, struct Allocate* allocate) {
+    allocate->size = sizeof(long);
+    allocate->next = Code2;
+    goto meta(context, Allocator);
+}
+
+__code code1_stub(struct Context* context) {
+    goto code1(context, &context->data[Allocate]->allocate);
+}
+
+__code code2(struct Context* context, long* count) {
+    *count = 0;
+    goto meta(context, Code3);
+}
+
+__code code2_stub(struct Context* context) {
+    goto code2(context, &context->data[Counter]->count);
+}
+
+__code code3(struct Context* context, long* count, struct Allocate* allocate) {
+    long loop = *count;
+    if(loop == NUM) {
+        goto meta(context, ThreadExit);
+    }
+    allocate->size = sizeof(struct Element);
+    allocate->next = Code4;
+    goto meta(context, Allocator);
+}
+
+__code code3_stub(struct Context* context) {
+    goto code3(context, &context->data[Counter]->count, &context->data[Allocate]->allocate);
+}
+
+__code code4(struct Context* context, long* count, struct Allocate* allocate, struct Element* element) {
+    allocate->after_put = Code3;
+    element->value = (*count)++;
+    goto meta(context, Sender);
+}
+
+__code code4_stub(struct Context* context) {
+    goto code4(context, &context->data[Counter]->count, &context->data[Allocate]->allocate, &context->data[context->dataNum]->element);
+}
+
+__code meta_sender(struct Context* context, struct Queue* queue, enum Code next) {
+    // lock
+    pthread_mutex_lock(&queue->mutex);
+    goto (context->code[next])(context);
+}
+
+__code sender(struct Context* context, struct Queue* queue) {
+  //    goto meta_sender(context, queue, Put);
+  //    goto meta_sender : put(queue);
+  goto put(queue);
+}
+
+__code sender_stub(struct Context* context) {
+    goto sender(context, &context->data[Queue]->queue);
+}
+
+__code meta_put(struct Context* context, struct Queue* queue, enum Code next) {
+    // signal
+    pthread_cond_signal(&queue->cond);
+    // unlock
+    pthread_mutex_unlock(&queue->mutex);
+    goto (context->code[next])(context);
+}
+
+__code put(struct Context* context, struct Allocate* allocate, struct Queue* queue, struct Element* element) {
+    if(queue->first) {
+        queue->last->next = element;
+    } else {
+        queue->first = element;
+    }
+    queue->last   = element;
+    element->next = 0;
+    queue->count++;
+    printf("Put %d\n\n", element->value);
+    goto meta_put(context, queue, allocate->after_put);
+}
+
+__code put_stub(struct Context* context) {
+    goto put(context, &context->data[Allocate]->allocate, &context->data[Queue]->queue, &context->data[context->dataNum]->element);
+}
+
+__code code5(struct Context* context, struct Allocate* allocate) {
+    allocate->size = sizeof(long);
+    allocate->next = Code6;
+    goto meta(context, Allocator);
+}
+
+__code code5_stub(struct Context* context) {
+    goto code5(context, &context->data[Allocate]->allocate);
+}
+
+__code code6(struct Context* context, long* count) {
+    *count = 0;
+    goto meta(context, Code7);
+}
+
+__code code6_stub(struct Context* context) {
+    goto code6(context, &context->data[Counter]->count);
+}
+
+__code code7(struct Context* context, long* count, struct Allocate* allocate) {
+    long loop = *count;
+    if(loop == NUM) {
+        goto meta(context, ThreadExit);
+    }
+    (*count)++;
+    allocate->after_get = Code7;
+    goto meta(context, Receiver);
+}
+
+__code code7_stub(struct Context* context) {
+    goto code7(context, &context->data[Counter]->count, &context->data[Allocate]->allocate);
+}
+
+__code meta_receiver(struct Context* context, struct Queue* queue, enum Code next) {
+    // lock
+    pthread_mutex_lock(&queue->mutex);
+    goto (context->code[next])(context);
+}
+
+__code receiver(struct Context* context, struct Queue* queue) {
+  //    goto meta_receiver(context, queue, Get);
+  goto get(queue);
+}
+
+__code receiver_stub(struct Context* context) {
+    goto receiver(context, &context->data[Queue]->queue);
+}
+__code meta_get(struct Context* context, enum Code next) {
+    pthread_mutex_unlock(&context->data[Queue]->queue.mutex);
+    goto (context->code[next])(context);
+}
+
+__code get(struct Context* context, struct Allocate* allocate, struct Queue* queue, struct Element* element) {
+    // thread wait if queue is empty
+    while (queue->count == 0) {
+        pthread_cond_wait(&queue->cond, &queue->mutex);
+    }
+    printf("      Get %d\n\n", queue->first->value);
+    queue->first = (queue->first->next) ? queue->first->next : 0;
+    queue->count--;
+    goto meta_get(context, allocate->after_get);
+}
+
+__code get_stub(struct Context* context) {
+    goto get(context, &context->data[Allocate]->allocate, &context->data[Queue]->queue, &context->data[context->dataNum]->element);
+}
+
+__code thread_exit(struct Context* context) {
+    free(context->code);
+    free(context->data);
+    free(context->heapStart);
+    pthread_exit(0);
+}
+
+__code thread_exit_stub(struct Context* context) {
+    goto thread_exit(context);
+}
+
+void* thread_func(void* context) {
+    goto start_code((struct Context*)context, Code1);
+    return 0;
+}
+
+void* thread_func2(void* context) {
+    goto start_code((struct Context*)context, Code5);
+    return 0;
+}
+
+int main() {
+    struct Context* context1 = (struct Context*)malloc(sizeof(struct Context));
+    initSynchronizedQueueContext(context1);
+    struct Context* context2 = (struct Context*)malloc(sizeof(struct Context));
+    initSynchronizedQueueContext(context2);
+    struct Context* context3 = (struct Context*)malloc(sizeof(struct Context));
+    initSynchronizedQueueContext(context3);
+    struct Context* context4 = (struct Context*)malloc(sizeof(struct Context));
+    initSynchronizedQueueContext(context4);
+    context2->data[Queue] = context1->data[Queue];
+    context3->data[Queue] = context1->data[Queue];
+    context4->data[Queue] = context1->data[Queue];
+    pthread_t thread1, thread2, thread3, thread4;
+    pthread_create(&thread1, NULL, thread_func, (void *)context1);
+    pthread_create(&thread2, NULL, thread_func, (void *)context2);
+    pthread_create(&thread3, NULL, thread_func2, (void *)context3);
+    pthread_create(&thread4, NULL, thread_func2, (void *)context4);
+    pthread_join(thread1, NULL);
+    pthread_join(thread2, NULL);
+    pthread_join(thread3, NULL);
+    pthread_join(thread4, NULL);
+}
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/meta_connector/meta_connector.py	Wed Jul 29 00:13:12 2015 +0900
@@ -0,0 +1,88 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+import sys
+import argparse
+import re
+
+# parse arguments and return arguments list.
+def get_args():
+    parser = argparse.ArgumentParser()
+    parser.add_argument('input_file',\
+                        nargs=None,\
+                        type=str,\
+                        help='input file path.')
+    parser.add_argument('-o', dest='output',\
+                        nargs=1,\
+                        type=str,\
+                        metavar='<file>',\
+                        help='write output to <file>')
+                        
+    return parser.parse_args()
+
+# parse input file and create meta connection list
+def parse_meta_syntax(lines):
+    connect_set = []
+    for i,l in enumerate(lines):
+        if l.find("meta_connect") >= 0:
+            offset = 0
+            connect_l = lines[i+offset].split('(')[1].strip()
+
+            while connect_l.find(')') < 0:
+                if (connect_l.find(':') >= 0):
+                    connect_set.append(re.split(':|,',connect_l))
+                offset = offset + 1
+                connect_l = lines[i+offset].strip()
+
+            if connect_l.find(':') >= 0:
+                connect_set.append(connect_l.split(')')[0].split(':'))
+    return connect_set
+            
+def connect_meta(lines, list, file):
+    comment_out = False
+    target_cs = False
+    meta_index = 0
+    for l in lines:
+        if l.find("meta_connect") >= 0:
+            comment_out = True
+            print('/* -- meta connector --')
+        
+        for meta_index, meta in enumerate(list):
+            if re.search(r" *__code +{0:s} *\(".format(meta[1].strip()),l) is not None:
+                target_cs = True
+                break
+
+        if target_cs:
+            # skip commnet outed line.
+            if re.search(r" *//+ *goto",l) is not None:
+                pass
+            # connect to meta code segment
+            elif re.search(r" *goto +\w+\(",l) is not None:
+                print("/*-- connected by script */")
+                print("// "+l, end='')
+                ll = re.split(r"\(|\)", l)
+                print("goto {0:s}(context, {1:s}, {2:s});".format(list[meta_index][0],\
+                                                                  ll[1],\
+                                                                  re.split(" +",ll[0].strip())[1].capitalize()))
+                print("/* connected by script --*/")
+                continue
+            if l.find('}') >= 0:
+                target_cs = False
+
+        print(l, end='')
+
+        if comment_out and l.find(')') >= 0:
+            comment_out = False
+            print('-- meta connector --*/')
+
+def main():
+    args = get_args()
+    try:
+        f = open(args.input_file,'r')
+    except IOError:
+        print("cannot read file %s" % input_file)
+    lines = f.readlines()
+    connect_list = parse_meta_syntax(lines)
+    connect_meta(lines, connect_list, args.output)
+    
+main()