|
@@ -154,7 +154,7 @@ static void _starpu_mpi_handle_ft_request_termination(struct _starpu_mpi_req *re
|
|
|
//_starpu_mpi_datatype_free(req->data_handle, &req->datatype);
|
|
|
}
|
|
|
}
|
|
|
- _STARPU_MPI_TRACE_TERMINATED(req, req->node_tag.node.rank, req->node_tag.data_tag);
|
|
|
+ //_STARPU_MPI_TRACE_TERMINATED(req, req->node_tag.node.rank, req->node_tag.data_tag);
|
|
|
}
|
|
|
|
|
|
_starpu_mpi_release_req_data(req);
|
|
@@ -193,13 +193,13 @@ void starpu_mpi_test_ft_detached_service_requests(void)
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
- _STARPU_MPI_TRACE_TESTING_DETACHED_BEGIN();
|
|
|
+ //_STARPU_MPI_TRACE_TESTING_DETACHED_BEGIN();
|
|
|
req = _starpu_mpi_req_list_begin(&detached_ft_service_requests);
|
|
|
while (req != _starpu_mpi_req_list_end(&detached_ft_service_requests))
|
|
|
{
|
|
|
STARPU_PTHREAD_MUTEX_UNLOCK(&detached_ft_service_requests_mutex);
|
|
|
|
|
|
- _STARPU_MPI_TRACE_TEST_BEGIN(req->node_tag.node.rank, req->node_tag.data_tag);
|
|
|
+ //_STARPU_MPI_TRACE_TEST_BEGIN(req->node_tag.node.rank, req->node_tag.data_tag);
|
|
|
//_STARPU_MPI_DEBUG(3, "Test detached request %p - mpitag %"PRIi64" - TYPE %s %d\n", &req->backend->data_request, req->node_tag.data_tag, _starpu_mpi_request_type(req->request_type), req->node_tag.node.rank);
|
|
|
#ifdef STARPU_SIMGRID
|
|
|
req->ret = _starpu_mpi_simgrid_mpi_test(&req->done, &flag);
|
|
@@ -209,7 +209,7 @@ void starpu_mpi_test_ft_detached_service_requests(void)
|
|
|
#endif
|
|
|
|
|
|
STARPU_MPI_ASSERT_MSG(req->ret == MPI_SUCCESS, "MPI_Test returning %s", _starpu_mpi_get_mpi_error_code(req->ret));
|
|
|
- _STARPU_MPI_TRACE_TEST_END(req->node_tag.node.rank, req->node_tag.data_tag);
|
|
|
+ //_STARPU_MPI_TRACE_TEST_END(req->node_tag.node.rank, req->node_tag.data_tag);
|
|
|
|
|
|
if (!flag)
|
|
|
{
|
|
@@ -217,11 +217,11 @@ void starpu_mpi_test_ft_detached_service_requests(void)
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
- _STARPU_MPI_TRACE_POLLING_END();
|
|
|
+ //_STARPU_MPI_TRACE_POLLING_END();
|
|
|
struct _starpu_mpi_req *next_req;
|
|
|
next_req = _starpu_mpi_req_list_next(req);
|
|
|
|
|
|
- _STARPU_MPI_TRACE_COMPLETE_BEGIN(req->request_type, req->node_tag.node.rank, req->node_tag.data_tag);
|
|
|
+ //_STARPU_MPI_TRACE_COMPLETE_BEGIN(req->request_type, req->node_tag.node.rank, req->node_tag.data_tag);
|
|
|
|
|
|
STARPU_PTHREAD_MUTEX_LOCK(&detached_ft_service_requests_mutex);
|
|
|
if (req->request_type == SEND_REQ)
|
|
@@ -230,7 +230,7 @@ void starpu_mpi_test_ft_detached_service_requests(void)
|
|
|
STARPU_PTHREAD_MUTEX_UNLOCK(&detached_ft_service_requests_mutex);
|
|
|
_starpu_mpi_handle_ft_request_termination(req);
|
|
|
|
|
|
- _STARPU_MPI_TRACE_COMPLETE_END(req->request_type, req->node_tag.node.rank, req->node_tag.data_tag);
|
|
|
+ //_STARPU_MPI_TRACE_COMPLETE_END(req->request_type, req->node_tag.node.rank, req->node_tag.data_tag);
|
|
|
|
|
|
STARPU_PTHREAD_MUTEX_LOCK(&req->backend->req_mutex);
|
|
|
/* We don't want to free internal non-detached
|
|
@@ -249,12 +249,12 @@ void starpu_mpi_test_ft_detached_service_requests(void)
|
|
|
}
|
|
|
|
|
|
req = next_req;
|
|
|
- _STARPU_MPI_TRACE_POLLING_BEGIN();
|
|
|
+ //_STARPU_MPI_TRACE_POLLING_BEGIN();
|
|
|
}
|
|
|
|
|
|
STARPU_PTHREAD_MUTEX_LOCK(&detached_ft_service_requests_mutex);
|
|
|
}
|
|
|
- _STARPU_MPI_TRACE_TESTING_DETACHED_END();
|
|
|
+ //_STARPU_MPI_TRACE_TESTING_DETACHED_END();
|
|
|
|
|
|
STARPU_PTHREAD_MUTEX_UNLOCK(&detached_ft_service_requests_mutex);
|
|
|
//_STARPU_MPI_LOG_OUT();
|