| /dports/net/mpich/mpich-3.4.3/modules/ucx/src/uct/ib/ud/base/ |
| H A D | ud_ep.c | 154 uct_ud_skb_is_completed(uct_ud_send_skb_t *skb, uct_ud_psn_t ack_psn) in uct_ud_skb_is_completed() argument
157 return UCT_UD_PSN_COMPARE(skb->neth->psn, <=, ack_psn) && in uct_ud_skb_is_completed()
163 uct_ud_psn_t ack_psn, ucs_status_t status, in uct_ud_ep_window_release_inline() argument
169 uct_ud_skb_is_completed(skb, ack_psn)) { in uct_ud_ep_window_release_inline()
591 uct_ud_psn_t ack_psn, int is_async) in uct_ud_ep_process_ack() argument
594 if (ucs_unlikely(UCT_UD_PSN_COMPARE(ack_psn, <=, ep->tx.acked_psn))) { in uct_ud_ep_process_ack()
598 ep->tx.acked_psn = ack_psn; in uct_ud_ep_process_ack()
600 uct_ud_ep_window_release_inline(iface, ep, ack_psn, UCS_OK, is_async, 0); in uct_ud_ep_process_ack()
832 uct_ud_ep_process_ack(iface, ep, neth->ack_psn, is_async); in uct_ud_ep_process_rx()
1193 skb->neth->ack_psn = ep->rx.acked_psn; in uct_ud_ep_resend()
|
| H A D | ud_log.c | 30 uct_ud_neth_get_dest_id(neth), neth->psn, neth->ack_psn, in uct_ud_dump_packet()
|
| H A D | ud_def.h | 124 uct_ud_psn_t ack_psn; member
|
| H A D | ud_ep.h | 361 neth->ack_psn = ep->rx.acked_psn = ucs_frag_list_sn(&ep->rx.ooo_pkts); in uct_ud_neth_init_data()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/infiniband/sw/rxe/ |
| H A D | rxe_verbs.h | 173 u32 ack_psn; member
|
| H A D | rxe_resp.c | 795 qp->resp.ack_psn = qp->resp.psn; in execute()
1054 u32 prev_psn = (qp->resp.ack_psn - 1) & BTH_PSN_MASK; in duplicate_request()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/infiniband/sw/rxe/ |
| H A D | rxe_verbs.h | 173 u32 ack_psn; member
|
| H A D | rxe_resp.c | 795 qp->resp.ack_psn = qp->resp.psn; in execute()
1054 u32 prev_psn = (qp->resp.ack_psn - 1) & BTH_PSN_MASK; in duplicate_request()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/infiniband/sw/rxe/ |
| H A D | rxe_verbs.h | 173 u32 ack_psn; member
|
| H A D | rxe_resp.c | 795 qp->resp.ack_psn = qp->resp.psn; in execute()
1054 u32 prev_psn = (qp->resp.ack_psn - 1) & BTH_PSN_MASK; in duplicate_request()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/infiniband/hw/qib/ |
| H A D | qib_rc.c | 1014 u32 ack_psn; in do_rc_ack() local
1023 ack_psn = psn; in do_rc_ack()
1025 ack_psn--; in do_rc_ack()
1033 while ((diff = qib_cmp24(ack_psn, wqe->lpsn)) >= 0) { in do_rc_ack()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/infiniband/hw/qib/ |
| H A D | qib_rc.c | 1014 u32 ack_psn; in do_rc_ack() local
1023 ack_psn = psn; in do_rc_ack()
1025 ack_psn--; in do_rc_ack()
1033 while ((diff = qib_cmp24(ack_psn, wqe->lpsn)) >= 0) { in do_rc_ack()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/infiniband/hw/qib/ |
| H A D | qib_rc.c | 1014 u32 ack_psn; in do_rc_ack() local
1023 ack_psn = psn; in do_rc_ack()
1025 ack_psn--; in do_rc_ack()
1033 while ((diff = qib_cmp24(ack_psn, wqe->lpsn)) >= 0) { in do_rc_ack()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/infiniband/hw/hfi1/ |
| H A D | tid_rdma.c | 2666 u32 ack_psn; in handle_read_kdeth_eflags() local
2688 ack_psn = ibpsn - 1; in handle_read_kdeth_eflags()
2693 while ((int)delta_psn(ack_psn, wqe->lpsn) >= 0) { in handle_read_kdeth_eflags()
4505 u32 aeth, psn, req_psn, ack_psn, flpsn, resync_psn, ack_kpsn; in hfi1_rc_rcv_tid_rdma_ack() local
4524 ack_psn = req_psn; in hfi1_rc_rcv_tid_rdma_ack()
4530 ack_psn--; in hfi1_rc_rcv_tid_rdma_ack()
4634 if (delta_psn(ack_psn, wqe->lpsn)) in hfi1_rc_rcv_tid_rdma_ack()
|
| H A D | rc.c | 2014 u32 ack_psn; in do_rc_ack() local
2025 ack_psn = psn; in do_rc_ack()
2027 ack_psn--; in do_rc_ack()
2035 while ((diff = delta_psn(ack_psn, wqe->lpsn)) >= 0) { in do_rc_ack()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/infiniband/hw/hfi1/ |
| H A D | tid_rdma.c | 2666 u32 ack_psn; in handle_read_kdeth_eflags() local
2688 ack_psn = ibpsn - 1; in handle_read_kdeth_eflags()
2693 while ((int)delta_psn(ack_psn, wqe->lpsn) >= 0) { in handle_read_kdeth_eflags()
4505 u32 aeth, psn, req_psn, ack_psn, flpsn, resync_psn, ack_kpsn; in hfi1_rc_rcv_tid_rdma_ack() local
4524 ack_psn = req_psn; in hfi1_rc_rcv_tid_rdma_ack()
4530 ack_psn--; in hfi1_rc_rcv_tid_rdma_ack()
4634 if (delta_psn(ack_psn, wqe->lpsn)) in hfi1_rc_rcv_tid_rdma_ack()
|
| H A D | rc.c | 2014 u32 ack_psn; in do_rc_ack() local
2025 ack_psn = psn; in do_rc_ack()
2027 ack_psn--; in do_rc_ack()
2035 while ((diff = delta_psn(ack_psn, wqe->lpsn)) >= 0) { in do_rc_ack()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/infiniband/hw/hfi1/ |
| H A D | tid_rdma.c | 2666 u32 ack_psn; in handle_read_kdeth_eflags() local
2688 ack_psn = ibpsn - 1; in handle_read_kdeth_eflags()
2693 while ((int)delta_psn(ack_psn, wqe->lpsn) >= 0) { in handle_read_kdeth_eflags()
4505 u32 aeth, psn, req_psn, ack_psn, flpsn, resync_psn, ack_kpsn; in hfi1_rc_rcv_tid_rdma_ack() local
4524 ack_psn = req_psn; in hfi1_rc_rcv_tid_rdma_ack()
4530 ack_psn--; in hfi1_rc_rcv_tid_rdma_ack()
4634 if (delta_psn(ack_psn, wqe->lpsn)) in hfi1_rc_rcv_tid_rdma_ack()
|
| H A D | rc.c | 2014 u32 ack_psn; in do_rc_ack() local
2025 ack_psn = psn; in do_rc_ack()
2027 ack_psn--; in do_rc_ack()
2035 while ((diff = delta_psn(ack_psn, wqe->lpsn)) >= 0) { in do_rc_ack()
|
| /dports/net/mpich/mpich-3.4.3/modules/ucx/test/gtest/uct/ib/ |
| H A D | test_ud.cc | 40 if (UCT_UD_PSN_COMPARE(neth->ack_psn, >, ep->tx.acked_psn)) { in count_rx_acks()
|