Mercurial > hg > Members > innparusu > Gears
annotate src/parallel_execution/main.c @ 117:c9ab10847fc3
Define dependency Task create function
author | Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp> |
---|---|
date | Tue, 19 Jul 2016 02:18:31 +0900 |
parents | 69fbd905d750 |
children | 4df53a60e59a |
rev | line source |
---|---|
86 | 1 #include <stdio.h> |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
2 #include <string.h> |
86 | 3 |
4 #include "context.h" | |
5 #include "origin_cs.h" | |
6 | |
7 extern __code initContext(struct Context* context); | |
90 | 8 extern void allocator(struct Context* context); |
86 | 9 |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
10 int cpu_num = 1; |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
11 int length = 1024; |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
12 int split; |
90 | 13 int* array_ptr; |
14 | |
15 void print_queue(struct Element* element) { | |
16 while (element) { | |
113
d05b9937aa95
Change element data from Task to Data
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
112
diff
changeset
|
17 printf("%d\n", ((struct Task *)(element->data))->key); |
90 | 18 element = element->next; |
19 } | |
20 } | |
21 | |
22 void print_tree(struct Node* node) { | |
23 if (node != 0) { | |
24 printf("%d\n", node->value->array.index); | |
25 print_tree(node->left); | |
26 print_tree(node->right); | |
27 } | |
28 } | |
86 | 29 |
30 __code code1(struct Context* context) { | |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
31 printf("cpus:\t\t%d\n", cpu_num); |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
32 printf("length:\t\t%d\n", length); |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
33 printf("length/task:\t%d\n", length/split); |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
34 /* puts("queue"); */ |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
35 /* print_queue(context->data[ActiveQueue]->queue.first); */ |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
36 /* puts("tree"); */ |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
37 /* print_tree(context->data[Tree]->tree.root); */ |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
38 /* puts("result"); */ |
90 | 39 |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
40 context->next = CreateWorker; |
102 | 41 |
42 struct Time *t = &context->data[Time]->time; | |
43 t->next = CreateWorker; | |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
44 goto meta(context, StartTime); |
86 | 45 } |
46 | |
47 __code code1_stub(struct Context* context) { | |
48 goto code1(context); | |
49 } | |
50 | |
92 | 51 __code code2(struct Context* context, struct Array* array, struct LoopCounter* loopCounter) { |
52 int i = loopCounter->i; | |
111 | 53 |
92 | 54 if (i < length) { |
114 | 55 //printf("%d\n", array->array[i]); |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
56 if (array->array[i] == (i*2)) { |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
57 loopCounter->i++; |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
58 goto meta(context, Code2); |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
59 } else |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
60 puts("wrong result"); |
92 | 61 |
62 } | |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
63 |
92 | 64 goto meta(context, Exit); |
65 } | |
66 | |
67 __code code2_stub(struct Context* context) { | |
68 goto code2(context, &context->data[Node]->node.value->array, &context->data[LoopCounter]->loopCounter); | |
69 } | |
70 | |
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
71 /* |
90 | 72 __code createData1(struct Context* context, struct Allocate* allocate, struct LoopCounter* loopCounter) { |
73 int i = loopCounter->i; | |
74 | |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
75 if ((length/split*i) < length) { |
90 | 76 allocate->size = sizeof(struct Array); |
77 allocator(context); | |
78 goto meta(context, CreateData2); | |
79 } | |
80 | |
92 | 81 loopCounter->i = 0; |
90 | 82 goto meta(context, Code1); |
83 } | |
111 | 84 |
90 | 85 __code createData1_stub(struct Context* context) { |
86 goto createData1(context, &context->data[Allocate]->allocate, &context->data[LoopCounter]->loopCounter); | |
87 } | |
88 | |
89 __code createData2(struct Context* context, struct LoopCounter* loopCounter, struct Array* array, struct Node* node) { | |
90 int i = loopCounter->i; | |
91 | |
92 array->index = i; | |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
93 array->prefix = length/split; |
90 | 94 array->array = array_ptr; |
95 | |
96 node->key = i; | |
97 node->value = (union Data*)array; | |
111 | 98 |
90 | 99 context->next = CreateTask1; |
100 | |
101 goto meta(context, PutTree); | |
102 } | |
103 | |
104 __code createData2_stub(struct Context* context) { | |
105 goto createData2(context, | |
111 | 106 &context->data[LoopCounter]->loopCounter, |
107 &context->data[context->dataNum]->array, | |
108 &context->data[Node]->node); | |
116 | 109 } */ |
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
110 |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
111 __code createData1(struct Context* context, struct Allocate* allocate, struct LoopCounter* loopCounter) { |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
112 int i = loopCounter->i; |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
113 |
116 | 114 if (i < 4) { |
115 allocate->size = sizeof(struct Queue); | |
116 metaAllocator(context); | |
117 allocate->size = sizeof(struct Integer); | |
118 allocator(context); | |
119 goto meta(context, CreateData2); | |
120 } | |
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
121 |
116 | 122 goto meta(context, CreateTask1); |
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
123 } |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
124 |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
125 __code createData1_stub(struct Context* context) { |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
126 goto createData1(context, &context->data[Allocate]->allocate, &context->data[LoopCounter]->loopCounter); |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
127 } |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
128 |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
129 __code createData2(struct Context* context, struct LoopCounter* loopCounter, struct Integer* integer, struct Node* node) { |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
130 int i = loopCounter->i; |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
131 integer->value = i; |
116 | 132 integer->mDataOffset = -sizeof(struct Queue); |
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
133 node->key = i; |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
134 node->value = (union Data*)integer; |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
135 |
116 | 136 context->next = CreateData1; |
137 loopCounter->i++; | |
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
138 |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
139 goto meta(context, PutTree); |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
140 } |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
141 |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
142 __code createData2_stub(struct Context* context) { |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
143 goto createData2(context, |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
144 &context->data[LoopCounter]->loopCounter, |
116 | 145 &context->data[context->dataNum]->integer, |
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
146 &context->data[Node]->node); |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
147 } |
90 | 148 |
149 __code createTask1(struct Context* context, struct Allocate* allocate) { | |
150 allocate->size = sizeof(struct Task); | |
151 allocator(context); | |
152 goto meta(context, CreateTask2); | |
153 } | |
154 | |
155 __code createTask1_stub(struct Context* context) { | |
156 goto createTask1(context, &context->data[Allocate]->allocate); | |
157 } | |
158 | |
116 | 159 /* |
160 __code createTask2(struct Context* context, struct LoopCounter* loopCounter, struct Task* task, struct Element* element) { | |
161 int i = loopCounter->i; | |
162 | |
163 task->code = Twice; | |
164 task->key = i; | |
165 | |
166 element->data = (union Data *)task; | |
167 | |
168 context->next = CreateData1; | |
169 loopCounter->i++; | |
170 | |
171 goto meta(context, SpawnTask); | |
172 } | |
173 | |
174 __code createTask2_stub(struct Context* context) { | |
175 goto createTask2(context, | |
176 &context->data[LoopCounter]->loopCounter, | |
177 &context->data[context->dataNum]->task, | |
178 &context->data[Element]->element); | |
179 } | |
180 */ | |
181 | |
182 | |
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
183 __code createTask2(struct Context* context, struct LoopCounter* loopCounter, struct Task* task, struct Element* element, struct Queue* activeQueue) { |
90 | 184 int i = loopCounter->i; |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
185 |
117
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
186 task->code = Mult; |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
187 task->iKeys[0] = i-1; |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
188 task->iKeys[1] = i-2; |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
189 task->idsCount = 1; |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
190 loopCounter->i -= 2; |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
191 |
113
d05b9937aa95
Change element data from Task to Data
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
112
diff
changeset
|
192 element->data = (union Data *)task; |
90 | 193 |
117
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
194 context->next = CreateTask3; |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
195 |
112 | 196 goto meta(context, SpawnTask); |
90 | 197 } |
198 | |
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
199 __code createTask2_stub(struct Context* context) { |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
200 goto createTask2(context, |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
201 &context->data[LoopCounter]->loopCounter, |
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
202 &context->data[context->dataNum]->task, |
116 | 203 &context->data[Element]->element); |
90 | 204 } |
205 | |
117
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
206 __code createTask3(struct Context* context, struct Allocate* allocate) { |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
207 allocate->size = sizeof(struct Task); |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
208 allocator(context); |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
209 goto meta(context, CreateTask2); |
116 | 210 } |
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
211 |
116 | 212 __code createTask3_stub(struct Context* context) { |
117
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
213 goto createTask1(context, &context->data[Allocate]->allocate); |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
214 } |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
215 |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
216 |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
217 __code createTask4(struct Context* context, struct LoopCounter* loopCounter, struct Task* task, struct Element* element, struct Node* node) { |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
218 int i = loopCounter->i; |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
219 |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
220 task->code = Add; |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
221 task->oKeys[0] = i; |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
222 task->iKeys[0] = i-1; |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
223 task->iKeys[1] = i-2; |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
224 loopCounter->i -= 2; |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
225 element->data = (union Data *)task; |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
226 context->next = WaitFor1; |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
227 |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
228 node->key = okeys[0]; |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
229 goto meta(context, Get); |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
230 } |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
231 |
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
232 __code createTask4_stub(struct Context* context) { |
116 | 233 goto createTask3(context, |
234 &context->data[LoopCounter]->loopCounter, | |
235 &context->data[context->dataNum]->task, | |
117
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
236 &context->data[Node]->node, |
116 | 237 &context->data[Element]->element); |
238 } | |
111 | 239 |
90 | 240 __code putQueue1(struct Context* context, struct Allocate* allocate) { |
241 allocate->size = sizeof(struct Element); | |
242 allocator(context); | |
243 | |
244 goto meta(context, PutQueue2); | |
245 } | |
246 | |
247 __code putQueue1_stub(struct Context* context) { | |
248 goto putQueue1(context, &context->data[Allocate]->allocate); | |
249 } | |
250 | |
251 __code putQueue2(struct Context* context, struct Element* new_element, struct Element* element, struct Queue* queue) { | |
113
d05b9937aa95
Change element data from Task to Data
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
112
diff
changeset
|
252 new_element->data = element->data; |
90 | 253 |
254 if (queue->first) | |
255 goto meta(context, PutQueue3); | |
256 else | |
257 goto meta(context, PutQueue4); | |
258 } | |
259 | |
260 __code putQueue2_stub(struct Context* context) { | |
261 goto putQueue2(context, | |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
262 &context->data[context->dataNum]->element, |
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
263 &context->data[Element]->element, |
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
264 &context->data[Queue]->queue); |
90 | 265 } |
266 | |
267 __code putQueue3(struct Context* context, struct Queue* queue, struct Element* new_element) { | |
268 struct Element* last = queue->last; | |
269 | |
270 if (__sync_bool_compare_and_swap(&queue->last, last, new_element)) { | |
271 last->next = new_element; | |
272 queue->count++; | |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
273 |
90 | 274 goto meta(context, context->next); |
275 } else { | |
276 goto meta(context, PutQueue3); | |
277 } | |
278 } | |
279 | |
280 __code putQueue3_stub(struct Context* context) { | |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
281 goto putQueue3(context, &context->data[Queue]->queue, &context->data[context->dataNum]->element); |
90 | 282 } |
283 | |
284 __code putQueue4(struct Context* context, struct Queue* queue, struct Element* new_element) { | |
285 if (__sync_bool_compare_and_swap(&queue->first, 0, new_element)) { | |
286 queue->last = new_element; | |
287 queue->count++; | |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
288 |
90 | 289 goto meta(context, context->next); |
290 } else { | |
291 goto meta(context, PutQueue3); | |
292 } | |
293 } | |
294 | |
295 __code putQueue4_stub(struct Context* context) { | |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
296 goto putQueue4(context, &context->data[Queue]->queue, &context->data[context->dataNum]->element); |
90 | 297 } |
298 | |
86 | 299 __code createWorker(struct Context* context, struct LoopCounter* loopCounter, struct Worker* worker) { |
300 int i = loopCounter->i; | |
301 | |
302 if (i < worker->num) { | |
303 struct Context* worker_context = &worker->contexts[i]; | |
91 | 304 worker_context->next = GetQueue; |
305 worker_context->data[Tree] = context->data[Tree]; | |
306 worker_context->data[ActiveQueue] = context->data[ActiveQueue]; | |
86 | 307 pthread_create(&worker_context->thread, NULL, (void*)&start_code, worker_context); |
92 | 308 worker_context->thread_num = i; |
86 | 309 loopCounter->i++; |
310 | |
311 goto meta(context, CreateWorker); | |
312 } | |
313 | |
314 loopCounter->i = 0; | |
315 goto meta(context, TaskManager); | |
316 } | |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
317 |
86 | 318 __code createWorker_stub(struct Context* context) { |
319 goto createWorker(context, &context->data[LoopCounter]->loopCounter, &context->data[Worker]->worker); | |
320 } | |
321 | |
322 __code taskManager(struct Context* context, struct LoopCounter* loopCounter, struct Worker* worker) { | |
323 int i = loopCounter->i; | |
324 | |
325 if (i < worker->num) { | |
326 pthread_join(worker->contexts[i].thread, NULL); | |
327 loopCounter->i++; | |
328 | |
329 goto meta(context, TaskManager); | |
330 } | |
331 | |
332 loopCounter->i = 0; | |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
333 |
102 | 334 struct Time *t = &context->data[Time]->time; |
335 t->next = Code2; | |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
336 goto meta(context, EndTime); |
86 | 337 } |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
338 |
86 | 339 __code taskManager_stub(struct Context* context) { |
340 goto taskManager(context, &context->data[LoopCounter]->loopCounter, &context->data[Worker]->worker); | |
341 } | |
342 | |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
343 void init(int argc, char** argv) { |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
344 for (int i = 1; argv[i]; ++i) { |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
345 if (strcmp(argv[i], "-cpu") == 0) |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
346 cpu_num = (int)atoi(argv[i+1]); |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
347 else if (strcmp(argv[i], "-l") == 0) |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
348 length = (int)atoi(argv[i+1]); |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
349 else if (strcmp(argv[i], "-s") == 0) |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
350 split = (int)atoi(argv[i+1]); |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
351 } |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
352 } |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
353 |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
354 |
86 | 355 int main(int argc, char** argv) { |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
356 init(argc, argv); |
90 | 357 |
101 | 358 array_ptr = NEWN(length, int); |
90 | 359 |
360 for(int i=0; i<length; i++) | |
361 array_ptr[i]=i; | |
86 | 362 |
101 | 363 struct Context* main_context = NEW(struct Context); |
86 | 364 initContext(main_context); |
90 | 365 main_context->next = CreateData1; |
86 | 366 |
101 | 367 struct Context* worker_contexts = NEWN(cpu_num, struct Context); |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
368 |
86 | 369 struct Worker* worker = &main_context->data[Worker]->worker; |
370 worker->num = cpu_num; | |
371 worker->contexts = worker_contexts; | |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
372 |
86 | 373 for (int i = 0;i<cpu_num;i++) |
374 initContext(&worker_contexts[i]); | |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
375 |
86 | 376 goto start_code(main_context); |
377 } |