Mercurial > hg > Game > Cerium

annotate example/regex_mas/main.cc @ 1959:6d343611bb03 draft

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
one task size changed 16k to 128k
author Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
date Sat, 08 Feb 2014 14:19:41 +0900
parents 59fc5bd0967f
children e1b377a42c54
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
1 #include <stdio.h>
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
2 #include <stdlib.h>
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
3 #include <string.h>
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
4 #include <sys/mman.h>
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
5 #include <sys/types.h>
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
6 #include <sys/stat.h>
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
7 #include <fcntl.h>
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
8 #include <unistd.h>
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
9 #include <sys/time.h>
1690
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1682
diff changeset
10 #include <iostream>
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1682
diff changeset
11 #include <vector>
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
12 #include "TaskManager.h"
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
13 #include "SchedTask.h"
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
14 #include "Func.h"
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
15 #include "WordCount.h"
1630
d2581892b8ad fix regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1620
diff changeset
16
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
17 /* ;TODO
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
18 * PS3でCPU数が2以上の時に、あまりが計算されてない
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
19 */
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
20
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
21 extern void task_init();
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
22 void TMend(TaskManager *);
1645
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
23 static double st_time;
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
24 static double ed_time;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
25 int all = 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
26 int use_task_array = 1;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
27 int use_task_creater = 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
28 int use_compat = 0;
1855
69250f6636e0 insert divide fileread in regex_mas (cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1806
diff changeset
29 int div_read = 0;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
30 int array_task_num = 8;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
31 int spe_num = 1;
1956
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
32 int block_read_flag = 0;
1855
69250f6636e0 insert divide fileread in regex_mas (cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1806
diff changeset
33 int DIVISION_SIZE = 4*4096;
1939
d862c573bf84 bugfix (change variable types in WordCount.h)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1937
diff changeset
34 int READ_DIVISION_SIZE = 4*4096 * 1024;
1748
61370f2987ff minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1747
diff changeset
35
1761
b98e23499add refactoring in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1759
diff changeset
36 unsigned char *sword = 0;
1788
06f5a4b09396 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1787
diff changeset
37 int task_count = 0;
06f5a4b09396 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1787
diff changeset
38
1959
6d343611bb03 one task size changed 16k to 128k
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1958
diff changeset
39 static int division = 128; // in Kbyte
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
40 CPU_TYPE spe_cpu = SPE_ANY;
1937
e5b4e61b6f85 change allocate size int to long long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1934
diff changeset
41 CPU_TYPE read_spe_cpu = IO_0;
1916
68ee760e1c7e running divide read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1914
diff changeset
42
1776
1c429035e0d1 Refactoring conditional expression
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1774
diff changeset
43 const char *usr_help_str = "Usage: ./word_count [-a -c -s] [-cpu spe_num] [-sw search_word] [-file filename]\n Required filename & search_word\n";
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
44
1645
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
45 static double
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
46 getTime() {
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
47 struct timeval tv;
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
48 gettimeofday(&tv, NULL);
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
49 return tv.tv_sec + (double)tv.tv_usec*1e-6;
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
50 }
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
51
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
52 typedef struct {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
53 caddr_t file_mmap;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
54 off_t size;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
55 } st_mmap_t;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
56
1955
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
57 static void
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
58 my_mmap(char *filename, WordCount *w)
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
59 {
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
60 /*マッピングだよ!*/
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
61 int map = MAP_PRIVATE;
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
62 st_mmap_t st_mmap;
1955
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
63 struct stat sb;
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
64 long fd = w->fd;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
65
1955
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
66 if ((fd=open(filename,O_RDONLY,0666))==0) {
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
67 fprintf(stderr,"can't open %s\n",filename);
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
68 }
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
69
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
70 if (fstat(fd,&sb)) {
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
71 fprintf(stderr,"can't fstat %s\n",filename);
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
72 }
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
73
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
74 w->file_mmap = (char*)mmap(NULL,w->read_filesize,PROT_READ,map,fd,(off_t)0);
1691
6b3991ac3f07 changed mmap to fread.
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1690
diff changeset
75 if (st_mmap.file_mmap == (caddr_t)-1) {
6b3991ac3f07 changed mmap to fread.
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1690
diff changeset
76 fprintf(stderr,"Can't mmap file\n");
6b3991ac3f07 changed mmap to fread.
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1690
diff changeset
77 perror(NULL);
6b3991ac3f07 changed mmap to fread.
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1690
diff changeset
78 exit(0);
6b3991ac3f07 changed mmap to fread.
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1690
diff changeset
79 }
6b3991ac3f07 changed mmap to fread.
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1690
diff changeset
80
1955
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
81 return ;
1691
6b3991ac3f07 changed mmap to fread.
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1690
diff changeset
82 }
6b3991ac3f07 changed mmap to fread.
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1690
diff changeset
83
1955
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
84
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
85 static void
1945
653c1caf1362 fix read spawn
masa
parents: 1940
diff changeset
86 run_tasks(SchedTask *manager, WordCount *w, int task_count,HTaskPtr t_read, HTaskPtr t_next, int size)
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
87 {
1788
06f5a4b09396 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1787
diff changeset
88
1787
5cde37f02c66 back main.cc
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1786
diff changeset
89 if (task_count < array_task_num) {
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
90 array_task_num = task_count;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
91 if (task_count<=0) return;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
92 }
1789
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
93 for (int i = 0; i < task_count; i += array_task_num) {
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
94 HTask *task_array;
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
95 if (use_task_array) {
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
96 int task_num = (w->size+size-1)/size;
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
97 if (task_num>array_task_num) task_num = array_task_num;
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
98 task_array = manager->create_task_array(TASK_EXEC,task_num,1,3,1);
1947
ef751840b388 running mmap mode (cannot running divide read)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1946
diff changeset
99 if (t_read != 0) task_array->wait_for(t_read);
1789
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
100 if (!all) {
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
101 t_next->wait_for(task_array);
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
102 } else {
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
103 w->t_print->wait_for(task_array);
1787
5cde37f02c66 back main.cc
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1786
diff changeset
104 }
5cde37f02c66 back main.cc
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1786
diff changeset
105 }
5cde37f02c66 back main.cc
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1786
diff changeset
106
1789
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
107 Task *t_exec = 0;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
108 HTask *h_exec = 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
109 for (int j = 0; j < array_task_num; j++) {
1946
502521591d7c remove RUN_READ_BLOCKS (cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1945
diff changeset
110 long i = w->task_spawned++;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
111 if (w->size < size) size = w->size;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
112 if (size==0) break;
1789
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
113 if (use_task_array) {
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
114 t_exec = task_array->next_task_array(TASK_EXEC,t_exec);
1945
653c1caf1362 fix read spawn
masa
parents: 1940
diff changeset
115 t_exec->set_inData(0,w->file_mmap + i*w->division_size, size);
1795
0aefbf042eb3 setting Data method change set_param to set_inData
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1789
diff changeset
116 t_exec->set_inData(1,w->search_word, w->search_word_len);
0aefbf042eb3 setting Data method change set_param to set_inData
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1789
diff changeset
117 t_exec->set_inData(2,w->BMskip_table, 256);
1787
5cde37f02c66 back main.cc
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1786
diff changeset
118
1945
653c1caf1362 fix read spawn
masa
parents: 1940
diff changeset
119 t_exec->set_param(0,(long)i);
1789
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
120
1946
502521591d7c remove RUN_READ_BLOCKS (cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1945
diff changeset
121 t_exec->set_outData(0,w->o_data + i*w->out_size, w->division_out_size);
1789
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
122 } else if (use_compat) {
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
123 h_exec = manager->create_task(TASK_EXEC);
1947
ef751840b388 running mmap mode (cannot running divide read)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1946
diff changeset
124 if (t_read != 0) h_exec->wait_for(t_read);
1787
5cde37f02c66 back main.cc
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1786
diff changeset
125 h_exec->set_inData(0,w->file_mmap + i*w->division_size, size);
5cde37f02c66 back main.cc
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1786
diff changeset
126 h_exec->set_outData(0,w->o_data + i*w->out_size, w->division_out_size);
5cde37f02c66 back main.cc
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1786
diff changeset
127
1789
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
128 t_next->wait_for(h_exec);
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
129
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
130 h_exec->set_cpu(spe_cpu);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
131 h_exec->spawn();
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
132 } else {
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
133 h_exec = manager->create_task(TASK_EXEC,
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
134 (memaddr)(w->file_mmap + i*w->division_size), size,
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
135 (memaddr)(w->o_data + i*w->out_size), w->division_out_size);
1947
ef751840b388 running mmap mode (cannot running divide read)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1946
diff changeset
136 if (t_read != 0) h_exec->wait_for(t_read);
1789
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
137 t_next->wait_for(h_exec);
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
138 h_exec->set_cpu(spe_cpu);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
139 h_exec->spawn();
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
140 }
1934
3d54a6c26caa fix w->size calc
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1932
diff changeset
141 w->size -= w->division_size;
1801
e91bf033443a fix task_size in run16
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1799
diff changeset
142 w->task_num--;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
143 }
1789
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
144 if (use_task_array) {
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
145 task_array->spawn_task_array(t_exec->next());
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
146 task_array->set_cpu(spe_cpu);
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
147 task_array->spawn();
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
148 } else {
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
149 //if (!all) t_next->wait_for(h_exec);
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
150 }
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
151 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
152 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
153
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
154 /**
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
155 * このTaskは、PPE上で実行されるので、並列に実行されることはない
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
156 * 二つ実行されていて、Task が足りなくなることがないようにしている。
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
157 */
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
158
1956
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
159 SchedDefineTask1(BREAD_RUN_TASK_BLOCKS,bread_run16);
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
160
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
161 static int
1956
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
162 bread_run16(SchedTask *manager, void *in, void *out)
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
163 {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
164 WordCount *w = *(WordCount **)in;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
165
1949
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
166 HTaskPtr t_read = manager->create_task(READ_TASK);
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
167 w->t_print->wait_for(t_read);
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
168 t_read->set_cpu(read_spe_cpu);
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
169 t_read->set_param(0,w->fd);
1948
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1947
diff changeset
170
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
171 if (w->task_num < w->task_blocks) {
1949
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
172 t_read->set_param(1,w->task_spawned*w->division_size);
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
173 t_read->set_outData(0, w->file_mmap + w->task_spawned * w->division_size, w->task_blocks * w->division_size);
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
174
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
175 // last case
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
176 while (w->size >= w->division_size)
1948
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1947
diff changeset
177 run_tasks(manager,w,w->task_num,t_read,w->t_print, w->division_size + w->extra_len);
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
178 // remaining data
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
179 while (w->size>0)
1948
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1947
diff changeset
180 run_tasks(manager,w,1,t_read,w->t_print, w->size);
1949
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
181
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
182 t_read->set_param(2,w->task_spawned*w->division_size);
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
183 t_read->spawn();
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
184 } else {
1956
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
185 HTaskPtr t_next = manager->create_task(BREAD_RUN_TASK_BLOCKS,
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
186 (memaddr)&w->self,sizeof(memaddr),0,0);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
187 w->t_print->wait_for(t_next);
1949
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
188
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
189 t_read->set_param(1,w->task_spawned*w->division_size);
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
190 t_read->set_outData(0, w->file_mmap + w->task_spawned * w->division_size, w->task_blocks * w->division_size);
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
191
1949
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
192 run_tasks(manager,w, w->task_blocks, t_read, t_next, w->division_size + w->extra_len);
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
193
1954
30b95f372a0d fix read_size
masa
parents: 1950
diff changeset
194 t_read->set_param(2,w->task_spawned*w->division_size + w->extra_len);
1945
653c1caf1362 fix read spawn
masa
parents: 1940
diff changeset
195
1948
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1947
diff changeset
196 t_read->spawn();
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
197 t_next->spawn();
1956
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
198 }
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
199 return 0;
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
200 }
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
201
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
202 SchedDefineTask1(MMAP_RUN_TASK_BLOCKS,mmap_run16);
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
203
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
204 static int
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
205 mmap_run16(SchedTask *manager, void *in, void *out)
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
206 {
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
207 WordCount *w = *(WordCount **)in;
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
208
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
209 if (w->task_num < w->task_blocks) {
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
210 // last case
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
211 while (w->size >= w->division_size)
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
212 run_tasks(manager,w,w->task_num,0, w->t_print, w->division_size + w->extra_len);
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
213 // remaining data
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
214 while (w->size>0)
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
215 run_tasks(manager,w,1,0,w->t_print, w->size);
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
216 } else {
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
217 HTaskPtr t_next = manager->create_task(MMAP_RUN_TASK_BLOCKS,
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
218 (memaddr)&w->self,sizeof(memaddr),0,0);
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
219 w->t_print->wait_for(t_next);
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
220
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
221 run_tasks(manager,w, w->task_blocks,0, t_next, w->division_size + w->extra_len);
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
222
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
223 t_next->spawn();
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
224 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
225 return 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
226 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
227
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
228
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
229 static int blocks = 48;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
230 //static int blocks = 31 * 6 * 24;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
231
1778
0e6ca13d2ed0 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1777
diff changeset
232 //Boyer Moore法に使用するテーブルを作成
1774
39734c8cbcfe To created BMsearch skip table method move Exec.cc to main.cc:run_start
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1761
diff changeset
233 static int*
39734c8cbcfe To created BMsearch skip table method move Exec.cc to main.cc:run_start
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1761
diff changeset
234 create_BMskiptable(unsigned char *search_word,int search_word_len,int *skip_table)
39734c8cbcfe To created BMsearch skip table method move Exec.cc to main.cc:run_start
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1761
diff changeset
235 {
39734c8cbcfe To created BMsearch skip table method move Exec.cc to main.cc:run_start
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1761
diff changeset
236 for(int i = 0; i < 256; ++i){
39734c8cbcfe To created BMsearch skip table method move Exec.cc to main.cc:run_start
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1761
diff changeset
237 skip_table[i] = search_word_len;
39734c8cbcfe To created BMsearch skip table method move Exec.cc to main.cc:run_start
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1761
diff changeset
238 }
39734c8cbcfe To created BMsearch skip table method move Exec.cc to main.cc:run_start
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1761
diff changeset
239
39734c8cbcfe To created BMsearch skip table method move Exec.cc to main.cc:run_start
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1761
diff changeset
240 for(int j = 0; j < search_word_len - 1; ++j){
39734c8cbcfe To created BMsearch skip table method move Exec.cc to main.cc:run_start
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1761
diff changeset
241 skip_table[(int)search_word[j]] = search_word_len - j - 1;
39734c8cbcfe To created BMsearch skip table method move Exec.cc to main.cc:run_start
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1761
diff changeset
242 }
39734c8cbcfe To created BMsearch skip table method move Exec.cc to main.cc:run_start
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1761
diff changeset
243 return skip_table;
39734c8cbcfe To created BMsearch skip table method move Exec.cc to main.cc:run_start
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1761
diff changeset
244 }
39734c8cbcfe To created BMsearch skip table method move Exec.cc to main.cc:run_start
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1761
diff changeset
245
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
246
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
247 static void
1795
0aefbf042eb3 setting Data method change set_param to set_inData
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1789
diff changeset
248 run_start(TaskManager *manager, char *filename,unsigned char *search_word, int search_word_len)
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
249 {
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
250 long fd = (long)manager->allocate(sizeof(long));
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
251 struct stat *sb = (struct stat*)manager->allocate(sizeof(struct stat));
1916
68ee760e1c7e running divide read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1914
diff changeset
252 HTaskPtr t_exec;
1860
d250caefe0ff Register divide read as Cerium task
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1859
diff changeset
253
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
254 if ((fd=open(filename,O_RDONLY,0666))==0) {
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
255 fprintf(stderr,"can't open %s\n",filename);
1945
653c1caf1362 fix read spawn
masa
parents: 1940
diff changeset
256 return ;
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
257 }
1860
d250caefe0ff Register divide read as Cerium task
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1859
diff changeset
258
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
259 if (fstat(fd,sb)) {
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
260 fprintf(stderr,"can't fstat %s\n",filename);
1945
653c1caf1362 fix read spawn
masa
parents: 1940
diff changeset
261 return ;
1855
69250f6636e0 insert divide fileread in regex_mas (cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1806
diff changeset
262 }
69250f6636e0 insert divide fileread in regex_mas (cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1806
diff changeset
263
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
264 WordCountPtr w = (WordCountPtr)manager->allocate(sizeof(WordCount));
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
265
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
266 w->self = w;
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
267 w->fd = fd;
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
268 w->read_filesize = sb->st_size;
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
269
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
270
1956
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
271 if (block_read_flag == 1) {
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
272 printf("[block read mode]\n");
1950
1f297d3eacb1 fix bugs
masa
parents: 1949
diff changeset
273 w->file_mmap = (char*)manager->allocate(w->read_filesize);
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
274 }else {
1916
68ee760e1c7e running divide read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1914
diff changeset
275 printf("[mmap mode]\n");
1955
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
276 my_mmap(filename, w);
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
277 }
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
278
1916
68ee760e1c7e running divide read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1914
diff changeset
279
1745
ef246e421c8c refactoring in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1744
diff changeset
280 /* prepare BMSearch*/
1949
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
281 int *skip = (int*)manager->allocate(256 * sizeof(int)); // 文字列に対応した table を用意
1745
ef246e421c8c refactoring in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1744
diff changeset
282 w->search_word = search_word;
1795
0aefbf042eb3 setting Data method change set_param to set_inData
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1789
diff changeset
283 w->search_word_len = search_word_len;
1774
39734c8cbcfe To created BMsearch skip table method move Exec.cc to main.cc:run_start
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1761
diff changeset
284 w->BMskip_table = create_BMskiptable(w->search_word, w->search_word_len, skip);
1777
7b11aceb41c4 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1776
diff changeset
285 w->extra_len = w->search_word_len - 1;
1745
ef246e421c8c refactoring in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1744
diff changeset
286
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
287 /* original */
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
288 HTaskPtr t_print;
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
289
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
290 //w->task_blocks = blocks;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
291 w->self = w;
1946
502521591d7c remove RUN_READ_BLOCKS (cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1945
diff changeset
292 w->task_spawned = 0;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
293
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
294 w->size = w->file_size = w->read_filesize;
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
295 printf("w %lx\n",(long)w);
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
296
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
297 /* 1task分のデータサイズ(byte) */
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
298 if (w->size >= 1024*division) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
299 w->division_size = 1024 * division;/*16kbyte*/
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
300 } else {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
301 w->division_size = w->size;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
302 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
303
1949
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
304 printf("division_size %ld\n",w->division_size);
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
305
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
306 /* "word num" and "line num" */
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
307 w->status_num = 2;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
308 /* taskの数 */
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
309 w->task_num = w->size / w->division_size;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
310 w->task_num = w->task_num + (w->division_size*w->task_num < w->size);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
311 int out_task_num = w->task_num;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
312
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
313 if(!all) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
314 w->task_blocks = blocks;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
315 } else {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
316 w->task_blocks = w->task_num;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
317 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
318
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
319 w->out_task_num = out_task_num;
1949
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
320 printf("task_num %ld\n",w->task_num);
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
321 printf("out_task_num %ld\n",w->out_task_num);
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
322
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
323 /* out用のdivision_size. statusが2つなので、あわせて16byteになるように、long long(4byte)を使用 */
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
324
1916
68ee760e1c7e running divide read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1914
diff changeset
325 w->division_out_size = sizeof(unsigned long long)*1;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
326 int out_size = w->division_out_size*out_task_num;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
327 w->o_data = (unsigned long long *)manager->allocate(out_size);
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
328 w->out_size_ = out_size;
1916
68ee760e1c7e running divide read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1914
diff changeset
329 w->out_size = 1;
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
330 printf("out size %d\n",out_size);
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
331
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
332 /*各SPEの結果を合計して出力するタスク*/
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
333
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
334 t_print = manager->create_task(PRINT_TASK,
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
335 (memaddr)&w->self,sizeof(memaddr),0,0);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
336 w->t_print = t_print;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
337
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
338 for(int i=0;i<1;i++) {
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
339 /* Task を task_blocks ずつ起動する Task */
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
340 /* serialize されていると仮定する... */
1956
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
341 if (block_read_flag == 1) {
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
342 t_exec = manager->create_task(BREAD_RUN_TASK_BLOCKS,
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
343 (memaddr)&w->self,sizeof(memaddr),0,0);
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
344 }else {
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
345 t_exec = manager->create_task(MMAP_RUN_TASK_BLOCKS,
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
346 (memaddr)&w->self,sizeof(memaddr),0,0);
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
347 }
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
348
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
349 t_print->wait_for(t_exec);
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
350 // t_exec->iterate(4);
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
351 t_exec->spawn();
1862
64c571a30bdb change Cerium Task to function() divide read ( cannot running )
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1860
diff changeset
352 }
1916
68ee760e1c7e running divide read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1914
diff changeset
353 w->t_exec = t_exec;
68ee760e1c7e running divide read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1914
diff changeset
354
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
355 t_print->spawn();
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
356 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
357
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
358 static char*
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
359 init(int argc, char **argv)
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
360 {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
361
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
362 char *filename = 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
363
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
364 for (int i = 1; argv[i]; ++i) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
365 if (strcmp(argv[i], "-file") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
366 filename = argv[i+1];
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
367 } else if (strcmp(argv[i], "-division") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
368 division = atoi(argv[i+1]);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
369 } else if (strcmp(argv[i], "-block") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
370 blocks = atoi(argv[i+1]);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
371 } else if (strcmp(argv[i], "-a") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
372 // create task all at once
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
373 all = 1;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
374 } else if (strcmp(argv[i], "-c") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
375 use_task_array = 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
376 use_compat = 1;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
377 } else if (strcmp(argv[i], "-s") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
378 use_task_array = 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
379 use_compat = 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
380 } else if (strcmp(argv[i], "-t") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
381 use_task_creater = 1;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
382 use_task_array = 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
383 use_compat = 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
384 } else if (strcmp(argv[i], "-anum") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
385 array_task_num = atoi(argv[i+1]);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
386 } else if (strcmp(argv[i], "-g") == 0 ) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
387 spe_cpu = GPU_0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
388 } else if (strcmp(argv[i], "-cpu") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
389 spe_num = atoi(argv[i+1]);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
390 if (spe_num==0) spe_num = 1;
1645
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
391 } else if (strcmp(argv[i], "-sw") == 0) {
1761
b98e23499add refactoring in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1759
diff changeset
392 sword = (unsigned char*)argv[i+1];
1956
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
393 } else if (strcmp(argv[i], "-br") == 0) {
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
394 block_read_flag = 1;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
395 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
396 }
1776
1c429035e0d1 Refactoring conditional expression
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1774
diff changeset
397 if ((filename==0) || (sword==0)) {
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
398 puts(usr_help_str);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
399 exit(1);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
400 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
401
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
402 return filename;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
403 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
404
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
405
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
406 int
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
407 TMmain(TaskManager *manager, int argc, char *argv[])
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
408 {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
409
1785
ae8e90890961 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1784
diff changeset
410 char *filename = init(argc, argv);
1796
355304646b4b send array to task
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1795
diff changeset
411 int sw_len = strlen((const char *)sword);
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
412
1795
0aefbf042eb3 setting Data method change set_param to set_inData
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1789
diff changeset
413 unsigned char *search_word = (unsigned char*)manager->allocate(sw_len + 1);
1797
964978cf41ae minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1796
diff changeset
414 memcpy(search_word, sword, sw_len + 1);
1748
61370f2987ff minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1747
diff changeset
415
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
416 task_init();
1723
d54e287eeef3 change time measurement point in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1707
diff changeset
417 st_time = getTime();
1795
0aefbf042eb3 setting Data method change set_param to set_inData
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1789
diff changeset
418 run_start(manager, filename, search_word, sw_len);
1645
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
419 manager->set_TMend(TMend);
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
420 return 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
421 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
422
1645
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
423 void
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
424 TMend(TaskManager *manager)
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
425 {
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
426 ed_time = getTime();
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
427 printf("Time: %0.6f\n",ed_time-st_time);
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
428 }
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
429
1662
d865530672fa fix regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1660
diff changeset
430 /* end */