Home
last modified time | relevance | path

Searched refs:ssk (Results 1 – 9 of 9) sorted by relevance

/freebsd/sys/ofed/drivers/infiniband/ulp/sdp/
H A Dsdp_rx.c66 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 Dsdp_main.c131 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 Dsdp_tx.c89 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 Dsdp_cma.c168 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 Dsdp_bcopy.c158 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 Dsdp_zcopy.c60 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 Dsdp.h148 #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 Dsdp_proc.c61 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 Ddnscrypt.c1035 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()