Commits

Nick Wade committed 2def7aa

Changed destroy before clean up

  • Participants
  • Parent commits ae69a5d

Comments (0)

Files changed (1)

controller/map_reduce.ml

 
   let rec perform_mapping work_table =
     if (Hashtbl.length work_table = 0) then
-      ( Worker_manager.clean_up_workers wm;
+      ( 
         Thread_pool.destroy p;
+        Worker_manager.clean_up_workers wm;
         print_map_results !results;
         !results )
     else
 
     let rec perform_reduce work_table =
       if (Hashtbl.length work_table = 0) then
-        ( Worker_manager.clean_up_workers wm;
+        ( 
           Thread_pool.destroy p;
+          Worker_manager.clean_up_workers wm;
           print_reduce_results !results;
           !results )
       else