diff --git a/ompi/mca/bml/bml.h b/ompi/mca/bml/bml.h index 475952c837..7ccbc9920f 100644 --- a/ompi/mca/bml/bml.h +++ b/ompi/mca/bml/bml.h @@ -356,19 +356,19 @@ static inline void mca_bml_base_prepare_dst(mca_bml_base_btl_t* bml_btl, } #if OMPI_HAVE_THREAD_SUPPORT -#define MCA_BML_BASE_BTL_DES_ALLOC(bml_btl, des, order, \ +#define MCA_BML_BASE_BTL_DES_ALLOC(bml_btl, des, arg_order, \ alloc_size, seg_size) \ do { \ - if( MCA_BTL_NO_ORDER == order && \ + if( MCA_BTL_NO_ORDER == arg_order && \ NULL != (des = bml_btl->btl_cache) ) { \ /* atomically acquire the cached descriptor */ \ if(opal_atomic_cmpset_ptr(&bml_btl->btl_cache, \ des, NULL) == 0) { \ - des = bml_btl->btl_alloc(bml_btl->btl, order, \ + des = bml_btl->btl_alloc(bml_btl->btl, arg_order, \ alloc_size); \ } \ } else { \ - des = bml_btl->btl_alloc(bml_btl->btl, order, alloc_size); \ + des = bml_btl->btl_alloc(bml_btl->btl, arg_order, alloc_size); \ } \ if( OPAL_LIKELY(des != NULL) ) { \ des->des_src->seg_len = seg_size; \ @@ -376,15 +376,15 @@ static inline void mca_bml_base_prepare_dst(mca_bml_base_btl_t* bml_btl, } \ } while(0) #else -#define MCA_BML_BASE_BTL_DES_ALLOC(bml_btl, des, _order, \ +#define MCA_BML_BASE_BTL_DES_ALLOC(bml_btl, des, arg_order, \ alloc_size, seg_size) \ do { \ - if( MCA_BTL_NO_ORDER == _order && \ + if( MCA_BTL_NO_ORDER == arg_order && \ NULL != (des = bml_btl->btl_cache) ) { \ bml_btl->btl_cache = NULL; \ des->order = MCA_BTL_NO_ORDER; \ } else { \ - des = bml_btl->btl_alloc(bml_btl->btl, _order, alloc_size); \ + des = bml_btl->btl_alloc(bml_btl->btl, arg_order, alloc_size); \ } \ if( OPAL_LIKELY(des != NULL) ) { \ des->des_src->seg_len = seg_size; \ diff --git a/ompi/mca/btl/openib/btl_openib_proc.c b/ompi/mca/btl/openib/btl_openib_proc.c index 6c8c2abae7..1beb83e6dc 100644 --- a/ompi/mca/btl/openib/btl_openib_proc.c +++ b/ompi/mca/btl/openib/btl_openib_proc.c @@ -137,7 +137,7 @@ mca_btl_openib_proc_t* mca_btl_openib_proc_create(ompi_proc_t* ompi_proc) if(OMPI_SUCCESS != rc) { - opal_output(mca_btl_base_output, "[%s:%d] mca_pml_base_modex_recv failed for peer [%ld,%ld,%ld]", + opal_output(mca_btl_base_output, "[%s:%d] ompi_modex_recv failed for peer [%ld,%ld,%ld]", __FILE__,__LINE__,ORTE_NAME_ARGS(&ompi_proc->proc_name)); OBJ_RELEASE(module_proc); return NULL; diff --git a/ompi/runtime/ompi_mpi_preconnect.c b/ompi/runtime/ompi_mpi_preconnect.c index 818ed3c80e..9651e096cb 100644 --- a/ompi/runtime/ompi_mpi_preconnect.c +++ b/ompi/runtime/ompi_mpi_preconnect.c @@ -78,22 +78,6 @@ ompi_init_preconnect_mpi(void) ret = ompi_request_wait_all(2, requests, MPI_STATUSES_IGNORE); if (OMPI_SUCCESS != ret) return ret; - - ret = MCA_PML_CALL(isend(outbuf, 1, MPI_CHAR, - next, 1, - MCA_PML_BASE_SEND_COMPLETE, - MPI_COMM_WORLD, - &requests[1])); - if (OMPI_SUCCESS != ret) return ret; - - ret = MCA_PML_CALL(irecv(inbuf, 1, MPI_CHAR, - prev, 1, - MPI_COMM_WORLD, - &requests[0])); - if(OMPI_SUCCESS != ret) return ret; - - ret = ompi_request_wait_all(2, requests, MPI_STATUSES_IGNORE); - if (OMPI_SUCCESS != ret) return ret; } return ret;