Mercurial > hg > Gears > GearsAgda

annotate src/parallel_execution/taskManager.c @ 221:2454f4392316

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Success create Task and inqueue Task
author Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
date Mon, 09 Jan 2017 21:39:33 +0900
parents 6c0692c9bfed
children 77faa28128b4
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
178
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
1 #include "context.h"
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
2 #include "stack.h"
182
57a11c15ff4c Add queue_test
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 178
diff changeset
3 #include "queue.h"
178
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
4 #include "origin_cs.h"
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
5 #include <stdio.h>
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
6
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
7 union Data* createTaskManager(struct Context* context) {
209
5708390a9d88 fix compile errors
mir3636
parents: 184
diff changeset
8 struct TaskManager* taskManager = &ALLOCATE(context, TaskManager)->TaskManager;
5708390a9d88 fix compile errors
mir3636
parents: 184
diff changeset
9 struct TaskManagerImpl* taskManagerImpl = &ALLOCATE(context, TaskManagerImpl)->TaskManagerImpl;
221
2454f4392316 Success create Task and inqueue Task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
10 taskManager->taskManager = (union Data*)taskManagerImpl;
220
6c0692c9bfed Fix rb_tree
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 219
diff changeset
11 taskManagerImpl -> activeQueue = &createSynchronizedQueue(context)->Queue;
6c0692c9bfed Fix rb_tree
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 219
diff changeset
12 taskManagerImpl -> taskQueue = &createSynchronizedQueue(context)->Queue;
178
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
13 taskManager->spawn = C_spawnTaskManager;
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
14 taskManager->shutdown = C_shutdownTaskManager;
209
5708390a9d88 fix compile errors
mir3636
parents: 184
diff changeset
15 // taskManager->deadLockDetected = C_deadLockDetected;
178
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
16 return (union Data*)(taskManager);
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
17 }
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
18
218
d8a59b727f65 Fix spawnTaskManager
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 209
diff changeset
19 __code spawnTaskManager(struct Context* context, struct TaskManagerImpl* taskManager, struct Queue* queue, struct Task* task, enum Code next) {
178
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
20 if (task->idsCount == 0) {
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
21 // enqueue activeQueue
218
d8a59b727f65 Fix spawnTaskManager
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 209
diff changeset
22 queue->queue = (union Data*)taskManager->activeQueue;
178
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
23 } else {
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
24 // enqueue waitQueue
218
d8a59b727f65 Fix spawnTaskManager
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 209
diff changeset
25 queue->queue = (union Data*)taskManager->taskQueue;
178
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
26 }
218
d8a59b727f65 Fix spawnTaskManager
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 209
diff changeset
27 queue->data = (union Data*)task;
d8a59b727f65 Fix spawnTaskManager
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 209
diff changeset
28 queue->next = next;
209
5708390a9d88 fix compile errors
mir3636
parents: 184
diff changeset
29 goto meta(context, queue->queue->Queue.put);
178
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
30 }
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
31
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
32 __code spawnTaskManager_stub(struct Context* context) {
209
5708390a9d88 fix compile errors
mir3636
parents: 184
diff changeset
33 goto spawnTaskManager(context,
221
2454f4392316 Success create Task and inqueue Task
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 220
diff changeset
34 &context->data[D_TaskManager]->TaskManager.taskManager->TaskManager.taskManager->TaskManagerImpl,
209
5708390a9d88 fix compile errors
mir3636
parents: 184
diff changeset
35 &context->data[D_Queue]->Queue,
218
d8a59b727f65 Fix spawnTaskManager
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 209
diff changeset
36 context->data[D_TaskManager]->TaskManager.task,
d8a59b727f65 Fix spawnTaskManager
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 209
diff changeset
37 context->data[D_TaskManager]->TaskManager.next
d8a59b727f65 Fix spawnTaskManager
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 209
diff changeset
38 );
178
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
39 }
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
40
182
57a11c15ff4c Add queue_test
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 178
diff changeset
41 __code shutdownTaskManager(struct Context* context, struct LoopCounter* loopCounter, struct Worker* worker) {
178
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
42 int i = loopCounter->i;
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
43
209
5708390a9d88 fix compile errors
mir3636
parents: 184
diff changeset
44 if (i < worker->id) {
178
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
45 pthread_join(worker->contexts[i].thread, NULL);
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
46 loopCounter->i++;
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
47
209
5708390a9d88 fix compile errors
mir3636
parents: 184
diff changeset
48 goto meta(context, C_taskManager);
178
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
49 }
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
50
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
51 loopCounter->i = 0;
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
52
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
53 Time *t = &context->data[D_Time]->Time;
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
54 t->next = C_code2;
209
5708390a9d88 fix compile errors
mir3636
parents: 184
diff changeset
55 goto meta(context, C_end_time);
178
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
56 }
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
57
182
57a11c15ff4c Add queue_test
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 178
diff changeset
58 __code shutdownTaskManager_stub(struct Context* context) {
218
d8a59b727f65 Fix spawnTaskManager
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 209
diff changeset
59 goto shutdownTaskManager(context, &context->data[D_LoopCounter]->LoopCounter, &context->data[D_Worker]->Worker);
178
5077cf9bf54e add TaskManager.c
mir3636
parents:
diff changeset
60 }