Mercurial > hg > Members > kono > Cerium

annotate TaskManager/Fifo/FifoTaskManagerImpl.cc @ 672:3b6290c05f9f

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add profiling code
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Sat, 05 Dec 2009 20:20:08 +0900
parents 7405d92733a8
children d9111086b2c4
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
672
3b6290c05f9f add profiling code
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 664
diff changeset
68 void FifoTaskManagerImpl::show_profile() {}
3b6290c05f9f add profiling code
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 664
diff changeset
69 void FifoTaskManagerImpl::start_profile() {}
3b6290c05f9f add profiling code
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 664
diff changeset
70
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
71 /**
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
72 * スケジューラに渡す TaskList を取得する。
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 * @return 実行タスクリスト
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 * ActiveTaskQueue (依存条件は満たし済み) のタスクを
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
77 * 実行タスクリストに入れる
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
78 */
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
79 TaskListPtr
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
80 FifoTaskManagerImpl::get_runTaskList()
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
81 {
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
82 TaskListPtr list, list_top;
634
0558abba673c SimpleTask start
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
83 #ifdef SIMPLE_TASK
664
7405d92733a8 word count
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 648
diff changeset
84 SimpleTaskPtr task; // Task (SPE に送る Task)
634
0558abba673c SimpleTask start
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
85 #else
664
7405d92733a8 word count
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 648
diff changeset
86 TaskPtr task; // Task (SPE に送る Task)
634
0558abba673c SimpleTask start
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
87 #endif
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
88
480
46464727d825 TaskQueueInfo initiaization...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 479
diff changeset
89 if (activeTaskQueue->empty()) {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
90 return NULL;
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
91 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
92
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
93 // PPE 側で実行される TaskList
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
94 list_top = mainTaskList;
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
95
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
96 // list_top->clear() とかの方がいいかもしれん。
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
97 list_top = taskListImpl->clear_taskList(list_top);
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
98 list = list_top;
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
99
499
eacbcdb23986 still fixing...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 498
diff changeset
100 // 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
101 while (HTaskPtr htask = activeTaskQueue->poll()) {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
102 task = &list->tasks[list->length++];
634
0558abba673c SimpleTask start
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
103 #ifdef SIMPLE_TASK
0558abba673c SimpleTask start
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
104 *task = *(SimpleTask*)htask;
0558abba673c SimpleTask start
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
105 #else
491
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 486
diff changeset
106 memcpy(task, (Task*)htask, sizeof(Task));
634
0558abba673c SimpleTask start
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
107 #endif
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
108 if (list->length >= TASK_MAX_SIZE) {
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
109 TaskListPtr newList = taskListImpl->create();
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
110 list_top = TaskListInfo::append(list_top, newList);
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
111 list = newList;
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
112 }
499
eacbcdb23986 still fixing...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 498
diff changeset
113 // activeTaskQueue->free_(htask); ここで free しないで、
eacbcdb23986 still fixing...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 498
diff changeset
114 // mail を待つ
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
115 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
116
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
117 mainTaskList = list_top;
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
118
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
119 return 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
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
122
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
123 void
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
124 FifoTaskManagerImpl::run()
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
125 {
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
126 TaskListPtr list;
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
127
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
128 list = get_runTaskList();
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
129
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
130 do {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
131 // list を実行する
647
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
132 schedule(list);
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
133
647
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
134 // ppe scheduler からの mail を調べる
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
135 mail_check(waitTaskQueue);
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
136
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
137 // 依存関係を満たしたものは実行可能キューへ
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
138 wakeup_waitTask();
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
139 list = get_runTaskList();
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
140 } while (list);
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
141 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
142
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
143 /**
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
144 * @param [list] 実行タスクリスト
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
145 * @return FifoScheduler からのメール
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
146 *
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
147 * [Tasklist] -> [番兵] -> scheduler->run を抜ける
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
148 */
647
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
149 void
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
150 FifoTaskManagerImpl::schedule(TaskListPtr list)
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
151 {
638
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 637
diff changeset
152 if (list) {
647
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
153 // TaskList のアドレスを送る
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
154 mainScheduler->mail_write_from_host((memaddr)list);
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
155
638
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 637
diff changeset
156 // EXIT_COMMAND (番兵的な意味で)
648
f1e10ba45d28 Mail modification. Working on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 647
diff changeset
157 // これを読むと、mainScheduler->run() から抜けて来る。
f1e10ba45d28 Mail modification. Working on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 647
diff changeset
158 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
159
638
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 637
diff changeset
160 // scheduler は受け取ったメールを元に実行する
640
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
161 mainScheduler->run();
638
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 637
diff changeset
162 }
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
163 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
164
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
165 /**
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
166 * PPE Scheduler からのメールをチェックする
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
167 *
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
168 * @param [mail_list]
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
169 * PPE 側で動く Scheduler からのメールリスト
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
170 * 終了した Task や、その他(今はまだ実装してないけど)の情報が入ってる
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
171 *
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
172 * @return Scheduler が次に実行する Task List
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
173 * NULL なら全てのタスクが実行終了したということ
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
174 */
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
175 void
647
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
176 FifoTaskManagerImpl::mail_check(HTaskInfo *wait_queue)
485
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 481
diff changeset
177 {
647
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
178 while (mainScheduler->has_mail_from_host()) {
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
179 memaddr data = mainScheduler->mail_read_from_host();
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
180
625
60aa3f241b10 64bit mode worked on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 619
diff changeset
181 if (data == (memaddr)MY_SPE_STATUS_READY) {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
182 __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
183 } 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
184 __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
185 } else if (data != (memaddr)MY_SPE_NOP) {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
186 __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
187 // post_func を先に実行しないと、systask_finish が active_queue
0decff4e867b RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 603
diff changeset
188 // 移されてから、wait_for されるという事態が起きることがある。
0decff4e867b RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 603
diff changeset
189 HTaskPtr task = (HTaskPtr)data;
0decff4e867b RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 603
diff changeset
190 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
191 check_task_finish(task, wait_queue);
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
192 }
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
193 }
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
194 }
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
195
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
196
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
197 /**
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
198 * # # # # # # # #
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
199 * Abstract Factory Pattern
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 */
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
202 #ifdef __CERIUM_FIFO__
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
203 TaskManagerImpl*
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
204 create_impl(int num)
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
205 {
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
206 return new FifoTaskManagerImpl();
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
207 }
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
208 #endif // __CERIUM_FIFO__
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
209