Mercurial > hg > GearsTemplate

annotate src/parallel_execution/context.h @ 352:3e01e963eb2d

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Fix compile error for calc example but not work
author Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
date Fri, 16 Jun 2017 16:29:27 +0900
parents b8be1d51f002
children b07078bd1f2c
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
1 /* Context definition for llrb example */
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
2 #ifndef CONTEXT_H
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
3 #define CONTEXT_H
207
7470b8382672 Fix compile error to stack_test
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 194
diff changeset
4 #include <stdlib.h>
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
5 #include <pthread.h>
304
9755206813cb helper_string.h for ANSI C
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 302
diff changeset
6 #ifdef USE_CUDAWorker
98
d400948dbbab add Cuda infomation to context
ikkun
parents: 95
diff changeset
7 #include <cuda.h>
101
8987cf13d5bb Add Allocate macro
innparusu
parents: 98
diff changeset
8 #endif
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
9
95
3e28ee215c0e modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 92
diff changeset
10 #define ALLOCATE_SIZE 20000000
101
8987cf13d5bb Add Allocate macro
innparusu
parents: 98
diff changeset
11 #define NEW(type) (type*)(calloc(1, sizeof(type)))
8987cf13d5bb Add Allocate macro
innparusu
parents: 98
diff changeset
12 #define NEWN(n, type) (type*)(calloc(n, sizeof(type)))
8987cf13d5bb Add Allocate macro
innparusu
parents: 98
diff changeset
13
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
14 #define ALLOC_DATA(context, dseg) ({\
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
15 struct Meta* meta = (struct Meta*)context->heap;\
148
473b7d990a1f fix data gears type enum
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 147
diff changeset
16 meta->type = D_##dseg;\
236
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
17 meta->size = 1;\
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
18 context->heap += sizeof(struct Meta);\
148
473b7d990a1f fix data gears type enum
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 147
diff changeset
19 context->data[D_##dseg] = context->heap; context->heap += sizeof(struct dseg); (struct dseg *)context->data[D_##dseg]; })
101
8987cf13d5bb Add Allocate macro
innparusu
parents: 98
diff changeset
20
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
21 #define ALLOC_DATA_TYPE(context, dseg, t) ({\
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
22 struct Meta* meta = (struct Meta*)context->heap;\
148
473b7d990a1f fix data gears type enum
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 147
diff changeset
23 meta->type = D_##t;\
236
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
24 meta->size = 1;\
326
f23f6d0aa4e9 Add examples/calc.cbc and build but not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 320
diff changeset
25 context->heap += sizeof(struct Meta);\
148
473b7d990a1f fix data gears type enum
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 147
diff changeset
26 context->data[D_##dseg] = context->heap; context->heap += sizeof(struct t); (struct t *)context->data[D_##dseg]; })
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
27
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
28 #define ALLOCATE(context, t) ({ \
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
29 struct Meta* meta = (struct Meta*)context->heap;\
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
30 context->heap += sizeof(struct Meta);\
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
31 union Data* data = context->heap; \
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
32 context->heap += sizeof(struct t); \
148
473b7d990a1f fix data gears type enum
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 147
diff changeset
33 meta->type = D_##t; \
236
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
34 meta->size = 1; \
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
35 data; })
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
36
233
06133afb3b5b create worker start_code
mir3636
parents: 232
diff changeset
37 #define ALLOC(context, t) (&ALLOCATE(context, t)->t)
06133afb3b5b create worker start_code
mir3636
parents: 232
diff changeset
38
237
mir3636
parents: 236
diff changeset
39 #define ALLOC_ARRAY(context, dseg, len) ({\
236
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
40 struct Meta* meta = (struct Meta*)context->heap;\
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
41 context->heap += sizeof(struct Meta);\
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
42 union Data* data = context->heap; \
244
d1567718f12c Fix error
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 242
diff changeset
43 context->heap += sizeof(struct dseg *)*len; \
236
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
44 meta->type = D_##dseg; \
237
mir3636
parents: 236
diff changeset
45 meta->size = len; \
236
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
46 data; })
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
47
327
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 326
diff changeset
48 #define ALLOCATE_DATA_GEAR(context, t) ({ \
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 326
diff changeset
49 union Data* data = ALLOCATE(context, t); \
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 326
diff changeset
50 struct Meta* meta = GET_META(data); \
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 326
diff changeset
51 meta->wait = createSingleLinkedQueue(context); \
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 326
diff changeset
52 data; })
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 326
diff changeset
53
288
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 287
diff changeset
54 #define GET_META(dseg) ((struct Meta*)(((void*)dseg) - sizeof(struct Meta)))
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 287
diff changeset
55 #define GET_TYPE(dseg) (GET_META(dseg)->type)
352
3e01e963eb2d Fix compile error for calc example but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 344
diff changeset
56 #define GET_SIZE(dseg) (GET_META(dseg)->size)
288
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 287
diff changeset
57 #define GET_WAIT_LIST(dseg) (GET_META(dseg)->wait)
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
58
149
63ab65b28466 Add Gearef macro
one
parents: 148
diff changeset
59 #define Gearef(context, t) (&(context)->data[D_##t]->t)
186
dbc064c26b98 generate context script
mir3636
parents: 185
diff changeset
60
232
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
61 // (struct SingleLinkedStack *)context->data[D_Stack]->Stack.stack->Stack.stack
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
62
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
63 #define GearImpl(context, intf, name) (Gearef(context, intf)->name->intf.name)
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
64
186
dbc064c26b98 generate context script
mir3636
parents: 185
diff changeset
65 #include "c/enumCode.h"
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
66
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
67 enum Relational {
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
68 EQ,
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
69 GT,
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
70 LT,
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
71 };
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
72
186
dbc064c26b98 generate context script
mir3636
parents: 185
diff changeset
73 #include "c/enumData.h"
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
74
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
75 struct Context {
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
76 enum Code next;
230
a1fb3f2d1a36 fix worker
ikkun
parents: 222
diff changeset
77 struct Worker* worker;
a1fb3f2d1a36 fix worker
ikkun
parents: 222
diff changeset
78 struct TaskManager* taskManager;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
79 int codeNum;
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
80 __code (**code) (struct Context*);
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
81 void* heapStart;
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
82 void* heap;
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
83 long heapLimit;
87
9e139a340bd1 rename directory
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 86
diff changeset
84 int dataNum;
236
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
85 int idgCount; //number of waiting dataGear
326
f23f6d0aa4e9 Add examples/calc.cbc and build but not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 320
diff changeset
86 int idg;
f23f6d0aa4e9 Add examples/calc.cbc and build but not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 320
diff changeset
87 int maxIdg;
282
a3448b0f0a56 Add input data gear
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 278
diff changeset
88 int odg;
288
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 287
diff changeset
89 int maxOdg;
242
9f3f8ed6ed9f Add sendTask
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 239
diff changeset
90 int workerId;
308
aeddca686007 CUDAtwice
ikkun
parents: 305
diff changeset
91 #ifdef USE_CUDAWorker
aeddca686007 CUDAtwice
ikkun
parents: 305
diff changeset
92 int num_exec;
aeddca686007 CUDAtwice
ikkun
parents: 305
diff changeset
93 CUmodule module;
aeddca686007 CUDAtwice
ikkun
parents: 305
diff changeset
94 CUfunction function;
309
8c2123bb577b fix compile errors
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 308
diff changeset
95 #endif
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
96 union Data **data;
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
97 };
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
98
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
99 union Data {
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
100 struct Meta {
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
101 enum DataType type;
236
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
102 long size;
176
f0427e27dd7b create interface of Task, TaskManager, Worker
mir3636
parents: 172
diff changeset
103 struct Queue* wait; // tasks waiting this dataGear
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
104 } meta;
259
195518ab62fc fix type gathering pattern match in generate_stub.pl
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 254
diff changeset
105 struct Context Context;
95
3e28ee215c0e modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 92
diff changeset
106 struct Time {
102
64c98838a291 remove stack StartTime&EndTime
ikkun
parents: 101
diff changeset
107 enum Code next;
95
3e28ee215c0e modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 92
diff changeset
108 double time;
149
63ab65b28466 Add Gearef macro
one
parents: 148
diff changeset
109 } Time;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
110 struct LoopCounter {
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
111 int i;
217
c34e6aa10967 Fix DataGear access name
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 207
diff changeset
112 } LoopCounter;
176
f0427e27dd7b create interface of Task, TaskManager, Worker
mir3636
parents: 172
diff changeset
113 struct TaskManager {
320
f730761bb044 non CUDA case clean up
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 316
diff changeset
114 #ifdef USE_CUDA_MAIN_THREAD
f730761bb044 non CUDA case clean up
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 316
diff changeset
115 volatile
f730761bb044 non CUDA case clean up
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 316
diff changeset
116 #endif
f730761bb044 non CUDA case clean up
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 316
diff changeset
117 union Data* taskManager;
234
47588c28f189 TaskManager
mir3636
parents: 233
diff changeset
118 enum Code spawn; // start NEW context on the worker
326
f23f6d0aa4e9 Add examples/calc.cbc and build but not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 320
diff changeset
119 enum Code setWaitTask;
176
f0427e27dd7b create interface of Task, TaskManager, Worker
mir3636
parents: 172
diff changeset
120 enum Code shutdown;
184
mir3636
parents: 183
diff changeset
121 enum Code next;
233
06133afb3b5b create worker start_code
mir3636
parents: 232
diff changeset
122 enum Code task;
06133afb3b5b create worker start_code
mir3636
parents: 232
diff changeset
123 struct Context* context;
352
3e01e963eb2d Fix compile error for calc example but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 344
diff changeset
124 struct Context** contexts;
326
f23f6d0aa4e9 Add examples/calc.cbc and build but not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 320
diff changeset
125 union Data* data;
233
06133afb3b5b create worker start_code
mir3636
parents: 232
diff changeset
126 int worker;
06133afb3b5b create worker start_code
mir3636
parents: 232
diff changeset
127 int cpu;
06133afb3b5b create worker start_code
mir3636
parents: 232
diff changeset
128 int gpu;
06133afb3b5b create worker start_code
mir3636
parents: 232
diff changeset
129 int io;
237
mir3636
parents: 236
diff changeset
130 int maxCPU;
184
mir3636
parents: 183
diff changeset
131 } TaskManager;
182
57a11c15ff4c Add queue_test
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 178
diff changeset
132 struct TaskManagerImpl {
233
06133afb3b5b create worker start_code
mir3636
parents: 232
diff changeset
133 int numWorker;
242
9f3f8ed6ed9f Add sendTask
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 239
diff changeset
134 int sendWorkerIndex;
239
mir3636
parents: 237
diff changeset
135 pthread_mutex_t mutex;
184
mir3636
parents: 183
diff changeset
136 struct Queue* activeQueue;
mir3636
parents: 183
diff changeset
137 struct Queue* taskQueue;
244
d1567718f12c Fix error
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 242
diff changeset
138 struct Worker** workers;
352
3e01e963eb2d Fix compile error for calc example but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 344
diff changeset
139 struct LoopCounter* loopCounter;
184
mir3636
parents: 183
diff changeset
140 } TaskManagerImpl;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
141 struct Worker {
232
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
142 union Data* worker;
222
77faa28128b4 Add taskSend for TaskManager
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 218
diff changeset
143 enum Code taskReceive;
176
f0427e27dd7b create interface of Task, TaskManager, Worker
mir3636
parents: 172
diff changeset
144 enum Code shutdown;
230
a1fb3f2d1a36 fix worker
ikkun
parents: 222
diff changeset
145 enum Code next;
244
d1567718f12c Fix error
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 242
diff changeset
146 struct Queue* tasks;
288
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 287
diff changeset
147 struct TaskManager* taskManager;
184
mir3636
parents: 183
diff changeset
148 } Worker;
232
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
149 struct CPUWorker {
233
06133afb3b5b create worker start_code
mir3636
parents: 232
diff changeset
150 pthread_t thread;
242
9f3f8ed6ed9f Add sendTask
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 239
diff changeset
151 pthread_mutex_t mutex;
9f3f8ed6ed9f Add sendTask
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 239
diff changeset
152 pthread_cond_t cond;
232
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
153 struct Context* context;
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
154 int id;
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
155 } CPUWorker;
302
8e7926f3e271 fix CUDAWorker
ikkun
parents: 288
diff changeset
156 #ifdef USE_CUDAWorker
8e7926f3e271 fix CUDAWorker
ikkun
parents: 288
diff changeset
157 struct CUDAWorker {
316
54d203daf06b CUDAtwice.cbc is called.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 309
diff changeset
158 CUdevice device;
54d203daf06b CUDAtwice.cbc is called.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 309
diff changeset
159 CUcontext cuCtx;
233
06133afb3b5b create worker start_code
mir3636
parents: 232
diff changeset
160 pthread_t thread;
232
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
161 struct Context* context;
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
162 int id;
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
163 struct Queue* tasks;
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
164 int runFlag;
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
165 enum Code next;
305
ec0a5b4fba05 CUDAWorker
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 304
diff changeset
166 int num_stream;
ec0a5b4fba05 CUDAWorker
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 304
diff changeset
167 CUstream *stream;
ec0a5b4fba05 CUDAWorker
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 304
diff changeset
168 } CUDAWorker;
187
bacc37265386 main.o fixed
mir3636
parents: 186
diff changeset
169 #else
302
8e7926f3e271 fix CUDAWorker
ikkun
parents: 288
diff changeset
170 struct CUDAWorker {
305
ec0a5b4fba05 CUDAWorker
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 304
diff changeset
171 } CUDAWorker;
101
8987cf13d5bb Add Allocate macro
innparusu
parents: 98
diff changeset
172 #endif
177
bb52f7f77bf5 add main
ikkun
parents: 176
diff changeset
173 struct Main {
bb52f7f77bf5 add main
ikkun
parents: 176
diff changeset
174 enum Code code;
bb52f7f77bf5 add main
ikkun
parents: 176
diff changeset
175 enum Code next;
bb52f7f77bf5 add main
ikkun
parents: 176
diff changeset
176 struct Queue* args;
185
247a2c4a8908 fix compile errors
mir3636
parents: 184
diff changeset
177 } Main;
169
ea7b11f3e717 Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 168
diff changeset
178 // Queue Interface
90
4b5bf5b40970 put queue
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 87
diff changeset
179 struct Queue {
136
a747dc9d4da6 stack refactering no compile error
mir3636
parents: 135
diff changeset
180 union Data* queue;
167
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
181 union Data* data;
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
182 enum Code whenEmpty;
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
183 enum Code clear;
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
184 enum Code put;
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
185 enum Code take;
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
186 enum Code isEmpty;
130
2bb5e4f0fd35 Stackinterface
ikkun
parents: 124
diff changeset
187 enum Code next;
184
mir3636
parents: 183
diff changeset
188 } Queue;
167
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
189 struct SingleLinkedQueue {
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
190 struct Element* top;
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
191 struct Element* last;
184
mir3636
parents: 183
diff changeset
192 } SingleLinkedQueue;
282
a3448b0f0a56 Add input data gear
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 278
diff changeset
193 struct SynchronizedQueue {
a3448b0f0a56 Add input data gear
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 278
diff changeset
194 struct Element* top;
a3448b0f0a56 Add input data gear
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 278
diff changeset
195 struct Element* last;
287
6b099d73949c Add queueCount sem to SynchronizedQueue
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 286
diff changeset
196 struct Semaphore* queueCount;
282
a3448b0f0a56 Add input data gear
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 278
diff changeset
197 } SynchronizedQueue;
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
198 // Stack Interface
130
2bb5e4f0fd35 Stackinterface
ikkun
parents: 124
diff changeset
199 struct Stack {
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
200 union Data* stack;
130
2bb5e4f0fd35 Stackinterface
ikkun
parents: 124
diff changeset
201 union Data* data;
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
202 union Data* data1;
169
ea7b11f3e717 Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 168
diff changeset
203 enum Code whenEmpty;
145
cc071cf1ba85 add stack clear interface
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 144
diff changeset
204 enum Code clear;
130
2bb5e4f0fd35 Stackinterface
ikkun
parents: 124
diff changeset
205 enum Code push;
2bb5e4f0fd35 Stackinterface
ikkun
parents: 124
diff changeset
206 enum Code pop;
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
207 enum Code pop2;
130
2bb5e4f0fd35 Stackinterface
ikkun
parents: 124
diff changeset
208 enum Code isEmpty;
134
2eccf4564efe fix stack call in rb_tree
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 133
diff changeset
209 enum Code get;
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
210 enum Code get2;
130
2bb5e4f0fd35 Stackinterface
ikkun
parents: 124
diff changeset
211 enum Code next;
194
081607dcf893 create generate_stub.pl
mir3636
parents: 187
diff changeset
212 } Stack;
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
213 // Stack implementations
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
214 struct SingleLinkedStack {
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
215 struct Element* top;
194
081607dcf893 create generate_stub.pl
mir3636
parents: 187
diff changeset
216 } SingleLinkedStack;
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
217 struct ArrayStack {
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
218 int size;
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
219 int limit;
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
220 struct Element* array;
194
081607dcf893 create generate_stub.pl
mir3636
parents: 187
diff changeset
221 } ArrayStack;
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
222 // Stack implementation end
90
4b5bf5b40970 put queue
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 87
diff changeset
223 struct Element {
113
d05b9937aa95 Change element data from Task to Data
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 112
diff changeset
224 union Data* data;
90
4b5bf5b40970 put queue
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 87
diff changeset
225 struct Element* next;
194
081607dcf893 create generate_stub.pl
mir3636
parents: 187
diff changeset
226 } Element;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
227 struct Array {
308
aeddca686007 CUDAtwice
ikkun
parents: 305
diff changeset
228 int size;
90
4b5bf5b40970 put queue
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 87
diff changeset
229 int index;
95
3e28ee215c0e modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 92
diff changeset
230 int prefix;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
231 int* array;
194
081607dcf893 create generate_stub.pl
mir3636
parents: 187
diff changeset
232 } Array;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
233 struct Tree {
166
mir3636
parents: 153
diff changeset
234 union Data* tree;
mir3636
parents: 153
diff changeset
235 struct Node* node;
152
7164f59660d4 create .cbc
mir3636
parents: 149
diff changeset
236 enum Code put;
7164f59660d4 create .cbc
mir3636
parents: 149
diff changeset
237 enum Code get;
7164f59660d4 create .cbc
mir3636
parents: 149
diff changeset
238 enum Code remove;
171
747067fe46bd Fix selected Queue
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
239 enum Code clear;
152
7164f59660d4 create .cbc
mir3636
parents: 149
diff changeset
240 enum Code next;
166
mir3636
parents: 153
diff changeset
241 } Tree;
172
661b0b0d0399 replace Tree to RedBlackTree
ikkun
parents: 171
diff changeset
242 struct RedBlackTree {
152
7164f59660d4 create .cbc
mir3636
parents: 149
diff changeset
243 struct Node* root;
122
73a679a85c04 node stack rewrite
ikkun
parents: 119
diff changeset
244 struct Node* current; // reading node of original tree
138
04a2f486a30d insert works but is not balanced
kono
parents: 136
diff changeset
245 struct Node* previous; // parent of reading node of original tree
124
36ac17d37be4 Fix compile error but not work
one
parents: 122
diff changeset
246 struct Node* newNode; // writing node of new tree
143
34a7a21edc36 recude stack get using traverse field
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 138
diff changeset
247 struct Node* parent;
34a7a21edc36 recude stack get using traverse field
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 138
diff changeset
248 struct Node* grandparent;
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
249 struct Stack* nodeStack;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
250 int result;
172
661b0b0d0399 replace Tree to RedBlackTree
ikkun
parents: 171
diff changeset
251 } RedBlackTree;
147
f2275f5777f4 add treeRotate data
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 145
diff changeset
252 struct RotateTree {
f2275f5777f4 add treeRotate data
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 145
diff changeset
253 enum Code next;
172
661b0b0d0399 replace Tree to RedBlackTree
ikkun
parents: 171
diff changeset
254 struct RedBlackTree* traverse;
147
f2275f5777f4 add treeRotate data
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 145
diff changeset
255 struct Tree* tree;
217
c34e6aa10967 Fix DataGear access name
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 207
diff changeset
256 } RotateTree;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
257 struct Node {
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
258 int key; // comparable data segment
90
4b5bf5b40970 put queue
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 87
diff changeset
259 union Data* value;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
260 struct Node* left;
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
261 struct Node* right;
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
262 // need to balancing
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
263 enum Color {
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
264 Red,
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
265 Black,
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
266 } color;
217
c34e6aa10967 Fix DataGear access name
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 207
diff changeset
267 } Node;
286
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
268 struct Semaphore {
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
269 union Data* semaphore;
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
270 enum Code p;
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
271 enum Code v;
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
272 enum Code next;
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
273 } Semaphore;
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
274 struct SemaphoreImpl {
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
275 int value;
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
276 pthread_mutex_t mutex;
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
277 pthread_cond_t cond;
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
278 } SemaphoreImpl;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
279 struct Allocate {
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
280 enum Code next;
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
281 long size;
217
c34e6aa10967 Fix DataGear access name
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 207
diff changeset
282 } Allocate;
326
f23f6d0aa4e9 Add examples/calc.cbc and build but not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 320
diff changeset
283 struct Integer {
f23f6d0aa4e9 Add examples/calc.cbc and build but not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 320
diff changeset
284 int value;
f23f6d0aa4e9 Add examples/calc.cbc and build but not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 320
diff changeset
285 } Integer;
254
edb3aff688d0 fix generator CLI
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 244
diff changeset
286 }; // union Data end this is necessary for context generator
113
d05b9937aa95 Change element data from Task to Data
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 112
diff changeset
287
259
195518ab62fc fix type gathering pattern match in generate_stub.pl
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 254
diff changeset
288 typedef union Data Data;
195518ab62fc fix type gathering pattern match in generate_stub.pl
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 254
diff changeset
289
186
dbc064c26b98 generate context script
mir3636
parents: 185
diff changeset
290 #include "c/typedefData.h"
278
23767f714f4a fix generate_stub
mir3636
parents: 259
diff changeset
291
23767f714f4a fix generate_stub
mir3636
parents: 259
diff changeset
292 #include "c/extern.h"
23767f714f4a fix generate_stub
mir3636
parents: 259
diff changeset
293
23767f714f4a fix generate_stub
mir3636
parents: 259
diff changeset
294 extern __code start_code(struct Context* context);
23767f714f4a fix generate_stub
mir3636
parents: 259
diff changeset
295 extern __code exit_code(struct Context* context);
23767f714f4a fix generate_stub
mir3636
parents: 259
diff changeset
296 extern __code meta(struct Context* context, enum Code next);
23767f714f4a fix generate_stub
mir3636
parents: 259
diff changeset
297 extern void initContext(struct Context* context);
23767f714f4a fix generate_stub
mir3636
parents: 259
diff changeset
298
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
299 #endif