Mercurial > hg > Members > innparusu > Gears
annotate src/parallel_execution/main.c @ 125:77e60b6cdace
Work dependency example
| author | Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp> |
|---|---|
| date | Tue, 27 Sep 2016 17:22:00 +0900 |
| parents | acf0453b1c7a |
| children | 337fdbffa693 |
| 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); |
|
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
9 extern void metaAllocator(struct Context* context); |
| 86 | 10 |
|
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
11 int cpu_num = 1; |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
12 int length = 1024; |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
13 int split; |
| 90 | 14 int* array_ptr; |
| 15 | |
| 16 void print_queue(struct Element* element) { | |
| 17 while (element) { | |
|
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
18 //printf("%d\n", ((struct Task *)(element->data))->key); |
| 90 | 19 element = element->next; |
| 20 } | |
| 21 } | |
| 22 | |
| 23 void print_tree(struct Node* node) { | |
| 24 if (node != 0) { | |
| 25 printf("%d\n", node->value->array.index); | |
| 26 print_tree(node->left); | |
| 27 print_tree(node->right); | |
| 28 } | |
| 29 } | |
| 86 | 30 |
| 31 __code code1(struct Context* context) { | |
|
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
32 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
|
33 printf("length:\t\t%d\n", length); |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
34 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
|
35 /* puts("queue"); */ |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
36 /* print_queue(context->data[ActiveQueue]->queue.first); */ |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
37 /* puts("tree"); */ |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
38 /* print_tree(context->data[Tree]->tree.root); */ |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
39 /* puts("result"); */ |
| 90 | 40 |
|
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
41 context->next = CreateWorker; |
| 102 | 42 |
| 43 struct Time *t = &context->data[Time]->time; | |
| 44 t->next = CreateWorker; | |
|
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
45 goto meta(context, StartTime); |
| 86 | 46 } |
| 47 | |
| 48 __code code1_stub(struct Context* context) { | |
| 49 goto code1(context); | |
| 50 } | |
| 51 | |
| 92 | 52 __code code2(struct Context* context, struct Array* array, struct LoopCounter* loopCounter) { |
| 53 int i = loopCounter->i; | |
| 111 | 54 |
|
124
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
55 //if (i < length) { |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
56 // //printf("%d\n", array->array[i]); |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
57 // if (array->array[i] == (i*2)) { |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
58 // loopCounter->i++; |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
59 // goto meta(context, Code2); |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
60 // } else |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
61 // puts("wrong result"); |
| 92 | 62 |
|
124
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
63 //} |
|
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
64 |
| 92 | 65 goto meta(context, Exit); |
| 66 } | |
| 67 | |
| 68 __code code2_stub(struct Context* context) { | |
| 69 goto code2(context, &context->data[Node]->node.value->array, &context->data[LoopCounter]->loopCounter); | |
| 70 } | |
| 71 | |
|
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
72 /* |
| 90 | 73 __code createData1(struct Context* context, struct Allocate* allocate, struct LoopCounter* loopCounter) { |
| 74 int i = loopCounter->i; | |
| 75 | |
|
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
76 if ((length/split*i) < length) { |
| 90 | 77 allocate->size = sizeof(struct Array); |
| 78 allocator(context); | |
| 79 goto meta(context, CreateData2); | |
| 80 } | |
| 81 | |
| 92 | 82 loopCounter->i = 0; |
| 90 | 83 goto meta(context, Code1); |
| 84 } | |
| 111 | 85 |
| 90 | 86 __code createData1_stub(struct Context* context) { |
| 87 goto createData1(context, &context->data[Allocate]->allocate, &context->data[LoopCounter]->loopCounter); | |
| 88 } | |
| 89 | |
| 90 __code createData2(struct Context* context, struct LoopCounter* loopCounter, struct Array* array, struct Node* node) { | |
| 91 int i = loopCounter->i; | |
| 92 | |
| 93 array->index = i; | |
|
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
94 array->prefix = length/split; |
| 90 | 95 array->array = array_ptr; |
| 96 | |
| 97 node->key = i; | |
| 98 node->value = (union Data*)array; | |
| 111 | 99 |
| 90 | 100 context->next = CreateTask1; |
| 101 | |
| 102 goto meta(context, PutTree); | |
| 103 } | |
| 104 | |
| 105 __code createData2_stub(struct Context* context) { | |
| 106 goto createData2(context, | |
| 111 | 107 &context->data[LoopCounter]->loopCounter, |
| 108 &context->data[context->dataNum]->array, | |
| 109 &context->data[Node]->node); | |
| 116 | 110 } */ |
|
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
111 |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
112 __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
|
113 int i = loopCounter->i; |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
114 |
| 116 | 115 if (i < 4) { |
| 116 allocate->size = sizeof(struct Queue); | |
| 117 metaAllocator(context); | |
| 118 allocate->size = sizeof(struct Integer); | |
| 119 allocator(context); | |
| 120 goto meta(context, CreateData2); | |
| 121 } | |
|
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
122 |
| 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 | |
|
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
184 __code createTask2(struct Context* context, struct LoopCounter* loopCounter, struct Task* task, struct Element* element) { |
| 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 |
|
117
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
187 task->code = Mult; |
|
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
188 task->iKeys[0] = i-1; |
|
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
189 task->iKeys[1] = i-2; |
|
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
190 task->idsCount = 1; |
|
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
191 loopCounter->i -= 2; |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
192 |
|
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
193 element->data = (union Data*)task; |
| 90 | 194 |
|
117
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
195 context->next = CreateTask3; |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
196 |
| 112 | 197 goto meta(context, SpawnTask); |
| 90 | 198 } |
| 199 | |
|
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
200 __code createTask2_stub(struct Context* context) { |
|
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
201 goto createTask2(context, |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
202 &context->data[LoopCounter]->loopCounter, |
|
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
203 &context->data[context->dataNum]->task, |
| 116 | 204 &context->data[Element]->element); |
| 90 | 205 } |
| 206 | |
|
117
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
207 __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
|
208 allocate->size = sizeof(struct Task); |
|
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
209 allocator(context); |
|
123
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
210 goto meta(context, CreateTask4); |
| 116 | 211 } |
|
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
114
diff
changeset
|
212 |
| 116 | 213 __code createTask3_stub(struct Context* context) { |
|
123
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
214 goto createTask3(context, &context->data[Allocate]->allocate); |
|
117
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 |
|
124
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
218 __code createTask4(struct Context* context, struct LoopCounter* loopCounter, struct Task* task, struct Node* node) { |
|
117
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
219 int i = loopCounter->i; |
|
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
220 |
|
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
221 task->code = Add; |
|
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
222 task->oKeys[0] = i; |
|
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
223 task->iKeys[0] = i-1; |
|
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
224 task->iKeys[1] = i-2; |
|
124
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
225 task->idsCount = 0; |
|
117
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
226 loopCounter->i -= 2; |
|
123
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
227 context->next = CreateTask5; |
|
124
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
228 |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
229 node->key = task->oKeys[0]; |
|
117
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
230 goto meta(context, Get); |
|
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 |
|
c9ab10847fc3
Define dependency Task create function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
116
diff
changeset
|
233 __code createTask4_stub(struct Context* context) { |
|
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
234 goto createTask4(context, |
| 116 | 235 &context->data[LoopCounter]->loopCounter, |
| 236 &context->data[context->dataNum]->task, | |
|
124
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
237 &context->data[Node]->node |
|
123
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
238 ); |
|
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
239 } |
|
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
240 |
|
124
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
241 __code createTask5(struct Context* context, struct Task* task) { |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
242 context->next = CreateTask6; |
|
123
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
243 goto meta(context, WaitFor); |
|
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
244 } |
|
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
245 |
|
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
246 __code createTask5_stub(struct Context* context) { |
|
124
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
247 goto createTask5(context, |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
248 &context->data[context->dataNum]->task |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
249 ); |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
250 } |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
251 |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
252 __code createTask6(struct Context* context, struct LoopCounter* loopCounter, struct Task* task, struct Element* element) { |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
253 element->data = (union Data *)task; |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
254 loopCounter->i = 0; |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
255 context->next = Code1; |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
256 goto meta(context, SpawnTask); |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
257 } |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
258 |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
259 __code createTask6_stub(struct Context* context) { |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
260 goto createTask6(context, |
|
123
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
261 &context->data[LoopCounter]->loopCounter, |
|
124
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
262 &context->data[context->dataNum-1]->task, |
|
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
263 &context->data[Element]->element |
|
123
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
264 ); |
| 116 | 265 } |
| 111 | 266 |
| 90 | 267 __code putQueue1(struct Context* context, struct Allocate* allocate) { |
| 268 allocate->size = sizeof(struct Element); | |
| 269 allocator(context); | |
| 270 | |
| 271 goto meta(context, PutQueue2); | |
| 272 } | |
| 273 | |
| 274 __code putQueue1_stub(struct Context* context) { | |
| 275 goto putQueue1(context, &context->data[Allocate]->allocate); | |
| 276 } | |
| 277 | |
| 278 __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
|
279 new_element->data = element->data; |
| 90 | 280 |
| 281 if (queue->first) | |
| 282 goto meta(context, PutQueue3); | |
| 283 else | |
| 284 goto meta(context, PutQueue4); | |
| 285 } | |
| 286 | |
| 287 __code putQueue2_stub(struct Context* context) { | |
| 288 goto putQueue2(context, | |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
289 &context->data[context->dataNum]->element, |
|
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
290 &context->data[Element]->element, |
|
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
291 &context->data[Queue]->queue); |
| 90 | 292 } |
| 293 | |
| 294 __code putQueue3(struct Context* context, struct Queue* queue, struct Element* new_element) { | |
| 295 struct Element* last = queue->last; | |
| 296 | |
| 297 if (__sync_bool_compare_and_swap(&queue->last, last, new_element)) { | |
| 298 last->next = new_element; | |
| 299 queue->count++; | |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
300 |
| 90 | 301 goto meta(context, context->next); |
| 302 } else { | |
| 303 goto meta(context, PutQueue3); | |
| 304 } | |
| 305 } | |
| 306 | |
| 307 __code putQueue3_stub(struct Context* context) { | |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
308 goto putQueue3(context, &context->data[Queue]->queue, &context->data[context->dataNum]->element); |
| 90 | 309 } |
| 310 | |
| 311 __code putQueue4(struct Context* context, struct Queue* queue, struct Element* new_element) { | |
| 312 if (__sync_bool_compare_and_swap(&queue->first, 0, new_element)) { | |
| 313 queue->last = new_element; | |
| 314 queue->count++; | |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
315 |
| 90 | 316 goto meta(context, context->next); |
| 317 } else { | |
| 318 goto meta(context, PutQueue3); | |
| 319 } | |
| 320 } | |
| 321 | |
| 322 __code putQueue4_stub(struct Context* context) { | |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
323 goto putQueue4(context, &context->data[Queue]->queue, &context->data[context->dataNum]->element); |
| 90 | 324 } |
| 325 | |
| 86 | 326 __code createWorker(struct Context* context, struct LoopCounter* loopCounter, struct Worker* worker) { |
| 327 int i = loopCounter->i; | |
| 328 | |
| 329 if (i < worker->num) { | |
| 330 struct Context* worker_context = &worker->contexts[i]; | |
|
125
77e60b6cdace
Work dependency example
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
124
diff
changeset
|
331 worker_context->next = GetTask; |
| 91 | 332 worker_context->data[Tree] = context->data[Tree]; |
| 333 worker_context->data[ActiveQueue] = context->data[ActiveQueue]; | |
|
119
4df53a60e59a
Add dependency function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
334 worker_context->data[WaitQueue] = context->data[WaitQueue]; |
|
4df53a60e59a
Add dependency function
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
117
diff
changeset
|
335 worker_context->data[Queue] = context->data[ActiveQueue]; |
|
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
336 pthread_create(&worker_context->thread, NULL, (void*)&start_code, worker_context); |
| 92 | 337 worker_context->thread_num = i; |
| 86 | 338 loopCounter->i++; |
| 339 | |
| 340 goto meta(context, CreateWorker); | |
| 341 } | |
| 342 | |
| 343 loopCounter->i = 0; | |
| 344 goto meta(context, TaskManager); | |
| 345 } | |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
346 |
| 86 | 347 __code createWorker_stub(struct Context* context) { |
| 348 goto createWorker(context, &context->data[LoopCounter]->loopCounter, &context->data[Worker]->worker); | |
| 349 } | |
| 350 | |
|
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
351 __code taskManager(struct Context* context, struct LoopCounter* loopCounter, struct Worker* worker, struct Queue* waitQueue, struct Queue* ActiveQueue) { |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
352 if (waitQueue->first) { |
|
123
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
353 goto meta(context, Poll1); |
|
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
354 } |
| 86 | 355 int i = loopCounter->i; |
| 356 if (i < worker->num) { | |
| 357 pthread_join(worker->contexts[i].thread, NULL); | |
| 358 loopCounter->i++; | |
| 359 | |
| 360 goto meta(context, TaskManager); | |
| 361 } | |
| 362 loopCounter->i = 0; | |
| 102 | 363 struct Time *t = &context->data[Time]->time; |
| 364 t->next = Code2; | |
|
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
365 goto meta(context, EndTime); |
| 86 | 366 } |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
367 |
| 86 | 368 __code taskManager_stub(struct Context* context) { |
|
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
369 goto taskManager(context, |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
370 &context->data[LoopCounter]->loopCounter, |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
371 &context->data[Worker]->worker, |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
372 &context->data[WaitQueue]->queue, |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
373 &context->data[ActiveQueue]->queue); |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
374 } |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
375 |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
376 __code meta_poll1(struct Context* context, struct Queue* queue, enum Code next) { |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
377 context->data[Queue] = (union Data *)queue; |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
378 goto (context->code[next])(context); |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
379 } |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
380 |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
381 __code poll1(struct Context* context, struct Queue* waitQueue) { |
|
123
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
382 usleep(100); |
|
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
383 context->next = Poll2; |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
384 goto meta_poll1(context, waitQueue, GetQueue1); |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
385 } |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
386 |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
387 __code poll1_stub(struct Context* context) { |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
388 goto poll1(context, |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
389 &context->data[WaitQueue]->queue); |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
390 } |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
391 |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
392 __code poll2(struct Context* context) { |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
393 context->next = TaskManager; |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
394 goto meta(context, SpawnTask); |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
395 } |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
396 |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
397 __code poll2_stub(struct Context* context) { |
|
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
121
diff
changeset
|
398 goto poll2(context); |
| 86 | 399 } |
| 400 | |
|
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
401 void init(int argc, char** argv) { |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
402 for (int i = 1; argv[i]; ++i) { |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
403 if (strcmp(argv[i], "-cpu") == 0) |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
404 cpu_num = (int)atoi(argv[i+1]); |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
405 else if (strcmp(argv[i], "-l") == 0) |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
406 length = (int)atoi(argv[i+1]); |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
407 else if (strcmp(argv[i], "-s") == 0) |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
408 split = (int)atoi(argv[i+1]); |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
409 } |
|
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
410 } |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
411 |
|
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
412 |
| 86 | 413 int main(int argc, char** argv) { |
|
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
414 init(argc, argv); |
| 90 | 415 |
| 101 | 416 array_ptr = NEWN(length, int); |
| 90 | 417 |
| 418 for(int i=0; i<length; i++) | |
| 419 array_ptr[i]=i; | |
| 86 | 420 |
| 101 | 421 struct Context* main_context = NEW(struct Context); |
| 86 | 422 initContext(main_context); |
| 90 | 423 main_context->next = CreateData1; |
| 86 | 424 |
| 101 | 425 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
|
426 |
| 86 | 427 struct Worker* worker = &main_context->data[Worker]->worker; |
| 428 worker->num = cpu_num; | |
| 429 worker->contexts = worker_contexts; | |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
430 |
| 86 | 431 for (int i = 0;i<cpu_num;i++) |
| 432 initContext(&worker_contexts[i]); | |
|
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
102
diff
changeset
|
433 |
| 86 | 434 goto start_code(main_context); |
| 435 } |