#include <stdio.h>
#include <string.h>
#include "Print.h"
#include "Func.h"
#include "FileMapReduce.h"
#include "regexParser.h"
#include "CeriumMain.h"

#define STATUS_NUM 2
/* これは必須 */
SchedDefineTask1(Print,run_print);

static int
run_print(SchedTask *s, void *rbuf, void *wbuf)
{
    MapReduce *w = (MapReduce*)s->get_input(0);
    
    int out_size = w->division_out_size / sizeof(unsigned long long);
    int out_task_num = w->task_num;
    ResultPtr prev = NULL;
    for (int i = 0; i < out_task_num ; i++) {
        ResultPtr r = (ResultPtr)w->o_data[i*out_size+0];
        if (r == NULL) {
            prev = NULL;
            continue;
        }
        StatePtr blockEnd = (StatePtr)w->o_data[i*out_size+2];
        StatePtr blockBegin = (StatePtr)w->o_data[i*out_size+4]; // next Block's blockBegin.
        if (prev) {
            if (i >= out_task_num) break; 
            // 最後のブロックでなく、前の blockEnd が state 1 でない場合)
#if 0
printf("task %d prev begin : %p r->begin : %p r->end : %p\n", i,prev->begin,r->begin,r->end);
printf("blockBegin : %lx blockEnd : %lx : string ",blockBegin->bitState.bitContainer,blockEnd->bitState.bitContainer);
fwrite(r->begin,r->end - r->begin-1,1,stdout);
printf(" match %d\n", ((blockBegin->bitState.bitContainer & ~blockEnd->bitState.bitContainer)==0)? 1 : 0  );
#endif
            if ((blockBegin->bitState.bitContainer & ~blockEnd->bitState.bitContainer)==0) {
                // 前のブロックの matchBegin から最初 result の end までがマッチ
                fwrite(prev->begin,r->end - prev->begin-1,1,stdout);
                if (!r->continued) puts("");
            }
            r = r->next;
        }
        prev = resultPrint(r,"Print");
    }
    return 0;
}