Lines Matching defs:sock
46 #include <net/sock.h>
62 struct socket *sock);
222 static inline struct rpc_xprt *xprt_from_sock(struct sock *sk)
348 xs_sock_recvmsg(struct socket *sock, struct msghdr *msg, int flags, size_t seek)
353 ret = sock_recvmsg(sock, msg, flags);
358 xs_read_kvec(struct socket *sock, struct msghdr *msg, int flags,
362 return xs_sock_recvmsg(sock, msg, flags, seek);
366 xs_read_bvec(struct socket *sock, struct msghdr *msg, int flags,
371 return xs_sock_recvmsg(sock, msg, flags, seek);
375 xs_read_discard(struct socket *sock, struct msghdr *msg, int flags,
379 return sock_recvmsg(sock, msg, flags);
403 xs_read_xdr_buf(struct socket *sock, struct msghdr *msg, int flags,
411 ret = xs_read_kvec(sock, msg, flags, &buf->head[0], want, seek);
429 ret = xs_read_bvec(sock, msg, flags, buf->bvec,
450 ret = xs_read_kvec(sock, msg, flags, &buf->tail[0], want, seek);
507 ret = xs_read_xdr_buf(transport->sock, msg, flags, buf,
550 return xs_read_kvec(transport->sock, msg, flags, &kvec, want, seek);
659 ret = xs_read_discard(transport->sock, &msg, flags,
681 return transport->sock->ops->poll(transport->file, transport->sock,
708 if (transport->sock == NULL)
718 kernel_sock_shutdown(transport->sock, SHUT_RDWR);
763 struct sock *sk = transport->inet;
795 struct sock *sk = transport->inet;
809 struct sock *sk = transport->inet;
882 status = xprt_sock_sendmsg(transport->sock, &msg, xdr,
954 status = xprt_sock_sendmsg(transport->sock, &msg, xdr, 0, 0, &sent);
1029 if (transport->sock != NULL)
1030 kernel_sock_shutdown(transport->sock, SHUT_RDWR);
1039 xs_tcp_set_socket_timeouts(xprt, transport->sock);
1046 status = xprt_sock_sendmsg(transport->sock, &msg, xdr,
1069 if (test_bit(SOCK_NOSPACE, &transport->sock->flags))
1113 static void xs_save_old_callbacks(struct sock_xprt *transport, struct sock *sk)
1121 static void xs_restore_old_callbacks(struct sock_xprt *transport, struct sock *sk)
1161 static void xs_error_report(struct sock *sk)
1187 struct socket *sock = transport->sock;
1188 struct sock *sk = transport->inet;
1208 kernel_sock_shutdown(sock, SHUT_RDWR);
1213 transport->sock = NULL;
1226 trace_rpc_socket_close(xprt, sock);
1292 struct sock *sk,
1348 struct sock *sk;
1383 static void xs_data_ready(struct sock *sk)
1426 static void xs_tcp_state_change(struct sock *sk)
1498 static void xs_write_space(struct sock *sk)
1532 static void xs_udp_write_space(struct sock *sk)
1536 /* from net/core/sock.c:sock_def_write_space */
1553 static void xs_tcp_write_space(struct sock *sk)
1567 struct sock *sk = transport->inet;
1629 static unsigned short xs_sock_getport(struct socket *sock)
1634 if (kernel_getsockname(sock, (struct sockaddr *)&buf) < 0)
1661 static void xs_set_srcport(struct sock_xprt *transport, struct socket *sock)
1664 transport->srcport = xs_sock_getport(sock);
1678 struct sock_xprt *sock = container_of(xprt, struct sock_xprt, xprt);
1679 return xs_sock_getport(sock->sock);
1693 static int xs_bind(struct sock_xprt *transport, struct socket *sock)
1721 err = kernel_bind(sock, (struct sockaddr *)&myaddr,
1761 static inline void xs_reclassify_socketu(struct socket *sock)
1763 struct sock *sk = sock->sk;
1769 static inline void xs_reclassify_socket4(struct socket *sock)
1771 struct sock *sk = sock->sk;
1777 static inline void xs_reclassify_socket6(struct socket *sock)
1779 struct sock *sk = sock->sk;
1785 static inline void xs_reclassify_socket(int family, struct socket *sock)
1787 if (WARN_ON_ONCE(!sock_allow_reclassification(sock->sk)))
1792 xs_reclassify_socketu(sock);
1795 xs_reclassify_socket4(sock);
1798 xs_reclassify_socket6(sock);
1803 static inline void xs_reclassify_socket(int family, struct socket *sock)
1817 struct socket *sock;
1820 err = __sock_create(xprt->xprt_net, family, type, protocol, &sock, 1);
1826 xs_reclassify_socket(family, sock);
1829 sock_set_reuseport(sock->sk);
1831 err = xs_bind(transport, sock);
1833 sock_release(sock);
1837 filp = sock_alloc_file(sock, O_NONBLOCK, NULL);
1842 return sock;
1848 struct socket *sock)
1854 struct sock *sk = sock->sk;
1869 transport->sock = sock;
1877 return kernel_connect(sock, xs_addr(xprt), xprt->addrlen, 0);
1888 struct socket *sock;
1892 SOCK_STREAM, 0, &sock, 1);
1898 xs_reclassify_socket(AF_LOCAL, sock);
1900 filp = sock_alloc_file(sock, O_NONBLOCK, NULL);
1910 status = xs_local_finish_connecting(xprt, sock);
1911 trace_rpc_socket_connect(xprt, sock, status);
1979 * If there's no sock, then we have nothing to set. The
2047 static void xs_udp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock)
2052 struct sock *sk = sock->sk;
2066 transport->sock = sock;
2083 struct socket *sock;
2086 sock = xs_create_sock(xprt, transport,
2089 if (IS_ERR(sock))
2098 xs_udp_finish_connecting(xprt, sock);
2099 trace_rpc_socket_connect(xprt, sock, 0);
2117 struct socket *sock = transport->sock;
2120 if (sock == NULL)
2124 kernel_sock_shutdown(sock, SHUT_RDWR);
2125 trace_rpc_socket_shutdown(xprt, sock);
2134 struct socket *sock)
2150 sock_set_keepalive(sock->sk);
2151 tcp_sock_set_keepidle(sock->sk, keepidle);
2152 tcp_sock_set_keepintvl(sock->sk, keepidle);
2153 tcp_sock_set_keepcnt(sock->sk, keepcnt);
2156 tcp_sock_set_user_timeout(sock->sk, timeo);
2187 static int xs_tcp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock)
2193 struct sock *sk = sock->sk;
2207 xs_tcp_set_socket_timeouts(xprt, sock);
2227 transport->sock = sock;
2242 ret = kernel_connect(sock, xs_addr(xprt), xprt->addrlen, O_NONBLOCK);
2245 xs_set_srcport(transport, sock);
2270 struct socket *sock = transport->sock;
2278 !sock) {
2280 sock = xs_create_sock(xprt, transport, xs_addr(xprt)->sa_family,
2282 if (IS_ERR(sock)) {
2283 status = PTR_ERR(sock);
2294 status = xs_tcp_finish_connecting(xprt, sock);
2295 trace_rpc_socket_connect(xprt, sock, status);
2296 dprintk("RPC: %p connect status %d connected %d sock state %d\n",
2298 sock->sk->sk_state);
2365 if (transport->sock != NULL) {
2399 if (transport->sock == NULL)
2567 err = xprt_sock_sendmsg(transport->sock, &msg, xdr, 0, marker, &sent);
3078 transport->sock = bc_sock->sk_sock;