Merge pull request #4850 from vspetrov/master

coll/hcoll: Fix return codes
open-mpi · Feb 22, 2018 · 40e0ae7 · 40e0ae7
2 parents 0a822f8 + bf4e694
commit 40e0ae7
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/ompi/mca/coll/hcoll/coll_hcoll_rte.c b/ompi/mca/coll/hcoll/coll_hcoll_rte.c
@@ -185,7 +185,7 @@ static int recv_nb(struct dte_data_representation_t data,
     if (NULL == ec_h.handle && -1 != ec_h.rank) {
         fprintf(stderr,"***Error in hcolrte_rml_recv_nb: wrong null argument: "
                 "ec_h.handle = %p, ec_h.rank = %d\n",ec_h.handle,ec_h.rank);
-        return 1;
+        return HCOLL_ERROR;
     }
     assert(HCOL_DTE_IS_INLINE(data));
     /*do inline nb recv*/
@@ -195,7 +195,7 @@ static int recv_nb(struct dte_data_representation_t data,
     if (!buffer && !HCOL_DTE_IS_ZERO(data)) {
         fprintf(stderr, "***Error in hcolrte_rml_recv_nb: buffer pointer is NULL"
                 " for non DTE_ZERO INLINE data representation\n");
-        return 1;
+        return HCOLL_ERROR;
     }
     size = (size_t)data.rep.in_line_rep.data_handle.in_line.packed_size*count/8;
 
@@ -204,7 +204,7 @@ static int recv_nb(struct dte_data_representation_t data,
     if (MCA_PML_CALL(irecv(buffer,size,&(ompi_mpi_unsigned_char.dt),ec_h.rank,
                            tag,comm,&ompi_req)))
     {
-        return 1;
+        return HCOLL_ERROR;
     }
     req->data = (void *)ompi_req;
     req->status = HCOLRTE_REQUEST_ACTIVE;
@@ -226,7 +226,7 @@ static int send_nb( dte_data_representation_t data,
     if (! ec_h.handle) {
         fprintf(stderr,"***Error in hcolrte_rml_send_nb: wrong null argument: "
                 "ec_h.handle = %p, ec_h.rank = %d\n",ec_h.handle,ec_h.rank);
-        return 1;
+        return HCOLL_ERROR;
     }
     assert(HCOL_DTE_IS_INLINE(data));
     /*do inline nb recv*/
@@ -235,15 +235,15 @@ static int send_nb( dte_data_representation_t data,
     if (!buffer && !HCOL_DTE_IS_ZERO(data)) {
         fprintf(stderr, "***Error in hcolrte_rml_send_nb: buffer pointer is NULL"
                 " for non DTE_ZERO INLINE data representation\n");
-        return 1;
+        return HCOLL_ERROR;
     }
     size = (size_t)data.rep.in_line_rep.data_handle.in_line.packed_size*count/8;
     HCOL_VERBOSE(30,"PML_ISEND: dest = %d: buf = %p: size = %u: comm = %p",
                  ec_h.rank, buffer, (unsigned int)size, (void *)comm);
     if (MCA_PML_CALL(isend(buffer,size,&(ompi_mpi_unsigned_char.dt),ec_h.rank,
                            tag,MCA_PML_BASE_SEND_STANDARD,comm,&ompi_req)))
     {
-        return 1;
+        return HCOLL_ERROR;
     }
     req->data = (void *)ompi_req;
     req->status = HCOLRTE_REQUEST_ACTIVE;