Mercurial > hg > Game > Cerium

annotate example/fileread/main.cc @ 1866:7b3aa1a31c3a draft

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix ( cannot wait for run16 )
author Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
date Wed, 25 Dec 2013 02:13:28 +0900
parents a009522ed6c6
children 7706faa6b0c9 14225fec047c
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
1 #include <stdio.h>
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
2 #include <stdlib.h>
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
3 #include <string.h>
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
4 #include <sys/stat.h>
1722
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
5 #include <sys/time.h>
1864
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
6 #include <sys/types.h>
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
7 #include <sys/mman.h>
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
8 #include "TaskManager.h"
1827
d1212026e2a0 some fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1825
diff changeset
9 #include "SchedTask.h"
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
10 #include "Func.h"
1865
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
11 #include "FileRead.h"
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
12
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
13 extern void task_init(void);
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
14
1722
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
15 static double st_time;
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
16 static double ed_time;
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
17 static int spe_num = 1;
1864
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
18 int divide_read_flag = 0;
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
19 static CPU_TYPE spe_cpu = SPE_ANY;
1808
c25aa7edd1ba fix conditional branch in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1802
diff changeset
20 static int DIVISION_SIZE = 4096 * 4;
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
21
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
22 extern TaskManager *manager;
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
23 const char *usr_help_str = "Usage: ./fileread [-cpu cpu_num] [-file filename]\n\
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
24 -cpu Number of SPE (default 1) \n\
1722
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
25 -file Opne file\n";
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
26
1864
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
27 typedef struct {
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
28 caddr_t file_mmap;
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
29 off_t size;
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
30 } st_mmap_t;
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
31
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
32 SchedDefineTask1(RUN_BLOCKS,run16);
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
33
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
34 static int
1827
d1212026e2a0 some fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1825
diff changeset
35 run16(SchedTask *manager, void *in, void *out) {
1825
82c2b9eec625 remove error and warning fileread(but cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1824
diff changeset
36
1865
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
37 FileReadPtr fr = (FileReadPtr)in;
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
38 HTaskPtr wait;
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
39
1827
d1212026e2a0 some fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1825
diff changeset
40 for (int i = 0; (fr->left_size > 0) && (i < fr->task_blocks); i++) {
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
41 HTaskPtr read = manager->create_task(Read_task);
1825
82c2b9eec625 remove error and warning fileread(but cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1824
diff changeset
42 read->set_cpu(fr->cpu);
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
43
1828
f0dab5fffe7a cannot running probrem resolve in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1827
diff changeset
44 if (i == fr->task_blocks / 2) wait = read;
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
45
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
46 read->set_param(0,(long)fr->task_number); //生成するTaskが何番目か
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
47 read->set_param(1,(long)fr->division_size); //1つのタスクが読み込む量
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
48 if(fr->left_size <= fr->division_size){
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
49 read->set_param(2,(long)fr->left_size);
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
50 }else{
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
51 read->set_param(2,(long)fr->division_size);
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
52 }
1840
0305732326ca change *fd to fd & change set_inData to set_param
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1828
diff changeset
53 read->set_param(3,(long)fr->fd); //fdの番号の受け渡し
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
54 read->spawn();
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
55
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
56 fr->left_size -= fr->division_size;
1827
d1212026e2a0 some fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1825
diff changeset
57 fr->task_number++;
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
58 }
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
59
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
60 if (fr->left_size > 0) {
1825
82c2b9eec625 remove error and warning fileread(but cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1824
diff changeset
61 HTaskPtr next = manager->create_task(RUN_BLOCKS, (memaddr)&fr->self, sizeof(memaddr),0,0);
82c2b9eec625 remove error and warning fileread(but cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1824
diff changeset
62 next->wait_for(wait);
82c2b9eec625 remove error and warning fileread(but cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1824
diff changeset
63 next->spawn();
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
64 }
1825
82c2b9eec625 remove error and warning fileread(but cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1824
diff changeset
65 return 0;
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
66 }
1722
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
67
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
68 static double
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
69 getTime(){
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
70 struct timeval tv;
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
71 gettimeofday(&tv,NULL);
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
72 return tv.tv_sec + (double)tv.tv_usec*1e-6;
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
73 }
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
74
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
75 void
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
76 TMend(TaskManager *manager)
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
77 {
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
78 ed_time = getTime();
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
79 printf("Time: %0.6f\n",ed_time-st_time);
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
80 }
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
81
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
82
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
83 static char*
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
84 init(int argc, char **argv)
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
85 {
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
86
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
87 char *filename = 0;
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
88
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
89 for (int i = 1; argv[i]; ++i) {
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
90 if (strcmp(argv[i], "-cpu") == 0) {
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
91 spe_num = atoi(argv[i+1]);
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
92 } else if (strcmp(argv[i], "-file") == 0) {
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
93 filename = argv[i+1];
1864
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
94 } else if (strcmp(argv[i], "-dr") == 0) {
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
95 divide_read_flag = 1;
1740
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1722
diff changeset
96 }
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
97 }
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
98
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
99 if (filename==0){
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
100 puts(usr_help_str);
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
101 exit(1);
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
102 }
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
103
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
104 return filename;
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
105 }
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
106
1864
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
107
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
108 SchedDefineTask1(MMAP,my_mmap);
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
109
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
110 static int
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
111 my_mmap(SchedTask *s, void *in, void *out)
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
112 {
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
113
1865
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
114 FileReadPtr fr = (FileReadPtr)in;
1864
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
115 /*マッピングだよ!*/
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
116
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
117 int map = MAP_PRIVATE;
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
118 st_mmap_t st_mmap;
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
119
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
120 int fd = fr->fd;
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
121 st_mmap.size = fr->filesize;
1866
7b3aa1a31c3a fix ( cannot wait for run16 )
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1865
diff changeset
122 fr->read_text = (char*)mmap(NULL,st_mmap.size,PROT_READ,map,fd,(off_t)0);
1864
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
123 if (st_mmap.file_mmap == (caddr_t)-1) {
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
124 fprintf(stderr,"Can't mmap file\n");
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
125
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
126 perror(NULL);
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
127 exit(0);
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
128 }
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
129
1866
7b3aa1a31c3a fix ( cannot wait for run16 )
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1865
diff changeset
130 printf("in mmap mode\n");
1864
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
131 return 0;
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
132 }
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
133
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
134
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
135 static void
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
136 run_start(TaskManager *manager,char *filename)
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
137 {
1840
0305732326ca change *fd to fd & change set_inData to set_param
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1828
diff changeset
138 long fd = (long)manager->allocate(sizeof(long));
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
139 struct stat *sb = (struct stat*)manager->allocate(sizeof(struct stat));
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
140
1840
0305732326ca change *fd to fd & change set_inData to set_param
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1828
diff changeset
141 if ((fd=open(filename,O_RDONLY,0666))==0) {
1827
d1212026e2a0 some fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1825
diff changeset
142 fprintf(stderr,"can't open %s\n",filename);
1740
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1722
diff changeset
143 }
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
144
1840
0305732326ca change *fd to fd & change set_inData to set_param
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1828
diff changeset
145 if (fstat(fd,sb)) {
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
146 fprintf(stderr,"can't fstat %s\n",filename);
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
147 }
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
148
1865
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
149 FileReadPtr fr = (FileReadPtr)manager->allocate(sizeof(FileRead));
1802
e08f6133f5d7 change iterator to spawn in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1740
diff changeset
150
1861
9e96c8c52574 some fix in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1840
diff changeset
151 fr->self = fr;
1827
d1212026e2a0 some fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1825
diff changeset
152 fr->fd = fd;
d1212026e2a0 some fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1825
diff changeset
153 fr->cpu = spe_cpu;
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
154 fr->task_blocks = 16;
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
155 fr->filesize = sb->st_size;
1825
82c2b9eec625 remove error and warning fileread(but cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1824
diff changeset
156 fr->left_size = fr->filesize;
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
157 fr->division_size = DIVISION_SIZE;
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
158 fr->task_num = fr->filesize / DIVISION_SIZE;
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
159 fr->task_num += ((fr->filesize % DIVISION_SIZE) != 0);
1802
e08f6133f5d7 change iterator to spawn in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1740
diff changeset
160
1825
82c2b9eec625 remove error and warning fileread(but cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1824
diff changeset
161 printf("filesize : %ld\n",fr->filesize);
82c2b9eec625 remove error and warning fileread(but cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1824
diff changeset
162 printf("one_task_size: %ld\n",fr->division_size);
82c2b9eec625 remove error and warning fileread(but cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1824
diff changeset
163 printf("task_num : %ld\n",fr->task_num);
1740
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1722
diff changeset
164
1865
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
165 HTaskPtr run = NULL;
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
166 HTaskPtr t_print = manager->create_task(Print_task, (memaddr)&fr->self, sizeof(memaddr),0,0);
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
167
1864
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
168 if (divide_read_flag != 0) {
1865
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
169 run = manager->create_task(RUN_BLOCKS, (memaddr)&fr->self, sizeof(memaddr),fr->read_text,fr->filesize);
1864
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
170 }else {
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
171 //my_mmap(filename, fd, fr);
1866
7b3aa1a31c3a fix ( cannot wait for run16 )
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1865
diff changeset
172 run = manager->create_task(MMAP , (memaddr)&fr->self, sizeof(memaddr),0,0);
1864
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
173 }
1865
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
174 t_print->wait_for(run);
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
175 run->spawn();
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
176
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
177 t_print->spawn();
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
178 }
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
179
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
180
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
181 int
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
182 TMmain(TaskManager *manager, int argc, char *argv[])
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
183 {
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
184 char *filename = 0;
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
185 filename = init(argc,argv);
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
186
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
187 if (filename < 0) {
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
188 return -1;
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
189 }
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
190
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
191 task_init();
1722
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
192 st_time = getTime();
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
193 run_start(manager, filename);
1722
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
194 manager->set_TMend(TMend);
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
195
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
196 return 0;
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
197 }