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