Mercurial > hg > Game > Cerium

annotate example/fileread/main.cc @ 1865:a009522ed6c6 draft

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add FileRead.h
author Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
date Tue, 24 Dec 2013 23:52:54 +0900
parents 7211816380bd
children 7b3aa1a31c3a
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
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
47 read->set_param(0,(long)fr->task_number); //生成するTaskが何番目か
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
48 read->set_param(1,(long)fr->division_size); //1つのタスクが読み込む量
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
49 if(fr->left_size <= fr->division_size){
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
50 read->set_param(2,(long)fr->left_size);
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
51 }else{
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
52 read->set_param(2,(long)fr->division_size);
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
53 }
1840
0305732326ca change *fd to fd & change set_inData to set_param
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1828
diff changeset
54 read->set_param(3,(long)fr->fd); //fdの番号の受け渡し
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
55 read->spawn();
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
56
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
57 fr->left_size -= fr->division_size;
1827
d1212026e2a0 some fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1825
diff changeset
58 fr->task_number++;
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
59 }
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
60
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
61 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
62 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
63 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
64 next->spawn();
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
65 }
1825
82c2b9eec625 remove error and warning fileread(but cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1824
diff changeset
66 return 0;
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
67 }
1722
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
68
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
69 static double
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
70 getTime(){
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
71 struct timeval tv;
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
72 gettimeofday(&tv,NULL);
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
73 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
74 }
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
75
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
76 void
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
77 TMend(TaskManager *manager)
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
78 {
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
79 ed_time = getTime();
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
80 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
81 }
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
82
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
83
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
84 static char*
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
85 init(int argc, char **argv)
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
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
88 char *filename = 0;
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
89
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
90 for (int i = 1; argv[i]; ++i) {
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
91 if (strcmp(argv[i], "-cpu") == 0) {
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
92 spe_num = atoi(argv[i+1]);
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
93 } else if (strcmp(argv[i], "-file") == 0) {
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
94 filename = argv[i+1];
1864
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
95 } 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
96 divide_read_flag = 1;
1740
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1722
diff changeset
97 }
1721
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
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
100 if (filename==0){
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
101 puts(usr_help_str);
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
102 exit(1);
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
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
105 return filename;
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
106 }
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
107
1864
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
108
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
109 SchedDefineTask1(MMAP,my_mmap);
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
110
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
111 static int
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
112 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
113 {
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
114
1865
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
115 FileReadPtr fr = (FileReadPtr)in;
1864
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
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
118 int map = MAP_PRIVATE;
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
119 st_mmap_t st_mmap;
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
120
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
121 int fd = fr->fd;
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
122 st_mmap.size = fr->filesize;
1865
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
123 out = 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
124 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
125 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
126
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
127 perror(NULL);
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
128 exit(0);
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
129 }
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
130
1865
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
131 //printf("%s\n",out);
1864
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
132 printf("in mmap\n");
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 return 0;
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
135 }
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
136
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
137
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
138 static void
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
139 run_start(TaskManager *manager,char *filename)
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 long fd = (long)manager->allocate(sizeof(long));
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
142 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
143
1840
0305732326ca change *fd to fd & change set_inData to set_param
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1828
diff changeset
144 if ((fd=open(filename,O_RDONLY,0666))==0) {
1827
d1212026e2a0 some fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1825
diff changeset
145 fprintf(stderr,"can't open %s\n",filename);
1740
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1722
diff changeset
146 }
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
147
1840
0305732326ca change *fd to fd & change set_inData to set_param
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1828
diff changeset
148 if (fstat(fd,sb)) {
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
149 fprintf(stderr,"can't fstat %s\n",filename);
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
150 }
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
151
1865
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
152 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
153
1861
9e96c8c52574 some fix in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1840
diff changeset
154 fr->self = fr;
1827
d1212026e2a0 some fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1825
diff changeset
155 fr->fd = fd;
d1212026e2a0 some fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1825
diff changeset
156 fr->cpu = spe_cpu;
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
157 fr->task_blocks = 16;
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
158 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
159 fr->left_size = fr->filesize;
1824
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
160 fr->division_size = DIVISION_SIZE;
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
161 fr->task_num = fr->filesize / DIVISION_SIZE;
016746241fc7 fix fileread
masakoha
parents: 1820
diff changeset
162 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
163
1825
82c2b9eec625 remove error and warning fileread(but cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1824
diff changeset
164 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
165 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
166 printf("task_num : %ld\n",fr->task_num);
1740
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1722
diff changeset
167
1865
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
168 HTaskPtr run = NULL;
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
169 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
170
1864
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
171 if (divide_read_flag != 0) {
1865
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
172 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
173 }else {
7211816380bd implement my_mmap in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1861
diff changeset
174 //my_mmap(filename, fd, fr);
1865
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
175 run = manager->create_task(MMAP , (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
176 }
1865
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
177 t_print->wait_for(run);
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
178 run->spawn();
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
179
a009522ed6c6 add FileRead.h
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1864
diff changeset
180 t_print->spawn();
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
181 }
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
182
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 int
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
185 TMmain(TaskManager *manager, int argc, char *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 char *filename = 0;
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
188 filename = init(argc,argv);
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 if (filename < 0) {
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
191 return -1;
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
192 }
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
193
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
194 task_init();
1722
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
195 st_time = getTime();
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
196 run_start(manager, filename);
1722
264a36d30f7f add time measurement function in fileread
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1721
diff changeset
197 manager->set_TMend(TMend);
1721
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
198
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
199 return 0;
797e3ec1ca74 add fileread only example
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
200 }