|
|
@@ -41,7 +41,7 @@ void _ack_msg_send_cb(void* _args)
|
|
|
struct _starpu_mpi_cp_ack_arg_cb* arg = (struct _starpu_mpi_cp_ack_arg_cb*) _args;
|
|
|
_STARPU_MPI_FT_STATS_SEND_FT_SERVICE_MSG(sizeof(struct _starpu_mpi_cp_ack_msg));
|
|
|
_STARPU_MPI_DEBUG(3, "Ack send succeeded cpid:%d, cpinst:%d, dest:%d\n", arg->msg.checkpoint_id, arg->msg.checkpoint_instance, arg->rank);
|
|
|
- free(arg);
|
|
|
+ //free(arg);
|
|
|
}
|
|
|
|
|
|
void _ack_msg_recv_cb(void* _args)
|
|
|
@@ -52,7 +52,7 @@ void _ack_msg_recv_cb(void* _args)
|
|
|
_STARPU_MPI_DEBUG(3, "ack msg recved id:%d inst:%d\n", arg->msg.checkpoint_id, arg->msg.checkpoint_instance);
|
|
|
ret = _checkpoint_template_digest_ack_reception(arg->msg.checkpoint_id, arg->msg.checkpoint_instance);
|
|
|
if (ret == 0) {
|
|
|
- free(arg);
|
|
|
+ //free(arg);
|
|
|
}
|
|
|
else if (ret == -1)
|
|
|
{
|