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

/freebsd-11-stable/sys/ofed/drivers/infiniband/ulp/sdp/
H A Dsdp_rx.c43 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 Dsdp_tx.c39 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 Dsdp_bcopy.c105 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 Dsdp_main.c113 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 Dsdp_cma.c78 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 Dsdp.h147 #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 Dsdp_zcopy.c51 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 Dsdp_proc.c59 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 Ddnscrypt.c1033 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 */

Completed in 204 milliseconds