Mercurial > hg > Game > Cerium

annotate example/many_task/main.cc @ 1264:5153ce1b2001 draft

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
change option
author Daichi Toma <toma@cr.ie.u-ryukyu.ac.jp>
date Sat, 19 Nov 2011 14:35:03 +0900
parents 7823233584da
children a7895ab4d0e3
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
109
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
1 #include <stdio.h>
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
2 #include <string.h>
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
3 #include <stdlib.h>
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
4 #include <sys/time.h>
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
5 #include "TaskManager.h"
945
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
6 #include "SchedTask.h"
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
7
109
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
8 #include "Func.h"
220
gongo@localhost.localdomain
parents: 217
diff changeset
9 #include "sort.h"
109
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
10
945
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
11 extern void task_init();
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
12 extern int get_split_num(int len, int num);
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
13
109
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
14
220
gongo@localhost.localdomain
parents: 217
diff changeset
15 // sort.cc
gongo@localhost.localdomain
parents: 217
diff changeset
16 extern int data_length;
gongo@localhost.localdomain
parents: 217
diff changeset
17 extern DataPtr data;
935
11b19708e613 -a option for sort
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 934
diff changeset
18 extern int all;
11b19708e613 -a option for sort
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 934
diff changeset
19 int all = 0;
220
gongo@localhost.localdomain
parents: 217
diff changeset
20
945
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
21 static int sort_task = SortSimple;
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
22
220
gongo@localhost.localdomain
parents: 217
diff changeset
23 // 計測用
gongo@localhost.localdomain
parents: 217
diff changeset
24 static double st_time;
gongo@localhost.localdomain
parents: 217
diff changeset
25 static double ed_time;
gongo@localhost.localdomain
parents: 217
diff changeset
26
gongo@localhost.localdomain
parents: 217
diff changeset
27 static int length = 1200;
gongo@localhost.localdomain
parents: 217
diff changeset
28
gongo@localhost.localdomain
parents: 217
diff changeset
29 // prototype
400
984e7890db0c Fix examples.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 256
diff changeset
30 void TMend(TaskManager *);
220
gongo@localhost.localdomain
parents: 217
diff changeset
31
gongo@localhost.localdomain
parents: 217
diff changeset
32 static double
945
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
33 getTime()
220
gongo@localhost.localdomain
parents: 217
diff changeset
34 {
gongo@localhost.localdomain
parents: 217
diff changeset
35 struct timeval tv;
gongo@localhost.localdomain
parents: 217
diff changeset
36 gettimeofday(&tv, NULL);
gongo@localhost.localdomain
parents: 217
diff changeset
37 return tv.tv_sec + (double)tv.tv_usec*1e-6;
gongo@localhost.localdomain
parents: 217
diff changeset
38 }
256
2c775d229cc6 fix examples
tkaito@localhost.localdomain
parents: 230
diff changeset
39 /*
220
gongo@localhost.localdomain
parents: 217
diff changeset
40 static void
gongo@localhost.localdomain
parents: 217
diff changeset
41 show_data(void)
gongo@localhost.localdomain
parents: 217
diff changeset
42 {
gongo@localhost.localdomain
parents: 217
diff changeset
43 puts("-----------------------------------------------");
gongo@localhost.localdomain
parents: 217
diff changeset
44 for(int i = 0; i < data_length; i++) {
gongo@localhost.localdomain
parents: 217
diff changeset
45 printf("data[%02d].index = %d\n", i, data[i].index);
gongo@localhost.localdomain
parents: 217
diff changeset
46 }
gongo@localhost.localdomain
parents: 217
diff changeset
47 puts("-----------------------------------------------");
gongo@localhost.localdomain
parents: 217
diff changeset
48 }
256
2c775d229cc6 fix examples
tkaito@localhost.localdomain
parents: 230
diff changeset
49 */
109
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
50
256
2c775d229cc6 fix examples
tkaito@localhost.localdomain
parents: 230
diff changeset
51 const char *usr_help_str = "Usage: ./sort [option]\n \
217
gongo@localhost.localdomain
parents: 109
diff changeset
52 options\n\
gongo@localhost.localdomain
parents: 109
diff changeset
53 -cpu Number of SPE used (default 1)\n\
gongo@localhost.localdomain
parents: 109
diff changeset
54 -l, --length Sorted number of data (default 1200)\n\
gongo@localhost.localdomain
parents: 109
diff changeset
55 -h, --help Print this message";
109
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
56
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
57 int
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
58 init(int argc, char **argv)
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
59 {
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
60 for (int i = 1; argv[i]; ++i) {
217
gongo@localhost.localdomain
parents: 109
diff changeset
61 if (strcmp(argv[i], "--length") == 0 || strcmp(argv[i], "-l") == 0) {
220
gongo@localhost.localdomain
parents: 217
diff changeset
62 length = atoi(argv[++i]);
109
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
63 }
935
11b19708e613 -a option for sort
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 934
diff changeset
64 if (strcmp(argv[i], "-a") == 0 ) {
11b19708e613 -a option for sort
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 934
diff changeset
65 all = 1;
11b19708e613 -a option for sort
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 934
diff changeset
66 }
945
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
67 if (strcmp(argv[i], "-c") == 0 ) {
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
68 sort_task = SortCompat;
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
69 }
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
70 if (strcmp(argv[i], "-s") == 0 ) {
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
71 sort_task = SortSimple;
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
72 }
256
2c775d229cc6 fix examples
tkaito@localhost.localdomain
parents: 230
diff changeset
73
109
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
74 }
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
75
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
76 return 0;
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
77 }
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
78
945
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
79 Sort sorter;
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
80
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
81 static void
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
82 check_data()
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
83 {
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
84 for(int i=0; i< sorter.data_length-1;i++) {
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
85 if (sorter.data[i].index>sorter.data[i+1].index) {
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
86 printf("Data are not sorted at %d. %d > %d \n",i, sorter.data[i].index,sorter.data[i+1].index);
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
87 return;
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
88 }
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
89 }
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
90 printf("Data are sorted\n");
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
91 }
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
92
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
93
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
94 static void
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
95 sort_init(SchedTask *manager, void *a, void *b)
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
96 {
1079
7823233584da single cpu run on Mac OS X
one@zeus.cr.ie.u-ryukyu.ac.jp
parents: 945
diff changeset
97 sorter.cpuNum = (long)a;
7823233584da single cpu run on Mac OS X
one@zeus.cr.ie.u-ryukyu.ac.jp
parents: 945
diff changeset
98 long length = (long)b;
945
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
99
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
100 sorter.data = (DataPtr)manager->allocate(sizeof(Data)*length);
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
101 sorter.data_length = length;
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
102
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
103 sorter.split_num = get_split_num(sorter.data_length, sorter.cpuNum); // data の分割数
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
104 int half_num = sorter.split_num-1;
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
105 sorter.fsort = (HTaskPtr*)manager->allocate(sizeof(HTaskPtr)*sorter.split_num);
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
106 sorter.bsort = (HTaskPtr*)manager->allocate(sizeof(HTaskPtr)*half_num);
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
107 memset((void*)sorter.bsort,0, sizeof(HTaskPtr)*half_num);
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
108
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
109 for (int i = 0; i < length; i++) {
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
110 sorter.data[i].index = manager->get_random()%10000;
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
111 sorter.data[i].ptr = i;
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
112 }
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
113
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
114 HTaskPtr restart = manager->create_task(sort_task,0,0,0,0);
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
115 restart->set_param(0,(memaddr)&sorter);
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
116 restart->spawn();
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
117 }
9ed1c4a877ca sort example fix ( simple task accepts one param and more compatible with old task)
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 935
diff changeset
118
220
gongo@localhost.localdomain
parents: 217
diff changeset
119 unsigned int ts, te;
gongo@localhost.localdomain
parents: 217
diff changeset
120
109
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
121 int
400
984e7890db0c Fix examples.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 256
diff changeset
122 TMmain(TaskManager *manager, int argc, char *argv[])
109
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
123 {
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
124 if (init(argc, argv) < 0) {
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
125 return -1;
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
126 }
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
127
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
128 task_init();
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
129
674
07351a5a51c9 fix many task example (sort).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 400
diff changeset
130 int cpu = manager->get_cpuNum();
675
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 674
diff changeset
131
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 674
diff changeset
132 // in case of -cpu 0
674
07351a5a51c9 fix many task example (sort).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 400
diff changeset
133 if (cpu==0) cpu = 1;
932
53ad3a61b40b sort test (add swap())
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 675
diff changeset
134 if (1) {
53ad3a61b40b sort test (add swap())
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 675
diff changeset
135 HTask *dummy = manager->create_task(Dummy);
53ad3a61b40b sort test (add swap())
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 675
diff changeset
136 dummy->set_post(sort_init, (void*)cpu, (void*)length);
53ad3a61b40b sort test (add swap())
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 675
diff changeset
137 dummy->spawn();
53ad3a61b40b sort test (add swap())
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 675
diff changeset
138 } else {
53ad3a61b40b sort test (add swap())
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 675
diff changeset
139 sort_init(manager->get_schedTask(),(void*)cpu, (void*)length);
53ad3a61b40b sort test (add swap())
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 675
diff changeset
140 }
109
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
141
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
142 st_time = getTime();
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
143
227
e7faaf516be1 add sort
gongo@localhost.localdomain
parents: 220
diff changeset
144 // 全ての Task が終了した後に実行する関数をセット
220
gongo@localhost.localdomain
parents: 217
diff changeset
145 manager->set_TMend(TMend);
109
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
146
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
147 return 0;
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
148 }
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
149
220
gongo@localhost.localdomain
parents: 217
diff changeset
150 void
400
984e7890db0c Fix examples.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 256
diff changeset
151 TMend(TaskManager *manager)
109
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
152 {
220
gongo@localhost.localdomain
parents: 217
diff changeset
153 ed_time = getTime();
230
56314060907f fix Random
gongo@localhost.localdomain
parents: 227
diff changeset
154 //show_data();
934
83b64b7a51bd sort fix ( not working now )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 932
diff changeset
155 check_data();
220
gongo@localhost.localdomain
parents: 217
diff changeset
156 printf("Time: %0.6f\n",ed_time-st_time);
109
028ffc9c0375 Cerium cvs version
gongo@gendarme.local
parents:
diff changeset
157 }
674
07351a5a51c9 fix many task example (sort).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 400
diff changeset
158
07351a5a51c9 fix many task example (sort).
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 400
diff changeset
159 /* end */