Lines Matching refs:clcsock
113 smc->clcsock->sk->sk_prot->keepalive(smc->clcsock->sk, val); in smc_set_keepalive()
248 struct sock *clcsk = smc->clcsock->sk; in smc_fback_restore_callbacks()
263 if (smc->clcsock->file) { /* non-accepted sockets have no file yet */ in smc_restore_fallback_changes()
264 smc->clcsock->file->private_data = smc->sk.sk_socket; in smc_restore_fallback_changes()
265 smc->clcsock->file = NULL; in smc_restore_fallback_changes()
286 rc = kernel_sock_shutdown(smc->clcsock, in __smc_release()
298 if (smc->clcsock) { in __smc_release()
326 tcp_abort(smc->clcsock->sk, ECONNABORTED); in smc_release()
431 smc->clcsock->sk->sk_reuse = sk->sk_reuse; in smc_bind()
432 smc->clcsock->sk->sk_reuseport = sk->sk_reuseport; in smc_bind()
433 rc = kernel_bind(smc->clcsock, uaddr, addr_len); in smc_bind()
480 smc_copy_sock_settings(smc->clcsock->sk, &smc->sk, SK_FLAGS_SMC_TO_CLC); in smc_copy_sock_settings_to_clc()
490 smc_copy_sock_settings(&smc->sk, smc->clcsock->sk, SK_FLAGS_CLC_TO_SMC); in smc_copy_sock_settings_to_smc()
845 struct sock *clcsk = smc->clcsock->sk; in smc_fback_replace_callbacks()
867 if (!smc->clcsock) { in smc_switch_to_fallback()
877 smc->clcsock->file = smc->sk.sk_socket->file; in smc_switch_to_fallback()
878 smc->clcsock->file->private_data = smc->clcsock; in smc_switch_to_fallback()
879 smc->clcsock->wq.fasync_list = in smc_switch_to_fallback()
960 smc_pnet_find_roce_resource(smc->clcsock->sk, ini); in smc_find_rdma_device()
973 smc_pnet_find_ism_resource(smc->clcsock->sk, ini); in smc_find_ism_device()
1070 ini->smcrv2.saddr = smc->clcsock->sk->sk_rcv_saddr; in smc_find_proposal_devices()
1072 smc->clcsock->sk->sk_family != AF_INET || in smc_find_proposal_devices()
1167 if (smc_ib_find_route(smc->clcsock->sk->sk_rcv_saddr, in smc_connect_rdma_v2_prepare()
1437 if (!tcp_sk(smc->clcsock->sk)->syn_smc) in __smc_connect()
1456 if (smc_vlan_by_tcpsk(smc->clcsock, ini)) { in __smc_connect()
1506 SMC_STAT_CLNT_SUCC_INC(sock_net(smc->clcsock->sk), aclc); in __smc_connect()
1529 lock_sock(smc->clcsock->sk); in smc_connect_work()
1530 if (smc->clcsock->sk->sk_err) { in smc_connect_work()
1531 smc->sk.sk_err = smc->clcsock->sk->sk_err; in smc_connect_work()
1532 } else if ((1 << smc->clcsock->sk->sk_state) & in smc_connect_work()
1534 rc = sk_stream_wait_connect(smc->clcsock->sk, &timeo); in smc_connect_work()
1536 ((1 << smc->clcsock->sk->sk_state) & in smc_connect_work()
1540 release_sock(smc->clcsock->sk); in smc_connect_work()
1563 smc->clcsock->sk->sk_write_space(smc->clcsock->sk); in smc_connect_work()
1617 tcp_sk(smc->clcsock->sk)->syn_smc = 1; in smc_connect()
1622 rc = kernel_connect(smc->clcsock, addr, alen, flags); in smc_connect()
1670 if (lsmc->clcsock) in smc_clcsock_accept()
1671 rc = kernel_accept(lsmc->clcsock, &new_clcsock, SOCK_NONBLOCK); in smc_clcsock_accept()
1704 (*new_smc)->clcsock = new_clcsock; in smc_clcsock_accept()
1750 if (isk->clcsock) { in smc_accept_dequeue()
1751 sock_release(isk->clcsock); in smc_accept_dequeue()
1752 isk->clcsock = NULL; in smc_accept_dequeue()
1761 smc_sk(new_sk)->clcsock->file = new_sock->file; in smc_accept_dequeue()
1762 isk->clcsock->file->private_data = isk->clcsock; in smc_accept_dequeue()
1840 if (tcp_sk(new_smc->clcsock->sk)->syn_smc) in smc_listen_out()
1965 struct socket *newclcsock = new_smc->clcsock; in smc_listen_prfx_check()
2191 ini->smcrv2.clc_sk = new_smc->clcsock->sk; in smc_find_rdma_v2_device_serv()
2192 ini->smcrv2.saddr = new_smc->clcsock->sk->sk_rcv_saddr; in smc_find_rdma_v2_device_serv()
2260 if (smc_vlan_by_tcpsk(new_smc->clcsock, ini)) in smc_listen_find_device()
2321 struct socket *newclcsock = new_smc->clcsock; in smc_listen_work()
2453 if (tcp_sk(new_smc->clcsock->sk)->syn_smc) in smc_tcp_listen_work()
2516 tcp_sk(smc->clcsock->sk)->syn_smc = 1; in smc_listen()
2521 write_lock_bh(&smc->clcsock->sk->sk_callback_lock); in smc_listen()
2522 smc->clcsock->sk->sk_user_data = in smc_listen()
2524 smc_clcsock_replace_cb(&smc->clcsock->sk->sk_data_ready, in smc_listen()
2526 write_unlock_bh(&smc->clcsock->sk->sk_callback_lock); in smc_listen()
2529 smc->ori_af_ops = inet_csk(smc->clcsock->sk)->icsk_af_ops; in smc_listen()
2534 inet_csk(smc->clcsock->sk)->icsk_af_ops = &smc->af_ops; in smc_listen()
2537 tcp_sk(smc->clcsock->sk)->smc_hs_congested = smc_hs_congested; in smc_listen()
2539 rc = kernel_listen(smc->clcsock, backlog); in smc_listen()
2541 write_lock_bh(&smc->clcsock->sk->sk_callback_lock); in smc_listen()
2542 smc_clcsock_restore_cb(&smc->clcsock->sk->sk_data_ready, in smc_listen()
2544 smc->clcsock->sk->sk_user_data = NULL; in smc_listen()
2545 write_unlock_bh(&smc->clcsock->sk->sk_callback_lock); in smc_listen()
2609 struct sock *clcsk = smc_sk(nsk)->clcsock->sk; in smc_accept()
2638 return smc->clcsock->ops->getname(smc->clcsock, addr, peer); in smc_getname()
2666 rc = smc->clcsock->ops->sendmsg(smc->clcsock, msg, len); in smc_sendmsg()
2701 rc = smc->clcsock->ops->recvmsg(smc->clcsock, msg, len, flags); in smc_recvmsg()
2739 mask = smc->clcsock->ops->poll(file, smc->clcsock, wait); in smc_poll()
2740 sk->sk_err = smc->clcsock->sk->sk_err; in smc_poll()
2753 mask |= smc->clcsock->ops->poll(file, smc->clcsock, in smc_poll()
2755 sk->sk_err = smc->clcsock->sk->sk_err; in smc_poll()
2815 rc = kernel_sock_shutdown(smc->clcsock, how); in smc_shutdown()
2816 sk->sk_shutdown = smc->clcsock->sk->sk_shutdown; in smc_shutdown()
2840 if (do_shutdown && smc->clcsock) in smc_shutdown()
2841 rc1 = kernel_sock_shutdown(smc->clcsock, how); in smc_shutdown()
2937 if (!smc->clcsock) { in smc_setsockopt()
2941 if (unlikely(!smc->clcsock->ops->setsockopt)) in smc_setsockopt()
2944 rc = smc->clcsock->ops->setsockopt(smc->clcsock, level, optname, in smc_setsockopt()
2946 if (smc->clcsock->sk->sk_err) { in smc_setsockopt()
2947 sk->sk_err = smc->clcsock->sk->sk_err; in smc_setsockopt()
3017 if (!smc->clcsock) { in smc_getsockopt()
3022 if (unlikely(!smc->clcsock->ops->getsockopt)) { in smc_getsockopt()
3026 rc = smc->clcsock->ops->getsockopt(smc->clcsock, level, optname, in smc_getsockopt()
3044 if (!smc->clcsock) { in smc_ioctl()
3048 answ = smc->clcsock->ops->ioctl(smc->clcsock, cmd, arg); in smc_ioctl()
3128 rc = kernel_sendpage(smc->clcsock, page, offset, in smc_sendpage()
3173 rc = smc->clcsock->ops->splice_read(smc->clcsock, ppos, in smc_splice_read()
3217 int kern, struct socket *clcsock) in __smc_create() argument
3248 if (!clcsock) { in __smc_create()
3250 &smc->clcsock); in __smc_create()
3256 smc->clcsock = clcsock; in __smc_create()