Mercurial > hg > GearsTemplate

annotate src/parallel_execution/CPUWorker.cbc @ 410:85b0ddbf458e

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Fix CudaWorker
author Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
date Thu, 14 Sep 2017 02:35:20 +0900
parents 8915fce522b3
children 0eba9a04633f
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
278
23767f714f4a fix generate_stub
mir3636
parents: 277
diff changeset
1 #include "../context.h"
272
mir3636
parents:
diff changeset
2
410
85b0ddbf458e Fix CudaWorker
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 405
diff changeset
3 static void startWorker(Worker* worker);
272
mir3636
parents:
diff changeset
4
280
2c2e4e597eb0 generate no compile errors
mir3636
parents: 278
diff changeset
5 Worker* createCPUWorker(struct Context* context, int id, Queue* queue) {
272
mir3636
parents:
diff changeset
6 struct Worker* worker = new Worker();
mir3636
parents:
diff changeset
7 struct CPUWorker* cpuWorker = new CPUWorker();
mir3636
parents:
diff changeset
8 worker->worker = (union Data*)cpuWorker;
mir3636
parents:
diff changeset
9 worker->tasks = queue;
mir3636
parents:
diff changeset
10 cpuWorker->id = id;
mir3636
parents:
diff changeset
11 worker->taskReceive = C_taskReceiveWorker;
mir3636
parents:
diff changeset
12 worker->shutdown = C_shutdownWorker;
410
85b0ddbf458e Fix CudaWorker
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 405
diff changeset
13 pthread_create(&worker->worker->CPUWorker.thread, NULL, (void*)&startWorker, worker);
272
mir3636
parents:
diff changeset
14 return worker;
mir3636
parents:
diff changeset
15 }
mir3636
parents:
diff changeset
16
410
85b0ddbf458e Fix CudaWorker
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 405
diff changeset
17 static void startWorker(Worker* worker) {
272
mir3636
parents:
diff changeset
18 CPUWorker* cpuWorker = (CPUWorker*)worker->worker;
mir3636
parents:
diff changeset
19 cpuWorker->context = NEW(struct Context);
mir3636
parents:
diff changeset
20 initContext(cpuWorker->context);
mir3636
parents:
diff changeset
21 Gearef(cpuWorker->context, Worker)->worker = (union Data*)worker;
282
a3448b0f0a56 Add input data gear
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 280
diff changeset
22 goto meta(cpuWorker->context, worker->taskReceive);
272
mir3636
parents:
diff changeset
23 }
mir3636
parents:
diff changeset
24
mir3636
parents:
diff changeset
25 __code taskReceiveWorker(struct Worker* worker,struct Queue* queue) {
mir3636
parents:
diff changeset
26 queue->queue = (union Data*)worker->tasks;
mir3636
parents:
diff changeset
27 queue->next = C_getTask;
mir3636
parents:
diff changeset
28 goto meta(context, worker->tasks->take);
mir3636
parents:
diff changeset
29 }
mir3636
parents:
diff changeset
30
mir3636
parents:
diff changeset
31 __code taskReceiveWorker_stub(struct Context* context) {
mir3636
parents:
diff changeset
32 goto taskReceiveWorker(context, &Gearef(context, Worker)->worker->Worker, Gearef(context, Queue));
mir3636
parents:
diff changeset
33 }
mir3636
parents:
diff changeset
34
mir3636
parents:
diff changeset
35 __code getTask(struct Worker* worker, struct Context* task) {
mir3636
parents:
diff changeset
36 if (!task)
mir3636
parents:
diff changeset
37 return; // end thread
mir3636
parents:
diff changeset
38 task->worker = worker;
289
3d70e21a3902 Delete createData
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 288
diff changeset
39 enum Code taskCg = task->next;
374
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
40 if (task->iterate) {
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
41 task->next = C_iterateCommit;
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
42 } else {
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
43 task->next = C_odgCommit; // set CG after task exec
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
44 }
289
3d70e21a3902 Delete createData
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 288
diff changeset
45 goto meta(task, taskCg);
272
mir3636
parents:
diff changeset
46 }
mir3636
parents:
diff changeset
47
mir3636
parents:
diff changeset
48 __code getTask_stub(struct Context* context) {
mir3636
parents:
diff changeset
49 Worker* worker = &Gearef(context,Worker)->worker->Worker;
mir3636
parents:
diff changeset
50 struct Context* task = &Gearef(context, Queue)->data->Context;
mir3636
parents:
diff changeset
51 goto getTask(context, worker, task);
mir3636
parents:
diff changeset
52 }
mir3636
parents:
diff changeset
53
374
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
54 __code iterateCommit(struct Iterator* iterator) {
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
55 iterator->iterator = (union Data*)context->iterator;
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
56 iterator->task = context;
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
57 iterator->next = C_odgCommit;
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
58 iterator->whenWait = C_iterateCommit1;
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
59 goto meta(context, context->iterator->barrier);
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
60 }
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
61
375
ad44fdb11433 Fix compile error but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 374
diff changeset
62 __code iterateCommit1(struct Context* task) {
374
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
63 goto meta(context, C_taskReceiveWorker);
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
64 }
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
65
375
ad44fdb11433 Fix compile error but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 374
diff changeset
66 __code iterateCommit1_stub(struct Context* context) {
374
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
67 struct Context* workerContext = context->worker->worker->CPUWorker.context;
375
ad44fdb11433 Fix compile error but not work
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 374
diff changeset
68 goto iterateCommit1(workerContext, context);
374
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
69 }
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
70
405
8915fce522b3 Fix shutdown TaskManager
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 375
diff changeset
71 __code odgCommit(struct LoopCounter* loopCounter, struct Context* task, struct TaskManager* taskManager) {
288
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
72 int i = loopCounter->i ;
374
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
73 if (task->odg+i < task->maxOdg) {
327
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
74 goto meta(task, C_odgCommit1);
288
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
75 }
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
76 loopCounter->i = 0;
405
8915fce522b3 Fix shutdown TaskManager
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 375
diff changeset
77 taskManager->taskManager = (union Data*)task->taskManager;
8915fce522b3 Fix shutdown TaskManager
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 375
diff changeset
78 taskManager->next = C_taskReceiveWorker;
8915fce522b3 Fix shutdown TaskManager
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 375
diff changeset
79 goto meta(context, task->taskManager->decrementTaskCount);
288
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
80 }
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
81
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
82 __code odgCommit_stub(struct Context* context) {
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
83 struct Context* workerContext = context->worker->worker->CPUWorker.context;
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
84 goto odgCommit(workerContext,
327
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
85 Gearef(context, LoopCounter),
405
8915fce522b3 Fix shutdown TaskManager
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 375
diff changeset
86 context,
8915fce522b3 Fix shutdown TaskManager
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 375
diff changeset
87 Gearef(workerContext, TaskManager));
288
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
88 }
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
89
327
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
90 __code odgCommit1(struct LoopCounter* loopCounter, struct Queue* queue) {
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
91 int i = loopCounter->i ;
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
92 queue->queue = (union Data*)GET_WAIT_LIST(context->data[context->odg+i]);
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
93 queue->whenEmpty = C_odgCommit4;
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
94 queue->next = C_odgCommit2;
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
95 goto meta(context, queue->queue->Queue.isEmpty);
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
96 }
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
97
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
98 __code odgCommit1_stub(struct Context* context) {
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
99 goto odgCommit1(context,
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
100 Gearef(context, LoopCounter),
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
101 Gearef(context, Queue));
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
102 }
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
103
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
104 __code odgCommit2(struct Queue* queue) {
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
105 queue->next = C_odgCommit3;
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
106 goto meta(context, queue->queue->Queue.take);
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
107 }
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
108
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
109 __code odgCommit2_stub(struct Context* context) {
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
110 goto odgCommit2(context,
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
111 Gearef(context, Queue));
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
112 }
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
113
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
114 __code odgCommit3(struct TaskManager* taskManager, struct Context* task) {
374
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
115 if (__sync_fetch_and_sub(&task->idgCount, 1) == 1) { // atomic decrement idg counter(__sync_fetch_and_sub function return initial value of task->idgCount point)
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
116 taskManager->taskManager = (union Data*)task->taskManager;
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
117 taskManager->context = task;
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
118 taskManager->next = C_odgCommit1;
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
119 goto meta(context, task->taskManager->spawn);
288
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
120 }
374
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
121 goto meta(context, C_odgCommit1);
288
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
122 }
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
123
327
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
124 __code odgCommit3_stub(struct Context* context) {
288
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
125 struct Context* task = &Gearef(context, Queue)->data->Context;
327
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
126 goto odgCommit3(context,
374
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
127 Gearef(context, TaskManager),
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
128 task);
327
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
129 }
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
130
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
131 __code odgCommit4(struct LoopCounter* loopCounter) {
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
132 loopCounter->i++;
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
133 goto meta(context, C_odgCommit);
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
134 }
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
135
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
136 __code odgCommit4_stub(struct Context* context) {
534601ed8c50 Running dependency example for single thread and single task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 325
diff changeset
137 goto odgCommit4(context,
374
fb50cf8aa615 Add Iterator Interface
Tatsuki IHA <innparusu@cr.ie.u-ryukyu.ac.jp>
parents: 372
diff changeset
138 Gearef(context, LoopCounter));
288
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
139 }
f1b0cc555b6e Add odgCommit
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 282
diff changeset
140
272
mir3636
parents:
diff changeset
141 __code shutdownWorker(struct CPUWorker* worker) {
mir3636
parents:
diff changeset
142 }