Lines Matching defs:transport
476 xs_read_header(struct sock_xprt *transport, struct xdr_buf *buf) in xs_read_header()
488 xs_read_stream_request_done(struct sock_xprt *transport) in xs_read_stream_request_done()
494 xs_read_stream_check_eor(struct sock_xprt *transport, in xs_read_stream_check_eor()
502 xs_read_stream_request(struct sock_xprt *transport, struct msghdr *msg, in xs_read_stream_request()
549 xs_read_stream_header(struct sock_xprt *transport, struct msghdr *msg, in xs_read_stream_header()
561 xs_read_stream_call(struct sock_xprt *transport, struct msghdr *msg, int flags) in xs_read_stream_call()
590 xs_read_stream_call(struct sock_xprt *transport, struct msghdr *msg, int flags) in xs_read_stream_call()
597 xs_read_stream_reply(struct sock_xprt *transport, struct msghdr *msg, int flags) in xs_read_stream_reply()
627 xs_read_stream(struct sock_xprt *transport, int flags) in xs_read_stream()
689 static __poll_t xs_poll_socket(struct sock_xprt *transport) in xs_poll_socket()
695 static bool xs_poll_socket_readable(struct sock_xprt *transport) in xs_poll_socket_readable()
702 static void xs_poll_check_readable(struct sock_xprt *transport) in xs_poll_check_readable()
712 static void xs_stream_data_receive(struct sock_xprt *transport) in xs_stream_data_receive()
738 struct sock_xprt *transport = in xs_stream_data_receive_workfn() local
747 xs_stream_reset_connect(struct sock_xprt *transport) in xs_stream_reset_connect()
756 xs_stream_start_connect(struct sock_xprt *transport) in xs_stream_start_connect()
770 static int xs_nospace(struct rpc_rqst *req, struct sock_xprt *transport) in xs_nospace()
797 struct sock_xprt *transport = in xs_sock_nospace() local
811 struct sock_xprt *transport = in xs_stream_nospace() local
835 xs_send_request_was_aborted(struct sock_xprt *transport, struct rpc_rqst *req) in xs_send_request_was_aborted()
865 struct sock_xprt *transport = in xs_local_send_request() local
936 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_send_request() local
1022 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_send_request() local
1108 static void xs_save_old_callbacks(struct sock_xprt *transport, struct sock *sk) in xs_save_old_callbacks()
1116 static void xs_restore_old_callbacks(struct sock_xprt *transport, struct sock *sk) in xs_restore_old_callbacks()
1126 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_sock_reset_state_flags() local
1135 static void xs_run_error_worker(struct sock_xprt *transport, unsigned int nr) in xs_run_error_worker()
1160 struct sock_xprt *transport; in xs_error_report() local
1179 static void xs_reset_transport(struct sock_xprt *transport) in xs_reset_transport()
1238 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_close() local
1266 struct sock_xprt *transport = container_of(xprt, in xs_destroy() local
1339 static void xs_udp_data_receive(struct sock_xprt *transport) in xs_udp_data_receive()
1364 struct sock_xprt *transport = in xs_udp_data_receive_workfn() local
1383 struct sock_xprt *transport = container_of(xprt, in xs_data_ready() local
1423 struct sock_xprt *transport; in xs_local_state_change() local
1443 struct sock_xprt *transport; in xs_tcp_state_change() local
1511 struct sock_xprt *transport; in xs_write_space() local
1563 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_do_set_buffer_size() local
1587 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_set_buffer_size() local
1658 static void xs_set_srcport(struct sock_xprt *transport, struct socket *sock) in xs_set_srcport()
1664 static int xs_get_srcport(struct sock_xprt *transport) in xs_get_srcport()
1703 static unsigned short xs_next_srcport(struct sock_xprt *transport, unsigned short port) in xs_next_srcport()
1713 static int xs_bind(struct sock_xprt *transport, struct socket *sock) in xs_bind()
1833 struct sock_xprt *transport, int family, int type, in xs_create_sock()
1870 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, in xs_local_finish_connecting() local
1904 static int xs_local_setup_socket(struct sock_xprt *transport) in xs_local_setup_socket()
1965 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_local_connect() local
2003 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, in xs_set_memalloc() local
2073 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_finish_connecting() local
2103 struct sock_xprt *transport = in xs_udp_setup_socket() local
2143 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_shutdown() local
2170 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_set_socket_timeouts() local
2197 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_set_connect_timeout() local
2223 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_finish_connecting() local
2285 struct sock_xprt *transport = in xs_tcp_setup_socket() local
2381 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_connect() local
2401 static void xs_wake_disconnect(struct sock_xprt *transport) in xs_wake_disconnect()
2407 static void xs_wake_write(struct sock_xprt *transport) in xs_wake_write()
2413 static void xs_wake_error(struct sock_xprt *transport) in xs_wake_error()
2431 static void xs_wake_pending(struct sock_xprt *transport) in xs_wake_pending()
2439 struct sock_xprt *transport = container_of(work, in xs_error_handle() local
2485 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_print_stats() local
2509 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_print_stats() local
2577 struct sock_xprt *transport = in bc_sendto() local
2836 struct sock_xprt *transport; in xs_setup_local() local
2904 struct sock_xprt *transport; in xs_setup_udp() local
2981 struct sock_xprt *transport; in xs_setup_tcp() local
3058 struct sock_xprt *transport; in xs_setup_bc_tcp() local