Home
last modified time | relevance | path

Searched refs:clcsock (Results 1 - 23 of 23) sorted by relevance

/kernel/linux/linux-5.10/net/smc/
H A Daf_smc.c69 smc->clcsock->sk->sk_prot->keepalive(smc->clcsock->sk, val); in smc_set_keepalive()
133 if (smc->clcsock->file) { /* non-accepted sockets have no file yet */ in smc_restore_fallback_changes()
134 smc->clcsock->file->private_data = smc->sk.sk_socket; in smc_restore_fallback_changes()
135 smc->clcsock->file = NULL; in smc_restore_fallback_changes()
154 /* wake up clcsock accept */ in __smc_release()
155 rc = kernel_sock_shutdown(smc->clcsock, in __smc_release()
167 if (smc->clcsock) { in __smc_release()
195 tcp_abort(smc->clcsock->sk, ECONNABORTED); in smc_release()
297 smc->clcsock in smc_bind()
[all...]
H A Dsmc_close.c23 /* release the clcsock that is assigned to the smc_sock */
31 if (smc->clcsock) { in smc_clcsock_release()
32 tcp = smc->clcsock; in smc_clcsock_release()
33 smc->clcsock = NULL; in smc_clcsock_release()
130 if (sk->sk_state != SMC_INIT && smc->clcsock && smc->clcsock->sk) { in smc_close_active_abort()
132 if (smc->clcsock && smc->clcsock->sk) in smc_close_active_abort()
133 tcp_abort(smc->clcsock->sk, ECONNABORTED); in smc_close_active_abort()
214 if (smc->clcsock in smc_close_active()
[all...]
H A Dsmc_clc.c214 static int smc_clc_prfx_set(struct socket *clcsock, in smc_clc_prfx_set() argument
218 struct dst_entry *dst = sk_dst_get(clcsock->sk); in smc_clc_prfx_set()
233 if (kernel_getsockname(clcsock, (struct sockaddr *)&addrs) < 0) in smc_clc_prfx_set()
305 int smc_clc_prfx_match(struct socket *clcsock, in smc_clc_prfx_match() argument
308 struct dst_entry *dst = sk_dst_get(clcsock->sk); in smc_clc_prfx_match()
335 * clcsock error, -EINTR, -ECONNRESET, -EPROTO otherwise.
340 long rcvtimeo = smc->clcsock->sk->sk_rcvtimeo; in smc_clc_wait_msg()
341 struct sock *clc_sk = smc->clcsock->sk; in smc_clc_wait_msg()
362 len = sock_recvmsg(smc->clcsock, &msg, krflags); in smc_clc_wait_msg()
409 len = sock_recvmsg(smc->clcsock, in smc_clc_wait_msg()
[all...]
H A Dsmc_diag.c54 if (!smc->clcsock) in smc_diag_msg_common_fill()
56 r->id.idiag_sport = htons(smc->clcsock->sk->sk_num); in smc_diag_msg_common_fill()
57 r->id.idiag_dport = smc->clcsock->sk->sk_dport; in smc_diag_msg_common_fill()
58 r->id.idiag_if = smc->clcsock->sk->sk_bound_dev_if; in smc_diag_msg_common_fill()
60 r->id.idiag_src[0] = smc->clcsock->sk->sk_rcv_saddr; in smc_diag_msg_common_fill()
61 r->id.idiag_dst[0] = smc->clcsock->sk->sk_daddr; in smc_diag_msg_common_fill()
64 memcpy(&r->id.idiag_src, &smc->clcsock->sk->sk_v6_rcv_saddr, in smc_diag_msg_common_fill()
65 sizeof(smc->clcsock->sk->sk_v6_rcv_saddr)); in smc_diag_msg_common_fill()
66 memcpy(&r->id.idiag_dst, &smc->clcsock->sk->sk_v6_daddr, in smc_diag_msg_common_fill()
67 sizeof(smc->clcsock in smc_diag_msg_common_fill()
[all...]
H A Dsmc.h219 struct socket *clcsock; /* internal tcp socket */ member
246 /* protects clcsock of a listen
287 return (smc->clcsock->sk->sk_policy[0] || in using_ipsec()
288 smc->clcsock->sk->sk_policy[1]) ? true : false; in using_ipsec()
H A Dsmc_cdc.c370 if (smc->clcsock && smc->clcsock->sk) in smc_cdc_msg_recv_action()
371 smc->clcsock->sk->sk_shutdown |= RCV_SHUTDOWN; in smc_cdc_msg_recv_action()
H A Dsmc_clc.h29 #define CLC_WAIT_TIME (6 * HZ) /* max. wait time on clcsock */
30 #define CLC_WAIT_TIME_SHORT HZ /* short wait time on clcsock */
321 int smc_clc_prfx_match(struct socket *clcsock,
H A Dsmc_core.h399 int smc_vlan_by_tcpsk(struct socket *clcsock, struct smc_init_info *ini);
H A Dsmc_tx.c126 struct tcp_sock *tp = tcp_sk(smc->clcsock->sk); in smc_tx_is_corked()
H A Dsmc_core.c1228 int smc_vlan_by_tcpsk(struct socket *clcsock, struct smc_init_info *ini) in smc_vlan_by_tcpsk() argument
1230 struct dst_entry *dst = sk_dst_get(clcsock->sk); in smc_vlan_by_tcpsk()
H A Dsmc_llc.c1779 struct net *net = sock_net(smc->clcsock->sk); in smc_llc_lgr_init()
/kernel/linux/linux-6.6/net/smc/
H A Dsmc_close.c23 /* release the clcsock that is assigned to the smc_sock */
31 if (smc->clcsock) { in smc_clcsock_release()
32 tcp = smc->clcsock; in smc_clcsock_release()
33 smc->clcsock = NULL; in smc_clcsock_release()
133 if (sk->sk_state != SMC_INIT && smc->clcsock && smc->clcsock->sk) { in smc_close_active_abort()
135 if (smc->clcsock && smc->clcsock->sk) in smc_close_active_abort()
136 tcp_abort(smc->clcsock->sk, ECONNABORTED); in smc_close_active_abort()
217 if (smc->clcsock in smc_close_active()
[all...]
H A Daf_smc.c114 smc->clcsock->sk->sk_prot->keepalive(smc->clcsock->sk, val); in smc_set_keepalive()
249 struct sock *clcsk = smc->clcsock->sk; in smc_fback_restore_callbacks()
264 if (smc->clcsock->file) { /* non-accepted sockets have no file yet */ in smc_restore_fallback_changes()
265 smc->clcsock->file->private_data = smc->sk.sk_socket; in smc_restore_fallback_changes()
266 smc->clcsock->file = NULL; in smc_restore_fallback_changes()
286 /* wake up clcsock accept */ in __smc_release()
287 rc = kernel_sock_shutdown(smc->clcsock, in __smc_release()
299 if (smc->clcsock) { in __smc_release()
327 tcp_abort(smc->clcsock in smc_release()
3286 __smc_create(struct net *net, struct socket *sock, int protocol, int kern, struct socket *clcsock) __smc_create() argument
[all...]
H A Dsmc_diag.c41 if (!smc->clcsock) in smc_diag_msg_common_fill()
43 r->id.idiag_sport = htons(smc->clcsock->sk->sk_num); in smc_diag_msg_common_fill()
44 r->id.idiag_dport = smc->clcsock->sk->sk_dport; in smc_diag_msg_common_fill()
45 r->id.idiag_if = smc->clcsock->sk->sk_bound_dev_if; in smc_diag_msg_common_fill()
47 r->id.idiag_src[0] = smc->clcsock->sk->sk_rcv_saddr; in smc_diag_msg_common_fill()
48 r->id.idiag_dst[0] = smc->clcsock->sk->sk_daddr; in smc_diag_msg_common_fill()
51 memcpy(&r->id.idiag_src, &smc->clcsock->sk->sk_v6_rcv_saddr, in smc_diag_msg_common_fill()
52 sizeof(smc->clcsock->sk->sk_v6_rcv_saddr)); in smc_diag_msg_common_fill()
53 memcpy(&r->id.idiag_dst, &smc->clcsock->sk->sk_v6_daddr, in smc_diag_msg_common_fill()
54 sizeof(smc->clcsock in smc_diag_msg_common_fill()
[all...]
H A Dsmc_clc.c554 static int smc_clc_prfx_set(struct socket *clcsock, in smc_clc_prfx_set() argument
558 struct dst_entry *dst = sk_dst_get(clcsock->sk); in smc_clc_prfx_set()
573 if (kernel_getsockname(clcsock, (struct sockaddr *)&addrs) < 0) in smc_clc_prfx_set()
645 int smc_clc_prfx_match(struct socket *clcsock, in smc_clc_prfx_match() argument
648 struct dst_entry *dst = sk_dst_get(clcsock->sk); in smc_clc_prfx_match()
675 * clcsock error, -EINTR, -ECONNRESET, -EPROTO otherwise.
680 long rcvtimeo = smc->clcsock->sk->sk_rcvtimeo; in smc_clc_wait_msg()
681 struct sock *clc_sk = smc->clcsock->sk; in smc_clc_wait_msg()
702 len = sock_recvmsg(smc->clcsock, &msg, krflags); in smc_clc_wait_msg()
749 len = sock_recvmsg(smc->clcsock, in smc_clc_wait_msg()
[all...]
H A Dsmc.h246 struct socket *clcsock; /* internal tcp socket */ member
284 /* protects clcsock of a listen
357 return (smc->clcsock->sk->sk_policy[0] || in using_ipsec()
358 smc->clcsock->sk->sk_policy[1]) ? true : false; in using_ipsec()
H A Dsmc_cdc.c385 if (smc->clcsock && smc->clcsock->sk) in smc_cdc_msg_recv_action()
386 smc->clcsock->sk->sk_shutdown |= RCV_SHUTDOWN; in smc_cdc_msg_recv_action()
H A Dsmc_tracepoint.h31 const struct sock *clcsk = smc->clcsock->sk;
H A Dsmc_core.h563 int smc_vlan_by_tcpsk(struct socket *clcsock, struct smc_init_info *ini);
H A Dsmc_clc.h31 #define CLC_WAIT_TIME (6 * HZ) /* max. wait time on clcsock */
32 #define CLC_WAIT_TIME_SHORT HZ /* short wait time on clcsock */
415 int smc_clc_prfx_match(struct socket *clcsock,
H A Dsmc_tx.c129 struct tcp_sock *tp = tcp_sk(smc->clcsock->sk); in smc_tx_is_corked()
H A Dsmc_core.c1797 int smc_vlan_by_tcpsk(struct socket *clcsock, struct smc_init_info *ini) in smc_vlan_by_tcpsk() argument
1799 struct dst_entry *dst = sk_dst_get(clcsock->sk); in smc_vlan_by_tcpsk()
H A Dsmc_llc.c2139 struct net *net = sock_net(smc->clcsock->sk); in smc_llc_lgr_init()

Completed in 28 milliseconds