Skip to content
Merged
Show file tree
Hide file tree
Changes from 4 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion src/uct/ib/mlx5/rc/rc_mlx5.inl
Original file line number Diff line number Diff line change
Expand Up @@ -1759,7 +1759,7 @@ static ucs_status_t UCS_F_ALWAYS_INLINE uct_rc_mlx5_common_dm_make_data(
if (ucs_unlikely(desc == NULL)) {
/* in case if no resources available - fallback to bcopy */
UCT_RC_IFACE_GET_TX_DESC(&iface->super, &iface->super.tx.mp, desc);
desc->super.handler = (uct_rc_send_handler_t)ucs_mpool_put;
desc->super.handler = uct_rc_ep_short_dm_desc_handler;
buffer = desc + 1;

/* condition is static-evaluated, no performance penalty */
Expand Down
2 changes: 1 addition & 1 deletion src/uct/ib/mlx5/rc/rc_mlx5_common.c
Original file line number Diff line number Diff line change
Expand Up @@ -767,7 +767,7 @@ static void uct_rc_mlx5_iface_common_dm_mp_obj_init(ucs_mpool_t *mp, void *obj,

desc->lkey = dm->mr->lkey;
desc->super.buffer = UCS_PTR_BYTE_OFFSET(dm->start_va, dm->seg_attached * dm->seg_len);
desc->super.handler = (uct_rc_send_handler_t)ucs_mpool_put;
desc->super.handler = uct_rc_ep_short_dm_desc_handler;
dm->seg_attached++;
}

Expand Down
Loading