@@ -185,7 +185,7 @@ static int recv_nb(struct dte_data_representation_t data,
185185 if (NULL == ec_h .handle && -1 != ec_h .rank ) {
186186 fprintf (stderr ,"***Error in hcolrte_rml_recv_nb: wrong null argument: "
187187 "ec_h.handle = %p, ec_h.rank = %d\n" ,ec_h .handle ,ec_h .rank );
188- return 1 ;
188+ return HCOLL_ERROR ;
189189 }
190190 assert (HCOL_DTE_IS_INLINE (data ));
191191 /*do inline nb recv*/
@@ -195,7 +195,7 @@ static int recv_nb(struct dte_data_representation_t data,
195195 if (!buffer && !HCOL_DTE_IS_ZERO (data )) {
196196 fprintf (stderr , "***Error in hcolrte_rml_recv_nb: buffer pointer is NULL"
197197 " for non DTE_ZERO INLINE data representation\n" );
198- return 1 ;
198+ return HCOLL_ERROR ;
199199 }
200200 size = (size_t )data .rep .in_line_rep .data_handle .in_line .packed_size * count /8 ;
201201
@@ -204,7 +204,7 @@ static int recv_nb(struct dte_data_representation_t data,
204204 if (MCA_PML_CALL (irecv (buffer ,size ,& (ompi_mpi_unsigned_char .dt ),ec_h .rank ,
205205 tag ,comm ,& ompi_req )))
206206 {
207- return 1 ;
207+ return HCOLL_ERROR ;
208208 }
209209 req -> data = (void * )ompi_req ;
210210 req -> status = HCOLRTE_REQUEST_ACTIVE ;
@@ -226,7 +226,7 @@ static int send_nb( dte_data_representation_t data,
226226 if (! ec_h .handle ) {
227227 fprintf (stderr ,"***Error in hcolrte_rml_send_nb: wrong null argument: "
228228 "ec_h.handle = %p, ec_h.rank = %d\n" ,ec_h .handle ,ec_h .rank );
229- return 1 ;
229+ return HCOLL_ERROR ;
230230 }
231231 assert (HCOL_DTE_IS_INLINE (data ));
232232 /*do inline nb recv*/
@@ -235,15 +235,15 @@ static int send_nb( dte_data_representation_t data,
235235 if (!buffer && !HCOL_DTE_IS_ZERO (data )) {
236236 fprintf (stderr , "***Error in hcolrte_rml_send_nb: buffer pointer is NULL"
237237 " for non DTE_ZERO INLINE data representation\n" );
238- return 1 ;
238+ return HCOLL_ERROR ;
239239 }
240240 size = (size_t )data .rep .in_line_rep .data_handle .in_line .packed_size * count /8 ;
241241 HCOL_VERBOSE (30 ,"PML_ISEND: dest = %d: buf = %p: size = %u: comm = %p" ,
242242 ec_h .rank , buffer , (unsigned int )size , (void * )comm );
243243 if (MCA_PML_CALL (isend (buffer ,size ,& (ompi_mpi_unsigned_char .dt ),ec_h .rank ,
244244 tag ,MCA_PML_BASE_SEND_STANDARD ,comm ,& ompi_req )))
245245 {
246- return 1 ;
246+ return HCOLL_ERROR ;
247247 }
248248 req -> data = (void * )ompi_req ;
249249 req -> status = HCOLRTE_REQUEST_ACTIVE ;
0 commit comments