view 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
line wrap: on
line source

#include <stdio.h>
#include <sys/time.h>
#include "TaskManager.h"
#include "SchedTask.h"
#include "Func.h"
#include "FileMapReduce.h"
#include "CeriumGrep.h"
#include "subsetConstruction.h"
#include "threadedSearch.h"

extern void task_init();
void TMend(TaskManager *);
static double st_time;
static double ed_time;
const char* usr_help_str = "";

static double
getTime() {
    struct timeval tv;
    gettimeofday(&tv, NULL);
    return tv.tv_sec + (double)tv.tv_usec*1e-6;
}

static
TSValue stateNothing(TSValue tsv) {
    return tsv;
}

static
TSValue stateSkip(TSValue tsv) {
    tsv.buff.matchBegin = tsv.buff.buffptr;
    return tsv;
}

static
TSValue stateMatch(TSValue tsv) {
    ResultPtr r = NEW(Result);
    r->begin = tsv.buff.matchBegin;
    r->end = tsv.buff.buffptr;
    *tsv.resultEnd = r;
    r->next = NULL;
    tsv.resultEnd = &r->next;
    tsv.current = tsv.tg->stateList->tState;
    tsv.buff.buffptr--;
    tsv = stateSkip(tsv);
    return tsv;
}

void ceriumCreateAnyState(TransitionGeneratorPtr tg) {
    tg->stateSkip = stateSkip;
    tg->stateMatch = stateMatch;
    tg->stateNothing = stateNothing;
    createAnyState(tg);
    generateTState(tg->anyState,tg);
    // generateTState for startState. It is used in stateMatch.
    generateTState(tg->stateList,tg);
}

int
TMmain(TaskManager *manager, int argc, char *argv[])
{
    char *filename = 0;
    st_time = getTime();
    Search s = grep(argc,argv,true);

    ceriumCreateAnyState(s.tg);

    FileMapReduce *fmp = new FileMapReduce(manager,TASK_EXEC,TASK_EXEC_DATA_PARALLEL,TASK_PRINT);
    filename = fmp->init(argc, argv);
    fmp->w->global = (void*)s.tg;
    if (filename < 0) {
        return -1;
    }
    fmp->division_out_size = sizeof(void*)*3; // *Result,*blockBegin,*blockEnd
    task_init();
    fmp->run_start(manager, filename);
    manager->set_TMend(TMend);
    return 0;
}

void
TMend(TaskManager *manager)
{
    ed_time = getTime();
    printf("Time: %0.6f\n",ed_time-st_time);
}

/* end */