annotate example/task_queue/main.cc @ 1584:4966029eeb32 draft

Fix
author Masa <e085726@ie.u-ryukyu.ac.jp>
date Sun, 31 Mar 2013 20:29:36 +0900
parents 8d6f7a42d134
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
492
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
1 #include <stdio.h>
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
2 #include <stdlib.h>
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
3 #include <string.h>
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
4 #include "TaskManager.h"
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
5 #include "Func.h"
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
6 #include "main.h"
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
7
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
8 extern void task_init(void);
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
9
961
efee36d2f84c fix QueueInfo
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 818
diff changeset
10 static int count = 10;
492
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
11
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
12 extern TaskManager *manager;
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
13
818
5d48fa762a24 too few template-parameter-lists
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
14 extern void queueInfoTest(int count);
5d48fa762a24 too few template-parameter-lists
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
15
961
efee36d2f84c fix QueueInfo
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 818
diff changeset
16 static QueueInfo<TaskQueue> *mainPool = new QueueInfo<TaskQueue>() ;
818
5d48fa762a24 too few template-parameter-lists
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
17
492
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
18 const char *usr_help_str = "Usage: ./hello [-cpu spe_num] [-count N]\n\
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
19 -cpu Number of SPE (default 1) \n\
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
20 -count Number of task is print \"Hello, World!!\"";
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
21
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
22 int
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
23 init(int argc, char **argv)
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
24 {
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
25 for (int i = 1; argv[i]; ++i) {
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
26 if (strcmp(argv[i], "-count") == 0) {
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
27 count = atoi(argv[++i]);
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
28 }
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
29
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
30 }
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
31
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
32 return 0;
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
33 }
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
34
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
35 Queues queues;
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
36
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
37 static void
619
278db3ca751d RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 496
diff changeset
38 repeat(SchedTask *s, void *arg, void *dm)
492
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
39 {
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
40 static int count = 4;
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
41 QueuePtr q = (QueuePtr) arg;
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
42 TaskManager *manager = q->m;
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
43
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
44 if (count-->0) {
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
45 HTask *t = manager->create_task(HELLO_TASK);
619
278db3ca751d RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 496
diff changeset
46 t->set_post(repeat, arg, 0);
625
94d82f2c842f 64bit mode worked on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 619
diff changeset
47 t->set_param(0,(memaddr)q->i);
94d82f2c842f 64bit mode worked on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 619
diff changeset
48 t->set_param(1,(memaddr)arg);
492
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
49 t->spawn();
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
50
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
51 printf("[PPE] Create Task : Hello count=%d id=%d\n\n",count, q->i);
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
52 } else {
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
53 printf("[PPE] End Task : Hello id=%d\n\n", q->i);
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
54 }
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
55 }
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
56
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
57 void
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
58 hello_init(TaskManager *manager)
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
59 {
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
60
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
61 if (count >MAX_QUEUE) return;
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
62
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
63 queues.m = manager;
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
64 queues.i = 0;
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
65 for (int i = 0; i < MAX_QUEUE; i++) {
961
efee36d2f84c fix QueueInfo
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 818
diff changeset
66 QueueInfo<TaskQueue> *q = new QueueInfo<TaskQueue>(mainPool) ;
962
8d6f7a42d134 QueueInfo fix
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 961
diff changeset
67 // QueueInfo<TaskQueue> *q = new QueueInfo<TaskQueue>() ; // wrong
492
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
68 queues.q[i] = q;
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
69 }
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
70
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
71 for (int i = 0; i < count; i++) {
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
72 /**
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
73 * Create Task
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
74 * create_task(Task ID);
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
75 */
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
76 HTask *hello = manager->create_task(HELLO_TASK);
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
77
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
78 /**
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
79 * Select CPU
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
80 * SPE_0, SPE_1, SPE_2, SPE_3, SPE_4, SPE_5, SPE_ANY
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
81 * if you do not call this, execute PPE.
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
82 */
496
67fb962f58fa PS3 double linked TaskQueue worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 492
diff changeset
83 hello->set_cpu(SPE_ANY);
492
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
84
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
85 /**
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
86 * Set 32bits parameter
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
87 * add_param(32bit parameter);
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
88 */
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
89 QueuePtr q = (QueuePtr) manager->allocate(sizeof(Queues));
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
90
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
91 q->i = i;
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
92 q->m = manager;
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
93 for (int j = 0; j < MAX_QUEUE; j++) {
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
94 q->q[j] = queues.q[j];
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
95 }
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
96
625
94d82f2c842f 64bit mode worked on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 619
diff changeset
97 hello->set_param(0,(memaddr)i);
94d82f2c842f 64bit mode worked on Mac OS X.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 619
diff changeset
98 hello->set_param(1,(memaddr)&queues);
619
278db3ca751d RenewTask removal
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 496
diff changeset
99 hello->set_post(repeat, (void*) &queues, 0);
492
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
100
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
101 hello->spawn();
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
102 }
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
103 }
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
104
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
105 int
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
106 TMmain(TaskManager *manager, int argc, char *argv[])
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
107 {
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
108 if (init(argc, argv) < 0) {
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
109 return -1;
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
110 }
961
efee36d2f84c fix QueueInfo
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 818
diff changeset
111 if (count<2) count = 2;
492
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
112
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
113 // Task Register
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
114 // ppe/task_init.cc
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
115 task_init();
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
116
818
5d48fa762a24 too few template-parameter-lists
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 625
diff changeset
117 queueInfoTest(count);
492
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
118 hello_init(manager);
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
119
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
120 return 0;
6b2dda81ea9d memcpy for param
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
diff changeset
121 }