Mercurial > hg > Members > innparusu > Gears
annotate src/parallel_execution/main.c @ 116:69fbd905d750
Modify Create_Data
| author | Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp> |
|---|---|
| date | Tue, 12 Jul 2016 16:26:05 +0900 |
| parents | 135472238fb7 |
| children | c9ab10847fc3 |
| 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 |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
122 loopCounter->i = 0; |
| 116 | 123 goto meta(context, CreateTask1); |
|
115
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 |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
126 __code createData1_stub(struct Context* context) { |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
127 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
|
128 } |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
129 |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
130 __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
|
131 int i = loopCounter->i; |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
132 integer->value = i; |
| 116 | 133 integer->mDataOffset = -sizeof(struct Queue); |
|
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
134 node->key = i; |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
135 node->value = (union Data*)integer; |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
136 |
| 116 | 137 context->next = CreateData1; |
| 138 loopCounter->i++; | |
|
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
139 |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
140 goto meta(context, PutTree); |
|
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 |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
143 __code createData2_stub(struct Context* context) { |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
144 goto createData2(context, |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
145 &context->data[LoopCounter]->loopCounter, |
| 116 | 146 &context->data[context->dataNum]->integer, |
|
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
147 &context->data[Node]->node); |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
148 } |
| 90 | 149 |
| 150 __code createTask1(struct Context* context, struct Allocate* allocate) { | |
| 151 allocate->size = sizeof(struct Task); | |
| 152 allocator(context); | |
| 153 goto meta(context, CreateTask2); | |
| 154 } | |
| 155 | |
| 156 __code createTask1_stub(struct Context* context) { | |
| 157 goto createTask1(context, &context->data[Allocate]->allocate); | |
| 158 } | |
| 159 | |
| 116 | 160 /* |
| 161 __code createTask2(struct Context* context, struct LoopCounter* loopCounter, struct Task* task, struct Element* element) { | |
| 162 int i = loopCounter->i; | |
| 163 | |
| 164 task->code = Twice; | |
| 165 task->key = i; | |
| 166 | |
| 167 element->data = (union Data *)task; | |
| 168 | |
| 169 context->next = CreateData1; | |
| 170 loopCounter->i++; | |
| 171 | |
| 172 goto meta(context, SpawnTask); | |
| 173 } | |
| 174 | |
| 175 __code createTask2_stub(struct Context* context) { | |
| 176 goto createTask2(context, | |
| 177 &context->data[LoopCounter]->loopCounter, | |
| 178 &context->data[context->dataNum]->task, | |
| 179 &context->data[Element]->element); | |
| 180 } | |
| 181 */ | |
| 182 | |
| 183 | |
|
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
184 __code createTask2(struct Context* context, struct LoopCounter* loopCounter, struct Task* task, struct Element* element, struct Queue* activeQueue) { |
| 90 | 185 int i = loopCounter->i; |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
186 |
| 116 | 187 task->code = TaskB; |
| 90 | 188 task->key = i; |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
189 |
|
113
d05b9937aa95
Change element data from Task to Data
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
112
diff
changeset
|
190 element->data = (union Data *)task; |
| 90 | 191 |
| 192 context->next = CreateData1; | |
| 193 loopCounter->i++; | |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
194 |
| 112 | 195 goto meta(context, SpawnTask); |
| 90 | 196 } |
| 197 | |
|
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
198 __code createTask2_stub(struct Context* context) { |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
199 goto createTask2(context, |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
200 &context->data[LoopCounter]->loopCounter, |
|
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
201 &context->data[context->dataNum]->task, |
| 116 | 202 &context->data[Element]->element); |
| 90 | 203 } |
| 204 | |
| 116 | 205 __code createTask3(struct Context* context, struct LoopCounter* loopCounter, struct Task* task, struct Task* slave, struct Element* element) { |
| 206 int i = loopCounter->i; | |
|
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
207 |
| 116 | 208 task->code = TaskA; |
| 209 task->key = i; | |
| 210 element->data = (union Data *)task; | |
|
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
211 |
| 116 | 212 context->next = CreateData1; |
| 213 loopCounter->i++; | |
|
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
214 |
| 116 | 215 goto meta(context, WaitFor1); |
| 216 } | |
|
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
217 |
| 116 | 218 __code createTask3_stub(struct Context* context) { |
| 219 goto createTask3(context, | |
| 220 &context->data[LoopCounter]->loopCounter, | |
| 221 &context->data[context->dataNum]->task, | |
| 222 &context->data[Element]->element); | |
| 223 } | |
| 111 | 224 |
| 90 | 225 __code putQueue1(struct Context* context, struct Allocate* allocate) { |
| 226 allocate->size = sizeof(struct Element); | |
| 227 allocator(context); | |
| 228 | |
| 229 goto meta(context, PutQueue2); | |
| 230 } | |
| 231 | |
| 232 __code putQueue1_stub(struct Context* context) { | |
| 233 goto putQueue1(context, &context->data[Allocate]->allocate); | |
| 234 } | |
| 235 | |
| 236 __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
|
237 new_element->data = element->data; |
| 90 | 238 |
| 239 if (queue->first) | |
| 240 goto meta(context, PutQueue3); | |
| 241 else | |
| 242 goto meta(context, PutQueue4); | |
| 243 } | |
| 244 | |
| 245 __code putQueue2_stub(struct Context* context) { | |
| 246 goto putQueue2(context, | |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
247 &context->data[context->dataNum]->element, |
|
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
248 &context->data[Element]->element, |
|
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
249 &context->data[Queue]->queue); |
| 90 | 250 } |
| 251 | |
| 252 __code putQueue3(struct Context* context, struct Queue* queue, struct Element* new_element) { | |
| 253 struct Element* last = queue->last; | |
| 254 | |
| 255 if (__sync_bool_compare_and_swap(&queue->last, last, new_element)) { | |
| 256 last->next = new_element; | |
| 257 queue->count++; | |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
258 |
| 90 | 259 goto meta(context, context->next); |
| 260 } else { | |
| 261 goto meta(context, PutQueue3); | |
| 262 } | |
| 263 } | |
| 264 | |
| 265 __code putQueue3_stub(struct Context* context) { | |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
266 goto putQueue3(context, &context->data[Queue]->queue, &context->data[context->dataNum]->element); |
| 90 | 267 } |
| 268 | |
| 269 __code putQueue4(struct Context* context, struct Queue* queue, struct Element* new_element) { | |
| 270 if (__sync_bool_compare_and_swap(&queue->first, 0, new_element)) { | |
| 271 queue->last = 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 putQueue4_stub(struct Context* context) { | |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
281 goto putQueue4(context, &context->data[Queue]->queue, &context->data[context->dataNum]->element); |
| 90 | 282 } |
| 283 | |
| 86 | 284 __code createWorker(struct Context* context, struct LoopCounter* loopCounter, struct Worker* worker) { |
| 285 int i = loopCounter->i; | |
| 286 | |
| 287 if (i < worker->num) { | |
| 288 struct Context* worker_context = &worker->contexts[i]; | |
| 91 | 289 worker_context->next = GetQueue; |
| 290 worker_context->data[Tree] = context->data[Tree]; | |
| 291 worker_context->data[ActiveQueue] = context->data[ActiveQueue]; | |
| 86 | 292 pthread_create(&worker_context->thread, NULL, (void*)&start_code, worker_context); |
| 92 | 293 worker_context->thread_num = i; |
| 86 | 294 loopCounter->i++; |
| 295 | |
| 296 goto meta(context, CreateWorker); | |
| 297 } | |
| 298 | |
| 299 loopCounter->i = 0; | |
| 300 goto meta(context, TaskManager); | |
| 301 } | |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
302 |
| 86 | 303 __code createWorker_stub(struct Context* context) { |
| 304 goto createWorker(context, &context->data[LoopCounter]->loopCounter, &context->data[Worker]->worker); | |
| 305 } | |
| 306 | |
| 307 __code taskManager(struct Context* context, struct LoopCounter* loopCounter, struct Worker* worker) { | |
| 308 int i = loopCounter->i; | |
| 309 | |
| 310 if (i < worker->num) { | |
| 311 pthread_join(worker->contexts[i].thread, NULL); | |
| 312 loopCounter->i++; | |
| 313 | |
| 314 goto meta(context, TaskManager); | |
| 315 } | |
| 316 | |
| 317 loopCounter->i = 0; | |
|
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
318 |
| 102 | 319 struct Time *t = &context->data[Time]->time; |
| 320 t->next = Code2; | |
|
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
321 goto meta(context, EndTime); |
| 86 | 322 } |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
323 |
| 86 | 324 __code taskManager_stub(struct Context* context) { |
| 325 goto taskManager(context, &context->data[LoopCounter]->loopCounter, &context->data[Worker]->worker); | |
| 326 } | |
| 327 | |
|
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
328 void init(int argc, char** argv) { |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
329 for (int i = 1; argv[i]; ++i) { |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
330 if (strcmp(argv[i], "-cpu") == 0) |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
331 cpu_num = (int)atoi(argv[i+1]); |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
332 else if (strcmp(argv[i], "-l") == 0) |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
333 length = (int)atoi(argv[i+1]); |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
334 else if (strcmp(argv[i], "-s") == 0) |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
335 split = (int)atoi(argv[i+1]); |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
336 } |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
337 } |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
338 |
|
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
339 |
| 86 | 340 int main(int argc, char** argv) { |
|
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
341 init(argc, argv); |
| 90 | 342 |
| 101 | 343 array_ptr = NEWN(length, int); |
| 90 | 344 |
| 345 for(int i=0; i<length; i++) | |
| 346 array_ptr[i]=i; | |
| 86 | 347 |
| 101 | 348 struct Context* main_context = NEW(struct Context); |
| 86 | 349 initContext(main_context); |
| 90 | 350 main_context->next = CreateData1; |
| 86 | 351 |
| 101 | 352 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
|
353 |
| 86 | 354 struct Worker* worker = &main_context->data[Worker]->worker; |
| 355 worker->num = cpu_num; | |
| 356 worker->contexts = worker_contexts; | |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
357 |
| 86 | 358 for (int i = 0;i<cpu_num;i++) |
| 359 initContext(&worker_contexts[i]); | |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
360 |
| 86 | 361 goto start_code(main_context); |
| 362 } |