Commits

Kelvin Jin committed 07aa38f Merge

Comments (0)

Files changed (1)

controller/map_reduce.ml

           (* Another thread already beat to it *)
           ( Mutex.unlock(work_mutex);
             Worker_manager.push_worker wm w; ))
-    | None -> () (* There was some error with the task *)
+    | None -> ()
   in
 
   let rec perform_mapping work_table =
         !results )
     else
       ( Hashtbl.iter (fun k v -> Thread_pool.add_work(a_job (k,v)) p) work_table;
-        Thread.delay(0.1); (* prevent flooding of unnecessary work *)
+        Thread.delay(0.10);
         perform_mapping work_table
       )
   in