1178
|
1 #include <stdio.h>
|
|
2 #include "TaskManager/CpuThreads.h"
|
1179
|
3 #include "TaskManager/CellTaskManagerImpl.h"
|
1178
|
4
|
|
5 static void
|
1182
|
6 fail(const char *reason)
|
|
7 {
|
|
8 printf("CpuThreadTest failed %s", reason);
|
|
9 }
|
|
10
|
|
11 static void
|
1189
|
12 tester(CpuThreads* c, int num, int size)
|
1182
|
13 {
|
|
14 for(int id = 0; id < num; id++){
|
|
15 for(int i = 0; i < size; i++) {
|
|
16 c->send_mail(id, 1, (memaddr *) i); //mailqueue1に書き込む
|
|
17 }
|
|
18 }
|
|
19
|
|
20 for(int id = 0; id < num; id++){
|
|
21 for(int i = 0; i < size; i++) {
|
|
22 memaddr data;
|
|
23 if (c->has_mail(id, 1, &data) == 0) {
|
|
24 fail("early read fail\n");
|
|
25 break;
|
|
26 }
|
|
27 if (data != (memaddr)i) {
|
|
28 fail("read data fail\n");
|
|
29 break;
|
|
30 }
|
|
31 }
|
|
32 }
|
|
33 }
|
|
34
|
|
35 static void
|
1178
|
36 test1() {
|
1179
|
37 int num = 1;
|
1189
|
38 CpuThreads* c = new CpuThreads(num);
|
1179
|
39 c->init();
|
1182
|
40 tester(c,num,16);
|
1179
|
41 delete c;
|
1178
|
42 }
|
|
43
|
|
44 int
|
|
45 main(int ac, const char *av[])
|
|
46 {
|
|
47 test1();
|
|
48 printf("CpuThreads succeed\n");
|
|
49 }
|
|
50
|
|
51 /* end */
|