Lines Matching refs:sk

86 	struct sock *sk = sock->sk;  in svc_reclassify_socket()  local
88 WARN_ON_ONCE(sock_owned_by_user(sk)); in svc_reclassify_socket()
89 if (sock_owned_by_user(sk)) in svc_reclassify_socket()
92 switch (sk->sk_family) { in svc_reclassify_socket()
94 sock_lock_init_class_and_name(sk, "slock-AF_INET-NFSD", in svc_reclassify_socket()
101 sock_lock_init_class_and_name(sk, "slock-AF_INET6-NFSD", in svc_reclassify_socket()
282 const struct sock *sk = svsk->sk_sk; in svc_one_sock_name() local
283 const char *proto_name = sk->sk_protocol == IPPROTO_UDP ? in svc_one_sock_name()
287 switch (sk->sk_family) { in svc_one_sock_name()
291 &inet_sk(sk)->inet_rcv_saddr, in svc_one_sock_name()
292 inet_sk(sk)->inet_num); in svc_one_sock_name()
298 &sk->sk_v6_rcv_saddr, in svc_one_sock_name()
299 inet_sk(sk)->inet_num); in svc_one_sock_name()
304 sk->sk_family); in svc_one_sock_name()
389 lock_sock(sock->sk); in svc_sock_setbufsize()
390 sock->sk->sk_sndbuf = snd * 2; in svc_sock_setbufsize()
391 sock->sk->sk_rcvbuf = rcv * 2; in svc_sock_setbufsize()
392 sock->sk->sk_write_space(sock->sk); in svc_sock_setbufsize()
393 release_sock(sock->sk); in svc_sock_setbufsize()
430 static void svc_udp_data_ready(struct sock *sk) in svc_udp_data_ready() argument
432 struct svc_sock *svsk = (struct svc_sock *)sk->sk_user_data; in svc_udp_data_ready()
433 wait_queue_head_t *wq = sk_sleep(sk); in svc_udp_data_ready()
437 svsk, sk, in svc_udp_data_ready()
449 static void svc_write_space(struct sock *sk) in svc_write_space() argument
451 struct svc_sock *svsk = (struct svc_sock *)(sk->sk_user_data); in svc_write_space()
452 wait_queue_head_t *wq = sk_sleep(sk); in svc_write_space()
456 svsk, sk, test_bit(XPT_BUSY, &svsk->sk_xprt.xpt_flags)); in svc_write_space()
484 static void svc_tcp_write_space(struct sock *sk) in svc_tcp_write_space() argument
486 struct svc_sock *svsk = (struct svc_sock *)(sk->sk_user_data); in svc_tcp_write_space()
487 struct socket *sock = sk->sk_socket; in svc_tcp_write_space()
489 if (!sk_stream_is_writeable(sk) || !sock) in svc_tcp_write_space()
493 svc_write_space(sk); in svc_tcp_write_space()
748 svc_xprt_init(sock_net(svsk->sk_sock->sk), &svc_udp_class, in svc_udp_init()
788 static void svc_tcp_listen_data_ready(struct sock *sk) in svc_tcp_listen_data_ready() argument
790 struct svc_sock *svsk = (struct svc_sock *)sk->sk_user_data; in svc_tcp_listen_data_ready()
794 sk, sk->sk_state); in svc_tcp_listen_data_ready()
806 if (sk->sk_state == TCP_LISTEN) { in svc_tcp_listen_data_ready()
811 printk("svc: socket %p: no user data\n", sk); in svc_tcp_listen_data_ready()
814 wq = sk_sleep(sk); in svc_tcp_listen_data_ready()
822 static void svc_tcp_state_change(struct sock *sk) in svc_tcp_state_change() argument
824 struct svc_sock *svsk = (struct svc_sock *)sk->sk_user_data; in svc_tcp_state_change()
825 wait_queue_head_t *wq = sk_sleep(sk); in svc_tcp_state_change()
828 sk, sk->sk_state, sk->sk_user_data); in svc_tcp_state_change()
831 printk("svc: socket %p: no user data\n", sk); in svc_tcp_state_change()
840 static void svc_tcp_data_ready(struct sock *sk) in svc_tcp_data_ready() argument
842 struct svc_sock *svsk = (struct svc_sock *)sk->sk_user_data; in svc_tcp_data_ready()
843 wait_queue_head_t *wq = sk_sleep(sk); in svc_tcp_data_ready()
846 sk, sk->sk_user_data); in svc_tcp_data_ready()
909 newsock->sk->sk_sndtimeo = HZ*30; in svc_tcp_accept()
923 if (sock_is_loopback(newsock->sk)) in svc_tcp_accept()
1349 struct sock *sk = svsk->sk_sk; in svc_tcp_init() local
1351 svc_xprt_init(sock_net(svsk->sk_sock->sk), &svc_tcp_class, in svc_tcp_init()
1354 if (sk->sk_state == TCP_LISTEN) { in svc_tcp_init()
1357 sk->sk_data_ready = svc_tcp_listen_data_ready; in svc_tcp_init()
1361 sk->sk_state_change = svc_tcp_state_change; in svc_tcp_init()
1362 sk->sk_data_ready = svc_tcp_data_ready; in svc_tcp_init()
1363 sk->sk_write_space = svc_tcp_write_space; in svc_tcp_init()
1370 tcp_sk(sk)->nonagle |= TCP_NAGLE_OFF; in svc_tcp_init()
1373 if (sk->sk_state != TCP_ESTABLISHED) in svc_tcp_init()
1410 inet = sock->sk; in svc_setup_socket()
1414 err = svc_register(serv, sock_net(sock->sk), inet->sk_family, in svc_setup_socket()
1456 if (sock_net(sock->sk) != net) in svc_alien_sock()
1488 if ((so->sk->sk_family != PF_INET) && (so->sk->sk_family != PF_INET6)) in svc_addsock()
1491 if (so->sk->sk_protocol != IPPROTO_TCP && in svc_addsock()
1492 so->sk->sk_protocol != IPPROTO_UDP) in svc_addsock()
1575 sock->sk->sk_reuse = SK_CAN_REUSE; /* allow address reuse */ in svc_create_socket()
1610 struct sock *sk = svsk->sk_sk; in svc_sock_detach() local
1616 sk->sk_state_change = svsk->sk_ostate; in svc_sock_detach()
1617 sk->sk_data_ready = svsk->sk_odata; in svc_sock_detach()
1618 sk->sk_write_space = svsk->sk_owspace; in svc_sock_detach()
1620 wq = sk_sleep(sk); in svc_sock_detach()