Skip to content
Permalink

Comparing changes

This is a direct comparison between two commits made in this repository or its related repositories. View the default comparison for this range or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: ofiwg/libfabric
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: 6ed30c68d5a044d858ec2492b2e994f57746625c
Choose a base ref
..
head repository: ofiwg/libfabric
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: 2abcf499f5310a54f825a1b8e117d1071160809c
Choose a head ref
Showing with 3 additions and 22 deletions.
  1. +0 −3 prov/efa/src/rdm/efa_rdm_ep.h
  2. +0 −3 prov/efa/src/rdm/efa_rdm_ep_fiops.c
  3. +3 −16 prov/efa/src/rdm/efa_rdm_ep_progress.c
3 changes: 0 additions & 3 deletions prov/efa/src/rdm/efa_rdm_ep.h
Original file line number Diff line number Diff line change
@@ -189,9 +189,6 @@ struct efa_rdm_ep {

size_t efa_total_posted_tx_ops;
size_t send_comps;
size_t failed_send_comps;
size_t failed_write_comps;
size_t failed_read_comps;
size_t recv_comps;
#endif
/* track allocated rx_entries and tx_entries for endpoint cleanup */
3 changes: 0 additions & 3 deletions prov/efa/src/rdm/efa_rdm_ep_fiops.c
Original file line number Diff line number Diff line change
@@ -492,9 +492,6 @@ int efa_rdm_ep_open(struct fid_domain *domain, struct fi_info *info,
#if ENABLE_DEBUG
efa_rdm_ep->efa_total_posted_tx_ops = 0;
efa_rdm_ep->send_comps = 0;
efa_rdm_ep->failed_send_comps = 0;
efa_rdm_ep->failed_write_comps = 0;
efa_rdm_ep->failed_read_comps = 0;
efa_rdm_ep->recv_comps = 0;
#endif

19 changes: 3 additions & 16 deletions prov/efa/src/rdm/efa_rdm_ep_progress.c
Original file line number Diff line number Diff line change
@@ -470,22 +470,9 @@ static inline void efa_rdm_ep_poll_ibv_cq(struct efa_rdm_ep *ep, size_t cqe_to_p
if (ep->ibv_cq_ex->status) {
prov_errno = ibv_wc_read_vendor_err(ep->ibv_cq_ex);
switch (opcode) {
case IBV_WC_SEND:
#if ENABLE_DEBUG
ep->failed_send_comps++;
#endif
efa_rdm_pke_handle_tx_error(pkt_entry, FI_EIO, prov_errno);
break;
case IBV_WC_RDMA_WRITE:
#if ENABLE_DEBUG
ep->failed_write_comps++;
#endif
efa_rdm_pke_handle_tx_error(pkt_entry, FI_EIO, prov_errno);
break;
case IBV_WC_RDMA_READ:
#if ENABLE_DEBUG
ep->failed_read_comps++;
#endif
case IBV_WC_SEND: /* fall through */
case IBV_WC_RDMA_WRITE: /* fall through */
case IBV_WC_RDMA_READ: /* fall through */
efa_rdm_pke_handle_tx_error(pkt_entry, FI_EIO, prov_errno);
break;
case IBV_WC_RECV: /* fall through */