/freebsd-11-stable/sys/ofed/drivers/infiniband/ulp/sdp/ |
H A D | sdp_rx.c | 43 sdp_handle_disconn(struct sdp_sock *ssk) argument 46 sdp_dbg(ssk->socket, "%s\n", __func__); 48 SDP_WLOCK_ASSERT(ssk); 49 if (TCPS_HAVERCVDFIN(ssk->state) == 0) 50 socantrcvmore(ssk->socket); 52 switch (ssk->state) { 55 ssk->state = TCPS_CLOSE_WAIT; 60 sdp_dbg(ssk->socket, 64 sdp_cancel_dreq_wait_timeout(ssk); 65 ssk 97 sdp_post_recv(struct sdp_sock *ssk) argument 163 sdp_post_recvs_needed(struct sdp_sock *ssk) argument 193 sdp_post_recvs(struct sdp_sock *ssk) argument 204 struct sdp_sock *ssk = sdp_sk(sk); local 253 sdp_get_recv_bytes(struct sdp_sock *ssk, u32 new_size) argument 260 sdp_init_buffers(struct sdp_sock *ssk, u32 new_size) argument 270 sdp_resize_buffers(struct sdp_sock *ssk, u32 new_size) argument 283 sdp_handle_resize_request(struct sdp_sock *ssk, struct sdp_chrecvbuf *buf) argument 293 sdp_handle_resize_ack(struct sdp_sock *ssk, struct sdp_chrecvbuf *buf) argument 302 sdp_recv_completion(struct sdp_sock *ssk, int id) argument 325 sdp_process_rx_ctl_mb(struct sdp_sock *ssk, struct mbuf *mb) argument 397 sdp_process_rx_mb(struct sdp_sock *ssk, struct mbuf *mb) argument 470 sdp_process_rx_wc(struct sdp_sock *ssk, struct ib_wc *wc) argument 521 sdp_bzcopy_write_space(struct sdp_sock *ssk) argument 531 sdp_poll_rx_cq(struct sdp_sock *ssk) argument 563 struct sdp_sock *ssk = container_of(work, struct sdp_sock, local 591 sdp_do_posts(struct sdp_sock *ssk) argument 632 sdp_process_rx(struct sdp_sock *ssk) argument 662 struct sdp_sock *ssk; local 676 sdp_rx_ring_purge(struct sdp_sock *ssk) argument 688 sdp_rx_ring_init(struct sdp_sock *ssk) argument 701 sdp_rx_ring_create(struct sdp_sock *ssk, struct ib_device *device) argument 739 sdp_rx_ring_destroy(struct sdp_sock *ssk) argument [all...] |
H A D | sdp_tx.c | 39 static int sdp_process_tx_cq(struct sdp_sock *ssk); 43 sdp_xmit_poll(struct sdp_sock *ssk, int force) argument 47 SDP_WLOCK_ASSERT(ssk); 48 sdp_prf(ssk->socket, NULL, "%s", __func__); 52 if (!callout_pending(&ssk->tx_ring.timer)) 53 callout_reset(&ssk->tx_ring.timer, SDP_TX_POLL_TIMEOUT, 54 sdp_poll_tx_timeout, ssk); 57 if (force || (++ssk->tx_ring.poll_cnt & (SDP_TX_POLL_MODER - 1)) == 0) 58 wc_processed = sdp_process_tx_cq(ssk); 64 sdp_post_send(struct sdp_sock *ssk, struc argument 165 sdp_send_completion(struct sdp_sock *ssk, int mseq) argument 196 sdp_handle_send_comp(struct sdp_sock *ssk, struct ib_wc *wc) argument 225 sdp_process_tx_wc(struct sdp_sock *ssk, struct ib_wc *wc) argument 278 sdp_process_tx_cq(struct sdp_sock *ssk) argument 310 sdp_poll_tx(struct sdp_sock *ssk) argument 353 struct sdp_sock *ssk = (struct sdp_sock *)data; local 364 struct sdp_sock *ssk; local 376 sdp_tx_ring_purge(struct sdp_sock *ssk) argument 388 sdp_post_keepalive(struct sdp_sock *ssk) argument 419 sdp_tx_ring_create(struct sdp_sock *ssk, struct ib_device *device) argument 458 sdp_tx_ring_destroy(struct sdp_sock *ssk) argument [all...] |
H A D | sdp_bcopy.c | 105 sdp_nagle_off(struct sdp_sock *ssk, struct mbuf *mb) argument 116 (ssk->flags & SDP_NODELAY) || 117 !ssk->nagle_last_unacked || 118 mb->m_pkthdr.len >= ssk->xmit_size_goal / 4 || 122 unsigned long mseq = ring_head(ssk->tx_ring); 123 ssk->nagle_last_unacked = mseq; 125 if (!callout_pending(&ssk->nagle_timer)) { 126 callout_reset(&ssk->nagle_timer, SDP_NAGLE_TIMEOUT, 127 sdp_nagle_timeout, ssk); 128 sdp_dbg_data(ssk 140 struct sdp_sock *ssk = (struct sdp_sock *)data; local 164 sdp_post_sends(struct sdp_sock *ssk, int wait) argument [all...] |
H A D | sdp_main.c | 113 sdp_destroy_cma(struct sdp_sock *ssk) argument 116 if (ssk->id == NULL) 118 rdma_destroy_id(ssk->id); 119 ssk->id = NULL; 123 sdp_pcbbind(struct sdp_sock *ssk, struct sockaddr *nam, struct ucred *cred) argument 129 SDP_WLOCK_ASSERT(ssk); 131 if (ssk->lport != 0 || ssk->laddr != INADDR_ANY) 134 SDP_WUNLOCK(ssk); 135 if (ssk 161 sdp_pcbfree(struct sdp_sock *ssk) argument 211 struct sdp_sock *ssk; local 228 struct sdp_sock *ssk; local 246 struct sdp_sock *ssk, *ssk_temp; local 279 sdp_output_reset(struct sdp_sock *ssk) argument 299 sdp_closed(struct sdp_sock *ssk) argument 329 struct sdp_sock *ssk; local 360 struct sdp_sock *ssk; local 380 sdp_2msl_wait(struct sdp_sock *ssk) argument 396 struct sdp_sock *ssk; local 422 sdp_cancel_dreq_wait_timeout(struct sdp_sock *ssk) argument 432 struct sdp_sock *ssk = sdp_sk(sk); local 456 struct sdp_sock *ssk; local 497 struct sdp_sock *ssk; local 519 struct sdp_sock *ssk; local 550 struct sdp_sock *ssk; local 580 sdp_start_connect(struct sdp_sock *ssk, struct sockaddr *nam, struct thread *td) argument 617 struct sdp_sock *ssk; local 645 sdp_drop(struct sdp_sock *ssk, int errno) argument 670 sdp_usrclosed(struct sdp_sock *ssk) argument 717 sdp_output_disconnect(struct sdp_sock *ssk) argument 736 sdp_start_disconnect(struct sdp_sock *ssk) argument 776 struct sdp_sock *ssk; local 808 struct sdp_sock *ssk = NULL; local 841 struct sdp_sock *ssk; local 861 sdp_append(struct sdp_sock *ssk, struct sockbuf *sb, struct mbuf *mb, int cnt) argument 931 struct sdp_sock *ssk; local 1055 struct sdp_sock *ssk; local 1233 struct sdp_sock *ssk; local 1426 struct sdp_sock *ssk; local 1447 struct sdp_sock *ssk; local 1478 struct sdp_sock *ssk; local 1512 sdp_urg(struct sdp_sock *ssk, struct mbuf *mb) argument 1540 sdp_notify(struct sdp_sock *ssk, int error) argument 1582 struct sdp_sock *ssk; local 1606 struct sdp_sock *ssk; local 1617 struct sdp_sock *ssk; local 1641 struct sdp_sock *ssk; local 1711 sdp_set_default_moderation(struct sdp_sock *ssk) argument 1751 struct sdp_sock *ssk; local 1784 struct sdp_sock *ssk; local [all...] |
H A D | sdp_cma.c | 78 struct sdp_sock *ssk; local 83 ssk = sdp_sk(sk); 84 ssk->max_sge = sdp_get_max_dev_sge(device); 85 sdp_dbg(sk, "Max sges: %d\n", ssk->max_sge); 87 qp_init_attr.cap.max_send_sge = MIN(ssk->max_sge, SDP_MAX_SEND_SGES); 91 qp_init_attr.cap.max_recv_sge = MIN(ssk->max_sge, SDP_MAX_RECV_SGES); 95 ssk->sdp_dev = ib_get_client_data(device, &sdp_client); 96 if (!ssk->sdp_dev) { 102 rc = sdp_rx_ring_create(ssk, device); 106 rc = sdp_tx_ring_create(ssk, devic 142 struct sdp_sock *ssk; local 188 struct sdp_sock *ssk; local 222 struct sdp_sock *ssk; local 244 struct sdp_sock *ssk; local 265 struct sdp_sock *ssk; local [all...] |
H A D | sdp.h | 147 #define rx_ring_posted(ssk) ring_posted(ssk->rx_ring) 149 #define tx_ring_posted(ssk) (ring_posted(ssk->tx_ring) + \ 150 (ssk->tx_ring.rdma_inflight ? ssk->tx_ring.rdma_inflight->busy : 0)) 152 #define tx_ring_posted(ssk) ring_posted(ssk->tx_ring) 262 struct sdp_sock *ssk; member in struct:bzcopy_state 322 #define tx_credits(ssk) (atomic_rea 486 sdp_arm_rx_cq(struct sdp_sock *ssk) argument 494 sdp_arm_tx_cq(struct sdp_sock *ssk) argument 507 tx_slots_free(struct sdp_sock *ssk) argument 640 sdp_tx_ring_slots_left(struct sdp_sock *ssk) argument 645 credit_update_needed(struct sdp_sock *ssk) argument 665 sdp_cleanup_sdp_buf(struct sdp_sock *ssk, struct sdp_buf *sbuf, enum dma_data_direction dir) argument [all...] |
H A D | sdp_zcopy.c | 51 struct sdp_sock *ssk = sdp_sk(sk); local 58 WARN_ON(ssk->tx_sa); 81 ssk->tx_sa = tx_sa; 85 payload_len = MIN(payload_len, ssk->xmit_size_goal - sizeof(struct sdp_srcah)); 101 mb_entail(sk, ssk, mb); 103 ssk->write_seq += payload_len; 116 struct sdp_sock *ssk = sdp_sk(sk); local 119 sdp_dbg_data(ssk->socket, "Posting srcavail cancel\n"); 122 mb_entail(sk, ssk, mb); 124 sdp_post_sends(ssk, 134 struct sdp_sock *ssk = local 148 sdp_wait_rdmardcompl(struct sdp_sock *ssk, long *timeo_p, int ignore_signals) argument 239 sdp_wait_rdma_wr_finished(struct sdp_sock *ssk) argument 281 sdp_post_rdma_rd_compl(struct sdp_sock *ssk, struct rx_srcavail_state *rx_sa) argument 337 sdp_handle_sendsm(struct sdp_sock *ssk, u32 mseq_ack) argument 368 sdp_handle_rdma_read_compl(struct sdp_sock *ssk, u32 mseq_ack, u32 bytes_completed) argument 520 struct sdp_sock *ssk = sdp_sk(sk); local 550 struct sdp_sock *ssk = sdp_sk(sk); local 622 struct sdp_sock *ssk = sdp_sk(sk); local 644 struct sdp_sock *ssk = sdp_sk(sk); local 713 struct sdp_sock *ssk = sdp_sk(sk); local 774 struct sdp_sock *ssk = sdp_sk(sk); local 795 struct sdp_sock *ssk = sdp_sk(sk); local [all...] |
H A D | sdp_proc.c | 59 struct sdp_sock *ssk; local 62 list_for_each_entry(ssk, &sock_list, sock_list) { 64 return ssk;
|
/freebsd-11-stable/contrib/unbound/dnscrypt/ |
H A D | dnscrypt.c | 1033 struct shared_secret_cache_key* ssk = (struct shared_secret_cache_key*)k; local 1035 + lock_get_mem(&ssk->entry.lock); 1037 (void)ssk; /* otherwise ssk is unused if no threading, or fixed locksize */ 1050 struct shared_secret_cache_key* ssk = (struct shared_secret_cache_key*)k; local 1051 lock_rw_destroy(&ssk->entry.lock); 1052 free(ssk); 1074 (void)nk; /* otherwise ssk is unused if no threading, or fixed locksize */
|