|
|
@@ -158,7 +158,8 @@ int starpu_mpi_submit_checkpoint_template(starpu_mpi_checkpoint_template_t cp_te
|
|
|
int current_instance;
|
|
|
|
|
|
current_instance = increment_current_instance();
|
|
|
- STARPU_ASSERT(current_instance<4);
|
|
|
+ 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.
|
