Mercurial > hg > Game > Cerium

annotate example/bm_search/main.cc @ 2054:2e7a6f40672f draft

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