mtl/ofi: Fix synchronous Recv from ANY_SRC.
Этот коммит содержится в:
родитель
fbb7c80312
Коммит
375611505b
@ -107,7 +107,7 @@ ompi_mtl_ofi_recv_callback(struct fi_cq_tagged_entry *wc,
|
|||||||
* If the recv request was posted for any source,
|
* If the recv request was posted for any source,
|
||||||
* we need to extract the source's actual address.
|
* we need to extract the source's actual address.
|
||||||
*/
|
*/
|
||||||
if (!ofi_req->remote_addr) {
|
if (ompi_mtl_ofi.any_addr == ofi_req->remote_addr) {
|
||||||
src = MTL_OFI_GET_SOURCE(wc->tag);
|
src = MTL_OFI_GET_SOURCE(wc->tag);
|
||||||
ompi_proc = ompi_comm_peer_lookup(ofi_req->comm, src );
|
ompi_proc = ompi_comm_peer_lookup(ofi_req->comm, src );
|
||||||
endpoint = ompi_proc->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_MTL];
|
endpoint = ompi_proc->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_MTL];
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user