Mercurial > hg > Members > kono > Cerium

annotate TaskManager/Fifo/FifoTaskManagerImpl.cc @ 721:2b167196cb27

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
cleanups..
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Sat, 19 Dec 2009 12:12:09 +0900
parents cafffff0f45a
children 31d0a5baafdf
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"
703
61b59376aec5 compatibility
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 685
diff changeset
10 #include "SysFunc.h"
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
11
721
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
12 // static void send_alloc_reply(FifoTaskManagerImpl *tm, int id, MainScheduler *s);
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
13
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
14 FifoTaskManagerImpl::~FifoTaskManagerImpl()
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
15 {
640
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
16 delete mainScheduler;
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
17
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
18 delete taskListImpl ;
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
19 delete taskQueueImpl ;
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
20 delete htaskImpl ;
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
21
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
22 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
23
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
24 /**
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
25 * MailManager は PPE スケジューラとのメール交換、
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
26 * FifoScheduler は PPE 側のスケジューラ
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
27 * BufferManager は Task、TaskList などのメモリ管理(大層なことしてないが
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
28 */
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
29 void
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
30 FifoTaskManagerImpl::init()
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
31 {
719
cafffff0f45a clean up scheduler main loop
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 713
diff changeset
32 // TaskManager から呼ばれるので、かなりの部分は初期化されている。
cafffff0f45a clean up scheduler main loop
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 713
diff changeset
33
640
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
34 mainScheduler = new MainScheduler();
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
35 mainScheduler->init(this);
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
36 mainScheduler->id = 0;
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
37 set_scheduler(mainScheduler);
42
aa11038dbdc1 *** empty log message ***
gongo
parents: 22
diff changeset
38
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
39 taskListImpl = new TaskListInfo;
719
cafffff0f45a clean up scheduler main loop
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 713
diff changeset
40 // taskQueueImpl = new TaskQueueInfo;
cafffff0f45a clean up scheduler main loop
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 713
diff changeset
41 // htaskImpl = new HTaskInfo();
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
42
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
43 mainTaskList = taskListImpl->create();
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
44
619
0decff4e867b RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 603
diff changeset
45 schedTaskManager = new SchedTask();
640
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
46 schedTaskManager->init(0,0,0,mainScheduler);
619
0decff4e867b RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 603
diff changeset
47
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
48 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
49
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
50 /**
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
51 * これは CellTaskManagerImpl から呼ばれる。
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
52 * TaskList等 は共用で使うので引数に。
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
53 * CellTaskManagerImpl と FifoTaskManagerImpl が同時に
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
54 * 上のデータにアクセスする事は(今は)ないのでこれでおk
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
55 */
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
56 void
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
57 FifoTaskManagerImpl::init(MainScheduler *_sched, TaskManagerImpl *tm)
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
58 {
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
59
640
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
60 mainScheduler = _sched;
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
61 mainScheduler->init(this);
a909c50081c2 SimpeTask on Cell worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 638
diff changeset
62 set_scheduler(mainScheduler);
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 taskListImpl = tm-> taskListImpl ;
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
65 taskQueueImpl = tm-> taskQueueImpl ;
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
66 htaskImpl = tm-> htaskImpl ;
719
cafffff0f45a clean up scheduler main loop
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 713
diff changeset
67 waitTaskQueue = tm->waitTaskQueue;
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
68
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
69 mainTaskList = taskListImpl->create();
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
70
674
bde5f13adf10 fix many task example (sort).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 673
diff changeset
71 schedTaskManager = new SchedTask();
bde5f13adf10 fix many task example (sort).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 673
diff changeset
72 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
73
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
74 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
75
721
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
76 // void FifoTaskManagerImpl::show_profile() {}
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
77 // void FifoTaskManagerImpl::start_profile() {}
672
3b6290c05f9f add profiling code
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 664
diff changeset
78
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
79 /**
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
80 * スケジューラに渡す TaskList を取得する。
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
81 *
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
82 * @return 実行タスクリスト
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
83 *
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
84 * ActiveTaskQueue (依存条件は満たし済み) のタスクを
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
85 * 実行タスクリストに入れる
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
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
88 FifoTaskManagerImpl::get_runTaskList()
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
89 {
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
90 TaskListPtr list, list_top;
664
7405d92733a8 word count
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 648
diff changeset
91 SimpleTaskPtr task; // Task (SPE に送る Task)
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
92
480
46464727d825 TaskQueueInfo initiaization...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 479
diff changeset
93 if (activeTaskQueue->empty()) {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
94 return NULL;
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
95 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
96
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
97 // PPE 側で実行される TaskList
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
98 list_top = mainTaskList;
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
99
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
100 // list_top->clear() とかの方がいいかもしれん。
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
101 list_top = taskListImpl->clear_taskList(list_top);
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
102 list = list_top;
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
103
499
eacbcdb23986 still fixing...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 498
diff changeset
104 // 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
105 while (HTaskPtr htask = activeTaskQueue->poll()) {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
106 task = &list->tasks[list->length++];
713
f725c6455d19 remove SIMPLE_TASK conditional
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 704
diff changeset
107
704
6d497c098455 Compatibility mode works.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 703
diff changeset
108 if (htask->command==TaskArray1) {
703
61b59376aec5 compatibility
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 685
diff changeset
109 // compatibility
704
6d497c098455 Compatibility mode works.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 703
diff changeset
110 int next = (htask->r_size+sizeof(SimpleTask))/sizeof(SimpleTask);
703
61b59376aec5 compatibility
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 685
diff changeset
111 if (list->length+next>=TASK_MAX_SIZE) {
61b59376aec5 compatibility
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 685
diff changeset
112 list->length--;
61b59376aec5 compatibility
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 685
diff changeset
113 TaskListPtr newList = taskListImpl->create();
61b59376aec5 compatibility
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 685
diff changeset
114 list_top = TaskListInfo::append(list_top, newList);
61b59376aec5 compatibility
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 685
diff changeset
115 list = newList;
61b59376aec5 compatibility
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 685
diff changeset
116 task = &list->tasks[list->length++];
61b59376aec5 compatibility
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 685
diff changeset
117 }
61b59376aec5 compatibility
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 685
diff changeset
118 Task *array = (Task*)&list->tasks[list->length];
61b59376aec5 compatibility
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 685
diff changeset
119 list->length += next;
704
6d497c098455 Compatibility mode works.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 703
diff changeset
120 memcpy(array, htask->rbuf, htask->r_size);
6d497c098455 Compatibility mode works.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 703
diff changeset
121 free(htask->rbuf);
6d497c098455 Compatibility mode works.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 703
diff changeset
122 htask->rbuf = 0; htask->r_size = 0;
703
61b59376aec5 compatibility
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 685
diff changeset
123 *task = *(SimpleTask*)htask;
61b59376aec5 compatibility
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 685
diff changeset
124 } else {
61b59376aec5 compatibility
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 685
diff changeset
125 *task = *(SimpleTask*)htask;
61b59376aec5 compatibility
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 685
diff changeset
126 }
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
127 if (list->length >= TASK_MAX_SIZE) {
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
128 TaskListPtr newList = taskListImpl->create();
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
129 list_top = TaskListInfo::append(list_top, newList);
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
130 list = newList;
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
131 }
499
eacbcdb23986 still fixing...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 498
diff changeset
132 // activeTaskQueue->free_(htask); ここで free しないで、
eacbcdb23986 still fixing...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 498
diff changeset
133 // mail を待つ
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
134 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
135
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
136 mainTaskList = list_top;
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
137
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
138 return list_top;
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
139 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
140
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
141
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
142 void
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
143 FifoTaskManagerImpl::run()
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
144 {
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
145 TaskListPtr list;
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
146
721
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
147 while((list = get_runTaskList())) {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
148 // list を実行する
721
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
149 sendTaskList(list);
647
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
150 // ppe scheduler からの mail を調べる
719
cafffff0f45a clean up scheduler main loop
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 713
diff changeset
151 mail_check();
721
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
152 }
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
153 if (!waitTaskQueue->empty()) {
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
154 fprintf(stderr,"Dead lock detected\n");
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
155 }
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
156 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
157
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
158 /**
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
159 * @param [list] 実行タスクリスト
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
160 * @return FifoScheduler からのメール
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
161 *
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
162 * [Tasklist] -> [番兵] -> scheduler->run を抜ける
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
163 */
647
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
164 void
721
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
165 FifoTaskManagerImpl::sendTaskList(TaskListPtr list)
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
166 {
721
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
167 // TaskList のアドレスを送る
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
168 mainScheduler->mail_write_from_host((memaddr)list);
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
169
721
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
170 // EXIT_COMMAND (番兵的な意味で)
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
171 // これを読むと、mainScheduler->run() から抜けて来る。
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
172 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
173
721
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
174 // scheduler は受け取ったメールを元に実行する
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
175 mainScheduler->run(new SchedNop());
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
176 // すべてのlistを実行するまで戻らない
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
177 }
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
178
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
179 /**
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
180 * PPE Scheduler からのメールをチェックする
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
181 *
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
182 * @param [mail_list]
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
183 * PPE 側で動く Scheduler からのメールリスト
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
184 * 終了した Task や、その他(今はまだ実装してないけど)の情報が入ってる
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
185 *
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
186 * @return Scheduler が次に実行する Task List
321
f64d75473f95 merge 317
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 318
diff changeset
187 * NULL なら全てのタスクが実行終了したということ
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
188 */
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
189 void
719
cafffff0f45a clean up scheduler main loop
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 713
diff changeset
190 FifoTaskManagerImpl::mail_check()
485
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 481
diff changeset
191 {
647
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
192 while (mainScheduler->has_mail_from_host()) {
7c9ded1ea750 MailManager rewrite. not yet worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 644
diff changeset
193 memaddr data = mainScheduler->mail_read_from_host();
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
194
625
60aa3f241b10 64bit mode worked on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 619
diff changeset
195 if (data == (memaddr)MY_SPE_STATUS_READY) {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
196 __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
197 } 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
198 __debug_ppe("mail_check(): Task List finish COMMAND\n");
721
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
199 } else if (data == (memaddr)MY_SPE_COMMAND_MALLOC) {
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
200 // MY_SPE_COMMAND_MALLOC PPE からのmain memory request
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
201 // 本来は呼ばれないはず...
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
202 fprintf(stderr, "error: MY_SPE_COMMAND_MALLOC from PPE\n");
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
203 // send_alloc_reply(this, 0, mainScheduler);
625
60aa3f241b10 64bit mode worked on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 619
diff changeset
204 } else if (data != (memaddr)MY_SPE_NOP) {
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
205 __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
206 // post_func を先に実行しないと、systask_finish が active_queue
0decff4e867b RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 603
diff changeset
207 // 移されてから、wait_for されるという事態が起きることがある。
0decff4e867b RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 603
diff changeset
208 HTaskPtr task = (HTaskPtr)data;
0decff4e867b RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 603
diff changeset
209 task->post_func(schedTaskManager, task->post_arg1, task->post_arg2);
719
cafffff0f45a clean up scheduler main loop
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 713
diff changeset
210 check_task_finish(task, waitTaskQueue);
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
211 }
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
212 }
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
213 }
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
214
721
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
215 #if 0
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
216 static void
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
217 send_alloc_reply(FifoTaskManagerImpl *tm, int id, MainScheduler *s)
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
218 {
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
219 /**
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
220 * info[0] = alloc_id; (CellScheduler::mainMem_alloc 参照)
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
221 * info[1] = alloc_addr;
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
222 */
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
223 memaddr alloc_info[2];
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
224 long alloc_size;
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
225 long command;
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
226
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
227 alloc_info[0] = s->mail_read_from_host();
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
228 alloc_info[1] = s->mail_read_from_host();
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
229 command = (long)alloc_info[0];
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
230 alloc_size = (long)alloc_info[1];
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
231
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
232 alloc_info[1] = (memaddr)tm->allocate(alloc_size);
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
233
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
234 s->mail_write_from_host(alloc_info[0]);
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
235 s->mail_write_from_host(alloc_info[1]);
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
236 }
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
237 #endif
2b167196cb27 cleanups..
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 719
diff changeset
238
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
239
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
240 /**
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
241 * # # # # # # # #
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
242 * Abstract Factory Pattern
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
243 * # # # # # # #
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
244 */
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
245 #ifdef __CERIUM_FIFO__
373
eab18aa0c7f6 MemList not working
kazz@kazzone.cr.ie.u-ryukyu.ac.jp
parents: 321
diff changeset
246 TaskManagerImpl*
3
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
247 create_impl(int num)
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
248 {
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
249 return new FifoTaskManagerImpl();
2356238ebea7 *** empty log message ***
gongo
parents:
diff changeset
250 }
109
5c194c71eca8 Cerium cvs version
gongo@gendarme.local
parents: 58
diff changeset
251 #endif // __CERIUM_FIFO__
475
e083c4ff91c1 BufferManager removed.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 373
diff changeset
252