|
817
|
1 #include <stdlib.h>
|
|
|
2 #include "types.h"
|
|
|
3 #include "CpuThreads.h"
|
|
|
4 #include "MainScheduler.h"
|
|
|
5 #include "SysFunc.h"
|
|
|
6 #include "SchedNop.h"
|
|
1179
|
7 #include "SpeTaskManagerImpl.h"
|
|
817
|
8
|
|
1179
|
9 //SchedExternTask(ShowTime);
|
|
|
10 //SchedExternTask(StartProfile);
|
|
817
|
11
|
|
|
12
|
|
1181
|
13 CpuThreads::CpuThreads(int num, int start_id) : cpu_num(num), id_offset(start_id) {
|
|
|
14
|
|
|
15 threads = new pthread_t[cpu_num];
|
|
|
16 args = new cpu_thread_arg_t[cpu_num];
|
|
|
17
|
|
|
18 for (int i = 0; i < cpu_num; i++) {
|
|
|
19 args[i].cpuid = i + id_offset;
|
|
|
20 args[i].scheduler = new MainScheduler();
|
|
|
21 args[i].run = 0;
|
|
|
22 }
|
|
|
23
|
|
|
24 }
|
|
817
|
25
|
|
|
26 CpuThreads::~CpuThreads()
|
|
|
27 {
|
|
|
28 memaddr mail = (memaddr)MY_SPE_COMMAND_EXIT;
|
|
|
29
|
|
|
30 for (int i = 0; i < cpu_num; i++) {
|
|
|
31 send_mail(i, 1, &mail);
|
|
|
32 }
|
|
|
33
|
|
|
34 for (int i = 0; i < cpu_num; i++) {
|
|
1179
|
35 pthread_join(threads[i], NULL);
|
|
|
36 }
|
|
|
37
|
|
|
38 for (int i = 0; i < cpu_num; i++) {
|
|
|
39 delete args[i].scheduler;
|
|
817
|
40 }
|
|
|
41
|
|
|
42 delete [] threads;
|
|
|
43 delete [] args;
|
|
|
44 }
|
|
|
45
|
|
|
46 void *
|
|
|
47 CpuThreads::cpu_thread_run(void *args)
|
|
|
48 {
|
|
|
49 cpu_thread_arg_t *argt = (cpu_thread_arg_t *) args;
|
|
|
50 Scheduler *c_scheduler = argt->scheduler;
|
|
|
51
|
|
1179
|
52 TaskManagerImpl *manager = new SpeTaskManagerImpl();
|
|
|
53 c_scheduler->init(manager);
|
|
|
54 c_scheduler->id = (int)argt->cpuid;
|
|
817
|
55
|
|
1179
|
56 manager->set_scheduler(c_scheduler);
|
|
|
57
|
|
|
58 //SchedRegister(ShowTime);
|
|
|
59 //SchedRegister(StartProfile);
|
|
817
|
60
|
|
1181
|
61 argt->run = 1;
|
|
|
62
|
|
817
|
63 c_scheduler->run(new SchedNop());
|
|
|
64 c_scheduler->finish();
|
|
|
65
|
|
|
66 return NULL;
|
|
|
67 }
|
|
|
68
|
|
|
69 void
|
|
1179
|
70 //CpuThreads::init()
|
|
817
|
71 CpuThreads::init()
|
|
|
72 {
|
|
|
73 for (int i = 0; i < cpu_num; i++) {
|
|
1181
|
74 pthread_create(&threads[i], NULL,
|
|
|
75 &cpu_thread_run, (void*)&args[i]);
|
|
817
|
76 }
|
|
|
77
|
|
|
78 for (int i = 0; i < cpu_num; i++) {
|
|
1181
|
79 while (args[i].run == 0){
|
|
|
80 }
|
|
817
|
81 }
|
|
|
82 }
|
|
|
83
|
|
|
84 /**
|
|
|
85 * このCPU からのメールを受信する。
|
|
|
86 *
|
|
|
87 * @param [cpuid] SPE ID
|
|
|
88 *
|
|
|
89 * @return Received 32-bit mailbox messages
|
|
|
90 * if ([ret] < 0) no data read
|
|
|
91 */
|
|
|
92 int
|
|
|
93 CpuThreads::get_mail(int cpuid, int count, memaddr *ret)
|
|
|
94 {
|
|
|
95 // need synchronization
|
|
|
96 *ret = args[cpuid-id_offset].scheduler->mail_read_from_host();
|
|
|
97 return 1;
|
|
|
98 }
|
|
|
99
|
|
|
100 int
|
|
|
101 CpuThreads::has_mail(int cpuid, int count, memaddr *ret)
|
|
|
102 {
|
|
1181
|
103 if (args[cpuid-id_offset].scheduler->has_mail_from_host() != 0) {
|
|
|
104 return get_mail(cpuid,count,ret);
|
|
|
105 } else {
|
|
|
106 return 0; //mailがないとき0を返す
|
|
|
107 }
|
|
817
|
108 }
|
|
|
109
|
|
|
110 /**
|
|
|
111 * Inbound Mailbox
|
|
|
112 * メール送信 Front End -> CPU
|
|
|
113 *
|
|
|
114 * なるべく NONBLOCKING なんだけど、
|
|
|
115 * Inbound Mailbox キューに空きがないと送信できないので
|
|
|
116 * 送信する数だけ空いているか確認してから送る。空いて無い場合は待つ。
|
|
|
117 *
|
|
|
118 * 結局待つんだよな。しかも ALL_BLOCKING って実は busy wait だったりするし
|
|
|
119 *
|
|
|
120 * @param [cpuid] SPE ID
|
|
|
121 * @param [data] Send 32-bit mailbox messages
|
|
|
122 * @param [num] The number of messages
|
|
|
123 */
|
|
|
124 void
|
|
|
125 CpuThreads::send_mail(int cpuid, int num, memaddr *data)
|
|
|
126 {
|
|
|
127 args[cpuid-id_offset].scheduler->mail_write_from_host(*data);
|
|
|
128 }
|
|
|
129
|
|
1179
|
130 void
|
|
|
131 CpuThreads::add_output_tasklist(int command, memaddr buff, int alloc_size)
|
|
|
132 {
|
|
|
133 /*
|
|
|
134 * output TaskList が無ければ新しく作る
|
|
|
135 * あれば TaskList に allocate した Task を追加
|
|
|
136 * command に対応した Task の初期化を実行する
|
|
|
137 * SPE に data が書き出し終わった後に PPE 側で初期化
|
|
|
138 */
|
|
|
139
|
|
|
140 }
|
|
817
|
141
|
|
|
142 /* end */
|
