btl/openib: fix compilation issues with XRC
Signed-off-by: Nathan Hjelm <hjelmn@lanl.gov>
Этот коммит содержится в:
родитель
a9763e123d
Коммит
953efc3eb2
@ -12,6 +12,7 @@
|
|||||||
|
|
||||||
#include "btl_openib.h"
|
#include "btl_openib.h"
|
||||||
#include "btl_openib_endpoint.h"
|
#include "btl_openib_endpoint.h"
|
||||||
|
#include "btl_openib_xrc.h"
|
||||||
|
|
||||||
#if HAVE_DECL_IBV_ATOMIC_HCA
|
#if HAVE_DECL_IBV_ATOMIC_HCA
|
||||||
|
|
||||||
|
@ -31,6 +31,7 @@
|
|||||||
#include "btl_openib.h"
|
#include "btl_openib.h"
|
||||||
#include "btl_openib_frag.h"
|
#include "btl_openib_frag.h"
|
||||||
#include "btl_openib_endpoint.h"
|
#include "btl_openib_endpoint.h"
|
||||||
|
#include "btl_openib_xrc.h"
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* RDMA READ remote buffer to local buffer address.
|
* RDMA READ remote buffer to local buffer address.
|
||||||
|
@ -31,6 +31,7 @@
|
|||||||
#include "btl_openib.h"
|
#include "btl_openib.h"
|
||||||
#include "btl_openib_frag.h"
|
#include "btl_openib_frag.h"
|
||||||
#include "btl_openib_endpoint.h"
|
#include "btl_openib_endpoint.h"
|
||||||
|
#include "btl_openib_xrc.h"
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* RDMA WRITE local buffer to remote buffer address.
|
* RDMA WRITE local buffer to remote buffer address.
|
||||||
|
@ -521,30 +521,33 @@ static int udcm_endpoint_init_self_xrc (struct mca_btl_base_endpoint_t *lcl_ep)
|
|||||||
|
|
||||||
opal_mutex_lock (&udep->udep_lock);
|
opal_mutex_lock (&udep->udep_lock);
|
||||||
do {
|
do {
|
||||||
|
#if OPAL_HAVE_CONNECTX_XRC_DOMAINS
|
||||||
|
rc = udcm_xrc_recv_qp_connect (lcl_ep, lcl_ep->qps[0].qp->lcl_qp->qp_num);
|
||||||
|
#else
|
||||||
|
lcl_ep->xrc_recv_qp_num = lcl_ep->qps[0].qp->lcl_qp->qp_num;
|
||||||
rc = udcm_xrc_recv_qp_connect (lcl_ep);
|
rc = udcm_xrc_recv_qp_connect (lcl_ep);
|
||||||
if (OMPI_SUCCESS != rc) {
|
#endif
|
||||||
|
if (OPAL_SUCCESS != rc) {
|
||||||
BTL_VERBOSE(("error connecting loopback XRC receive queue pair"));
|
BTL_VERBOSE(("error connecting loopback XRC receive queue pair"));
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
lcl_ep->xrc_recv_qp_num = lcl_ep->qps[0].qp->lcl_qp->qp_num;
|
|
||||||
|
|
||||||
rc = mca_btl_openib_endpoint_post_recvs (lcl_ep);
|
rc = mca_btl_openib_endpoint_post_recvs (lcl_ep);
|
||||||
if (OMPI_SUCCESS != rc) {
|
if (OPAL_SUCCESS != rc) {
|
||||||
BTL_VERBOSE(("error posting receives for loopback queue pair"));
|
BTL_VERBOSE(("error posting receives for loopback queue pair"));
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
rc = udcm_xrc_recv_qp_create (lcl_ep, lcl_ep->qps[0].qp->lcl_qp->qp_num,
|
rc = udcm_xrc_recv_qp_create (lcl_ep, lcl_ep->qps[0].qp->lcl_qp->qp_num,
|
||||||
lcl_ep->qps[0].qp->lcl_psn);
|
lcl_ep->qps[0].qp->lcl_psn);
|
||||||
if (OMPI_SUCCESS != rc) {
|
if (OPAL_SUCCESS != rc) {
|
||||||
BTL_VERBOSE(("error creating loopback XRC receive queue pair"));
|
BTL_VERBOSE(("error creating loopback XRC receive queue pair"));
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
rc = udcm_xrc_send_qp_connect (lcl_ep, lcl_ep->qps[0].qp->lcl_qp->qp_num,
|
rc = udcm_xrc_send_qp_connect (lcl_ep, lcl_ep->qps[0].qp->lcl_qp->qp_num,
|
||||||
lcl_ep->qps[0].qp->lcl_psn);
|
lcl_ep->qps[0].qp->lcl_psn);
|
||||||
if (OMPI_SUCCESS != rc) {
|
if (OPAL_SUCCESS != rc) {
|
||||||
BTL_VERBOSE(("error creating loopback XRC send queue pair"));
|
BTL_VERBOSE(("error creating loopback XRC send queue pair"));
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user