Searched refs:ssk (Results 1 – 9 of 9) sorted by relevance
/freebsd/sys/ofed/drivers/infiniband/ulp/sdp/ |
H A D | sdp_rx.c | 66 if (ssk->id) { in sdp_handle_disconn() 69 id = ssk->id; in sdp_handle_disconn() 72 SDP_WLOCK(ssk); in sdp_handle_disconn() 170 if (!ssk->qp_active || !ssk->socket) in sdp_post_recvs_needed() 263 ssk->recv_bytes = sdp_get_recv_bytes(ssk, new_size); in sdp_init_buffers() 276 ssk->recv_bytes = sdp_get_recv_bytes(ssk, new_size); in sdp_resize_buffers() 286 ssk->recv_request_head = ring_head(ssk->rx_ring) + 1; in sdp_handle_resize_request() 288 ssk->recv_request_head = ring_tail(ssk->rx_ring); in sdp_handle_resize_request() 526 if (tx_credits(ssk) >= ssk->min_bufs && sk) in sdp_bzcopy_write_space() 610 if (!ssk->rx_ring.cq || !ssk->tx_ring.cq) in sdp_do_posts() [all …]
|
H A D | sdp_main.c | 131 if (ssk->lport != 0 || ssk->laddr != INADDR_ANY) in sdp_pcbbind() 288 ssk = data; in sdp_shutdown_task() 296 ssk); in sdp_shutdown_task() 319 ssk = data; in sdp_2msl_timeout() 638 ssk = sdp_closed(ssk); in sdp_usrclosed() 704 ssk = sdp_closed(ssk); in sdp_start_disconnect() 708 ssk = sdp_drop(ssk, 0); in sdp_start_disconnect() 1428 ssk, ssk->flags)); in sdp_abort() 1729 ssk = sdp_notify(ssk, ECONNRESET); in sdp_dev_rem() 1730 if (ssk) in sdp_dev_rem() [all …]
|
H A D | sdp_tx.c | 89 ssk->tx_packets++; in sdp_post_send() 161 atomic_set(&ssk->remote_credits, rx_ring_posted(ssk)); in sdp_post_send() 319 ring_head(ssk->tx_ring), ring_tail(ssk->tx_ring)); in sdp_poll_tx() 360 sdp_poll_tx(ssk); in sdp_poll_tx_timeout() 368 ssk = cq_context; in sdp_tx_irq() 372 SDP_WLOCK(ssk); in sdp_tx_irq() 382 mb = sdp_send_completion(ssk, ring_tail(ssk->tx_ring)); in sdp_tx_ring_purge() 433 callout_init_rw(&ssk->tx_ring.timer, &ssk->lock, 0); in sdp_tx_ring_create() 434 callout_init_rw(&ssk->nagle_timer, &ssk->lock, 0); in sdp_tx_ring_create() 465 SDP_WLOCK(ssk); in sdp_tx_ring_destroy() [all …]
|
H A D | sdp_cma.c | 168 SDP_WLOCK(ssk); in sdp_connect_handler() 170 ssk->id = id; in sdp_connect_handler() 179 atomic_set(&ssk->tx_ring.credits, ssk->max_bufs); in sdp_connect_handler() 180 ssk->min_bufs = tx_credits(ssk) / 4; in sdp_connect_handler() 199 SDP_WLOCK(ssk); in sdp_response_handler() 211 atomic_set(&ssk->tx_ring.credits, ssk->max_bufs); in sdp_response_handler() 212 ssk->min_bufs = tx_credits(ssk) / 4; in sdp_response_handler() 234 SDP_WLOCK(ssk); in sdp_connected_handler() 280 if (ssk) in sdp_cma_handler() 282 if (!ssk || !sk || !ssk->id) { in sdp_cma_handler() [all …]
|
H A D | sdp_bcopy.c | 158 sowwakeup(ssk->socket); in sdp_nagle_timeout() 173 sk = ssk->socket; in sdp_post_sends() 176 sdp_dbg(ssk->socket, in sdp_post_sends() 184 sdp_xmit_poll(ssk, 1); in sdp_post_sends() 186 if (ssk->recv_request && in sdp_post_sends() 187 ring_tail(ssk->rx_ring) >= ssk->recv_request_head && in sdp_post_sends() 194 ssk->recv_request = 0; in sdp_post_sends() 195 sdp_post_send(ssk, mb); in sdp_post_sends() 222 if (credit_update_needed(ssk) && ssk->state >= TCPS_ESTABLISHED && in sdp_post_sends() 250 sdp_arm_tx_cq(ssk); in sdp_post_sends() [all …]
|
H A D | sdp_zcopy.c | 60 WARN_ON(ssk->tx_sa); in sdp_post_srcavail() 83 ssk->tx_sa = tx_sa; in sdp_post_srcavail() 145 wake_up(&ssk->wq); in srcavail_cancel_timeout() 208 ssk->rx_sa && in sdp_wait_rdmardcompl() 346 if (!ssk->tx_sa) { in sdp_handle_sendsm() 376 sdp_prf1(sk, NULL, "RdmaRdCompl ssk=%p tx_sa=%p", ssk, ssk->tx_sa); in sdp_handle_rdma_read_compl() 377 sdp_dbg_data(sk, "RdmaRdCompl ssk=%p tx_sa=%p\n", ssk, ssk->tx_sa); in sdp_handle_rdma_read_compl() 381 BUG_ON(!ssk); in sdp_handle_rdma_read_compl() 383 if (!ssk->tx_sa) { in sdp_handle_rdma_read_compl() 634 sdp_do_posts(ssk); in wait_for_sndbuf() [all …]
|
H A D | sdp.h | 148 #define rx_ring_posted(ssk) ring_posted(ssk->rx_ring) argument 150 #define tx_ring_posted(ssk) (ring_posted(ssk->tx_ring) + \ argument 153 #define tx_ring_posted(ssk) ring_posted(ssk->tx_ring) argument 280 #define tx_credits(ssk) (atomic_read(&ssk->tx_ring.credits)) argument 367 #define rcv_nxt(ssk) atomic_read(&(ssk->rcv_nxt)) argument 372 #define mseq_ack(ssk) (atomic_read(&ssk->mseq_ack)) argument 406 #define SDP_RLOCK(ssk) rw_rlock(&(ssk)->lock) argument 407 #define SDP_WLOCK(ssk) rw_wlock(&(ssk)->lock) argument 408 #define SDP_RUNLOCK(ssk) rw_runlock(&(ssk)->lock) argument 409 #define SDP_WUNLOCK(ssk) rw_wunlock(&(ssk)->lock) argument [all …]
|
H A D | sdp_proc.c | 61 struct sdp_sock *ssk; in sdp_get_idx() local 64 list_for_each_entry(ssk, &sock_list, sock_list) { in sdp_get_idx() 66 return ssk; in sdp_get_idx()
|
/freebsd/contrib/unbound/dnscrypt/ |
H A D | dnscrypt.c | 1035 struct shared_secret_cache_key* ssk = (struct shared_secret_cache_key*)k; in dnsc_shared_secrets_sizefunc() local 1037 + lock_get_mem(&ssk->entry.lock); in dnsc_shared_secrets_sizefunc() 1039 (void)ssk; /* otherwise ssk is unused if no threading, or fixed locksize */ in dnsc_shared_secrets_sizefunc() 1052 struct shared_secret_cache_key* ssk = (struct shared_secret_cache_key*)k; in dnsc_shared_secrets_delkeyfunc() local 1053 lock_rw_destroy(&ssk->entry.lock); in dnsc_shared_secrets_delkeyfunc() 1054 free(ssk); in dnsc_shared_secrets_delkeyfunc()
|