Mercurial > hg > Members > kono > Cerium

annotate TaskManager/Fifo/FifoTaskManagerImpl.cc @ 673:d9111086b2c4

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