call ob1 progress rather than endpoint - as it may not have one
This commit was SVN r6696.
Этот коммит содержится в:
родитель
0c32f34cb7
Коммит
2324f36065
@ -270,7 +270,8 @@ int mca_pml_ob1_add_procs(ompi_proc_t** procs, size_t nprocs)
|
|||||||
size_t size = sizeof(uint32_t);
|
size_t size = sizeof(uint32_t);
|
||||||
rc = mca_base_modex_recv(&mca_pml_ob1_component.pmlm_version, procs[p],
|
rc = mca_base_modex_recv(&mca_pml_ob1_component.pmlm_version, procs[p],
|
||||||
(void**)&proc_arch, &size);
|
(void**)&proc_arch, &size);
|
||||||
if(rc != OMPI_SUCCESS) return rc;
|
if(rc != OMPI_SUCCESS)
|
||||||
|
return rc;
|
||||||
if(size != sizeof(uint32_t))
|
if(size != sizeof(uint32_t))
|
||||||
return OMPI_ERROR;
|
return OMPI_ERROR;
|
||||||
procs[p]->proc_arch = ntohl(*proc_arch);
|
procs[p]->proc_arch = ntohl(*proc_arch);
|
||||||
|
@ -483,7 +483,7 @@ int mca_pml_ob1_send_request_schedule(mca_pml_ob1_send_request_t* sendreq)
|
|||||||
if(bytes_remaining == 0)
|
if(bytes_remaining == 0)
|
||||||
sendreq->t_scheduled = get_profiler_timestamp();
|
sendreq->t_scheduled = get_profiler_timestamp();
|
||||||
#endif
|
#endif
|
||||||
ep->btl_progress(); /* call progress */
|
mca_pml_ob1_progress();
|
||||||
}
|
}
|
||||||
} while (OPAL_THREAD_ADD32(&sendreq->req_lock,-1) > 0);
|
} while (OPAL_THREAD_ADD32(&sendreq->req_lock,-1) > 0);
|
||||||
}
|
}
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user