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_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 528 xs_read_header(struct sock_xprt *transport, struct xdr_buf *buf) in xs_read_header() argument 530 if (!transport->recv.copied) { in xs_read_header() 531 if (buf->head[0].iov_len >= transport->recv.offset) in xs_read_header() 533 &transport->recv.xid, in xs_read_header() 534 transport in xs_read_header() 540 xs_read_stream_request_done(struct sock_xprt * transport) xs_read_stream_request_done() argument 546 xs_read_stream_check_eor(struct sock_xprt * transport,struct msghdr * msg) xs_read_stream_check_eor() argument 554 xs_read_stream_request(struct sock_xprt * transport,struct msghdr * msg,int flags,struct rpc_rqst * req) xs_read_stream_request() argument 601 xs_read_stream_header(struct sock_xprt * transport,struct msghdr * msg,int flags,size_t want,size_t seek) xs_read_stream_header() argument 613 xs_read_stream_call(struct sock_xprt * transport,struct msghdr * msg,int flags) xs_read_stream_call() argument 642 xs_read_stream_call(struct sock_xprt * transport,struct msghdr * msg,int flags) xs_read_stream_call() argument 649 xs_read_stream_reply(struct sock_xprt * transport,struct msghdr * msg,int flags) xs_read_stream_reply() argument 679 xs_read_stream(struct sock_xprt * transport,int flags) xs_read_stream() argument 741 xs_poll_socket(struct sock_xprt * transport) xs_poll_socket() argument 747 xs_poll_socket_readable(struct sock_xprt * transport) xs_poll_socket_readable() argument 754 xs_poll_check_readable(struct sock_xprt * transport) xs_poll_check_readable() argument 766 xs_stream_data_receive(struct sock_xprt * transport) xs_stream_data_receive() argument 794 struct sock_xprt *transport = xs_stream_data_receive_workfn() local 803 xs_stream_reset_connect(struct sock_xprt * transport) xs_stream_reset_connect() argument 812 xs_stream_start_connect(struct sock_xprt * transport) xs_stream_start_connect() argument 826 xs_nospace(struct rpc_rqst * req,struct sock_xprt * transport) xs_nospace() argument 853 struct sock_xprt *transport = xs_sock_nospace() local 867 struct sock_xprt *transport = xs_stream_nospace() local 891 xs_send_request_was_aborted(struct sock_xprt * transport,struct rpc_rqst * req) xs_send_request_was_aborted() argument 921 struct sock_xprt *transport = xs_local_send_request() local 992 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_udp_send_request() local 1078 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_tcp_send_request() local 1164 xs_save_old_callbacks(struct sock_xprt * transport,struct sock * sk) xs_save_old_callbacks() argument 1172 xs_restore_old_callbacks(struct sock_xprt * transport,struct sock * sk) xs_restore_old_callbacks() argument 1182 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_sock_reset_state_flags() local 1192 xs_run_error_worker(struct sock_xprt * transport,unsigned int nr) xs_run_error_worker() argument 1217 struct sock_xprt *transport; xs_error_report() local 1236 xs_reset_transport(struct sock_xprt * transport) xs_reset_transport() argument 1297 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_close() local 1327 struct sock_xprt *transport = container_of(xprt, xs_destroy() local 1400 xs_udp_data_receive(struct sock_xprt * transport) xs_udp_data_receive() argument 1425 struct sock_xprt *transport = xs_udp_data_receive_workfn() local 1446 struct sock_xprt *transport = container_of(xprt, xs_data_ready() local 1490 struct sock_xprt *transport; xs_local_state_change() local 1510 struct sock_xprt *transport; xs_tcp_state_change() local 1578 struct sock_xprt *transport; xs_write_space() local 1630 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_udp_do_set_buffer_size() local 1654 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_udp_set_buffer_size() local 1725 xs_set_srcport(struct sock_xprt * transport,struct socket * sock) xs_set_srcport() argument 1731 xs_get_srcport(struct sock_xprt * transport) xs_get_srcport() argument 1770 xs_next_srcport(struct sock_xprt * transport,unsigned short port) xs_next_srcport() argument 1780 xs_bind(struct sock_xprt * transport,struct socket * sock) xs_bind() argument 1900 xs_create_sock(struct rpc_xprt * xprt,struct sock_xprt * transport,int family,int type,int protocol,bool reuseport) xs_create_sock() argument 1944 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xs_local_finish_connecting() local 1979 xs_local_setup_socket(struct sock_xprt * transport) xs_local_setup_socket() argument 2040 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_local_connect() local 2078 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xs_set_memalloc() local 2148 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_udp_finish_connecting() local 2179 struct sock_xprt *transport = xs_udp_setup_socket() local 2219 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_tcp_shutdown() local 2247 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_tcp_set_socket_timeouts() local 2287 struct sock_xprt *transport = xs_tcp_do_set_connect_timeout() local 2307 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_tcp_set_connect_timeout() local 2320 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_tcp_finish_connecting() local 2383 struct sock_xprt *transport = xs_tcp_setup_socket() local 2754 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_connect() local 2775 xs_wake_disconnect(struct sock_xprt * transport) xs_wake_disconnect() argument 2781 xs_wake_write(struct sock_xprt * transport) xs_wake_write() argument 2787 xs_wake_error(struct sock_xprt * transport) xs_wake_error() argument 2805 xs_wake_pending(struct sock_xprt * transport) xs_wake_pending() argument 2813 struct sock_xprt *transport = container_of(work, xs_error_handle() local 2859 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_udp_print_stats() local 2883 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); xs_tcp_print_stats() local 2951 struct sock_xprt *transport = bc_sendto() local 3210 struct sock_xprt *transport; xs_setup_local() local 3278 struct sock_xprt *transport; xs_setup_udp() local 3355 struct sock_xprt *transport; xs_setup_tcp() local 3437 struct sock_xprt *transport; xs_setup_tcp_tls() local 3525 struct sock_xprt *transport; xs_setup_bc_tcp() local [all...] |