Browse Source

debidouille

Romain LION 5 years ago
parent
commit
a05af1c942
1 changed files with 2 additions and 2 deletions
  1. 2 2
      mpi/src/mpi_failure_tolerance/starpu_mpi_checkpoint.c

+ 2 - 2
mpi/src/mpi_failure_tolerance/starpu_mpi_checkpoint.c

@@ -158,8 +158,8 @@ int starpu_mpi_submit_checkpoint_template(starpu_mpi_checkpoint_template_t cp_te
 	int current_instance;
 
 	current_instance = increment_current_instance();
-	if (current_instance>3)
-		starpu_task_wait_for_all();
+//	if (current_instance>3)
+//		starpu_task_wait_for_all();
 	_starpu_mpi_checkpoint_post_cp_discard_recv(cp_template);
 	_starpu_mpi_checkpoint_template_create_instance_tracker(cp_template, cp_template->cp_id, cp_template->checkpoint_domain, current_instance);
 	//TODO check what happens when all the ack msg are received when we arrrive here.