|
@@ -216,8 +216,6 @@ int starpu_mpi_submit_checkpoint_template(starpu_mpi_checkpoint_template_t cp_te
|
|
|
arg->type = STARPU_R;
|
|
|
arg->count = item->count;
|
|
|
arg->checkpoint_instance_hint = current_instance;
|
|
|
- if (arg->msg.checkpoint_instance>3)
|
|
|
- fprintf(stderr, "arg->msg.checkpoint_instance:%d\n", arg->msg.checkpoint_instance);
|
|
|
_starpu_mpi_isend_cache_aware(handle, item->backupped_by, starpu_mpi_data_get_tag(handle), MPI_COMM_WORLD, 1, 0, prio,
|
|
|
&_send_cp_internal_data_cb, (void*)arg, 1, &arg->cache_flag);
|
|
|
// the callbacks need to post ack recv. The cache one needs to release the handle.
|
|
@@ -238,8 +236,6 @@ int starpu_mpi_submit_checkpoint_template(starpu_mpi_checkpoint_template_t cp_te
|
|
|
arg->count = item->count;
|
|
|
arg->msg.checkpoint_id = cp_template->cp_id;
|
|
|
arg->msg.checkpoint_instance = current_instance;
|
|
|
- if (arg->msg.checkpoint_instance>3)
|
|
|
- fprintf(stderr, "arg->msg.checkpoint_instance:%d\n", arg->msg.checkpoint_instance);
|
|
|
_starpu_mpi_irecv_cache_aware(handle, starpu_mpi_data_get_rank(handle), starpu_mpi_data_get_tag(handle), MPI_COMM_WORLD, 1, 0,
|
|
|
NULL, NULL, 1, 0, 1, &arg->cache_flag);
|
|
|
// The callback needs to do nothing. The cached one must release the handle.
|