annotate regexParser/cerium/CeriumMain.cc @ 278:99d635926ef3

ceriumCreateAnyState implemented
author Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
date Sat, 30 Jan 2016 21:19:05 +0900
parents 7b4bcc7b5ae6
children 6cc1d9779f45
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
266
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
1 #include <stdio.h>
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
2 #include <sys/time.h>
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
3 #include "TaskManager.h"
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
4 #include "SchedTask.h"
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
5 #include "Func.h"
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
6 #include "FileMapReduce.h"
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
7 #include "CeriumGrep.h"
272
5aa9d01926f1 Cerium version no compile errors
kono
parents: 271
diff changeset
8 #include "subsetConstruction.h"
5aa9d01926f1 Cerium version no compile errors
kono
parents: 271
diff changeset
9 #include "threadedSearch.h"
266
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
10
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
11 extern void task_init();
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
12 void TMend(TaskManager *);
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
13 static double st_time;
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
14 static double ed_time;
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
15 const char* usr_help_str = "";
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
16
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
17 static double
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
18 getTime() {
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
19 struct timeval tv;
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
20 gettimeofday(&tv, NULL);
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
21 return tv.tv_sec + (double)tv.tv_usec*1e-6;
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
22 }
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
23
278
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
24 static
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
25 TSValue stateNothing(TSValue tsv) {
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
26 return tsv;
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
27 }
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
28
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
29 static
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
30 TSValue stateSkip(TSValue tsv) {
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
31 tsv.buff.matchBegin = tsv.buff.buffptr;
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
32 return tsv;
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
33 }
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
34
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
35 static
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
36 TSValue stateMatch(TSValue tsv) {
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
37 ResultPtr r = NEW(Result);
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
38 r->begin = tsv.buff.matchBegin;
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
39 r->end = tsv.buff.buffptr;
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
40 *tsv.resultEnd = r;
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
41 r->next = NULL;
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
42 tsv.resultEnd = &r->next;
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
43 tsv.current = tsv.tg->stateList->tState;
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
44 tsv.buff.buffptr--;
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
45 tsv = stateSkip(tsv);
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
46 return tsv;
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
47 }
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
48
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
49 void ceriumCreateAnyState(TransitionGeneratorPtr tg) {
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
50 tg->stateSkip = stateSkip;
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
51 tg->stateMatch = stateMatch;
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
52 tg->stateNothing = stateNothing;
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
53 createAnyState(tg);
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
54 generateTState(tg->anyState,tg);
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
55 // generateTState for startState. It is used in stateMatch.
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
56 generateTState(tg->stateList,tg);
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
57 }
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
58
266
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
59 int
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
60 TMmain(TaskManager *manager, int argc, char *argv[])
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
61 {
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
62 char *filename = 0;
271
6640b0d5bf13 remove anystate processing in sequential seqrch
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 268
diff changeset
63 st_time = getTime();
266
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
64 Search s = grep(argc,argv,true);
277
7b4bcc7b5ae6 nextTState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 272
diff changeset
65
278
99d635926ef3 ceriumCreateAnyState implemented
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 277
diff changeset
66 ceriumCreateAnyState(s.tg);
268
0e423d9f9647 remove error (remain 1 warning(no use variable))
Masataka Kohagura <kohagura@cr.ie.u-ryukyu.ac.jp>
parents: 266
diff changeset
67
266
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
68 FileMapReduce *fmp = new FileMapReduce(manager,TASK_EXEC,TASK_EXEC_DATA_PARALLEL,TASK_PRINT);
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
69 filename = fmp->init(argc, argv);
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
70 fmp->w->global = (void*)s.tg;
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
71 if (filename < 0) {
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
72 return -1;
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
73 }
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
74 fmp->division_out_size = sizeof(void*)*3; // *Result,*blockBegin,*blockEnd
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
75 task_init();
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
76 fmp->run_start(manager, filename);
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
77 manager->set_TMend(TMend);
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
78 return 0;
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
79 }
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
80
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
81 void
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
82 TMend(TaskManager *manager)
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
83 {
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
84 ed_time = getTime();
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
85 printf("Time: %0.6f\n",ed_time-st_time);
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
86 }
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
87
e51cac73e42a CeriumGrep start
masa
parents:
diff changeset
88 /* end */