Mercurial > hg > Members > innparusu > Gears
annotate src/parallel_execution/context.h @ 122:a086857e1812
implement dependency example. do not work
author | Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp> |
---|---|
date | Thu, 25 Aug 2016 03:23:29 +0900 |
parents | c9ab10847fc3 |
children | 4ff6f093b695 |
rev | line source |
---|---|
86 | 1 /* Context definition for llrb example */ |
2 #include <pthread.h> | |
101 | 3 #ifdef USE_CUDA |
98 | 4 #include <cuda.h> |
101 | 5 #endif |
86 | 6 #include "stack.h" |
7 | |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
8 #define ALLOCATE_SIZE 20000000 |
101 | 9 #define NEW(type) (type*)(calloc(1, sizeof(type))) |
10 #define NEWN(n, type) (type*)(calloc(n, sizeof(type))) | |
11 | |
12 #define ALLOC_DATA(context, dseg) ({ context->data[dseg] = context->heap; context->heap += sizeof(struct dseg); (struct dseg *)context->data[dseg]; }) | |
13 | |
14 #define ALLOC_DATA_TYPE(context, dseg, type) ({ context->data[dseg] = context->heap; context->heap += sizeof(struct type); (struct type *)context->data[dseg]; }) | |
86 | 15 |
16 enum Code { | |
17 Code1, | |
18 Code2, | |
19 Code3, | |
20 Code4, | |
21 Code5, | |
22 Find, | |
23 Not_find, | |
24 Code6, | |
25 Allocator, | |
90 | 26 PutTree, |
86 | 27 Replace, |
28 Insert, | |
29 Compare, | |
30 RotateL, | |
31 RotateR, | |
32 SetTree, | |
33 InsertCase1, | |
34 InsertCase2, | |
35 InsertCase3, | |
36 InsertCase4, | |
37 InsertCase4_1, | |
38 InsertCase4_2, | |
39 InsertCase5, | |
40 StackClear, | |
41 Get, | |
42 Search, | |
43 Delete, | |
44 Delete1, | |
45 Delete2, | |
46 Delete3, | |
47 Replace_d1, | |
48 Replace_d2, | |
49 FindMax1, | |
50 FindMax2, | |
51 DeleteCase1, | |
52 DeleteCase2, | |
53 DeleteCase3, | |
54 DeleteCase4, | |
55 DeleteCase5, | |
56 DeleteCase6, | |
57 CreateWorker, | |
58 TaskManager, | |
90 | 59 CreateData1, |
60 CreateData2, | |
61 CreateTask1, | |
62 CreateTask2, | |
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
63 CreateTask3, |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
64 CreateTask4, |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
65 Poll1, |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
66 Poll2, |
90 | 67 PutQueue1, |
68 PutQueue2, | |
69 PutQueue3, | |
70 PutQueue4, | |
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
71 InitWorker, |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
72 GetQueue1, |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
73 GetInputData1, |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
74 GetInputData2, |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
75 GetOutputData1, |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
76 GetOutputData2, |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
77 WaitFor, |
112 | 78 SpawnTask, |
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
79 CheckTaskFinish1, |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
80 CheckTaskFinish2, |
92 | 81 Twice, |
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
82 Add, |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
83 Mult, |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
84 StartTime, |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
85 EndTime, |
86 | 86 Exit, |
87 }; | |
88 | |
89 enum Relational { | |
90 EQ, | |
91 GT, | |
92 LT, | |
93 }; | |
94 | |
95 enum UniqueData { | |
96 Worker, | |
97 Allocate, | |
98 Tree, | |
91 | 99 Traverse, |
86 | 100 Node, |
101 LoopCounter, | |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
102 Time, |
90 | 103 Element, |
87 | 104 ActiveQueue, |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
104
diff
changeset
|
105 WaitQueue, |
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
104
diff
changeset
|
106 Queue, |
86 | 107 }; |
108 | |
109 struct Context { | |
110 enum Code next; | |
111 int codeNum; | |
112 __code (**code) (struct Context*); | |
113 void* heapStart; | |
114 void* heap; | |
115 long heapLimit; | |
116 pthread_t thread; | |
92 | 117 int thread_num; |
86 | 118 stack_ptr code_stack; |
119 stack_ptr node_stack; | |
87 | 120 int dataNum; |
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
113
diff
changeset
|
121 int metaDataNum; |
86 | 122 union Data **data; |
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
113
diff
changeset
|
123 union MetaData **mData; |
86 | 124 }; |
125 | |
126 union Data { | |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
127 struct Time { |
102 | 128 enum Code next; |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
129 double time; |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
130 } time; |
86 | 131 struct LoopCounter { |
132 int i; | |
133 } loopCounter; | |
134 struct Worker { | |
135 int num; | |
136 struct Context* contexts; | |
137 } worker; | |
101 | 138 #ifdef USE_CUDA |
98 | 139 struct CudaTask { |
140 CUdevice device; | |
141 CUcontext cuCtx; | |
142 CUfunction code; | |
143 CUdeviceptr* deviceptr; | |
144 CUstream stream; | |
145 } cudatask; | |
101 | 146 #endif |
90 | 147 struct Task { |
148 enum Code code; | |
117
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
149 int iKeys[2]; |
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
150 int oKeys[1]; |
117
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
151 int idsCount; |
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
152 union Data* iargs[2]; |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
153 union Data* oargs[1]; |
90 | 154 } task; |
155 struct Queue { | |
156 struct Element* first; | |
157 struct Element* last; | |
158 int count; | |
159 } queue; | |
160 struct Element { | |
113
d05b9937aa95
Change element data from Task to Data
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
112
diff
changeset
|
161 union Data* data; |
90 | 162 struct Element* next; |
163 } element; | |
86 | 164 struct Array { |
90 | 165 int index; |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
166 int prefix; |
86 | 167 int* array; |
168 } array; | |
169 struct Tree { | |
170 struct Node* root; | |
91 | 171 } tree; |
172 struct Traverse { | |
103 | 173 enum Code next; |
86 | 174 struct Node* current; |
175 int result; | |
91 | 176 } traverse; |
86 | 177 struct Node { |
178 // need to tree | |
179 enum Code next; | |
180 int key; // comparable data segment | |
90 | 181 union Data* value; |
86 | 182 struct Node* left; |
183 struct Node* right; | |
184 // need to balancing | |
185 enum Color { | |
186 Red, | |
187 Black, | |
188 } color; | |
189 } node; | |
190 struct Allocate { | |
191 enum Code next; | |
192 long size; | |
193 } allocate; | |
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
113
diff
changeset
|
194 struct Integer { |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
113
diff
changeset
|
195 int value; |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
113
diff
changeset
|
196 int mDataOffset; |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
113
diff
changeset
|
197 } integer; |
86 | 198 }; |
113
d05b9937aa95
Change element data from Task to Data
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
112
diff
changeset
|
199 |
d05b9937aa95
Change element data from Task to Data
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
112
diff
changeset
|
200 union MetaData { |
d05b9937aa95
Change element data from Task to Data
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
112
diff
changeset
|
201 struct Queue waitMeTasks; |
d05b9937aa95
Change element data from Task to Data
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
112
diff
changeset
|
202 }; |
d05b9937aa95
Change element data from Task to Data
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
112
diff
changeset
|
203 |