Lines Matching refs:clcsock
116 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()
287 rc = kernel_sock_shutdown(smc->clcsock, in __smc_release()
299 if (smc->clcsock) { in __smc_release()
327 tcp_abort(smc->clcsock->sk, ECONNABORTED); in smc_release()
437 smc->clcsock->sk->sk_reuse = sk->sk_reuse; in smc_bind()
438 smc->clcsock->sk->sk_reuseport = sk->sk_reuseport; in smc_bind()
439 rc = kernel_bind(smc->clcsock, uaddr, addr_len); in smc_bind()
499 smc_copy_sock_settings(smc->clcsock->sk, &smc->sk, SK_FLAGS_SMC_TO_CLC); in smc_copy_sock_settings_to_clc()
509 smc_copy_sock_settings(&smc->sk, smc->clcsock->sk, SK_FLAGS_CLC_TO_SMC); in smc_copy_sock_settings_to_smc()
881 struct sock *clcsk = smc->clcsock->sk; in smc_fback_replace_callbacks()
903 if (!smc->clcsock) { in smc_switch_to_fallback()
913 smc->clcsock->file = smc->sk.sk_socket->file; in smc_switch_to_fallback()
914 smc->clcsock->file->private_data = smc->clcsock; in smc_switch_to_fallback()
915 smc->clcsock->wq.fasync_list = in smc_switch_to_fallback()
997 smc_pnet_find_roce_resource(smc->clcsock->sk, ini); in smc_find_rdma_device()
1010 smc_pnet_find_ism_resource(smc->clcsock->sk, ini); in smc_find_ism_device()
1117 ini->smcrv2.saddr = smc->clcsock->sk->sk_rcv_saddr; in smc_find_proposal_devices()
1119 smc->clcsock->sk->sk_family != AF_INET || in smc_find_proposal_devices()
1213 if (smc_ib_find_route(net, smc->clcsock->sk->sk_rcv_saddr, in smc_connect_rdma_v2_prepare()
1499 if (!tcp_sk(smc->clcsock->sk)->syn_smc) in __smc_connect()
1518 if (smc_vlan_by_tcpsk(smc->clcsock, ini)) { in __smc_connect()
1563 SMC_STAT_CLNT_SUCC_INC(sock_net(smc->clcsock->sk), aclc); in __smc_connect()
1586 lock_sock(smc->clcsock->sk); in smc_connect_work()
1587 if (smc->clcsock->sk->sk_err) { in smc_connect_work()
1588 smc->sk.sk_err = smc->clcsock->sk->sk_err; in smc_connect_work()
1589 } else if ((1 << smc->clcsock->sk->sk_state) & in smc_connect_work()
1591 rc = sk_stream_wait_connect(smc->clcsock->sk, &timeo); in smc_connect_work()
1593 ((1 << smc->clcsock->sk->sk_state) & in smc_connect_work()
1597 release_sock(smc->clcsock->sk); in smc_connect_work()
1620 smc->clcsock->sk->sk_write_space(smc->clcsock->sk); in smc_connect_work()
1674 tcp_sk(smc->clcsock->sk)->syn_smc = 1; in smc_connect()
1679 rc = kernel_connect(smc->clcsock, addr, alen, flags); in smc_connect()
1727 if (lsmc->clcsock) in smc_clcsock_accept()
1728 rc = kernel_accept(lsmc->clcsock, &new_clcsock, SOCK_NONBLOCK); in smc_clcsock_accept()
1761 (*new_smc)->clcsock = new_clcsock; in smc_clcsock_accept()
1807 if (isk->clcsock) { in smc_accept_dequeue()
1808 sock_release(isk->clcsock); in smc_accept_dequeue()
1809 isk->clcsock = NULL; in smc_accept_dequeue()
1818 smc_sk(new_sk)->clcsock->file = new_sock->file; in smc_accept_dequeue()
1819 isk->clcsock->file->private_data = isk->clcsock; in smc_accept_dequeue()
1901 if (tcp_sk(new_smc->clcsock->sk)->syn_smc) in smc_listen_out()
2030 struct socket *newclcsock = new_smc->clcsock; in smc_listen_prfx_check()
2283 ini->smcrv2.clc_sk = new_smc->clcsock->sk; in smc_find_rdma_v2_device_serv()
2284 ini->smcrv2.saddr = new_smc->clcsock->sk->sk_rcv_saddr; in smc_find_rdma_v2_device_serv()
2355 if (smc_vlan_by_tcpsk(new_smc->clcsock, ini)) in smc_listen_find_device()
2416 struct socket *newclcsock = new_smc->clcsock; in smc_listen_work()
2572 if (tcp_sk(new_smc->clcsock->sk)->syn_smc) in smc_tcp_listen_work()
2633 tcp_sk(smc->clcsock->sk)->syn_smc = 1; in smc_listen()
2638 write_lock_bh(&smc->clcsock->sk->sk_callback_lock); in smc_listen()
2639 smc->clcsock->sk->sk_user_data = in smc_listen()
2641 smc_clcsock_replace_cb(&smc->clcsock->sk->sk_data_ready, in smc_listen()
2643 write_unlock_bh(&smc->clcsock->sk->sk_callback_lock); in smc_listen()
2646 smc->ori_af_ops = inet_csk(smc->clcsock->sk)->icsk_af_ops; in smc_listen()
2651 inet_csk(smc->clcsock->sk)->icsk_af_ops = &smc->af_ops; in smc_listen()
2654 tcp_sk(smc->clcsock->sk)->smc_hs_congested = smc_hs_congested; in smc_listen()
2656 rc = kernel_listen(smc->clcsock, backlog); in smc_listen()
2658 write_lock_bh(&smc->clcsock->sk->sk_callback_lock); in smc_listen()
2659 smc_clcsock_restore_cb(&smc->clcsock->sk->sk_data_ready, in smc_listen()
2661 smc->clcsock->sk->sk_user_data = NULL; in smc_listen()
2662 write_unlock_bh(&smc->clcsock->sk->sk_callback_lock); in smc_listen()
2726 struct sock *clcsk = smc_sk(nsk)->clcsock->sk; in smc_accept()
2755 return smc->clcsock->ops->getname(smc->clcsock, addr, peer); in smc_getname()
2786 rc = smc->clcsock->ops->sendmsg(smc->clcsock, msg, len); in smc_sendmsg()
2821 rc = smc->clcsock->ops->recvmsg(smc->clcsock, msg, len, flags); in smc_recvmsg()
2859 mask = smc->clcsock->ops->poll(file, smc->clcsock, wait); in smc_poll()
2860 sk->sk_err = smc->clcsock->sk->sk_err; in smc_poll()
2873 mask |= smc->clcsock->ops->poll(file, smc->clcsock, in smc_poll()
2875 sk->sk_err = smc->clcsock->sk->sk_err; in smc_poll()
2935 rc = kernel_sock_shutdown(smc->clcsock, how); in smc_shutdown()
2936 sk->sk_shutdown = smc->clcsock->sk->sk_shutdown; in smc_shutdown()
2960 if (do_shutdown && smc->clcsock) in smc_shutdown()
2961 rc1 = kernel_sock_shutdown(smc->clcsock, how); in smc_shutdown()
3057 if (!smc->clcsock) { in smc_setsockopt()
3061 if (unlikely(!smc->clcsock->ops->setsockopt)) in smc_setsockopt()
3064 rc = smc->clcsock->ops->setsockopt(smc->clcsock, level, optname, in smc_setsockopt()
3066 if (smc->clcsock->sk->sk_err) { in smc_setsockopt()
3067 sk->sk_err = smc->clcsock->sk->sk_err; in smc_setsockopt()
3137 if (!smc->clcsock) { in smc_getsockopt()
3142 if (unlikely(!smc->clcsock->ops->getsockopt)) { in smc_getsockopt()
3146 rc = smc->clcsock->ops->getsockopt(smc->clcsock, level, optname, in smc_getsockopt()
3164 if (!smc->clcsock) { in smc_ioctl()
3168 answ = smc->clcsock->ops->ioctl(smc->clcsock, cmd, arg); in smc_ioctl()
3265 rc = smc->clcsock->ops->splice_read(smc->clcsock, ppos, in smc_splice_read()
3313 &smc->clcsock); in smc_create_clcsk()
3322 sk = smc->clcsock->sk; in smc_create_clcsk()
3331 int kern, struct socket *clcsock) in __smc_create() argument
3357 if (clcsock) in __smc_create()
3358 smc->clcsock = clcsock; in __smc_create()