|
|
@@ -160,6 +160,7 @@ int starpu_mpi_submit_checkpoint_template(starpu_mpi_checkpoint_template_t cp_te
|
|
|
current_instance = increment_current_instance();
|
|
|
// if (current_instance>3)
|
|
|
// starpu_task_wait_for_all();
|
|
|
+ fprintf(stderr, "Node %d submitting CP inst %d\n", _my_rank, current_instance);
|
|
|
_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.
|
