1
1

Uniform conditions in ob1 recv

In ob1 we have four similar conditions but they are not written
in a uniform way

Signed-off-by: Julien EMMANUEL <julien.emmanuel@inria.fr>
Этот коммит содержится в:
Julien EMMANUEL 2020-11-19 17:32:29 +01:00
родитель 208c2d270b
Коммит 7d493c6bcd
3 изменённых файлов: 4 добавлений и 4 удалений

Просмотреть файл

@ -134,7 +134,7 @@ int mca_pml_ob1_recv(void *addr,
MCA_PML_OB1_RECV_REQUEST_START(recvreq);
ompi_request_wait_completion(&recvreq->req_recv.req_base.req_ompi);
if( true == recvreq->req_recv.req_base.req_pml_complete ) {
if (recvreq->req_recv.req_base.req_pml_complete) {
/* make buffer defined when the request is completed */
MEMCHECKER(
memchecker_call(&opal_memchecker_base_mem_defined,

Просмотреть файл

@ -80,7 +80,7 @@ static int mca_pml_ob1_recv_request_free(struct ompi_request_t** request)
PERUSE_TRACE_COMM_EVENT( PERUSE_COMM_REQ_NOTIFY,
&(recvreq->req_recv.req_base), PERUSE_RECV );
if( true == recvreq->req_recv.req_base.req_pml_complete ) {
if (recvreq->req_recv.req_base.req_pml_complete) {
/* make buffer defined when the request is completed,
and before releasing the objects. */
MEMCHECKER(
@ -105,7 +105,7 @@ static int mca_pml_ob1_recv_request_cancel(struct ompi_request_t* ompi_request,
/* The rest should be protected behind the match logic lock */
OB1_MATCHING_LOCK(&ob1_comm->matching_lock);
if( true == request->req_match_received ) { /* way to late to cancel this one */
if (request->req_match_received) { /* way to late to cancel this one */
OB1_MATCHING_UNLOCK(&ob1_comm->matching_lock);
assert( OMPI_ANY_TAG != ompi_request->req_status.MPI_TAG ); /* not matched isn't it */
return OMPI_SUCCESS;

Просмотреть файл

@ -106,7 +106,7 @@ static int mca_pml_ob1_send_request_free(struct ompi_request_t** request)
PERUSE_TRACE_COMM_EVENT( PERUSE_COMM_REQ_NOTIFY,
&(sendreq->req_send.req_base), PERUSE_SEND );
if( true == sendreq->req_send.req_base.req_pml_complete ) {
if (sendreq->req_send.req_base.req_pml_complete) {
/* make buffer defined when the request is completed,
and before releasing the objects. */
MEMCHECKER(