| H A D | xprtsock.c | 5 * Client-side transport implementation for sockets. 16 * IP socket transport implementation, (C) 2005 Chuck Lever <cel@netapp.com> 65 static void xs_reset_srcport(struct sock_xprt *transport); 66 static void xs_set_srcport(struct sock_xprt *transport, struct socket *sock); 181 * transport connection with the server. Some servers like to drop a TCP 188 * TCP idle timeout; client drops the transport socket if it is idle 548 xs_read_header(struct sock_xprt *transport, struct xdr_buf *buf) in xs_read_header() argument 550 if (!transport->recv.copied) { in xs_read_header() 551 if (buf->head[0].iov_len >= transport->recv.offset) in xs_read_header() 553 &transport in xs_read_header() 560 xs_read_stream_request_done(struct sock_xprt * transport) xs_read_stream_request_done() argument 566 xs_read_stream_check_eor(struct sock_xprt * transport,struct msghdr * msg) xs_read_stream_check_eor() argument 574 xs_read_stream_request(struct sock_xprt * transport,struct msghdr * msg,int flags,struct rpc_rqst * req) xs_read_stream_request() argument 621 xs_read_stream_header(struct sock_xprt * transport,struct msghdr * msg,int flags,size_t want,size_t seek) xs_read_stream_header() argument 633 xs_read_stream_call(struct sock_xprt * transport,struct msghdr * msg,int flags) xs_read_stream_call() argument 662 xs_read_stream_call(struct sock_xprt * transport,struct msghdr * msg,int flags) xs_read_stream_call() argument 669 xs_read_stream_reply(struct sock_xprt * transport,struct msghdr * msg,int flags) xs_read_stream_reply() argument 699 xs_read_stream(struct sock_xprt * transport,int flags) xs_read_stream() argument 761 xs_poll_socket(struct sock_xprt * transport) xs_poll_socket() argument 767 xs_poll_socket_readable(struct sock_xprt * transport) xs_poll_socket_readable() argument 774 xs_poll_check_readable(struct sock_xprt * transport) xs_poll_check_readable() argument 786 xs_stream_data_receive(struct sock_xprt * transport) xs_stream_data_receive() argument 814 struct sock_xprt *transport = xs_stream_data_receive_workfn() local 823 xs_stream_reset_connect(struct sock_xprt * transport) xs_stream_reset_connect() argument 832 xs_stream_start_connect(struct sock_xprt * transport) xs_stream_start_connect() argument 846 xs_nospace(struct rpc_rqst * req,struct sock_xprt * transport) xs_nospace() argument 873 struct sock_xprt *transport = xs_sock_nospace() local 887 struct sock_xprt *transport = xs_stream_nospace() local 909 struct sock_xprt *transport = xs_stream_abort_send_request() local 922 xs_send_request_was_aborted(struct sock_xprt * transport,struct rpc_rqst * req) xs_send_request_was_aborted() argument 952 struct sock_xprt *transport = xs_local_send_request() local 1023 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_udp_send_request() local 1109 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_tcp_send_request() local 1195 xs_save_old_callbacks(struct sock_xprt * transport,struct sock * sk) xs_save_old_callbacks() argument 1203 xs_restore_old_callbacks(struct sock_xprt * transport,struct sock * sk) xs_restore_old_callbacks() argument 1213 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_sock_reset_state_flags() local 1224 xs_run_error_worker(struct sock_xprt * transport,unsigned int nr) xs_run_error_worker() argument 1249 struct sock_xprt *transport; xs_error_report() local 1268 xs_reset_transport(struct sock_xprt * transport) xs_reset_transport() argument 1330 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_close() local 1360 struct sock_xprt *transport = container_of(xprt, xs_destroy() local 1433 xs_udp_data_receive(struct sock_xprt * transport) xs_udp_data_receive() argument 1458 struct sock_xprt *transport = xs_udp_data_receive_workfn() local 1479 struct sock_xprt *transport = container_of(xprt, xs_data_ready() local 1523 struct sock_xprt *transport; xs_local_state_change() local 1543 struct sock_xprt *transport; xs_tcp_state_change() local 1613 struct sock_xprt *transport; xs_write_space() local 1665 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_udp_do_set_buffer_size() local 1689 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_udp_set_buffer_size() local 1760 xs_reset_srcport(struct sock_xprt * transport) xs_reset_srcport() argument 1765 xs_set_srcport(struct sock_xprt * transport,struct socket * sock) xs_set_srcport() argument 1771 xs_get_srcport(struct sock_xprt * transport) xs_get_srcport() argument 1810 xs_next_srcport(struct sock_xprt * transport,unsigned short port) xs_next_srcport() argument 1820 xs_bind(struct sock_xprt * transport,struct socket * sock) xs_bind() argument 1940 xs_create_sock(struct rpc_xprt * xprt,struct sock_xprt * transport,int family,int type,int protocol,bool reuseport) xs_create_sock() argument 1980 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xs_local_finish_connecting() local 2015 xs_local_setup_socket(struct sock_xprt * transport) xs_local_setup_socket() argument 2076 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_local_connect() local 2114 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xs_set_memalloc() local 2184 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_udp_finish_connecting() local 2215 struct sock_xprt *transport = xs_udp_setup_socket() local 2255 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_tcp_shutdown() local 2283 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_tcp_set_socket_timeouts() local 2323 struct sock_xprt *transport = xs_tcp_do_set_connect_timeout() local 2343 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_tcp_set_connect_timeout() local 2356 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_tcp_finish_connecting() local 2419 struct sock_xprt *transport = xs_tcp_setup_socket() local 2792 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_connect() local 2813 xs_wake_disconnect(struct sock_xprt * transport) xs_wake_disconnect() argument 2819 xs_wake_write(struct sock_xprt * transport) xs_wake_write() argument 2825 xs_wake_error(struct sock_xprt * transport) xs_wake_error() argument 2838 xs_wake_pending(struct sock_xprt * transport) xs_wake_pending() argument 2846 struct sock_xprt *transport = container_of(work, xs_error_handle() local 2892 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_udp_print_stats() local 2916 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_tcp_print_stats() local 2984 struct sock_xprt *transport = bc_sendto() local 3236 struct sock_xprt *transport; xs_setup_local() local 3304 struct sock_xprt *transport; xs_setup_udp() local 3381 struct sock_xprt *transport; xs_setup_tcp() local 3463 struct sock_xprt *transport; xs_setup_tcp_tls() local 3551 struct sock_xprt *transport; xs_setup_bc_tcp() local [all...] |