Mercurial > hg > CbC > old > CbC_scripts
changeset 12:dac62c00581b
remove old script
author | Kaito Tokumori <e105711@ie.u-ryukyu.ac.jp> |
---|---|
date | Mon, 05 Oct 2015 16:18:27 +0900 |
parents | 09470e372dda |
children | 9bea91fdd283 |
files | meta_connector/meta_connect_test.c meta_connector/meta_connect_test_pipe.c meta_connector/meta_connector.py meta_connector/meta_connector_pipe.py |
diffstat | 4 files changed, 0 insertions(+), 618 deletions(-) [+] |
line wrap: on
line diff
--- a/meta_connector/meta_connect_test.c Mon Oct 05 16:16:27 2015 +0900 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,232 +0,0 @@ -#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); -}
--- a/meta_connector/meta_connect_test_pipe.c Mon Oct 05 16:16:27 2015 +0900 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,227 +0,0 @@ -#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 - -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 meta_get | 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); -}
--- a/meta_connector/meta_connector.py Mon Oct 05 16:16:27 2015 +0900 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,95 +0,0 @@ -#!/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(description='Parse meta connect syntax. Default output is stdout.') - 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 - file.write('/* -- meta connector --\n') - - 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: - file.write("/*-- connected by script */\n") - file.write("// "+l) - ll = re.split(r"\(|\)", l) - file.write("goto {0:s}(context, {1:s}, {2:s});\n".format(list[meta_index][0],\ - ll[1],\ - re.split(" +",ll[0].strip())[1].capitalize())) - file.write("/* connected by script --*/\n") - continue - if l.find('}') >= 0: - target_cs = False - - file.write(l) - - if comment_out and l.find(')') >= 0: - comment_out = False - file.write('-- meta connector --*/\n') - -def main(): - args = get_args() - output = sys.stdout - try: - f = open(args.input_file,'r') - except IOError: - print("cannot open file %s" % input_file) - if args.output is not None: - try: - output = open(args.output[0],'w') - except IOError: - print("cannot open file %s" % args.output) - - lines = f.readlines() - connect_list = parse_meta_syntax(lines) - connect_meta(lines, connect_list, output) - -main()
--- a/meta_connector/meta_connector_pipe.py Mon Oct 05 16:16:27 2015 +0900 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,64 +0,0 @@ -#!/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( - formatter_class=argparse.RawDescriptionHelpFormatter, - description="""\ -Parse meta connect syntax. Default output is stdout. - -sample) - goto meta_code1|code1(arg1, arg2, ...); - \t| - \tV - goto meta_code1(context, arg1, arg2, ..., Code1); - """) - 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,file): - comment_out = False - target_cs = False - for i,l in enumerate(lines): - if re.search(r" *goto +[a-zA-Z0-9_]+ *\| *[a-zA-Z0-9_]+ *\(",l) is not None: - cs_names = re.search(r"[a-zA-Z0-9_]+ *\| *[a-zA-Z0-9_]+",l).group(0).strip().split('|') - file.write("/*-- connected by script */\n") - file.write('// '+l) - file.write("goto {0:s}(context, {1:s}, {2:s});\n".format(cs_names[0].strip(),\ - re.split(r"\(|\)", l)[1],\ - cs_names[1].strip().capitalize())) - else: - file.write(l) - -def main(): - args = get_args() - output = sys.stdout - try: - f = open(args.input_file,'r') - except IOError: - print("cannot open file %s" % input_file) - if args.output is not None: - try: - output = open(args.output[0],'w') - except IOError: - print("cannot open file %s" % args.output) - - lines = f.readlines() - connect_list = parse_meta_syntax(lines, output) - -main()