Mercurial > hg > Game > Cerium
annotate example/word_count/main.cc @ 1994:727e896269e9 draft
commit
author | Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp> |
---|---|
date | Mon, 21 Apr 2014 00:02:11 +0900 |
parents | 82e6eb0fa692 |
children | 9657434c21a4 |
rev | line source |
---|---|
1584 | 1 #include <stdio.h> |
393 | 2 #include <stdlib.h> |
3 #include <string.h> | |
4 #include <sys/mman.h> | |
5 #include <sys/types.h> | |
6 #include <sys/stat.h> | |
7 #include <fcntl.h> | |
8 #include <unistd.h> | |
1544
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
9 #include <sys/time.h> |
393 | 10 #include "TaskManager.h" |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
11 #include "SchedTask.h" |
393 | 12 #include "Func.h" |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
13 #include "WordCount.h" |
393 | 14 |
1268 | 15 /* ;TODO |
16 * PS3でCPU数が2以上の時に、あまりが計算されてない | |
17 */ | |
18 | |
400 | 19 extern void task_init(); |
1544
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
20 void TMend(TaskManager *); |
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
21 static double st_time; |
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
22 static double ed_time; |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
23 int all = 0; |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
24 int use_task_array = 1; |
1039
e8ef7f5f22f6
add TaskCreater test funciton..
yutaka@localhost.localdomain
parents:
1021
diff
changeset
|
25 int use_task_creater = 0; |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
26 int use_compat = 0; |
1799
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
27 int use_iterate = 0; |
1963
6988e5478a8c
fix CudaScheduler
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1962
diff
changeset
|
28 int array_task_num = 11; |
970
1a4849b2acad
change pipeline and TaskArray fast
Yutaka Kinjyo <yutaka@cr.ie.u-ryukyu.ac.jp>
parents:
968
diff
changeset
|
29 int spe_num = 1; |
1986
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
30 int read_type = MY_MMAP; |
1991 | 31 int t_exec_num = 4; |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
32 CPU_TYPE spe_cpu = SPE_ANY; |
1988 | 33 CPU_TYPE read_spe_cpu = IO_0; |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
34 |
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
35 const char *usr_help_str = "Usage: ./word_count [-a -c -s] [-cpu spe_num] [-g] [-file filename] [-br]\n"; |
1542
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
36 |
1544
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
37 static double |
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
38 getTime() { |
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
39 struct timeval tv; |
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
40 gettimeofday(&tv, NULL); |
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
41 return tv.tv_sec + (double)tv.tv_usec*1e-6; |
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
42 } |
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
43 |
393 | 44 typedef struct { |
45 caddr_t file_mmap; | |
46 off_t size; | |
47 } st_mmap_t; | |
48 | |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
49 static void |
1986
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
50 my_read(char *filename, WordCount *w) |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
51 { |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
52 /*マッピングだよ!*/ |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
53 struct stat sb; |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
54 long fd = w->fd; |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
55 |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
56 if ((fd=open(filename,O_RDONLY,0666))==0) { |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
57 fprintf(stderr,"can't open %s\n",filename); |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
58 } |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
59 |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
60 if (fstat(fd,&sb)) { |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
61 fprintf(stderr,"can't fstat %s\n",filename); |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
62 } |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
63 |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
64 //madvise(w->file_mmap, w->read_filesize, POSIX_MADV_NORMAL); |
1987
1420e4521b4a
implement my_read in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1986
diff
changeset
|
65 //w->file_mmap = (char*)mmap(NULL,w->read_filesize,PROT_READ,map,fd,(off_t)0); |
1420e4521b4a
implement my_read in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1986
diff
changeset
|
66 w->file_mmap = (char*)malloc(w->read_filesize); |
1420e4521b4a
implement my_read in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1986
diff
changeset
|
67 read(fd, w->file_mmap, w->read_filesize); |
1986
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
68 |
1987
1420e4521b4a
implement my_read in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1986
diff
changeset
|
69 if (w->file_mmap == (caddr_t)-1) { |
1986
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
70 fprintf(stderr,"Can't mmap file\n"); |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
71 perror(NULL); |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
72 exit(0); |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
73 } |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
74 |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
75 return ; |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
76 } |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
77 |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
78 static void |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
79 my_mmap(char *filename, WordCount *w) |
1913
53c074e60b08
restore some files
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1912
diff
changeset
|
80 { |
53c074e60b08
restore some files
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1912
diff
changeset
|
81 /*マッピングだよ!*/ |
53c074e60b08
restore some files
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1912
diff
changeset
|
82 int map = MAP_PRIVATE; |
53c074e60b08
restore some files
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1912
diff
changeset
|
83 st_mmap_t st_mmap; |
53c074e60b08
restore some files
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1912
diff
changeset
|
84 struct stat sb; |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
85 long fd = w->fd; |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
86 |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
87 if ((fd=open(filename,O_RDONLY,0666))==0) { |
1913
53c074e60b08
restore some files
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1912
diff
changeset
|
88 fprintf(stderr,"can't open %s\n",filename); |
393 | 89 } |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
90 |
1913
53c074e60b08
restore some files
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1912
diff
changeset
|
91 if (fstat(fd,&sb)) { |
53c074e60b08
restore some files
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1912
diff
changeset
|
92 fprintf(stderr,"can't fstat %s\n",filename); |
53c074e60b08
restore some files
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1912
diff
changeset
|
93 } |
1910
b7b528e9ec5e
Implement divide read in word_count ( but cannot running )
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1897
diff
changeset
|
94 |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
95 //madvise(w->file_mmap, w->read_filesize, POSIX_MADV_NORMAL); |
1991 | 96 w->file_mmap = (char*)mmap(NULL,w->read_filesize,PROT_WRITE|PROT_READ,map,fd,(off_t)0); |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
97 |
393 | 98 if (st_mmap.file_mmap == (caddr_t)-1) { |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
99 fprintf(stderr,"Can't mmap file\n"); |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
100 perror(NULL); |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
101 exit(0); |
393 | 102 } |
103 | |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
104 return ; |
1910
b7b528e9ec5e
Implement divide read in word_count ( but cannot running )
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1897
diff
changeset
|
105 } |
393 | 106 |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
107 static void |
1984
7bea670cdba0
divide read flag change enum type
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1981
diff
changeset
|
108 run_tasks(SchedTask *manager, WordCount *w, int task_count, HTaskPtr t_read, HTaskPtr t_next, int size) |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
109 { |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
110 |
1542
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
111 if (task_count < array_task_num) { |
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
112 array_task_num = task_count; |
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
113 if (task_count<=0) return; |
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
114 } |
1688
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
115 for (int i = 0; i < task_count; i += array_task_num) { |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
116 HTask *task_array; |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
117 if (use_task_array) { |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
118 int task_num = (w->size+size-1)/size; |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
119 if (task_num>array_task_num) task_num = array_task_num; |
1836
56692133c5fb
success run wordcount with gpu, but result is wrong
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1835
diff
changeset
|
120 task_array = manager->create_task_array(TASK_EXEC,task_num,1,1,1); |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
121 if (t_read != 0) task_array->wait_for(t_read); |
1688
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
122 if (!all) { |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
123 t_next->wait_for(task_array); |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
124 } else { |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
125 w->t_print->wait_for(task_array); |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
126 } |
1542
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
127 } |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
128 |
1688
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
129 Task *t_exec = 0; |
1542
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
130 HTask *h_exec = 0; |
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
131 for (int j = 0; j < array_task_num; j++) { |
1979
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
132 int i = w->task_spawned++; |
1542
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
133 if (w->size < size) size = w->size; |
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
134 if (size==0) break; |
1688
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
135 if (use_task_array) { |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
136 t_exec = task_array->next_task_array(TASK_EXEC,t_exec); |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
137 t_exec->set_inData(0,w->file_mmap + i*w->division_size, size); |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
138 t_exec->set_outData(0,w->o_data + i*w->out_size, w->division_out_size); |
1836
56692133c5fb
success run wordcount with gpu, but result is wrong
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1835
diff
changeset
|
139 t_exec->set_param(0,(long)size); |
1688
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
140 } else if (use_compat) { |
1542
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
141 h_exec = manager->create_task(TASK_EXEC); |
1688
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
142 h_exec->set_inData(0,w->file_mmap + i*w->division_size, size); |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
143 h_exec->set_outData(0,w->o_data + i*w->out_size, w->division_out_size); |
1913
53c074e60b08
restore some files
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1912
diff
changeset
|
144 |
1688
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
145 t_next->wait_for(h_exec); |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
146 |
1737 | 147 h_exec->set_cpu(spe_cpu); |
1542
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
148 h_exec->spawn(); |
1799
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
149 } else if (use_iterate) { |
1991 | 150 array_task_num = w->task_num; |
151 use_iterate = 0; | |
152 use_compat = 1; | |
153 | |
1799
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
154 w->size -= size*array_task_num; |
1991 | 155 if(w->size < 0) { |
156 array_task_num -= 1; | |
157 w->size += size; | |
158 } | |
1799
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
159 h_exec = manager->create_task(TASK_EXEC_DATA_PARALLEL); |
1897
606f6f6cb784
run wordcount used iterate
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1894
diff
changeset
|
160 h_exec->flip(); |
1799
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
161 h_exec->set_inData(0,w->file_mmap,w->file_size); |
1897
606f6f6cb784
run wordcount used iterate
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1894
diff
changeset
|
162 h_exec->set_inData(1,w->o_data,w->out_size_); |
606f6f6cb784
run wordcount used iterate
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1894
diff
changeset
|
163 h_exec->set_outData(0,w->file_mmap,w->file_size); |
606f6f6cb784
run wordcount used iterate
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1894
diff
changeset
|
164 h_exec->set_outData(1,w->o_data,w->out_size_); |
1799
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
165 h_exec->set_param(0,(long)i); |
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
166 h_exec->set_param(1,(long)w->division_size); |
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
167 h_exec->set_param(2,(long)size); |
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
168 h_exec->set_param(3,(long)w->out_size); |
1913
53c074e60b08
restore some files
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1912
diff
changeset
|
169 |
1799
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
170 t_next->wait_for(h_exec); |
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
171 h_exec->set_cpu(spe_cpu); |
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
172 h_exec->iterate(array_task_num); |
1913
53c074e60b08
restore some files
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1912
diff
changeset
|
173 |
1799
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
174 w->task_num -= array_task_num; |
1979
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
175 w->task_spawned += array_task_num-1; |
1913
53c074e60b08
restore some files
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1912
diff
changeset
|
176 |
1799
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
177 break; |
1542
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
178 } else { |
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
179 h_exec = manager->create_task(TASK_EXEC, |
1688
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
180 (memaddr)(w->file_mmap + i*w->division_size), size, |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
181 (memaddr)(w->o_data + i*w->out_size), w->division_out_size); |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
182 t_next->wait_for(h_exec); |
1737 | 183 h_exec->set_cpu(spe_cpu); |
1542
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
184 h_exec->spawn(); |
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
185 } |
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
186 w->size -= size; |
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
187 w->task_num--; |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
188 } |
1688
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
189 if (use_task_array) { |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
190 task_array->spawn_task_array(t_exec->next()); |
1737 | 191 task_array->set_cpu(spe_cpu); |
1688
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
192 task_array->spawn(); |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
193 } else { |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
194 //if (!all) t_next->wait_for(h_exec); |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
195 } |
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
196 } |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
197 } |
393 | 198 |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
199 /** |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
200 * このTaskは、PPE上で実行されるので、並列に実行されることはない |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
201 * 二つ実行されていて、Task が足りなくなることがないようにしている。 |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
202 */ |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
203 |
1979
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
204 SchedDefineTask1(BREAD_RUN_TASK_BLOCKS,bread_run16); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
205 |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
206 static int |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
207 bread_run16(SchedTask *manager, void *in, void *out) |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
208 { |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
209 WordCount *w = *(WordCount **)in; |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
210 |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
211 HTaskPtr t_read = manager->create_task(READ_TASK); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
212 w->t_print->wait_for(t_read); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
213 t_read->set_cpu(read_spe_cpu); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
214 t_read->set_param(0,w->fd); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
215 |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
216 if (w->task_num < w->task_blocks) { |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
217 t_read->set_param(1,w->task_spawned*w->division_size); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
218 t_read->set_outData(0, w->file_mmap + w->task_spawned * w->division_size, w->task_blocks * w->division_size); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
219 |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
220 // last case |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
221 while (w->size >= w->division_size) |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
222 run_tasks(manager,w,w->task_num,t_read,w->t_print, w->division_size); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
223 // remaining data |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
224 while (w->size>0) |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
225 run_tasks(manager,w,1,t_read,w->t_print, w->division_size); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
226 |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
227 t_read->set_param(2,w->task_spawned*w->division_size); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
228 t_read->spawn(); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
229 } else { |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
230 HTaskPtr t_next = manager->create_task(BREAD_RUN_TASK_BLOCKS, |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
231 (memaddr)&w->self,sizeof(memaddr),0,0); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
232 w->t_print->wait_for(t_next); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
233 |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
234 t_read->set_param(1,w->task_spawned*w->division_size); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
235 t_read->set_outData(0, w->file_mmap + w->task_spawned * w->division_size, w->task_blocks * w->division_size); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
236 |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
237 run_tasks(manager,w, w->task_blocks, t_read, t_next, w->division_size); |
1979
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
238 |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
239 t_read->set_param(2,w->task_spawned*w->division_size); |
1979
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
240 |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
241 t_read->spawn(); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
242 t_next->spawn(); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
243 } |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
244 return 0; |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
245 } |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
246 |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
247 SchedDefineTask1(RUN_TASK_BLOCKS,run16); |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
248 |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
249 static int |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
250 run16(SchedTask *manager, void *in, void *out) |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
251 { |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
252 WordCount *w = *(WordCount **)in; |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
253 |
1991 | 254 if(use_iterate) { |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
255 run_tasks(manager, w, w->task_num, 0, w->t_print, w->division_size); |
1897
606f6f6cb784
run wordcount used iterate
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1894
diff
changeset
|
256 } else if (w->task_num < w->task_blocks) { |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
257 // last case |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
258 while (w->size >= w->division_size) |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
259 run_tasks(manager,w,w->task_num,0,w->t_print, w->division_size); |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
260 // remaining data |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
261 while (w->size>0) |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
262 run_tasks(manager,w,1,0, w->t_print, w->size); |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
263 // printf("run16 last %d\n",w->task_num); |
949 | 264 } else { |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
265 HTaskPtr t_next = manager->create_task(RUN_TASK_BLOCKS, |
1542
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
266 (memaddr)&w->self,sizeof(memaddr),0,0); |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
267 w->t_print->wait_for(t_next); |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
268 |
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
269 run_tasks(manager,w, w->task_blocks,0, t_next, w->division_size); |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
270 |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
271 t_next->spawn(); |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
272 // printf("run16 next %d\n",w->task_num); |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
273 } |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
274 return 0; |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
275 } |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
276 |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
277 static int blocks = 48; |
1123 | 278 //static int blocks = 31 * 6 * 24; |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
279 static int division = 16; // in Kbyte |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
280 |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
281 static void |
400 | 282 run_start(TaskManager *manager, char *filename) |
393 | 283 { |
1979
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
284 long fd = (long)manager->allocate(sizeof(long)); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
285 struct stat *sb = (struct stat*)manager->allocate(sizeof(struct stat)); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
286 HTaskPtr t_exec; |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
287 |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
288 if ((fd=open(filename,O_RDONLY,0666))==0) { |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
289 fprintf(stderr,"can't open %s\n",filename); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
290 return ; |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
291 } |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
292 |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
293 if (fstat(fd,sb)) { |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
294 fprintf(stderr,"can't fstat %s\n",filename); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
295 return ; |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
296 } |
393 | 297 |
1979
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
298 WordCountPtr w = (WordCountPtr)manager->allocate(sizeof(WordCount)); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
299 |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
300 w->self = w; |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
301 w->fd = fd; |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
302 w->read_filesize = sb->st_size; |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
303 |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
304 |
1986
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
305 if (read_type == BLOCKED_READ) { |
1979
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
306 printf("[block read mode]\n"); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
307 w->file_mmap = (char*)manager->allocate(w->read_filesize); |
1986
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
308 }else if (read_type == MY_READ) { |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
309 printf("[single read mode]\n"); |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
310 my_read(filename, w); |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
311 }else if(read_type == MY_MMAP) { |
1979
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
312 printf("[mmap mode]\n"); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
313 my_mmap(filename, w); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
314 } |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
315 |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
316 HTaskPtr t_print; |
393 | 317 |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
318 //w->task_blocks = blocks; |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
319 w->self = w; |
1979
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
320 w->task_spawned = 0; |
393 | 321 |
1981 | 322 w->size = w->file_size = w->read_filesize; |
949 | 323 printf("w %lx\n",(long)w); |
1979
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
324 |
393 | 325 /* 1task分のデータサイズ(byte) */ |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
326 if (w->size >= 1024*division) { |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
327 w->division_size = 1024 * division;/*16kbyte*/ |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
328 } else { |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
329 w->division_size = w->size; |
393 | 330 } |
331 | |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
332 printf("division_size %ld\n",w->division_size); |
393 | 333 |
334 /* "word num" and "line num" */ | |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
335 w->status_num = 2; |
393 | 336 /* taskの数 */ |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
337 w->task_num = w->size / w->division_size; |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
338 w->task_num = w->task_num + (w->division_size*w->task_num < w->size); |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
339 int out_task_num = w->task_num; |
394 | 340 |
968 | 341 if(!all) { |
342 w->task_blocks = blocks; | |
343 } else { | |
344 w->task_blocks = w->task_num; | |
345 } | |
346 | |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
347 w->out_task_num = out_task_num; |
1979
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
348 printf("task_num %ld\n",w->task_num); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
349 printf("out_task_num %ld\n",w->out_task_num); |
394 | 350 |
1007 | 351 /* out用のdivision_size. statusが2つなので、あわせて16byteになるように、long long(4byte)を使用 */ |
393 | 352 |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
353 w->division_out_size = sizeof(unsigned long long)*4; |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
354 int out_size = w->division_out_size*out_task_num; |
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
355 w->o_data = (unsigned long long *)manager->allocate(out_size); |
1799
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
356 w->out_size_ = out_size; |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
357 w->out_size = 4; |
393 | 358 printf("out size %d\n",out_size); |
359 | |
360 /*各SPEの結果を合計して出力するタスク*/ | |
361 | |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
362 t_print = manager->create_task(TASK_PRINT, |
1542
9ccfdc408d51
fix gpu word count.but not count line num.
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1538
diff
changeset
|
363 (memaddr)&w->self,sizeof(memaddr),0,0); |
1913
53c074e60b08
restore some files
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1912
diff
changeset
|
364 w->t_print = t_print; |
1991 | 365 for(int i=0;i<t_exec_num;i++) { |
1783 | 366 /* Task を task_blocks ずつ起動する Task */ |
367 /* serialize されていると仮定する... */ | |
1986
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
368 if (read_type == BLOCKED_READ) { |
1979
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
369 t_exec = manager->create_task(BREAD_RUN_TASK_BLOCKS, |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
370 (memaddr)&w->self,sizeof(memaddr),0,0); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
371 }else { |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
372 t_exec = manager->create_task(RUN_TASK_BLOCKS, |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
373 (memaddr)&w->self,sizeof(memaddr),0,0); |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
374 } |
889472b0e6d5
implement blocked read (not running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1969
diff
changeset
|
375 |
1783 | 376 t_print->wait_for(t_exec); |
1799
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
377 // t_exec->iterate(4); |
1783 | 378 t_exec->spawn(); |
379 } | |
393 | 380 t_print->spawn(); |
381 } | |
382 | |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
383 static char* |
393 | 384 init(int argc, char **argv) |
385 { | |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
386 |
394 | 387 char *filename = 0; |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
388 |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
389 for (int i = 1; argv[i]; ++i) { |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
390 if (strcmp(argv[i], "-file") == 0) { |
1679
ff43dc274ec9
word_count fix for GPU
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1678
diff
changeset
|
391 filename = argv[i+1]; i++; |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
392 } else if (strcmp(argv[i], "-division") == 0) { |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
393 division = atoi(argv[i+1]); |
1679
ff43dc274ec9
word_count fix for GPU
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1678
diff
changeset
|
394 i++; |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
395 } else if (strcmp(argv[i], "-block") == 0) { |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
396 blocks = atoi(argv[i+1]); |
1679
ff43dc274ec9
word_count fix for GPU
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1678
diff
changeset
|
397 i++; |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
398 } else if (strcmp(argv[i], "-a") == 0) { |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
399 // create task all at once |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
400 all = 1; |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
401 } else if (strcmp(argv[i], "-c") == 0) { |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
402 use_task_array = 0; |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
403 use_compat = 1; |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
404 } else if (strcmp(argv[i], "-s") == 0) { |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
405 use_task_array = 0; |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
406 use_compat = 0; |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
407 } else if (strcmp(argv[i], "-t") == 0) { |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
408 use_task_creater = 1; |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
409 use_task_array = 0; |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
410 use_compat = 0; |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
411 } else if (strcmp(argv[i], "-anum") == 0) { |
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
412 array_task_num = atoi(argv[i+1]); |
1679
ff43dc274ec9
word_count fix for GPU
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1678
diff
changeset
|
413 i++; |
1894
b37dfbf3380d
fix GpuTaskManagerFactory
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1870
diff
changeset
|
414 } else if (strcmp(argv[i], "-g") == 0) { |
1941
f19885ea776d
add wordcount for cuda. fix CudaScheduler. add makefile
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1913
diff
changeset
|
415 spe_cpu = GPU_0; |
1894
b37dfbf3380d
fix GpuTaskManagerFactory
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1870
diff
changeset
|
416 } else if (strcmp(argv[i], "-any") == 0) { |
b37dfbf3380d
fix GpuTaskManagerFactory
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1870
diff
changeset
|
417 spe_cpu = ANY_ANY; |
1799
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
418 } else if (strcmp(argv[i], "-i") == 0) { |
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
419 use_iterate = 1; |
d9122ca02431
Exec wordcount by Data Parallel
Shohei KOKUBO <e105744@ie.u-ryukyu.ac.jp>
parents:
1783
diff
changeset
|
420 use_task_array = 0; |
1991 | 421 t_exec_num = 1; |
1980
aa5fabf2d4b2
remove error and warning (not perform check)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1979
diff
changeset
|
422 } else if (strcmp(argv[i], "-br") == 0) { |
1986
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
423 read_type = BLOCKED_READ; |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
424 } else if (strcmp(argv[i], "-r") == 0) { |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
425 read_type = MY_READ; |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
426 } |
c05e575da760
blocked read flag change enum tyoe in word_count
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
1984
diff
changeset
|
427 /* else if (strcmp(argv[i], "-cpu") == 0) { |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
428 spe_num = atoi(argv[i+1]); |
1679
ff43dc274ec9
word_count fix for GPU
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1678
diff
changeset
|
429 i++; |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
430 if (spe_num==0) spe_num = 1; |
1688
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
431 } else { |
1679
ff43dc274ec9
word_count fix for GPU
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1678
diff
changeset
|
432 fprintf(stderr,"%s\n",usr_help_str); |
ff43dc274ec9
word_count fix for GPU
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
1678
diff
changeset
|
433 exit (0); |
1688
705f09f646ac
remove spe_num roop
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1684
diff
changeset
|
434 }*/ |
393 | 435 } |
400 | 436 if (filename==0) { |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
437 puts(usr_help_str); |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
438 exit(1); |
400 | 439 } |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
440 |
393 | 441 return filename; |
442 } | |
443 | |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
444 |
393 | 445 int |
400 | 446 TMmain(TaskManager *manager, int argc, char *argv[]) |
393 | 447 { |
448 | |
394 | 449 char *filename = 0; |
450 filename = init(argc, argv); | |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
451 |
393 | 452 if (filename < 0) { |
1538
fac06524090b
add gpu task wordcount. But not work print
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1351
diff
changeset
|
453 return -1; |
393 | 454 } |
455 | |
456 task_init(); | |
1988 | 457 st_time = getTime(); |
400 | 458 run_start(manager, filename); |
1544
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
459 manager->set_TMend(TMend); |
393 | 460 return 0; |
461 } | |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
462 |
1544
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
463 void |
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
464 TMend(TaskManager *manager) |
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
465 { |
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
466 ed_time = getTime(); |
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
467 printf("Time: %0.6f\n",ed_time-st_time); |
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
468 } |
5c4e3f0d372a
many_task add task array
Yuhi TOMARI <yuhi@cr.ie.u-ryukyu.ac.jp>
parents:
1542
diff
changeset
|
469 |
946
852ed17d8af1
unify word count examples....
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
797
diff
changeset
|
470 /* end */ |