Mercurial > hg > Members > Moririn

annotate src/parallel_execution/context.h @ 495:2e7ea81e5943

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Work BoundedBuffer if singlethread
author Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
date Sun, 31 Dec 2017 04:36:20 +0900
parents d8b2036c6942
children 04441dd783c5
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>
462
8d7e5d48cad3 Running CPU examples
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 461
diff changeset
8 #include <driver_types.h>
8d7e5d48cad3 Running CPU examples
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 461
diff changeset
9 #include <cuda_runtime.h>
465
b6437feb04ee Running CUDA examples
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 464
diff changeset
10 #include "helper_cuda.h"
101
8987cf13d5bb Add Allocate macro
innparusu
parents: 98
diff changeset
11 #endif
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
12
95
3e28ee215c0e modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 92
diff changeset
13 #define ALLOCATE_SIZE 20000000
101
8987cf13d5bb Add Allocate macro
innparusu
parents: 98
diff changeset
14 #define NEW(type) (type*)(calloc(1, sizeof(type)))
8987cf13d5bb Add Allocate macro
innparusu
parents: 98
diff changeset
15 #define NEWN(n, type) (type*)(calloc(n, sizeof(type)))
8987cf13d5bb Add Allocate macro
innparusu
parents: 98
diff changeset
16
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
17 #define ALLOC_DATA(context, dseg) ({\
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
18 Meta* meta = (Meta*)context->heap;\
148
473b7d990a1f fix data gears type enum
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 147
diff changeset
19 meta->type = D_##dseg;\
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
20 meta->size = sizeof(dseg);\
430
35b37fe8d3a7 Add size member in struct Meta
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
21 meta->len = 1;\
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
22 context->heap += sizeof(Meta);\
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
23 context->data[D_##dseg] = context->heap; context->heap += sizeof(dseg); (dseg *)context->data[D_##dseg]; })
101
8987cf13d5bb Add Allocate macro
innparusu
parents: 98
diff changeset
24
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
25 #define ALLOC_DATA_TYPE(context, dseg, t) ({\
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
26 Meta* meta = (Meta*)context->heap;\
148
473b7d990a1f fix data gears type enum
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 147
diff changeset
27 meta->type = D_##t;\
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
28 meta->size = sizeof(t);\
430
35b37fe8d3a7 Add size member in struct Meta
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
29 meta->len = 1;\
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
30 context->heap += sizeof(Meta);\
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
31 context->data[D_##dseg] = context->heap; context->heap += sizeof(t); (t *)context->data[D_##dseg]; })
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
32
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
33 #define ALLOCATE(context, t) ({ \
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
34 Meta* meta = (Meta*)context->heap;\
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
35 context->heap += sizeof(Meta);\
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
36 union Data* data = context->heap; \
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
37 context->heap += sizeof(t); \
148
473b7d990a1f fix data gears type enum
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 147
diff changeset
38 meta->type = D_##t; \
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
39 meta->size = sizeof(t); \
430
35b37fe8d3a7 Add size member in struct Meta
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
40 meta->len = 1;\
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
41 data; })
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
42
430
35b37fe8d3a7 Add size member in struct Meta
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
43 #define ALLOCATE_ARRAY(context, t, length) ({ \
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
44 Meta* meta = (Meta*)context->heap;\
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
45 context->heap += sizeof(Meta);\
404
c5cd9888bf2a Fix bitonicSort
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 402
diff changeset
46 union Data* data = context->heap; \
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
47 context->heap += sizeof(t)*length; \
404
c5cd9888bf2a Fix bitonicSort
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 402
diff changeset
48 meta->type = D_##t; \
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
49 meta->size = sizeof(t)*length; \
430
35b37fe8d3a7 Add size member in struct Meta
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
50 meta->len = length; \
404
c5cd9888bf2a Fix bitonicSort
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 402
diff changeset
51 data; })
c5cd9888bf2a Fix bitonicSort
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 402
diff changeset
52
430
35b37fe8d3a7 Add size member in struct Meta
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
53 #define ALLOCATE_PTR_ARRAY(context, dseg, length) ({\
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
54 Meta* meta = (Meta*)context->heap;\
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
55 context->heap += sizeof(Meta);\
236
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
56 union Data* data = context->heap; \
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
57 context->heap += sizeof(dseg *)*length; \
236
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
58 meta->type = D_##dseg; \
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
59 meta->size = sizeof(dseg *)*length; \
430
35b37fe8d3a7 Add size member in struct Meta
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
60 meta->len = length; \
236
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
61 data; })
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
62
327
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 326
diff changeset
63 #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
64 union Data* data = ALLOCATE(context, t); \
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
65 Meta* meta = GET_META(data); \
449
0181b7fa5f53 Using SynchornizedQueue in data gear wait list
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 447
diff changeset
66 meta->wait = createSynchronizedQueue(context); \
327
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 326
diff changeset
67 data; })
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 326
diff changeset
68
430
35b37fe8d3a7 Add size member in struct Meta
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
69 #define ALLOC(context, t) (&ALLOCATE(context, t)->t)
35b37fe8d3a7 Add size member in struct Meta
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
70
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
71 #define GET_META(dseg) ((Meta*)(((void*)dseg) - sizeof(Meta)))
288
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 287
diff changeset
72 #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
73 #define GET_SIZE(dseg) (GET_META(dseg)->size)
430
35b37fe8d3a7 Add size member in struct Meta
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
74 #define GET_LEN(dseg) (GET_META(dseg)->len)
288
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 287
diff changeset
75 #define GET_WAIT_LIST(dseg) (GET_META(dseg)->wait)
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
76
149
63ab65b28466 Add Gearef macro
one
parents: 148
diff changeset
77 #define Gearef(context, t) (&(context)->data[D_##t]->t)
186
dbc064c26b98 generate context script
mir3636
parents: 185
diff changeset
78
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
79 // (SingleLinkedStack *)context->data[D_Stack]->Stack.stack->Stack.stack
232
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
80
438
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
81 #define GearImpl(context, intf, name) (Gearef(context, intf)->name->intf.name)
232
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
82
186
dbc064c26b98 generate context script
mir3636
parents: 185
diff changeset
83 #include "c/enumCode.h"
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
84
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
85 enum Relational {
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
86 EQ,
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
87 GT,
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
88 LT,
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
89 };
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
90
186
dbc064c26b98 generate context script
mir3636
parents: 185
diff changeset
91 #include "c/enumData.h"
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
92
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
93 struct Context {
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
94 enum Code next;
230
a1fb3f2d1a36 fix worker
ikkun
parents: 222
diff changeset
95 struct Worker* worker;
a1fb3f2d1a36 fix worker
ikkun
parents: 222
diff changeset
96 struct TaskManager* taskManager;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
97 int codeNum;
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
98 __code (**code) (struct Context*);
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
99 void* heapStart;
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
100 void* heap;
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
101 long heapLimit;
87
9e139a340bd1 rename directory
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 86
diff changeset
102 int dataNum;
236
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
103 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
104 int idg;
f23f6d0aa4e9 Add examples/calc.cbc and build but not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 320
diff changeset
105 int maxIdg;
282
a3448b0f0a56 Add input data gear
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 278
diff changeset
106 int odg;
288
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 287
diff changeset
107 int maxOdg;
242
9f3f8ed6ed9f Add sendTask
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 239
diff changeset
108 int workerId;
410
85b0ddbf458e Fix CudaWorker
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 406
diff changeset
109 int gpu; // GPU task
406
9b35e6581b5c Use task member of context by par goto meta
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 405
diff changeset
110 struct Context* task;
482
5859bed4edff Refactoring spawnTasks method
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 481
diff changeset
111 struct Element* taskList;
308
aeddca686007 CUDAtwice
ikkun
parents: 305
diff changeset
112 #ifdef USE_CUDAWorker
aeddca686007 CUDAtwice
ikkun
parents: 305
diff changeset
113 int num_exec;
aeddca686007 CUDAtwice
ikkun
parents: 305
diff changeset
114 CUmodule module;
aeddca686007 CUDAtwice
ikkun
parents: 305
diff changeset
115 CUfunction function;
438
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
116 #endif
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
117 union Data **data;
372
d6ce4273e7d1 Add dimension task spawn
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 369
diff changeset
118
d6ce4273e7d1 Add dimension task spawn
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 369
diff changeset
119 /* multi dimension parameter */
374
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
120 int iterate;
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
121 struct Iterator* iterator;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
122 };
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
123
438
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
124 typedef int Int;
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
125 #ifndef USE_CUDAWorker
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
126 typedef unsigned long long CUdeviceptr;
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
127 #endif
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
128 union Data {
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
129 struct Meta {
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
130 enum DataType type;
236
865179a0a56d fix taskManager
ikkun
parents: 234
diff changeset
131 long size;
430
35b37fe8d3a7 Add size member in struct Meta
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
132 long len;
176
f0427e27dd7b create interface of Task, TaskManager, Worker
mir3636
parents: 172
diff changeset
133 struct Queue* wait; // tasks waiting this dataGear
441
5a737c3df91c Add AtomicReference Implements of Atomic Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 438
diff changeset
134 } Meta;
259
195518ab62fc fix type gathering pattern match in generate_stub.pl
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 254
diff changeset
135 struct Context Context;
464
7d67c9cf09ee Rename from Time interface to Timer interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 462
diff changeset
136 struct Timer {
7d67c9cf09ee Rename from Time interface to Timer interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 462
diff changeset
137 union Data* timer;
364
a0a3301bac4d Add Time interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 362
diff changeset
138 enum Code start;
a0a3301bac4d Add Time interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 362
diff changeset
139 enum Code end;
102
64c98838a291 remove stack StartTime&EndTime
ikkun
parents: 101
diff changeset
140 enum Code next;
464
7d67c9cf09ee Rename from Time interface to Timer interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 462
diff changeset
141 } Timer;
7d67c9cf09ee Rename from Time interface to Timer interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 462
diff changeset
142 struct TimerImpl {
95
3e28ee215c0e modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 92
diff changeset
143 double time;
464
7d67c9cf09ee Rename from Time interface to Timer interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 462
diff changeset
144 } TimerImpl;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
145 struct LoopCounter {
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
146 int i;
217
c34e6aa10967 Fix DataGear access name
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 207
diff changeset
147 } LoopCounter;
176
f0427e27dd7b create interface of Task, TaskManager, Worker
mir3636
parents: 172
diff changeset
148 struct TaskManager {
320
f730761bb044 non CUDA case clean up
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 316
diff changeset
149 union Data* taskManager;
234
47588c28f189 TaskManager
mir3636
parents: 233
diff changeset
150 enum Code spawn; // start NEW context on the worker
398
fc4fcd441700 Fix spanwTasks
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 397
diff changeset
151 enum Code spawnTasks; // start NEW tasks on the worker
176
f0427e27dd7b create interface of Task, TaskManager, Worker
mir3636
parents: 172
diff changeset
152 enum Code shutdown;
405
8915fce522b3 Fix shutdown TaskManager
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 404
diff changeset
153 enum Code incrementTaskCount;
8915fce522b3 Fix shutdown TaskManager
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 404
diff changeset
154 enum Code decrementTaskCount;
184
mir3636
parents: 183
diff changeset
155 enum Code next;
353
b07078bd1f2c Add spawn Tasks to TaskManagerImpl
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 352
diff changeset
156 enum Code next1;
459
57c715bd6283 Change taskManager parameter from context to task
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 454
diff changeset
157 enum Code setWaitTask;
57c715bd6283 Change taskManager parameter from context to task
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 454
diff changeset
158 struct Context* task;
482
5859bed4edff Refactoring spawnTasks method
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 481
diff changeset
159 struct Element* taskList;
326
f23f6d0aa4e9 Add examples/calc.cbc and build but not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 320
diff changeset
160 union Data* data;
184
mir3636
parents: 183
diff changeset
161 } TaskManager;
182
57a11c15ff4c Add queue_test
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 178
diff changeset
162 struct TaskManagerImpl {
388
8940d1451a0d handle local continuation
masataka
parents: 383
diff changeset
163 enum Code next;
233
06133afb3b5b create worker start_code
mir3636
parents: 232
diff changeset
164 int numWorker;
410
85b0ddbf458e Fix CudaWorker
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 406
diff changeset
165 int sendCPUWorkerIndex;
85b0ddbf458e Fix CudaWorker
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 406
diff changeset
166 int sendGPUWorkerIndex;
405
8915fce522b3 Fix shutdown TaskManager
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 404
diff changeset
167 int taskCount;
239
mir3636
parents: 237
diff changeset
168 pthread_mutex_t mutex;
184
mir3636
parents: 183
diff changeset
169 struct Queue* activeQueue;
244
d1567718f12c Fix error
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 242
diff changeset
170 struct Worker** workers;
482
5859bed4edff Refactoring spawnTasks method
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 481
diff changeset
171 struct Element* taskList;
480
39b5df2d1c93 Change loopCounter type from struct LoopCounter to Integer for TaskManagerImpl
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
172 int loopCounter;
461
6b71cf5b1c22 Change Interface files from cbc to header
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 459
diff changeset
173 int cpu;
6b71cf5b1c22 Change Interface files from cbc to header
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 459
diff changeset
174 int gpu;
6b71cf5b1c22 Change Interface files from cbc to header
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 459
diff changeset
175 int io;
6b71cf5b1c22 Change Interface files from cbc to header
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 459
diff changeset
176 int maxCPU;
184
mir3636
parents: 183
diff changeset
177 } TaskManagerImpl;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
178 struct Worker {
232
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
179 union Data* worker;
222
77faa28128b4 Add taskSend for TaskManager
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 218
diff changeset
180 enum Code taskReceive;
176
f0427e27dd7b create interface of Task, TaskManager, Worker
mir3636
parents: 172
diff changeset
181 enum Code shutdown;
230
a1fb3f2d1a36 fix worker
ikkun
parents: 222
diff changeset
182 enum Code next;
244
d1567718f12c Fix error
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 242
diff changeset
183 struct Queue* tasks;
411
0eba9a04633f Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 410
diff changeset
184 pthread_t thread;
288
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 287
diff changeset
185 struct TaskManager* taskManager;
474
b92898d3a630 Refactoring CPUWorker.cbc
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 473
diff changeset
186 struct Context* task;
184
mir3636
parents: 183
diff changeset
187 } Worker;
232
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
188 struct CPUWorker {
242
9f3f8ed6ed9f Add sendTask
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 239
diff changeset
189 pthread_mutex_t mutex;
9f3f8ed6ed9f Add sendTask
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 239
diff changeset
190 pthread_cond_t cond;
232
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
191 struct Context* context;
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
192 int id;
473
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 465
diff changeset
193 int loopCounter;
232
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
194 } CPUWorker;
302
8e7926f3e271 fix CUDAWorker
ikkun
parents: 288
diff changeset
195 #ifdef USE_CUDAWorker
8e7926f3e271 fix CUDAWorker
ikkun
parents: 288
diff changeset
196 struct CUDAWorker {
316
54d203daf06b CUDAtwice.cbc is called.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 309
diff changeset
197 CUdevice device;
54d203daf06b CUDAtwice.cbc is called.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 309
diff changeset
198 CUcontext cuCtx;
232
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
199 struct Context* context;
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
200 int id;
481
a517b11c37f7 Refactoring CUDAWorker.cbc
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 480
diff changeset
201 int loopCounter;
487
d6983ce1015d Fix extern cudainit parameter
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 482
diff changeset
202 int deviceNum;
232
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
203 struct Queue* tasks;
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
204 int runFlag;
123b0d277b84 worker interface
mir3636
parents: 230
diff changeset
205 enum Code next;
451
dcc42f3e7e97 Auto choice blockDim
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 450
diff changeset
206 int numStream;
436
08a93fc2f0d3 Fix CudaExecutor but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 435
diff changeset
207 struct Executor* executor;
305
ec0a5b4fba05 CUDAWorker
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 304
diff changeset
208 CUstream *stream;
ec0a5b4fba05 CUDAWorker
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 304
diff changeset
209 } CUDAWorker;
187
bacc37265386 main.o fixed
mir3636
parents: 186
diff changeset
210 #else
302
8e7926f3e271 fix CUDAWorker
ikkun
parents: 288
diff changeset
211 struct CUDAWorker {
305
ec0a5b4fba05 CUDAWorker
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 304
diff changeset
212 } CUDAWorker;
101
8987cf13d5bb Add Allocate macro
innparusu
parents: 98
diff changeset
213 #endif
177
bb52f7f77bf5 add main
ikkun
parents: 176
diff changeset
214 struct Main {
bb52f7f77bf5 add main
ikkun
parents: 176
diff changeset
215 enum Code code;
bb52f7f77bf5 add main
ikkun
parents: 176
diff changeset
216 enum Code next;
bb52f7f77bf5 add main
ikkun
parents: 176
diff changeset
217 struct Queue* args;
185
247a2c4a8908 fix compile errors
mir3636
parents: 184
diff changeset
218 } Main;
169
ea7b11f3e717 Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 168
diff changeset
219 // Queue Interface
90
4b5bf5b40970 put queue
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 87
diff changeset
220 struct Queue {
136
a747dc9d4da6 stack refactering no compile error
mir3636
parents: 135
diff changeset
221 union Data* queue;
167
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
222 union Data* data;
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
223 enum Code whenEmpty;
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
224 enum Code clear;
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
225 enum Code put;
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
226 enum Code take;
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
227 enum Code isEmpty;
130
2bb5e4f0fd35 Stackinterface
ikkun
parents: 124
diff changeset
228 enum Code next;
184
mir3636
parents: 183
diff changeset
229 } Queue;
167
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
230 struct SingleLinkedQueue {
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
231 struct Element* top;
34562e63981f create queue.c
mir3636
parents: 166
diff changeset
232 struct Element* last;
184
mir3636
parents: 183
diff changeset
233 } SingleLinkedQueue;
282
a3448b0f0a56 Add input data gear
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 278
diff changeset
234 struct SynchronizedQueue {
a3448b0f0a56 Add input data gear
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 278
diff changeset
235 struct Element* top;
a3448b0f0a56 Add input data gear
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 278
diff changeset
236 struct Element* last;
444
0c024ea61601 Using cas interface but occurred warning
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 441
diff changeset
237 struct Atomic* atomic;
282
a3448b0f0a56 Add input data gear
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 278
diff changeset
238 } SynchronizedQueue;
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
239 // Stack Interface
130
2bb5e4f0fd35 Stackinterface
ikkun
parents: 124
diff changeset
240 struct Stack {
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
241 union Data* stack;
130
2bb5e4f0fd35 Stackinterface
ikkun
parents: 124
diff changeset
242 union Data* data;
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
243 union Data* data1;
438
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
244 enum Code whenEmpty;
145
cc071cf1ba85 add stack clear interface
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 144
diff changeset
245 enum Code clear;
130
2bb5e4f0fd35 Stackinterface
ikkun
parents: 124
diff changeset
246 enum Code push;
2bb5e4f0fd35 Stackinterface
ikkun
parents: 124
diff changeset
247 enum Code pop;
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
248 enum Code pop2;
130
2bb5e4f0fd35 Stackinterface
ikkun
parents: 124
diff changeset
249 enum Code isEmpty;
134
2eccf4564efe fix stack call in rb_tree
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 133
diff changeset
250 enum Code get;
133
568730b1239e call stack interface in rb_tree
mir3636
parents: 132
diff changeset
251 enum Code get2;
130
2bb5e4f0fd35 Stackinterface
ikkun
parents: 124
diff changeset
252 enum Code next;
194
081607dcf893 create generate_stub.pl
mir3636
parents: 187
diff changeset
253 } Stack;
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
254 // Stack implementations
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
255 struct SingleLinkedStack {
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
256 struct Element* top;
194
081607dcf893 create generate_stub.pl
mir3636
parents: 187
diff changeset
257 } SingleLinkedStack;
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
258 struct ArrayStack {
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
259 int size;
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
260 int limit;
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
261 struct Element* array;
194
081607dcf893 create generate_stub.pl
mir3636
parents: 187
diff changeset
262 } ArrayStack;
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
263 // Stack implementation end
90
4b5bf5b40970 put queue
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 87
diff changeset
264 struct Element {
114
d05b9937aa95 Change element data from Task to Data
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 112
diff changeset
265 union Data* data;
90
4b5bf5b40970 put queue
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 87
diff changeset
266 struct Element* next;
194
081607dcf893 create generate_stub.pl
mir3636
parents: 187
diff changeset
267 } Element;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
268 struct Array {
438
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
269 int prefix;
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
270 Int* array;
194
081607dcf893 create generate_stub.pl
mir3636
parents: 187
diff changeset
271 } Array;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
272 struct Tree {
166
mir3636
parents: 153
diff changeset
273 union Data* tree;
mir3636
parents: 153
diff changeset
274 struct Node* node;
150
7164f59660d4 create .cbc
mir3636
parents: 149
diff changeset
275 enum Code put;
7164f59660d4 create .cbc
mir3636
parents: 149
diff changeset
276 enum Code get;
7164f59660d4 create .cbc
mir3636
parents: 149
diff changeset
277 enum Code remove;
171
747067fe46bd Fix selected Queue
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
278 enum Code clear;
150
7164f59660d4 create .cbc
mir3636
parents: 149
diff changeset
279 enum Code next;
166
mir3636
parents: 153
diff changeset
280 } Tree;
172
661b0b0d0399 replace Tree to RedBlackTree
ikkun
parents: 171
diff changeset
281 struct RedBlackTree {
150
7164f59660d4 create .cbc
mir3636
parents: 149
diff changeset
282 struct Node* root;
122
73a679a85c04 node stack rewrite
ikkun
parents: 119
diff changeset
283 struct Node* current; // reading node of original tree
138
04a2f486a30d insert works but is not balanced
kono
parents: 136
diff changeset
284 struct Node* previous; // parent of reading node of original tree
124
36ac17d37be4 Fix compile error but not work
one
parents: 122
diff changeset
285 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
286 struct Node* parent;
438
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
287 struct Node* grandparent;
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
288 struct Stack* nodeStack;
470
355f7f78e3cf remove error, RedBlackTree.cbc Deletion Code
ryokka
parents: 465
diff changeset
289 enum Code findNodeNext;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
290 int result;
172
661b0b0d0399 replace Tree to RedBlackTree
ikkun
parents: 171
diff changeset
291 } RedBlackTree;
147
f2275f5777f4 add treeRotate data
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 145
diff changeset
292 struct RotateTree {
f2275f5777f4 add treeRotate data
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 145
diff changeset
293 enum Code next;
172
661b0b0d0399 replace Tree to RedBlackTree
ikkun
parents: 171
diff changeset
294 struct RedBlackTree* traverse;
147
f2275f5777f4 add treeRotate data
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 145
diff changeset
295 struct Tree* tree;
217
c34e6aa10967 Fix DataGear access name
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 207
diff changeset
296 } RotateTree;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
297 struct Node {
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
298 int key; // comparable data segment
90
4b5bf5b40970 put queue
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents: 87
diff changeset
299 union Data* value;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
300 struct Node* left;
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
301 struct Node* right;
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
302 // need to balancing
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
303 enum Color {
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
304 Red,
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
305 Black,
454
77de0283ac92 Debug RedBlackTree.cbc.
ryokka
parents: 452
diff changeset
306 // Red eq 0,Black eq 1. enum name convert intager.
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
307 } color;
217
c34e6aa10967 Fix DataGear access name
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 207
diff changeset
308 } Node;
441
5a737c3df91c Add AtomicReference Implements of Atomic Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 438
diff changeset
309 struct Atomic {
5a737c3df91c Add AtomicReference Implements of Atomic Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 438
diff changeset
310 union Data* atomic;
444
0c024ea61601 Using cas interface but occurred warning
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 441
diff changeset
311 union Data** ptr;
0c024ea61601 Using cas interface but occurred warning
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 441
diff changeset
312 union Data* oldData;
0c024ea61601 Using cas interface but occurred warning
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 441
diff changeset
313 union Data* newData;
441
5a737c3df91c Add AtomicReference Implements of Atomic Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 438
diff changeset
314 enum Code checkAndSet;
5a737c3df91c Add AtomicReference Implements of Atomic Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 438
diff changeset
315 enum Code next;
5a737c3df91c Add AtomicReference Implements of Atomic Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 438
diff changeset
316 enum Code fail;
5a737c3df91c Add AtomicReference Implements of Atomic Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 438
diff changeset
317 } Atomic;
5a737c3df91c Add AtomicReference Implements of Atomic Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 438
diff changeset
318 struct AtomicReference {
5a737c3df91c Add AtomicReference Implements of Atomic Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 438
diff changeset
319 } AtomicReference;
286
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
320 struct Semaphore {
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
321 union Data* semaphore;
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
322 enum Code p;
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
323 enum Code v;
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
324 enum Code next;
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
325 } Semaphore;
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
326 struct SemaphoreImpl {
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
327 int value;
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
328 pthread_mutex_t mutex;
493
82f0c49750f1 Add codeGear for boundedBuffer example
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 492
diff changeset
329 struct Queue* waitThreadQueue;
286
fd470e090403 Add sempahore
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
330 } SemaphoreImpl;
86
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
331 struct Allocate {
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
332 enum Code next;
e06e1a9e569e create worker
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
diff changeset
333 long size;
217
c34e6aa10967 Fix DataGear access name
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 207
diff changeset
334 } Allocate;
326
f23f6d0aa4e9 Add examples/calc.cbc and build but not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 320
diff changeset
335 struct Integer {
f23f6d0aa4e9 Add examples/calc.cbc and build but not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 320
diff changeset
336 int value;
f23f6d0aa4e9 Add examples/calc.cbc and build but not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 320
diff changeset
337 } Integer;
404
c5cd9888bf2a Fix bitonicSort
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 402
diff changeset
338 struct SortArray {
c5cd9888bf2a Fix bitonicSort
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 402
diff changeset
339 struct Integer *array; //Array arrayじゃできない？
379
2744cb933ebc Fix compile error for bitonicSort but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 375
diff changeset
340 int loopCounter;
404
c5cd9888bf2a Fix bitonicSort
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 402
diff changeset
341 int block;
c5cd9888bf2a Fix bitonicSort
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 402
diff changeset
342 int first;
383
300c18700ca5 Add split to bitonicSort
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 381
diff changeset
343 int prefix;
374
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
344 } SortArray;
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
345 struct Iterator {
375
ad44fdb11433 Fix compile error but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 374
diff changeset
346 union Data* iterator;
ad44fdb11433 Fix compile error but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 374
diff changeset
347 struct Context* task;
410
85b0ddbf458e Fix CudaWorker
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 406
diff changeset
348 int numGPU;
374
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
349 enum Code exec;
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
350 enum Code barrier;
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
351 enum Code whenWait;
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
352 enum Code next;
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
353 } Iterator;
402
e958a409943c Change iterator implement from oneDim to multiDim
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 398
diff changeset
354 struct MultiDimIterator {
374
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
355 int x;
402
e958a409943c Change iterator implement from oneDim to multiDim
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 398
diff changeset
356 int y;
e958a409943c Change iterator implement from oneDim to multiDim
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 398
diff changeset
357 int z;
374
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
358 int count;
402
e958a409943c Change iterator implement from oneDim to multiDim
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 398
diff changeset
359 int counterX;
e958a409943c Change iterator implement from oneDim to multiDim
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 398
diff changeset
360 int counterY;
e958a409943c Change iterator implement from oneDim to multiDim
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 398
diff changeset
361 int counterZ;
e958a409943c Change iterator implement from oneDim to multiDim
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 398
diff changeset
362 } MultiDimIterator;
e958a409943c Change iterator implement from oneDim to multiDim
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 398
diff changeset
363 struct MultiDim {
e958a409943c Change iterator implement from oneDim to multiDim
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 398
diff changeset
364 int x;
e958a409943c Change iterator implement from oneDim to multiDim
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 398
diff changeset
365 int y;
e958a409943c Change iterator implement from oneDim to multiDim
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 398
diff changeset
366 int z;
e958a409943c Change iterator implement from oneDim to multiDim
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 398
diff changeset
367 } MultiDim;
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
368 struct Executor {
436
08a93fc2f0d3 Fix CudaExecutor but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 435
diff changeset
369 union Data* executor;
434
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
370 struct Context* task;
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
371 enum Code read;
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
372 enum Code exec;
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
373 enum Code write;
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
374 enum Code next;
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
375 } Executor;
b75badf42701 Define Executor to context
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 431
diff changeset
376 #ifdef USE_CUDAWorker
435
af0ec811b20e Add CUDAExecutor
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 434
diff changeset
377 struct CUDAExecutor {
436
08a93fc2f0d3 Fix CudaExecutor but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 435
diff changeset
378 CUdeviceptr** kernelParams;
08a93fc2f0d3 Fix CudaExecutor but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 435
diff changeset
379 struct CUDABuffer* buffer;
451
dcc42f3e7e97 Auto choice blockDim
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 450
diff changeset
380 int maxThreadPerBlock;
435
af0ec811b20e Add CUDAExecutor
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 434
diff changeset
381 } CUDAExecutor;
af0ec811b20e Add CUDAExecutor
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 434
diff changeset
382 struct CUDABuffer {
431
b3359544adbb Edit cudaExec but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 430
diff changeset
383 int inputLen;
b3359544adbb Edit cudaExec but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 430
diff changeset
384 int outputLen;
b3359544adbb Edit cudaExec but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 430
diff changeset
385 union Data** inputData;
b3359544adbb Edit cudaExec but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 430
diff changeset
386 union Data** outputData;
435
af0ec811b20e Add CUDAExecutor
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 434
diff changeset
387 } CUDABuffer;
438
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
388 CUdeviceptr CUdeviceptr;
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
389 #else
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
390 struct CUDAExecutor {
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
391 } CUDAExecutor;
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
392 struct CUDABuffer {
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
393 } CUDABuffer;
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
394 CUdeviceptr CUdeviceptr;
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
395 #endif
7679093bdd72 Work CUDAtwice
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 436
diff changeset
396 Int Int;
447
57132ef16009 Remove ALLOCATE_DATA_GEAR from par goto code gear arguments
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 444
diff changeset
397 struct Memory {
57132ef16009 Remove ALLOCATE_DATA_GEAR from par goto code gear arguments
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 444
diff changeset
398 union Data* adr;
57132ef16009 Remove ALLOCATE_DATA_GEAR from par goto code gear arguments
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 444
diff changeset
399 int length;
57132ef16009 Remove ALLOCATE_DATA_GEAR from par goto code gear arguments
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 444
diff changeset
400 union Data* body;
57132ef16009 Remove ALLOCATE_DATA_GEAR from par goto code gear arguments
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 444
diff changeset
401 int hash;
57132ef16009 Remove ALLOCATE_DATA_GEAR from par goto code gear arguments
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 444
diff changeset
402 } Memory;
494
d8b2036c6942 BoundedBuffer implments Buffer interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 493
diff changeset
403 struct Buffer {
d8b2036c6942 BoundedBuffer implments Buffer interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 493
diff changeset
404 union Data* buffer;
d8b2036c6942 BoundedBuffer implments Buffer interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 493
diff changeset
405 union Data* data;
d8b2036c6942 BoundedBuffer implments Buffer interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 493
diff changeset
406 enum Code put;
d8b2036c6942 BoundedBuffer implments Buffer interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 493
diff changeset
407 enum Code take;
d8b2036c6942 BoundedBuffer implments Buffer interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 493
diff changeset
408 enum Code next;
d8b2036c6942 BoundedBuffer implments Buffer interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 493
diff changeset
409 } Buffer;
493
82f0c49750f1 Add codeGear for boundedBuffer example
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 492
diff changeset
410 struct BoundedBuffer {
82f0c49750f1 Add codeGear for boundedBuffer example
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 492
diff changeset
411 struct Element* top;
82f0c49750f1 Add codeGear for boundedBuffer example
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 492
diff changeset
412 struct Element* last;
82f0c49750f1 Add codeGear for boundedBuffer example
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 492
diff changeset
413 struct Semaphore* fullCount;
82f0c49750f1 Add codeGear for boundedBuffer example
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 492
diff changeset
414 struct Semaphore* emptyCount;
82f0c49750f1 Add codeGear for boundedBuffer example
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 492
diff changeset
415 struct Semaphore* lock;
82f0c49750f1 Add codeGear for boundedBuffer example
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 492
diff changeset
416 } BoundedBuffer;
254
edb3aff688d0 fix generator CLI
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 244
diff changeset
417 }; // union Data end this is necessary for context generator
259
195518ab62fc fix type gathering pattern match in generate_stub.pl
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 254
diff changeset
418 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
419
186
dbc064c26b98 generate context script
mir3636
parents: 185
diff changeset
420 #include "c/typedefData.h"
278
23767f714f4a fix generate_stub
mir3636
parents: 259
diff changeset
421
23767f714f4a fix generate_stub
mir3636
parents: 259
diff changeset
422 #include "c/extern.h"
23767f714f4a fix generate_stub
mir3636
parents: 259
diff changeset
423
23767f714f4a fix generate_stub
mir3636
parents: 259
diff changeset
424 extern __code start_code(struct Context* context);
23767f714f4a fix generate_stub
mir3636
parents: 259
diff changeset
425 extern __code exit_code(struct Context* context);
23767f714f4a fix generate_stub
mir3636
parents: 259
diff changeset
426 extern __code meta(struct Context* context, enum Code next);
398
fc4fcd441700 Fix spanwTasks
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 397
diff changeset
427 extern __code par_meta(struct Context* context, enum Code spawns, enum Code next);
278
23767f714f4a fix generate_stub
mir3636
parents: 259
diff changeset
428 extern void initContext(struct Context* context);
23767f714f4a fix generate_stub
mir3636
parents: 259
diff changeset
429
132
7c309e1aea73 Code Gears stack api
one
parents: 131
diff changeset
430 #endif