Bugfix and use INLINE flag on send.
This commit was SVN r6600.
Этот коммит содержится в:
родитель
28d6651350
Коммит
e33a8205e8
@ -91,10 +91,9 @@ struct mca_btl_openib_component_t {
|
|||||||
|
|
||||||
size_t eager_limit;
|
size_t eager_limit;
|
||||||
size_t max_send_size;
|
size_t max_send_size;
|
||||||
|
|
||||||
uint32_t leave_pinned;
|
uint32_t leave_pinned;
|
||||||
uint32_t reg_mru_len;
|
uint32_t reg_mru_len;
|
||||||
|
|
||||||
uint32_t ib_cq_size; /**< Max outstanding CQE on the CQ */
|
uint32_t ib_cq_size; /**< Max outstanding CQE on the CQ */
|
||||||
uint32_t ib_wq_size; /**< Max outstanding WR on the WQ */
|
uint32_t ib_wq_size; /**< Max outstanding WR on the WQ */
|
||||||
uint32_t ib_sg_list_size; /**< Max scatter/gather descriptor entries on the WQ*/
|
uint32_t ib_sg_list_size; /**< Max scatter/gather descriptor entries on the WQ*/
|
||||||
|
@ -71,7 +71,7 @@ static inline int mca_btl_openib_endpoint_post_send(mca_btl_openib_module_t* ope
|
|||||||
struct ibv_send_wr* bad_wr;
|
struct ibv_send_wr* bad_wr;
|
||||||
frag->sg_entry.addr = (uintptr_t) frag->hdr;
|
frag->sg_entry.addr = (uintptr_t) frag->hdr;
|
||||||
|
|
||||||
if(frag->base.des_flags && MCA_BTL_DES_FLAGS_PRIORITY && frag->size <= openib_btl->super.btl_eager_limit){
|
if(frag->base.des_flags & MCA_BTL_DES_FLAGS_PRIORITY && frag->size <= openib_btl->super.btl_eager_limit){
|
||||||
ib_qp = endpoint->lcl_qp_high;
|
ib_qp = endpoint->lcl_qp_high;
|
||||||
} else {
|
} else {
|
||||||
ib_qp = endpoint->lcl_qp_low;
|
ib_qp = endpoint->lcl_qp_low;
|
||||||
@ -85,9 +85,10 @@ static inline int mca_btl_openib_endpoint_post_send(mca_btl_openib_module_t* ope
|
|||||||
|
|
||||||
|
|
||||||
if(frag->sg_entry.length <= openib_btl->ib_inline_max) {
|
if(frag->sg_entry.length <= openib_btl->ib_inline_max) {
|
||||||
/* frag->wr_desc.sr_desc.send_flags |= IBV_SEND_INLINE; */
|
frag->wr_desc.sr_desc.send_flags |= IBV_SEND_INLINE;
|
||||||
}
|
} else {
|
||||||
|
frag->wr_desc.sr_desc.send_flags = IBV_SEND_SIGNALED;
|
||||||
|
}
|
||||||
|
|
||||||
if(ibv_post_send(ib_qp,
|
if(ibv_post_send(ib_qp,
|
||||||
&frag->wr_desc.sr_desc,
|
&frag->wr_desc.sr_desc,
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user