diff --git a/ompi/mca/btl/elan/btl_elan.c b/ompi/mca/btl/elan/btl_elan.c index ca7e16a096..31a54037b5 100644 --- a/ompi/mca/btl/elan/btl_elan.c +++ b/ompi/mca/btl/elan/btl_elan.c @@ -157,7 +157,9 @@ static int mca_btl_elan_add_procs( struct mca_btl_base_module_t* btl, frag->base.des_src = NULL; frag->base.des_src_cnt = 0; frag->type = MCA_BTL_ELAN_HDR_TYPE_RECV; - frag->elan_event = elan_tportRxStart( elan_btl->tport, 0/*ELAN_TPORT_RXANY*/, 0, 0, 0, 0, + frag->elan_event = elan_tportRxStart( elan_btl->tport, + ELAN_TPORT_RXBUF | ELAN_TPORT_RXANY, + 0, 0, 0, 0, frag->base.des_dst->seg_addr.pval, mca_btl_elan_module.super.btl_eager_limit ); /* Add the fragment to the pending RDMA list */ diff --git a/ompi/mca/btl/elan/btl_elan_component.c b/ompi/mca/btl/elan/btl_elan_component.c index 275142b583..3bfa8ec58b 100644 --- a/ompi/mca/btl/elan/btl_elan_component.c +++ b/ompi/mca/btl/elan/btl_elan_component.c @@ -292,7 +292,9 @@ int mca_btl_elan_component_progress( void ) frag->base.des_dst->seg_addr.pval = (void*)(frag+1); } OPAL_THREAD_LOCK(&elan_btl->elan_lock); - frag->elan_event = elan_tportRxStart( elan_btl->tport, 0/*ELAN_TPORT_RXANY*/, 0, 0, 0, 0, + frag->elan_event = elan_tportRxStart( elan_btl->tport, + ELAN_TPORT_RXBUF | ELAN_TPORT_RXANY, + 0, 0, 0, 0, frag->base.des_dst->seg_addr.pval, mca_btl_elan_module.super.btl_eager_limit ); opal_list_append( &(elan_btl->recv_list), (opal_list_item_t*)frag );