Mercurial > hg > Game > Cerium

annotate example/bm_search/main.cc @ 1976:a8f4227d6a21 draft

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
rename regex_mas to bm_search
author Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
date Mon, 03 Mar 2014 19:12:02 +0900
parents example/regex_mas/main.cc@9ebee99a9aef
children 455e620ad2b2
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
1974
9ebee99a9aef fix bitreverse for cuda(float2)
kkb
parents: 1967
diff changeset
74 //w->file_mmap = (char*)mmap(NULL,w->read_filesize,PROT_READ,map,fd,(off_t)0);
9ebee99a9aef fix bitreverse for cuda(float2)
kkb
parents: 1967
diff changeset
75 madvise(w->file_mmap, w->read_filesize, POSIX_MADV_NORMAL);
1955
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
76 w->file_mmap = (char*)mmap(NULL,w->read_filesize,PROT_READ,map,fd,(off_t)0);
1974
9ebee99a9aef fix bitreverse for cuda(float2)
kkb
parents: 1967
diff changeset
77
1691
6b3991ac3f07 changed mmap to fread.
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1690
diff changeset
78 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
79 fprintf(stderr,"Can't mmap file\n");
6b3991ac3f07 changed mmap to fread.
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1690
diff changeset
80 perror(NULL);
6b3991ac3f07 changed mmap to fread.
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1690
diff changeset
81 exit(0);
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 return ;
1691
6b3991ac3f07 changed mmap to fread.
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1690
diff changeset
85 }
6b3991ac3f07 changed mmap to fread.
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1690
diff changeset
86
1955
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
87
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
88 static void
1945
653c1caf1362 fix read spawn
masa
parents: 1940
diff changeset
89 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
90 {
1788
06f5a4b09396 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1787
diff changeset
91
1787
5cde37f02c66 back main.cc
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1786
diff changeset
92 if (task_count < array_task_num) {
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
93 array_task_num = task_count;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
94 if (task_count<=0) return;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
95 }
1789
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
96 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
97 HTask *task_array;
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
98 if (use_task_array) {
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
99 int task_num = (w->size+size-1)/size;
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
100 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
101 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
102 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
103 if (!all) {
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
104 t_next->wait_for(task_array);
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
105 } else {
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
106 w->t_print->wait_for(task_array);
1787
5cde37f02c66 back main.cc
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1786
diff changeset
107 }
5cde37f02c66 back main.cc
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1786
diff changeset
108 }
5cde37f02c66 back main.cc
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1786
diff changeset
109
1789
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
110 Task *t_exec = 0;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
111 HTask *h_exec = 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
112 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
113 long i = w->task_spawned++;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
114 if (w->size < size) size = w->size;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
115 if (size==0) break;
1789
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
116 if (use_task_array) {
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
117 t_exec = task_array->next_task_array(TASK_EXEC,t_exec);
1945
653c1caf1362 fix read spawn
masa
parents: 1940
diff changeset
118 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
119 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
120 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
121
1945
653c1caf1362 fix read spawn
masa
parents: 1940
diff changeset
122 t_exec->set_param(0,(long)i);
1789
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
123
1946
502521591d7c remove RUN_READ_BLOCKS (cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1945
diff changeset
124 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
125 } else if (use_compat) {
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
126 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
127 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
128 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
129 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
130
1789
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
131 t_next->wait_for(h_exec);
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
132
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
133 h_exec->set_cpu(spe_cpu);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
134 h_exec->spawn();
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
135 } else {
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
136 h_exec = manager->create_task(TASK_EXEC,
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
137 (memaddr)(w->file_mmap + i*w->division_size), size,
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
138 (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
139 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
140 t_next->wait_for(h_exec);
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
141 h_exec->set_cpu(spe_cpu);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
142 h_exec->spawn();
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
143 }
1934
3d54a6c26caa fix w->size calc
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1932
diff changeset
144 w->size -= w->division_size;
1801
e91bf033443a fix task_size in run16
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1799
diff changeset
145 w->task_num--;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
146 }
1789
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
147 if (use_task_array) {
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
148 task_array->spawn_task_array(t_exec->next());
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
149 task_array->set_cpu(spe_cpu);
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
150 task_array->spawn();
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
151 } else {
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
152 //if (!all) t_next->wait_for(h_exec);
82f8250f23d5 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1788
diff changeset
153 }
1598
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 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
156
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 * このTaskは、PPE上で実行されるので、並列に実行されることはない
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
159 * 二つ実行されていて、Task が足りなくなることがないようにしている。
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
1956
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
162 SchedDefineTask1(BREAD_RUN_TASK_BLOCKS,bread_run16);
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 static int
1956
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
165 bread_run16(SchedTask *manager, void *in, void *out)
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
166 {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
167 WordCount *w = *(WordCount **)in;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
168
1949
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
169 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
170 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
171 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
172 t_read->set_param(0,w->fd);
1948
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1947
diff changeset
173
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
174 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
175 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
176 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
177
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
178 // last case
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
179 while (w->size >= w->division_size)
1948
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1947
diff changeset
180 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
181 // remaining data
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
182 while (w->size>0)
1948
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1947
diff changeset
183 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
184
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
185 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
186 t_read->spawn();
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
187 } else {
1956
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
188 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
189 (memaddr)&w->self,sizeof(memaddr),0,0);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
190 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
191
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
192 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
193 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
194
1949
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
195 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
196
1954
30b95f372a0d fix read_size
masa
parents: 1950
diff changeset
197 t_read->set_param(2,w->task_spawned*w->division_size + w->extra_len);
1945
653c1caf1362 fix read spawn
masa
parents: 1940
diff changeset
198
1948
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1947
diff changeset
199 t_read->spawn();
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
200 t_next->spawn();
1956
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 return 0;
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
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
205 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
206
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
207 static int
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
208 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
209 {
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
210 WordCount *w = *(WordCount **)in;
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
211
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
212 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
213 // last case
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
214 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
215 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
216 // remaining data
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
217 while (w->size>0)
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
218 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
219 } else {
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
220 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
221 (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
222 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
223
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
224 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
225
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
226 t_next->spawn();
1598
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 return 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
229 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
230
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
231
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
232 static int blocks = 48;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
233 //static int blocks = 31 * 6 * 24;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
234
1778
0e6ca13d2ed0 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1777
diff changeset
235 //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
236 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
237 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
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 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
240 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
241 }
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 for(int j = 0; j < search_word_len - 1; ++j){
1967
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1959
diff changeset
244 skip_table[search_word[j]] = search_word_len - j - 1;
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
245 }
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
246 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
247 }
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
248
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
249
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
250 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
251 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
252 {
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
253 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
254 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
255 HTaskPtr t_exec;
1860
d250caefe0ff Register divide read as Cerium task
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1859
diff changeset
256
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
257 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
258 fprintf(stderr,"can't open %s\n",filename);
1945
653c1caf1362 fix read spawn
masa
parents: 1940
diff changeset
259 return ;
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
260 }
1860
d250caefe0ff Register divide read as Cerium task
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1859
diff changeset
261
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
262 if (fstat(fd,sb)) {
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
263 fprintf(stderr,"can't fstat %s\n",filename);
1945
653c1caf1362 fix read spawn
masa
parents: 1940
diff changeset
264 return ;
1855
69250f6636e0 insert divide fileread in regex_mas (cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1806
diff changeset
265 }
69250f6636e0 insert divide fileread in regex_mas (cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1806
diff changeset
266
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
267 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
268
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
269 w->self = w;
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
270 w->fd = fd;
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
271 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
272
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
273
1956
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
274 if (block_read_flag == 1) {
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
275 printf("[block read mode]\n");
1950
1f297d3eacb1 fix bugs
masa
parents: 1949
diff changeset
276 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
277 }else {
1916
68ee760e1c7e running divide read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1914
diff changeset
278 printf("[mmap mode]\n");
1955
2573919e0d72 MMAP change Task to Function
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1954
diff changeset
279 my_mmap(filename, w);
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
280 }
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
281
1916
68ee760e1c7e running divide read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1914
diff changeset
282
1745
ef246e421c8c refactoring in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1744
diff changeset
283 /* prepare BMSearch*/
1949
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
284 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
285 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
286 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
287 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
288 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
289
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
290 /* original */
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
291 HTaskPtr t_print;
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
292
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
293 //w->task_blocks = blocks;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
294 w->self = w;
1946
502521591d7c remove RUN_READ_BLOCKS (cannot running)
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1945
diff changeset
295 w->task_spawned = 0;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
296
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
297 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
298 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
299
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
300 /* 1task分のデータサイズ(byte) */
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
301 if (w->size >= 1024*division) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
302 w->division_size = 1024 * division;/*16kbyte*/
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
303 } else {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
304 w->division_size = w->size;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
305 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
306
1949
f3e9f811c387 change some variables types int to long
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1948
diff changeset
307 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
308
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
309 /* "word num" and "line num" */
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
310 w->status_num = 2;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
311 /* taskの数 */
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
312 w->task_num = w->size / w->division_size;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
313 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
314 int out_task_num = w->task_num;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
315
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
316 if(!all) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
317 w->task_blocks = blocks;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
318 } else {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
319 w->task_blocks = w->task_num;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
320 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
321
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
322 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
323 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
324 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
325
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
326 /* out用のdivision_size. statusが2つなので、あわせて16byteになるように、long long(4byte)を使用 */
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
327
1916
68ee760e1c7e running divide read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1914
diff changeset
328 w->division_out_size = sizeof(unsigned long long)*1;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
329 int out_size = w->division_out_size*out_task_num;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
330 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
331 w->out_size_ = out_size;
1916
68ee760e1c7e running divide read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1914
diff changeset
332 w->out_size = 1;
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
333 printf("out size %d\n",out_size);
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
334
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
335 /*各SPEの結果を合計して出力するタスク*/
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
336
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
337 t_print = manager->create_task(PRINT_TASK,
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
338 (memaddr)&w->self,sizeof(memaddr),0,0);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
339 w->t_print = t_print;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
340
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
341 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
342 /* Task を task_blocks ずつ起動する Task */
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
343 /* serialize されていると仮定する... */
1956
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
344 if (block_read_flag == 1) {
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(BREAD_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 }else {
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
348 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
349 (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
350 }
b52fe4cceff3 rename divide read to block read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1955
diff changeset
351
1914
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
352 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
353 // t_exec->iterate(4);
08e9e416c2e0 Implement divide read in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1863
diff changeset
354 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
355 }
1916
68ee760e1c7e running divide read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1914
diff changeset
356 w->t_exec = t_exec;
68ee760e1c7e running divide read
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1914
diff changeset
357
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
358 t_print->spawn();
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
359 }
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 static char*
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
362 init(int argc, char **argv)
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
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
365 char *filename = 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
366
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
367 for (int i = 1; argv[i]; ++i) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
368 if (strcmp(argv[i], "-file") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
369 filename = argv[i+1];
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
370 } else if (strcmp(argv[i], "-division") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
371 division = atoi(argv[i+1]);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
372 } else if (strcmp(argv[i], "-block") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
373 blocks = atoi(argv[i+1]);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
374 } else if (strcmp(argv[i], "-a") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
375 // create task all at once
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
376 all = 1;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
377 } else if (strcmp(argv[i], "-c") == 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 = 1;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
380 } else if (strcmp(argv[i], "-s") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
381 use_task_array = 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
382 use_compat = 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
383 } else if (strcmp(argv[i], "-t") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
384 use_task_creater = 1;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
385 use_task_array = 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
386 use_compat = 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
387 } else if (strcmp(argv[i], "-anum") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
388 array_task_num = atoi(argv[i+1]);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
389 } else if (strcmp(argv[i], "-g") == 0 ) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
390 spe_cpu = GPU_0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
391 } else if (strcmp(argv[i], "-cpu") == 0) {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
392 spe_num = atoi(argv[i+1]);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
393 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
394 } 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
395 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
396 } 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
397 block_read_flag = 1;
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
398 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
399 }
1776
1c429035e0d1 Refactoring conditional expression
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1774
diff changeset
400 if ((filename==0) || (sword==0)) {
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
401 puts(usr_help_str);
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
402 exit(1);
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 return filename;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
406 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
407
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 int
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
410 TMmain(TaskManager *manager, int argc, char *argv[])
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
411 {
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
412
1785
ae8e90890961 minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1784
diff changeset
413 char *filename = init(argc, argv);
1796
355304646b4b send array to task
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1795
diff changeset
414 int sw_len = strlen((const char *)sword);
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
415
1795
0aefbf042eb3 setting Data method change set_param to set_inData
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1789
diff changeset
416 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
417 memcpy(search_word, sword, sw_len + 1);
1748
61370f2987ff minor fix
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1747
diff changeset
418
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
419 task_init();
1723
d54e287eeef3 change time measurement point in regex_mas
Masataka Kohagura <e085726@ie.u-ryukyu.ac.jp>
parents: 1707
diff changeset
420 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
421 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
422 manager->set_TMend(TMend);
1598
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
423 return 0;
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
424 }
0f94d9d580f9 add regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents:
diff changeset
425
1645
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
426 void
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
427 TMend(TaskManager *manager)
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 ed_time = getTime();
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
430 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
431 }
4698c92bf2ca Regex_mas implement time measurement.
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1642
diff changeset
432
1662
d865530672fa fix regex_mas
Masa <e085726@ie.u-ryukyu.ac.jp>
parents: 1660
diff changeset
433 /* end */