Mercurial > hg > Members > Moririn
annotate src/parallel_execution/context.c @ 170:ee7134f3bef1
Fix
author | Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp> |
---|---|
date | Tue, 22 Nov 2016 10:36:45 +0900 |
parents | ea7b11f3e717 |
children | 661b0b0d0399 |
rev | line source |
---|---|
86 | 1 #include <stdlib.h> |
2 | |
3 #include "context.h" | |
132 | 4 #include "stack.h" |
167 | 5 #include "queue.h" |
86 | 6 |
7 extern __code code1_stub(struct Context*); | |
8 extern __code code2_stub(struct Context*); | |
9 extern __code code3_stub(struct Context*); | |
169
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
10 extern __code code4_stub(struct Context*); |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
11 extern __code code5_stub(struct Context*); |
86 | 12 extern __code find(struct Context*); |
13 extern __code not_find(struct Context*); | |
14 extern __code code6(struct Context*); | |
15 extern __code meta(struct Context*); | |
16 extern __code put_stub(struct Context*); | |
17 extern __code replaceNode_stub(struct Context*); | |
124 | 18 extern __code replaceNode1_stub(struct Context*); |
86 | 19 extern __code insertNode_stub(struct Context*); |
20 extern __code rotateLeft_stub(struct Context*); | |
140 | 21 extern __code rotateLeft1_stub(struct Context*); |
86 | 22 extern __code rotateRight_stub(struct Context*); |
140 | 23 extern __code rotateRight1_stub(struct Context*); |
86 | 24 extern __code colorFlip_stub(struct Context*); |
25 extern __code fixUp_stub(struct Context*); | |
26 extern __code changeReference_stub(struct Context*); | |
144 | 27 extern __code insertCase1_stub(struct Context*); |
28 extern __code insertCase2_stub(struct Context*); | |
29 extern __code insertCase3_stub(struct Context*); | |
30 extern __code insertCase4_stub(struct Context*); | |
31 extern __code insertCase5_stub(struct Context*); | |
32 extern __code insertCase51_stub(struct Context*); | |
86 | 33 extern __code get_stub(struct Context*); |
34 extern __code search_stub(struct Context*); | |
35 extern __code delete_stub(struct Context*); | |
36 extern __code delete1_stub(struct Context*); | |
37 extern __code delete2_stub(struct Context*); | |
38 extern __code delete3_stub(struct Context*); | |
39 extern __code replaceNodeForDelete1_stub(struct Context*); | |
40 extern __code replaceNodeForDelete2_stub(struct Context*); | |
41 extern __code findMax1_stub(struct Context*); | |
42 extern __code findMax2_stub(struct Context*); | |
43 extern __code deleteCase1_stub(struct Context*); | |
44 extern __code deleteCase2_stub(struct Context*); | |
45 extern __code deleteCase3_stub(struct Context*); | |
46 extern __code deleteCase4_stub(struct Context*); | |
47 extern __code deleteCase5_stub(struct Context*); | |
48 extern __code deleteCase6_stub(struct Context*); | |
49 extern __code createWorker_stub(struct Context*); | |
50 extern __code taskManager_stub(struct Context*); | |
90 | 51 extern __code createData1_stub(struct Context*); |
52 extern __code createData2_stub(struct Context*); | |
53 extern __code createTask1_stub(struct Context*); | |
54 extern __code createTask2_stub(struct Context*); | |
112 | 55 extern __code createTask3_stub(struct Context*); |
56 extern __code createTask4_stub(struct Context*); | |
90 | 57 extern __code putQueue1_stub(struct Context*); |
58 extern __code putQueue2_stub(struct Context*); | |
59 extern __code putQueue3_stub(struct Context*); | |
60 extern __code putQueue4_stub(struct Context*); | |
169
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
61 extern __code getTask1_stub(struct Context*); |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
62 extern __code getTask2_stub(struct Context*); |
112 | 63 extern __code spawnTask_stub(struct Context*); |
92 | 64 extern __code twice_stub(struct Context*); |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
65 extern __code start_time_stub(struct Context*); |
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
66 extern __code end_time_stub(struct Context*); |
86 | 67 extern __code exit_code(struct Context*); |
169
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
68 extern __code clearSingleLinkedQueue_stub(struct Context*); |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
69 extern __code putSingleLinkedQueue_stub(struct Context *); |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
70 extern __code takeSingleLinkedQueue_stub(struct Context *); |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
71 extern __code isEmptySingleLinkedQueue_stub(struct Context *); |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
72 extern __code clearSynchronizedQueue_stub(struct Context*); |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
73 extern __code putSynchronizedQueue_stub(struct Context *); |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
74 extern __code takeSynchronizedQueue_stub(struct Context *); |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
75 extern __code isEmptySynchronizedQueue_stub(struct Context *); |
86 | 76 |
77 __code initContext(struct Context* context) { | |
78 context->heapLimit = sizeof(union Data)*ALLOCATE_SIZE; | |
101 | 79 context->code = (__code(**) (struct Context*)) NEWN(ALLOCATE_SIZE, void*); |
80 context->data = NEWN(ALLOCATE_SIZE, union Data*); | |
81 context->heapStart = NEWN(context->heapLimit, char); | |
82 context->heap = context->heapStart; | |
86 | 83 |
84 context->codeNum = Exit; | |
85 | |
169
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
86 context->code[C_code1] = code1_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
87 context->code[C_code2] = code2_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
88 context->code[C_put] = put_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
89 context->code[C_replaceNode] = replaceNode_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
90 context->code[C_replaceNode1] = replaceNode1_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
91 context->code[C_insertNode] = insertNode_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
92 context->code[C_rotateLeft] = rotateLeft_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
93 context->code[C_rotateLeft1] = rotateLeft1_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
94 context->code[C_rotateRight] = rotateRight_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
95 context->code[C_rotateRight1] = rotateRight1_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
96 context->code[C_insertCase1] = insertCase1_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
97 context->code[C_insertCase2] = insertCase2_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
98 context->code[C_insertCase3] = insertCase3_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
99 context->code[C_insertCase4] = insertCase4_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
100 context->code[C_insertCase5] = insertCase5_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
101 context->code[C_insertCase51] = insertCase51_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
102 context->code[C_stackClear] = stackClear_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
103 context->code[C_get] = get_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
104 context->code[C_search] = search_stub; |
140 | 105 |
169
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
106 context->code[C_clearSingleLinkedStack] = clearSingleLinkedStack_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
107 context->code[C_pushSingleLinkedStack] = pushSingleLinkedStack_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
108 context->code[C_popSingleLinkedStack] = popSingleLinkedStack_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
109 context->code[C_pop2SingleLinkedStack] = pop2SingleLinkedStack_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
110 context->code[C_getSingleLinkedStack] = getSingleLinkedStack_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
111 context->code[C_get2SingleLinkedStack] = get2SingleLinkedStack_stub; |
144 | 112 context->code[C_isEmptySingleLinkedStack] = isEmptySingleLinkedStack_stub; |
140 | 113 |
169
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
114 context->code[C_clearSingleLinkedQueue] = clearSingleLinkedQueue_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
115 context->code[C_putSingleLinkedQueue] = putSingleLinkedQueue_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
116 context->code[C_takeSingleLinkedQueue] = takeSingleLinkedQueue_stub; |
167 | 117 context->code[C_isEmptySingleLinkedQueue] = isEmptySingleLinkedQueue_stub; |
118 | |
169
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
119 context->code[C_clearSynchronizedQueue] = clearSynchronizedQueue_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
120 context->code[C_putSynchronizedQueue] = putSynchronizedQueue_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
121 context->code[C_takeSynchronizedQueue] = takeSynchronizedQueue_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
122 context->code[C_isEmptySynchronizedQueue] = isEmptySynchronizedQueue_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
123 |
86 | 124 /* context->code[Delete] = delete_stub; */ |
125 /* context->code[Delete1] = delete1_stub; */ | |
126 /* context->code[Delete2] = delete2_stub; */ | |
127 /* context->code[Delete3] = delete3_stub; */ | |
128 /* context->code[Replace_d1] = replaceNodeForDelete1_stub; */ | |
129 /* context->code[Replace_d2] = replaceNodeForDelete2_stub; */ | |
130 /* context->code[FindMax1] = findMax1_stub; */ | |
131 /* context->code[FindMax2] = findMax2_stub; */ | |
132 /* context->code[DeleteCase1] = deleteCase1_stub; */ | |
133 /* context->code[DeleteCase2] = deleteCase2_stub; */ | |
134 /* context->code[DeleteCase3] = deleteCase3_stub; */ | |
135 /* context->code[DeleteCase4] = deleteCase4_stub; */ | |
136 /* context->code[DeleteCase5] = deleteCase5_stub; */ | |
137 /* context->code[DeleteCase6] = deleteCase6_stub; */ | |
138 context->code[CreateWorker] = createWorker_stub; | |
139 context->code[TaskManager] = taskManager_stub; | |
90 | 140 context->code[CreateData1] = createData1_stub; |
141 context->code[CreateData2] = createData2_stub; | |
142 context->code[CreateTask1] = createTask1_stub; | |
143 context->code[CreateTask2] = createTask2_stub; | |
112 | 144 context->code[CreateTask3] = createTask3_stub; |
145 context->code[CreateTask4] = createTask4_stub; | |
90 | 146 context->code[PutQueue1] = putQueue1_stub; |
147 context->code[PutQueue2] = putQueue2_stub; | |
148 context->code[PutQueue3] = putQueue3_stub; | |
149 context->code[PutQueue4] = putQueue4_stub; | |
169
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
150 context->code[C_getTask1] = getTask1_stub; |
ea7b11f3e717
Using Queue Interface
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
167
diff
changeset
|
151 context->code[C_getTask2] = getTask2_stub; |
112 | 152 context->code[SpawnTask] = spawnTask_stub; |
92 | 153 context->code[Twice] = twice_stub; |
95
3e28ee215c0e
modify twice, use OSAtomiceCompareAndSwap
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
92
diff
changeset
|
154 context->code[StartTime] = start_time_stub; |
112 | 155 context->code[EndTime] = end_time_stub; |
156 context->code[Exit] = exit_code; | |
86 | 157 |
101 | 158 struct Worker* worker = ALLOC_DATA(context, Worker); |
87 | 159 worker->num = 0; |
160 worker->contexts = 0; | |
161 | |
101 | 162 struct Allocate* allocate = ALLOC_DATA(context, Allocate); |
87 | 163 allocate->size = 0; |
164 | |
131
a4507906938c
Fix compile error but not work
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
130
diff
changeset
|
165 |
132 | 166 ALLOC_DATA(context, Stack); |
130 | 167 |
101 | 168 struct Tree* tree = ALLOC_DATA(context, Tree); |
86 | 169 tree->root = 0; |
87 | 170 |
124 | 171 struct Traverse* traverse = ALLOC_DATA(context, Traverse); |
132 | 172 traverse->nodeStack = &createSingleLinkedStack(context)->stack; |
101 | 173 |
147 | 174 ALLOC_DATA(context, RotateTree); |
175 | |
101 | 176 struct Node* node = ALLOC_DATA(context, Node); |
87 | 177 node->key = 0; |
178 node->value = 0; | |
179 node->left = 0; | |
180 node->right = 0; | |
101 | 181 |
182 struct LoopCounter* counter = ALLOC_DATA(context, LoopCounter); | |
86 | 183 counter->i = 0; |
87 | 184 |
101 | 185 struct Element* element = ALLOC_DATA(context, Element); |
114
d05b9937aa95
Change element data from Task to Data
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
112
diff
changeset
|
186 element->data = 0; |
90 | 187 element->next = 0; |
188 | |
101 | 189 ALLOC_DATA(context, Time); |
190 | |
170 | 191 context->data[D_ActiveQueue] = createSynchronizedQueue(context); |
192 context->data[D_WaitQueue] = createSynchronizedQueue(context); | |
109
059b26a250cc
Change put_queue process
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents:
101
diff
changeset
|
193 |
148
473b7d990a1f
fix data gears type enum
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
147
diff
changeset
|
194 context->dataNum = D_Queue; |
86 | 195 } |