diff example/bm_search/ppe/Print.cc @ 2064:f786ffb2a198 draft

add bm.h
author Nozomi
date Wed, 17 Feb 2016 17:37:06 +0900
parents a8f4227d6a21
children
line wrap: on
line diff
--- a/example/bm_search/ppe/Print.cc	Sat Feb 06 20:05:05 2016 +0900
+++ b/example/bm_search/ppe/Print.cc	Wed Feb 17 17:37:06 2016 +0900
@@ -2,25 +2,23 @@
 #include <string.h>
 #include "Print.h"
 #include "Func.h"
-#include "WordCount.h"
+#include "FileMapReduce.h"
 
 /* これは必須 */
-SchedDefineTask1(PRINT_TASK,print_task);
+SchedDefineTask1(Print,print_task);
 
 static int
 print_task(SchedTask *s, void *rbuf, void *wbuf)
 {
-    WordCount *w = *(WordCount**)rbuf;
+    MapReduce *w = (MapReduce*)s->get_input(0);
     unsigned long long *idata = w->o_data;
-    unsigned int idata_task_num = w->out_size * w->out_task_num;
+    unsigned int idata_task_num = w->task_num;
     int match_counter = 0;
 
     for (int i = 0;i < idata_task_num;i++) {
-
             match_counter += idata[i];
             //s->printf("idata[%d]=:%d\n",i,idata[i]);
     }
-
     s->printf("HIT:%d\n",match_counter);
     return 0;
 }