# HG changeset patch # User Kaito Tokumori # Date 1438096392 -32400 # Node ID 4a172166e6c3f5779a2b12d8dc9a917aa351c009 # Parent d66cc78ae8243e3af73d68029a3bc5b0e63f3e25 add meta connector script diff -r d66cc78ae824 -r 4a172166e6c3 meta_connector/meta_connect_test.c --- /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 +#include + +#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); +} diff -r d66cc78ae824 -r 4a172166e6c3 meta_connector/meta_connector.py --- /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='',\ + help='write output to ') + + 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()