|
@@ -45,10 +45,10 @@ void _starpu_mpi_treat_ack_receipt_cb(void* _args)
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-void _print_ack_sent_cb(void* _args)
|
|
|
+void _arg_free(void* _args)
|
|
|
{
|
|
|
struct _starpu_mpi_cp_ack_arg_cb* arg = (struct _starpu_mpi_cp_ack_arg_cb*) _args;
|
|
|
- fprintf(stderr, "Ack send succeeded cpid:%d, cpinst:%d, dest:%d\n", arg->msg.checkpoint_id, arg->msg.checkpoint_instance, arg->rank);
|
|
|
+ _STARPU_DEBUG(3,stderr, "Ack send succeeded cpid:%d, cpinst:%d, dest:%d\n", arg->msg.checkpoint_id, arg->msg.checkpoint_instance, arg->rank);
|
|
|
free(_args);
|
|
|
}
|
|
|
|
|
@@ -56,7 +56,7 @@ void _starpu_mpi_push_cp_ack_send_cb(void* _args)
|
|
|
{
|
|
|
struct _starpu_mpi_cp_ack_arg_cb* arg = (struct _starpu_mpi_cp_ack_arg_cb*) _args;
|
|
|
_STARPU_DEBUG(3,"Send ack msg to %d: id=%d inst=%d\n", arg->rank, arg->msg.checkpoint_id, arg->msg.checkpoint_instance);
|
|
|
- _ft_service_msg_isend_cb((void*)&arg->msg, sizeof(struct _starpu_mpi_cp_ack_msg), arg->rank, _STARPU_MPI_TAG_CP_ACK, MPI_COMM_WORLD, _print_ack_sent_cb, _args);
|
|
|
+ _ft_service_msg_isend_cb((void*)&arg->msg, sizeof(struct _starpu_mpi_cp_ack_msg), arg->rank, _STARPU_MPI_TAG_CP_ACK, MPI_COMM_WORLD, _arg_free, _args);
|
|
|
}
|
|
|
|
|
|
void _starpu_mpi_store_data_and_push_cp_ack_send_cb(void* _args)
|