diff --git a/ompi/mca/pml/ob1/pml_ob1.c b/ompi/mca/pml/ob1/pml_ob1.c index f79dc0e130..8bd8e5cef4 100644 --- a/ompi/mca/pml/ob1/pml_ob1.c +++ b/ompi/mca/pml/ob1/pml_ob1.c @@ -270,7 +270,8 @@ int mca_pml_ob1_add_procs(ompi_proc_t** procs, size_t nprocs) size_t size = sizeof(uint32_t); rc = mca_base_modex_recv(&mca_pml_ob1_component.pmlm_version, procs[p], (void**)&proc_arch, &size); - if(rc != OMPI_SUCCESS) return rc; + if(rc != OMPI_SUCCESS) + return rc; if(size != sizeof(uint32_t)) return OMPI_ERROR; procs[p]->proc_arch = ntohl(*proc_arch); diff --git a/ompi/mca/pml/ob1/pml_ob1_sendreq.c b/ompi/mca/pml/ob1/pml_ob1_sendreq.c index 5b9a3b04db..56fd937ce2 100644 --- a/ompi/mca/pml/ob1/pml_ob1_sendreq.c +++ b/ompi/mca/pml/ob1/pml_ob1_sendreq.c @@ -483,7 +483,7 @@ int mca_pml_ob1_send_request_schedule(mca_pml_ob1_send_request_t* sendreq) if(bytes_remaining == 0) sendreq->t_scheduled = get_profiler_timestamp(); #endif - ep->btl_progress(); /* call progress */ + mca_pml_ob1_progress(); } } while (OPAL_THREAD_ADD32(&sendreq->req_lock,-1) > 0); }