Mercurial > hg > Members > Moririn
view src/parallel_execution/examples/calc/calc.cbc @ 381:b81492c74d2b
Create examples directory
author | Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp> |
---|---|
date | Mon, 24 Jul 2017 16:52:09 +0900 |
parents | src/parallel_execution/examples/calc.cbc@9049c19036fd |
children | bba401f93dcd |
line wrap: on
line source
#include <stdio.h> #include <string.h> #include <stdlib.h> #include <unistd.h> #include <assert.h> #include "../../../context.h" int cpu_num = 1; int length = 100; int gpu_num = 0; int CPU_ANY = -1; int CPU_CUDA = -1; void print_queue(struct Element* element) { while (element) { printf("%p\n", ((struct Task *)(element->data))); element = element->next; } } void print_tree(struct Node* node) { if (node != 0) { printf("%d\n", node->value->Array.index); print_tree(node->left); print_tree(node->right); } } void *start_taskManager(struct Context *context) { goto initDataGears(context, Gearef(context, LoopCounter), Gearef(context, TaskManager)); return 0; } #ifdef USE_CUDAWorker #ifdef USE_CUDA_MAIN_THREAD extern volatile int cuda_initialized; #endif #endif __code initDataGears(struct LoopCounter* loopCounter, struct TaskManager* taskManager) { // loopCounter->tree = createRedBlackTree(context); loopCounter->i = 0; taskManager->taskManager = (union Data*)createTaskManagerImpl(context, cpu_num, gpu_num, 0); #ifdef USE_CUDAWorker #ifdef USE_CUDA_MAIN_THREAD while(! cuda_initialized) {}; #endif #endif goto meta(context, C_createTask1); } __code initDataGears_stub(struct Context* context) { struct TaskManager* taskManager = Gearef(context, TaskManager); taskManager->taskManager = 0; #if (! defined(USE_CUDAWorker) || ! defined(USE_CUDA_MAIN_THREAD)) struct LoopCounter* loopCounter = Gearef(context, LoopCounter); goto initDataGears(context, loopCounter, taskManager); #else cuda_initialized = 0; pthread_t thread; pthread_create(&thread, NULL, (void*)&start_taskManager, context); while (taskManager->taskManager == 0); TaskManager *t = (TaskManager*)taskManager->taskManager; TaskManagerImpl *im = (TaskManagerImpl*)t->taskManager; struct Queue *q = (Queue *)im->workers[0]; createCUDAWorker(context,0,q, im); pthread_join(thread,0); exit(0); #endif } __code code1(struct Time* time) { printf("cpus:\t\t%d\n", cpu_num); printf("gpus:\t\t%d\n", gpu_num); printf("length:\t\t%d\n", length); /* puts("queue"); */ /* print_queue(context->data[ActiveQueue]->queue.first); */ /* puts("tree"); */ /* print_tree(context->data[Tree]->tree.root); */ /* puts("result"); */ //time->next = C_code2; goto meta(context, C_exit_code); //goto meta(context, C_start_time); } __code code1_stub(struct Context* context) { goto code1(context, Gearef(context, Time)); } __code createTask1(struct LoopCounter* loopCounter, struct TaskManager* taskManager) { int i = loopCounter->i; if (i < length) { loopCounter->i++; goto meta(context, C_createTask2); } loopCounter->i = 0; taskManager->next = C_code1; sleep(5); goto meta(context, taskManager->taskManager->TaskManager.shutdown); } __code createTask2(struct LoopCounter* loopCounter, struct TaskManager* taskManager) { struct Context** tasks = (struct Context**)ALLOC_ARRAY(context, Context, 3); Integer* integer1 = &ALLOCATE_DATA_GEAR(context, Integer)->Integer; Integer* integer2 = &ALLOCATE_DATA_GEAR(context, Integer)->Integer; Integer* integer3 = &ALLOCATE_DATA_GEAR(context, Integer)->Integer; // par goto mult(integer1, integer2, integer3, __exit); struct Context* task = NEW(struct Context); initContext(task); task->next = C_mult; task->idgCount = 2; task->idg = task->dataNum; task->data[task->idg] = (union Data*)integer1; task->data[task->idg+1] = (union Data*)integer2; task->maxIdg = task->idg + 2; task->odg = task->maxIdg; task->data[task->odg] = (union Data*)integer3; task->maxOdg = task->odg + 1; tasks[0] = task; Integer* integer4 = &ALLOCATE_DATA_GEAR(context, Integer)->Integer; Integer* integer5 = &ALLOCATE_DATA_GEAR(context, Integer)->Integer; // par goto add(integer4, integer5, integer1, __exit); task = NEW(struct Context); initContext(task); task->next = C_add; task->idgCount = 2; task->idg = task->dataNum; task->data[task->idg] = (union Data*)integer4; task->data[task->idg+1] = (union Data*)integer5; task->maxIdg = task->idg + 2; task->odg = task->maxIdg; task->data[task->odg] = (union Data*)integer1; task->maxOdg = task->odg + 1; tasks[1] = task; // par goto initIntegerDataGears(integer2, integer4, integer5, __exit); task = NEW(struct Context); initContext(task); task->next = C_initIntegerDataGears; task->idgCount = 0; task->idg = task->dataNum; task->maxIdg = task->idg; task->odg = task->maxIdg; task->data[task->odg] = (union Data*)integer2; task->data[task->odg+1] = (union Data*)integer4; task->data[task->odg+2] = (union Data*)integer5; task->maxOdg = task->odg + 3; tasks[2] = task; taskManager->contexts = tasks; // goto crateTask1(); taskManager->next1 = C_createTask1; goto meta(context, taskManager->taskManager->TaskManager.spawnTasks); } void init(int argc, char** argv) { for (int i = 1; argv[i]; ++i) { if (strcmp(argv[i], "-cpu") == 0) cpu_num = (int)atoi(argv[i+1]); else if (strcmp(argv[i], "-l") == 0) length = (int)atoi(argv[i+1]); else if (strcmp(argv[i], "-cuda") == 0) { gpu_num = 1; CPU_CUDA = 0; } } } int main(int argc, char** argv) { init(argc, argv); struct Context* main_context = NEW(struct Context); initContext(main_context); main_context->next = C_initDataGears; goto start_code(main_context); }