"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "src/mpid/ch3/channels/common/src/cm/cm.c" between
mvapich2-2.3.1.tar.gz and mvapich2-2.3.2.tar.gz

About: MVAPICH2 offers "MPI over InfiniBand, 10GigE/iWARP and RDMA over Converged Ethernet (RoCE)" to achieve best performance, scalability and fault tolerance for high-end computing systems and servers.

cm.c  (mvapich2-2.3.1):cm.c  (mvapich2-2.3.2)
skipping to change at line 63 skipping to change at line 63
vc->state = MPIDI_VC_STATE_ACTIVE; \ vc->state = MPIDI_VC_STATE_ACTIVE; \
} else { \ } else { \
vc->state = MPIDI_VC_STATE_ACTIVE; \ vc->state = MPIDI_VC_STATE_ACTIVE; \
} \ } \
MV2_HYBRID_SEND_NOOP_IF_NEEDED(vc); \ MV2_HYBRID_SEND_NOOP_IF_NEEDED(vc); \
if (mv2_use_eager_fast_send && \ if (mv2_use_eager_fast_send && \
vc->ch.state == MPIDI_CH3I_VC_STATE_IDLE && \ vc->ch.state == MPIDI_CH3I_VC_STATE_IDLE && \
(USE_XRC && VC_XST_ISSET (vc, XF_SEND_IDLE)) && \ (USE_XRC && VC_XST_ISSET (vc, XF_SEND_IDLE)) && \
MPIDI_CH3I_CM_SendQ_empty(vc) && \ MPIDI_CH3I_CM_SendQ_empty(vc) && \
!(SMP_INIT && (vc->smp.local_nodes >= 0))) { \ !(SMP_INIT && (vc->smp.local_nodes >= 0))) { \
vc->eager_fast_fn = mv2_eager_fast_send; \ if (likely(rdma_use_coalesce)) { \
vc->eager_fast_fn = mv2_eager_fast_coalesce_send;\
} else { \
vc->eager_fast_fn = mv2_eager_fast_send; \
} \
} \ } \
} while (0); } while (0);
#else #else
#define VC_SET_ACTIVE(vc) \ #define VC_SET_ACTIVE(vc) \
do { \ do { \
vc->state = MPIDI_VC_STATE_ACTIVE; \ vc->state = MPIDI_VC_STATE_ACTIVE; \
MV2_HYBRID_SEND_NOOP_IF_NEEDED(vc); \ MV2_HYBRID_SEND_NOOP_IF_NEEDED(vc); \
if (mv2_use_eager_fast_send && \ if (mv2_use_eager_fast_send && \
vc->ch.state == MPIDI_CH3I_VC_STATE_IDLE && \ vc->ch.state == MPIDI_CH3I_VC_STATE_IDLE && \
MPIDI_CH3I_CM_SendQ_empty(vc) && \ MPIDI_CH3I_CM_SendQ_empty(vc) && \
!(SMP_INIT && (vc->smp.local_nodes >= 0))) { \ !(SMP_INIT && (vc->smp.local_nodes >= 0))) { \
vc->eager_fast_fn = mv2_eager_fast_send; \ if (likely(rdma_use_coalesce)) { \
vc->eager_fast_fn = mv2_eager_fast_coalesce_send;\
} else { \
vc->eager_fast_fn = mv2_eager_fast_send; \
} \
} \ } \
} while (0); } while (0);
#endif #endif
#if defined(CKPT) #if defined(CKPT)
#define CM_MSG_TYPE_REACTIVATE_REQ 10 #define CM_MSG_TYPE_REACTIVATE_REQ 10
#define CM_MSG_TYPE_REACTIVATE_REP 11 #define CM_MSG_TYPE_REACTIVATE_REP 11
#endif /* defined(CKPT) */ #endif /* defined(CKPT) */
#define CM_MSG_TYPE_FIN_SELF 99 #define CM_MSG_TYPE_FIN_SELF 99
skipping to change at line 1194 skipping to change at line 1202
#ifdef _ENABLE_XRC_ #ifdef _ENABLE_XRC_
void cm_xrc_send_enable(MPIDI_VC_t * vc) void cm_xrc_send_enable(MPIDI_VC_t * vc)
{ {
xrc_pending_conn_t *iter, *tmp; xrc_pending_conn_t *iter, *tmp;
VC_XST_SET(vc, XF_SEND_IDLE); VC_XST_SET(vc, XF_SEND_IDLE);
VC_XST_CLR(vc, XF_SEND_CONNECTING); VC_XST_CLR(vc, XF_SEND_CONNECTING);
VC_XST_CLR(vc, XF_REUSE_WAIT); VC_XST_CLR(vc, XF_REUSE_WAIT);
#ifdef _ENABLE_UD_ #ifdef _ENABLE_UD_
if (vc->mrail.state & MRAILI_UD_CONNECTED) { if (rdma_enable_hybrid && vc->mrail.state & MRAILI_UD_CONNECTED) {
MRAILI_RC_Enable(vc); MRAILI_RC_Enable(vc);
} }
#endif #endif
iter = vc->ch.xrc_conn_queue; iter = vc->ch.xrc_conn_queue;
while (iter) { while (iter) {
tmp = iter->next; tmp = iter->next;
PRINT_DEBUG(DEBUG_XRC_verbose > 0, "Activating conn to %d\n", PRINT_DEBUG(DEBUG_XRC_verbose > 0, "Activating conn to %d\n",
iter->vc->pg_rank); iter->vc->pg_rank);
cm_qp_reuse(iter->vc, vc); cm_qp_reuse(iter->vc, vc);
 End of changes. 3 change blocks. 
3 lines changed or deleted 11 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)