Mercurial > hg > Members > innparusu > Gears
annotate src/parallel_execution/context.c @ 138:337fdbffa693 default tip
Merge
author | Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp> |
---|---|
date | Sat, 01 Oct 2016 00:23:35 +0900 |
parents | 36ac17d37be4 77e60b6cdace |
children |
rev | line source |
---|---|
86 | 1 #include <stdlib.h> |
2 | |
3 #include "context.h" | |
4 | |
5 extern __code code1_stub(struct Context*); | |
6 extern __code code2_stub(struct Context*); | |
7 extern __code code3_stub(struct Context*); | |
8 extern __code code4(struct Context*); | |
9 extern __code code5(struct Context*); | |
10 extern __code find(struct Context*); | |
11 extern __code not_find(struct Context*); | |
12 extern __code code6(struct Context*); | |
13 extern __code meta(struct Context*); | |
14 extern __code put_stub(struct Context*); | |
15 extern __code replaceNode_stub(struct Context*); | |
134 | 16 extern __code replaceNode1_stub(struct Context*); |
86 | 17 extern __code insertNode_stub(struct Context*); |
18 extern __code rotateLeft_stub(struct Context*); | |
19 extern __code rotateRight_stub(struct Context*); | |
20 extern __code colorFlip_stub(struct Context*); | |
21 extern __code fixUp_stub(struct Context*); | |
22 extern __code changeReference_stub(struct Context*); | |
23 extern __code insert1_stub(struct Context*); | |
24 extern __code insert2_stub(struct Context*); | |
25 extern __code insert3_stub(struct Context*); | |
134 | 26 extern __code insert31_stub(struct Context*); |
86 | 27 extern __code insert4_stub(struct Context*); |
134 | 28 extern __code insert4_01_stub(struct Context*); |
29 extern __code insert4_02_stub(struct Context*); | |
86 | 30 extern __code insert4_1_stub(struct Context*); |
31 extern __code insert4_2_stub(struct Context*); | |
32 extern __code insert5_stub(struct Context*); | |
33 extern __code stackClear_stub(struct Context*); | |
34 extern __code get_stub(struct Context*); | |
35 extern __code search_stub(struct Context*); | |
36 extern __code delete_stub(struct Context*); | |
37 extern __code delete1_stub(struct Context*); | |
38 extern __code delete2_stub(struct Context*); | |
39 extern __code delete3_stub(struct Context*); | |
40 extern __code replaceNodeForDelete1_stub(struct Context*); | |
41 extern __code replaceNodeForDelete2_stub(struct Context*); | |
42 extern __code findMax1_stub(struct Context*); | |
43 extern __code findMax2_stub(struct Context*); | |
44 extern __code deleteCase1_stub(struct Context*); | |
45 extern __code deleteCase2_stub(struct Context*); | |
46 extern __code deleteCase3_stub(struct Context*); | |
47 extern __code deleteCase4_stub(struct Context*); | |
48 extern __code deleteCase5_stub(struct Context*); | |
49 extern __code deleteCase6_stub(struct Context*); | |
50 extern __code createWorker_stub(struct Context*); | |
51 extern __code taskManager_stub(struct Context*); | |
90 | 52 extern __code createData1_stub(struct Context*); |
53 extern __code createData2_stub(struct Context*); | |
54 extern __code createTask1_stub(struct Context*); | |
55 extern __code createTask2_stub(struct Context*); | |
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
56 extern __code createTask3_stub(struct Context*); |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
57 extern __code createTask4_stub(struct Context*); |
123
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
58 extern __code createTask5_stub(struct Context*); |
124
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
59 extern __code createTask6_stub(struct Context*); |
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
60 extern __code poll1_stub(struct Context*); |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
61 extern __code poll2_stub(struct Context*); |
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
113
diff
changeset
|
62 /* extern __code createTask3_stub(struct Context*); */ |
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
113
diff
changeset
|
63 /* extern __code createTask4_stub(struct Context*); */ |
90 | 64 extern __code putQueue1_stub(struct Context*); |
65 extern __code putQueue2_stub(struct Context*); | |
66 extern __code putQueue3_stub(struct Context*); | |
67 extern __code putQueue4_stub(struct Context*); | |
125
77e60b6cdace
Work dependency example
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
124
diff
changeset
|
68 extern __code getTask_stub(struct Context*); |
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
69 extern __code getQueue1_stub(struct Context*); |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
70 extern __code getInputData1_stub(struct Context*); |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
71 extern __code getInputData2_stub(struct Context*); |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
72 extern __code getOutputData1_stub(struct Context*); |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
73 extern __code getOutputData2_stub(struct Context*); |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
74 extern __code waitFor_stub(struct Context*); |
112 | 75 extern __code spawnTask_stub(struct Context*); |
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
76 extern __code checkTaskFinish1_stub(struct Context*); |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
77 extern __code checkTaskFinish2_stub(struct Context*); |
92 | 78 extern __code twice_stub(struct Context*); |
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
79 extern __code add_stub(struct Context*); |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
80 extern __code mult_stub(struct Context*); |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
81 extern __code start_time_stub(struct Context*); |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
82 extern __code end_time_stub(struct Context*); |
86 | 83 extern __code exit_code(struct Context*); |
84 | |
85 __code initContext(struct Context* context) { | |
86 context->heapLimit = sizeof(union Data)*ALLOCATE_SIZE; | |
101 | 87 context->code = (__code(**) (struct Context*)) NEWN(ALLOCATE_SIZE, void*); |
88 context->data = NEWN(ALLOCATE_SIZE, union Data*); | |
124
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
89 context->mData = NEWN(ALLOCATE_SIZE, union MetaData*); |
101 | 90 context->heapStart = NEWN(context->heapLimit, char); |
91 context->heap = context->heapStart; | |
86 | 92 |
93 context->codeNum = Exit; | |
94 | |
95 context->code[Code1] = code1_stub; | |
92 | 96 context->code[Code2] = code2_stub; |
86 | 97 /* context->code[Code3] = code3_stub; */ |
98 /* context->code[Code4] = code4; */ | |
99 /* context->code[Code5] = code5; */ | |
100 /* context->code[Find] = find; */ | |
101 /* context->code[Not_find] = not_find; */ | |
102 /* context->code[Code6] = code6; */ | |
112 | 103 context->code[PutTree] = put_stub; |
104 context->code[Replace] = replaceNode_stub; | |
134 | 105 context->code[Replace1] = replaceNode1_stub; |
112 | 106 context->code[Insert] = insertNode_stub; |
107 context->code[RotateL] = rotateLeft_stub; | |
108 context->code[RotateR] = rotateRight_stub; | |
86 | 109 context->code[InsertCase1] = insert1_stub; |
110 context->code[InsertCase2] = insert2_stub; | |
111 context->code[InsertCase3] = insert3_stub; | |
134 | 112 context->code[InsertCase31] = insert31_stub; |
86 | 113 context->code[InsertCase4] = insert4_stub; |
134 | 114 context->code[InsertCase4_01]= insert4_01_stub; |
115 context->code[InsertCase4_02]= insert4_02_stub; | |
86 | 116 context->code[InsertCase4_1] = insert4_1_stub; |
117 context->code[InsertCase4_2] = insert4_2_stub; | |
118 context->code[InsertCase5] = insert5_stub; | |
119 context->code[StackClear] = stackClear_stub; | |
112 | 120 context->code[Get] = get_stub; |
92 | 121 context->code[Search] = search_stub; |
86 | 122 /* context->code[Delete] = delete_stub; */ |
123 /* context->code[Delete1] = delete1_stub; */ | |
124 /* context->code[Delete2] = delete2_stub; */ | |
125 /* context->code[Delete3] = delete3_stub; */ | |
126 /* context->code[Replace_d1] = replaceNodeForDelete1_stub; */ | |
127 /* context->code[Replace_d2] = replaceNodeForDelete2_stub; */ | |
128 /* context->code[FindMax1] = findMax1_stub; */ | |
129 /* context->code[FindMax2] = findMax2_stub; */ | |
130 /* context->code[DeleteCase1] = deleteCase1_stub; */ | |
131 /* context->code[DeleteCase2] = deleteCase2_stub; */ | |
132 /* context->code[DeleteCase3] = deleteCase3_stub; */ | |
133 /* context->code[DeleteCase4] = deleteCase4_stub; */ | |
134 /* context->code[DeleteCase5] = deleteCase5_stub; */ | |
135 /* context->code[DeleteCase6] = deleteCase6_stub; */ | |
136 context->code[CreateWorker] = createWorker_stub; | |
137 context->code[TaskManager] = taskManager_stub; | |
90 | 138 context->code[CreateData1] = createData1_stub; |
139 context->code[CreateData2] = createData2_stub; | |
140 context->code[CreateTask1] = createTask1_stub; | |
141 context->code[CreateTask2] = createTask2_stub; | |
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
142 context->code[CreateTask3] = createTask3_stub; |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
143 context->code[CreateTask4] = createTask4_stub; |
123
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
144 context->code[CreateTask5] = createTask5_stub; |
124
acf0453b1c7a
Fix meta data pointer calculate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
123
diff
changeset
|
145 context->code[CreateTask6] = createTask6_stub; |
123
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
146 context->code[Poll1] = poll1_stub; |
4ff6f093b695
Fix segmentation fault
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
122
diff
changeset
|
147 context->code[Poll2] = poll2_stub; |
90 | 148 context->code[PutQueue1] = putQueue1_stub; |
149 context->code[PutQueue2] = putQueue2_stub; | |
150 context->code[PutQueue3] = putQueue3_stub; | |
151 context->code[PutQueue4] = putQueue4_stub; | |
125
77e60b6cdace
Work dependency example
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
124
diff
changeset
|
152 context->code[GetTask] = getTask_stub; |
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
153 context->code[GetQueue1] = getQueue1_stub; |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
154 context->code[GetInputData1] = getInputData1_stub; |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
155 context->code[GetInputData2] = getInputData2_stub; |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
156 context->code[GetOutputData1] = getOutputData1_stub; |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
157 context->code[GetOutputData2] = getOutputData2_stub; |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
158 context->code[WaitFor] = waitFor_stub; |
112 | 159 context->code[SpawnTask] = spawnTask_stub; |
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
160 context->code[CheckTaskFinish1] = checkTaskFinish1_stub; |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
161 context->code[CheckTaskFinish2] = checkTaskFinish2_stub; |
92 | 162 context->code[Twice] = twice_stub; |
122
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
163 context->code[Add] = add_stub; |
a086857e1812
implement dependency example. do not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
115
diff
changeset
|
164 context->code[Mult] = mult_stub; |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
165 context->code[StartTime] = start_time_stub; |
112 | 166 context->code[EndTime] = end_time_stub; |
167 context->code[Exit] = exit_code; | |
86 | 168 |
101 | 169 struct Worker* worker = ALLOC_DATA(context, Worker); |
87 | 170 worker->num = 0; |
171 worker->contexts = 0; | |
172 | |
101 | 173 struct Allocate* allocate = ALLOC_DATA(context, Allocate); |
87 | 174 allocate->size = 0; |
175 | |
101 | 176 struct Tree* tree = ALLOC_DATA(context, Tree); |
86 | 177 tree->root = 0; |
87 | 178 |
134 | 179 struct Traverse* traverse = ALLOC_DATA(context, Traverse); |
180 traverse->nodeStack = NULL; | |
101 | 181 |
182 struct Node* node = ALLOC_DATA(context, Node); | |
87 | 183 node->key = 0; |
184 node->value = 0; | |
185 node->left = 0; | |
186 node->right = 0; | |
101 | 187 |
188 struct LoopCounter* counter = ALLOC_DATA(context, LoopCounter); | |
86 | 189 counter->i = 0; |
87 | 190 |
101 | 191 struct Element* element = ALLOC_DATA(context, Element); |
113
d05b9937aa95
Change element data from Task to Data
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
112
diff
changeset
|
192 element->data = 0; |
90 | 193 element->next = 0; |
194 | |
101 | 195 ALLOC_DATA(context, Time); |
196 | |
197 struct Queue* activeQueue = ALLOC_DATA_TYPE(context, ActiveQueue, Queue); | |
90 | 198 activeQueue->first = 0; |
199 activeQueue->last = 0; | |
200 activeQueue->count = 0; | |
101 | 201 |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
101
diff
changeset
|
202 struct Queue* waitQueue = ALLOC_DATA_TYPE(context, WaitQueue, Queue); |
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
101
diff
changeset
|
203 waitQueue->first = 0; |
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
101
diff
changeset
|
204 waitQueue->last = 0; |
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
101
diff
changeset
|
205 waitQueue->count = 0; |
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
101
diff
changeset
|
206 |
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
101
diff
changeset
|
207 context->dataNum = Queue; |
86 | 208 |
115
135472238fb7
Add meta Data Gear allocate
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
113
diff
changeset
|
209 context->metaDataNum = 0; |
86 | 210 context->node_stack = stack_init(sizeof(struct Node*), 100); |
211 context->code_stack = stack_init(sizeof(enum Code), 100); | |
212 } |