# HG changeset patch
# User masa
# Date 1454148377 -32400
# Node ID f3e748c0e7ea5a59268b00709301912c5a5cfd1d
# Parent  ce57fa0495a7161174554eae6dcb18997c1d0323
change parameter in create_task_array

diff -r ce57fa0495a7 -r f3e748c0e7ea TaskManager/ManyCore/FileMapReduce.cc
--- a/TaskManager/ManyCore/FileMapReduce.cc	Sat Jan 30 17:42:41 2016 +0900
+++ b/TaskManager/ManyCore/FileMapReduce.cc	Sat Jan 30 19:06:17 2016 +0900
@@ -99,6 +99,8 @@
         exit(1);
     }
 
+    MapReducePtr w = (MapReducePtr)malloc(sizeof(MapReduce));
+    this->w = w;
     return filename;
 }
 
@@ -192,7 +194,7 @@
         if (use_task_array) {
             int task_num = (w->size+size-1)/size;
             if (task_num>array_task_num) task_num = array_task_num;
-            task_array = manager->create_task_array(TASK_EXEC,task_num,1,1,1);
+            task_array = manager->create_task_array(TASK_EXEC,task_num,5,1,1);
             if (t_read != 0) task_array->wait_for(t_read);
             if (!all) { 
                 t_next->wait_for(task_array);
@@ -376,9 +378,6 @@
         return ;
     }
 
-    MapReducePtr w = (MapReducePtr)manager->allocate(sizeof(MapReduce));
-    this->w = w;
-
     w->self = w;
     w->fmp = this;
     w->fd = fd;