Mercurial > hg > Members > kono > Cerium

annotate TaskManager/Fifo/FifoTaskManagerImpl.cc @ 685:b386522827ae

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Bulk task on going.
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Mon, 07 Dec 2009 00:32:34 +0900
parents bde5f13adf10
children 61b59376aec5
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
1 #include <stdio.h>
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
2 #include <stdlib.h>
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
3 #include <string.h>
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
4 #include "FifoTaskManagerImpl.h"
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
5 #include "Scheduler.h"
619
0decff4e867b RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 603
diff changeset
6 #include "SchedTask.h"
47
8266445bdac2 *** empty log message ***
gongo
parents: 42
diff changeset
7 #include "types.h"
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
8 #include "error.h"
685
b386522827ae Bulk task on going.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 674
diff changeset
9 #include "SchedNop.h"
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
10
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
11 FifoTaskManagerImpl::~FifoTaskManagerImpl()
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
12 {
640
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
13 delete mainScheduler;
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
14
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
15 delete taskListImpl ;
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
16 delete taskQueueImpl ;
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
17 delete htaskImpl ;
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
18
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
19 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
20
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
21 /**
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
22 * MailManager は PPE スケジューラとのメール交換、
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
23 * FifoScheduler は PPE 側のスケジューラ
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
24 * BufferManager は Task、TaskList などのメモリ管理(大層なことしてないが
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
25 */
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
26 void
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
27 FifoTaskManagerImpl::init()
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
28 {
640
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
29 mainScheduler = new MainScheduler();
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
30 mainScheduler->init(this);
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
31 mainScheduler->id = 0;
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
32 set_scheduler(mainScheduler);
42
aa11038dbdc1 *** empty log message ***
gongo
parents: 22
diff changeset
33
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
34 taskListImpl = new TaskListInfo;
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
35 taskQueueImpl = new TaskQueueInfo;
498
cb5ecfc5aaa3 double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 494
diff changeset
36 htaskImpl = new HTaskInfo();
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
37
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
38 mainTaskList = taskListImpl->create();
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
39
619
0decff4e867b RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 603
diff changeset
40 schedTaskManager = new SchedTask();
640
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
41 schedTaskManager->init(0,0,0,mainScheduler);
619
0decff4e867b RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 603
diff changeset
42
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
43 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
44
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
45 /**
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
46 * これは CellTaskManagerImpl から呼ばれる。
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
47 * TaskList等 は共用で使うので引数に。
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
48 * CellTaskManagerImpl と FifoTaskManagerImpl が同時に
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
49 * 上のデータにアクセスする事は(今は)ないのでこれでおk
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
50 */
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
51 void
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
52 FifoTaskManagerImpl::init(MainScheduler *_sched, TaskManagerImpl *tm)
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
53 {
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
54
640
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
55 mainScheduler = _sched;
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
56 mainScheduler->init(this);
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
57 set_scheduler(mainScheduler);
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
58
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
59 taskListImpl = tm-> taskListImpl ;
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
60 taskQueueImpl = tm-> taskQueueImpl ;
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
61 htaskImpl = tm-> htaskImpl ;
485
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 481
diff changeset
62 waitTaskQueue = NULL; // mail_check で外から設定される
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
63
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
64 mainTaskList = taskListImpl->create();
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
65
674
bde5f13adf10 fix many task example (sort).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 673
diff changeset
66 schedTaskManager = new SchedTask();
bde5f13adf10 fix many task example (sort).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 673
diff changeset
67 schedTaskManager->init(0,0,0,mainScheduler);
479
5bda98b0b56d Double Linked List base TaskQueue
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 475
diff changeset
68
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
69 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
70
673
d9111086b2c4 profiling worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 672
diff changeset
71 void FifoTaskManagerImpl::show_profile() {
d9111086b2c4 profiling worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 672
diff changeset
72 printf("HEHEHEHEH\n");
d9111086b2c4 profiling worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 672
diff changeset
73 }
672
3b6290c05f9f add profiling code
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 664
diff changeset
74 void FifoTaskManagerImpl::start_profile() {}
3b6290c05f9f add profiling code
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 664
diff changeset
75
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
76 /**
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
77 * スケジューラに渡す TaskList を取得する。
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
78 *
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
79 * @return 実行タスクリスト
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
80 *
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
81 * ActiveTaskQueue (依存条件は満たし済み) のタスクを
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
82 * 実行タスクリストに入れる
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
83 */
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
84 TaskListPtr
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
85 FifoTaskManagerImpl::get_runTaskList()
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
86 {
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
87 TaskListPtr list, list_top;
634
0558abba673c SimpleTask start
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
88 #ifdef SIMPLE_TASK
664
7405d92733a8 word count
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 648
diff changeset
89 SimpleTaskPtr task; // Task (SPE に送る Task)
634
0558abba673c SimpleTask start
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
90 #else
664
7405d92733a8 word count
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 648
diff changeset
91 TaskPtr task; // Task (SPE に送る Task)
634
0558abba673c SimpleTask start
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
92 #endif
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
93
480
46464727d825 TaskQueueInfo initiaization...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 479
diff changeset
94 if (activeTaskQueue->empty()) {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
95 return NULL;
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
96 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
97
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
98 // PPE 側で実行される TaskList
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
99 list_top = mainTaskList;
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
100
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
101 // list_top->clear() とかの方がいいかもしれん。
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
102 list_top = taskListImpl->clear_taskList(list_top);
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
103 list = list_top;
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
104
499
eacbcdb23986 still fixing...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 498
diff changeset
105 // printf("active task queue length = %d\n",activeTaskQueue->length());
498
cb5ecfc5aaa3 double linked HTaskInfo/HTask
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 494
diff changeset
106 while (HTaskPtr htask = activeTaskQueue->poll()) {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
107 task = &list->tasks[list->length++];
634
0558abba673c SimpleTask start
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
108 #ifdef SIMPLE_TASK
0558abba673c SimpleTask start
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
109 *task = *(SimpleTask*)htask;
0558abba673c SimpleTask start
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
110 #else
491
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 486
diff changeset
111 memcpy(task, (Task*)htask, sizeof(Task));
634
0558abba673c SimpleTask start
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
112 #endif
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
113 if (list->length >= TASK_MAX_SIZE) {
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
114 TaskListPtr newList = taskListImpl->create();
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
115 list_top = TaskListInfo::append(list_top, newList);
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
116 list = newList;
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
117 }
499
eacbcdb23986 still fixing...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 498
diff changeset
118 // activeTaskQueue->free_(htask); ここで free しないで、
eacbcdb23986 still fixing...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 498
diff changeset
119 // mail を待つ
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
120 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
121
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
122 mainTaskList = list_top;
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
123
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
124 return list_top;
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
125 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
126
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
127
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
128 void
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
129 FifoTaskManagerImpl::run()
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
130 {
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
131 TaskListPtr list;
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
132
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
133 list = get_runTaskList();
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
134
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
135 do {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
136 // list を実行する
647
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
137 schedule(list);
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
138
647
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
139 // ppe scheduler からの mail を調べる
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
140 mail_check(waitTaskQueue);
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
141
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
142 // 依存関係を満たしたものは実行可能キューへ
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
143 wakeup_waitTask();
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
144 list = get_runTaskList();
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
145 } while (list);
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
146 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
147
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
148 /**
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
149 * @param [list] 実行タスクリスト
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
150 * @return FifoScheduler からのメール
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
151 *
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
152 * [Tasklist] -> [番兵] -> scheduler->run を抜ける
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
153 */
647
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
154 void
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
155 FifoTaskManagerImpl::schedule(TaskListPtr list)
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
156 {
638
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 637
diff changeset
157 if (list) {
647
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
158 // TaskList のアドレスを送る
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
159 mainScheduler->mail_write_from_host((memaddr)list);
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
160
638
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 637
diff changeset
161 // EXIT_COMMAND (番兵的な意味で)
648
f1e10ba45d28 Mail modification. Working on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 647
diff changeset
162 // これを読むと、mainScheduler->run() から抜けて来る。
f1e10ba45d28 Mail modification. Working on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 647
diff changeset
163 mainScheduler->mail_write_from_host((memaddr)MY_SPE_COMMAND_EXIT);
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
164
638
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 637
diff changeset
165 // scheduler は受け取ったメールを元に実行する
685
b386522827ae Bulk task on going.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 674
diff changeset
166 // new SchedTaskList(list, mainScheduler) の方が良さそうだけど...
b386522827ae Bulk task on going.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 674
diff changeset
167 mainScheduler->run(new SchedNop());
638
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 637
diff changeset
168 }
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
169 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
170
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
171 /**
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
172 * PPE Scheduler からのメールをチェックする
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
173 *
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
174 * @param [mail_list]
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
175 * PPE 側で動く Scheduler からのメールリスト
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
176 * 終了した Task や、その他(今はまだ実装してないけど)の情報が入ってる
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
177 *
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
178 * @return Scheduler が次に実行する Task List
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
179 * NULL なら全てのタスクが実行終了したということ
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
180 */
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
181 void
647
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
182 FifoTaskManagerImpl::mail_check(HTaskInfo *wait_queue)
485
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 481
diff changeset
183 {
647
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
184 while (mainScheduler->has_mail_from_host()) {
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
185 memaddr data = mainScheduler->mail_read_from_host();
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
186
625
60aa3f241b10 64bit mode worked on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 619
diff changeset
187 if (data == (memaddr)MY_SPE_STATUS_READY) {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
188 __debug_ppe("mail_check(): Task List finish\n");
640
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
189 } else if (data == (memaddr)MY_SPE_COMMAND_EXIT) {
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
190 __debug_ppe("mail_check(): Task List finish COMMAND\n");
625
60aa3f241b10 64bit mode worked on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 619
diff changeset
191 } else if (data != (memaddr)MY_SPE_NOP) {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
192 __debug_ppe("mail_check(): recv from 0x%x\n", data);
619
0decff4e867b RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 603
diff changeset
193 // post_func を先に実行しないと、systask_finish が active_queue
0decff4e867b RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 603
diff changeset
194 // 移されてから、wait_for されるという事態が起きることがある。
0decff4e867b RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 603
diff changeset
195 HTaskPtr task = (HTaskPtr)data;
0decff4e867b RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 603
diff changeset
196 task->post_func(schedTaskManager, task->post_arg1, task->post_arg2);
647
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
197 check_task_finish(task, wait_queue);
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
198 }
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
199 }
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
200 }
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
201
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
202
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
203 /**
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
204 * # # # # # # # #
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
205 * Abstract Factory Pattern
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
206 * # # # # # # #
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
207 */
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
208 #ifdef __CERIUM_FIFO__
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
209 TaskManagerImpl*
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
210 create_impl(int num)
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
211 {
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
212 return new FifoTaskManagerImpl();
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
213 }
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
214 #endif // __CERIUM_FIFO__
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
215