Lines Matching defs:transport
469 xs_read_header(struct sock_xprt *transport, struct xdr_buf *buf) in xs_read_header()
481 xs_read_stream_request_done(struct sock_xprt *transport) in xs_read_stream_request_done()
487 xs_read_stream_check_eor(struct sock_xprt *transport, in xs_read_stream_check_eor()
495 xs_read_stream_request(struct sock_xprt *transport, struct msghdr *msg, in xs_read_stream_request()
542 xs_read_stream_header(struct sock_xprt *transport, struct msghdr *msg, in xs_read_stream_header()
554 xs_read_stream_call(struct sock_xprt *transport, struct msghdr *msg, int flags) in xs_read_stream_call()
579 xs_read_stream_call(struct sock_xprt *transport, struct msghdr *msg, int flags) in xs_read_stream_call()
586 xs_read_stream_reply(struct sock_xprt *transport, struct msghdr *msg, int flags) in xs_read_stream_reply()
616 xs_read_stream(struct sock_xprt *transport, int flags) in xs_read_stream()
678 static __poll_t xs_poll_socket(struct sock_xprt *transport) in xs_poll_socket()
684 static bool xs_poll_socket_readable(struct sock_xprt *transport) in xs_poll_socket_readable()
691 static void xs_poll_check_readable(struct sock_xprt *transport) in xs_poll_check_readable()
701 static void xs_stream_data_receive(struct sock_xprt *transport) in xs_stream_data_receive()
727 struct sock_xprt *transport = in xs_stream_data_receive_workfn() local
736 xs_stream_reset_connect(struct sock_xprt *transport) in xs_stream_reset_connect()
745 xs_stream_start_connect(struct sock_xprt *transport) in xs_stream_start_connect()
761 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_nospace() local
806 xs_send_request_was_aborted(struct sock_xprt *transport, struct rpc_rqst *req) in xs_send_request_was_aborted()
836 struct sock_xprt *transport = in xs_local_send_request() local
908 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_send_request() local
991 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_send_request() local
1088 static void xs_save_old_callbacks(struct sock_xprt *transport, struct sock *sk) in xs_save_old_callbacks()
1096 static void xs_restore_old_callbacks(struct sock_xprt *transport, struct sock *sk) in xs_restore_old_callbacks()
1106 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_sock_reset_state_flags() local
1114 static void xs_run_error_worker(struct sock_xprt *transport, unsigned int nr) in xs_run_error_worker()
1138 struct sock_xprt *transport; in xs_error_report() local
1160 static void xs_reset_transport(struct sock_xprt *transport) in xs_reset_transport()
1209 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_close() local
1237 struct sock_xprt *transport = container_of(xprt, in xs_destroy() local
1310 static void xs_udp_data_receive(struct sock_xprt *transport) in xs_udp_data_receive()
1335 struct sock_xprt *transport = in xs_udp_data_receive_workfn() local
1356 struct sock_xprt *transport = container_of(xprt, in xs_data_ready() local
1394 struct sock_xprt *transport; in xs_tcp_state_change() local
1466 struct sock_xprt *transport; in xs_write_space() local
1531 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_do_set_buffer_size() local
1555 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_set_buffer_size() local
1626 static void xs_set_srcport(struct sock_xprt *transport, struct socket *sock) in xs_set_srcport()
1632 static int xs_get_srcport(struct sock_xprt *transport) in xs_get_srcport()
1641 static unsigned short xs_next_srcport(struct sock_xprt *transport, unsigned short port) in xs_next_srcport()
1651 static int xs_bind(struct sock_xprt *transport, struct socket *sock) in xs_bind()
1770 struct sock_xprt *transport, int family, int type, in xs_create_sock()
1807 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, in xs_local_finish_connecting() local
1841 static int xs_local_setup_socket(struct sock_xprt *transport) in xs_local_setup_socket()
1901 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_local_connect() local
1931 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, in xs_set_memalloc() local
2005 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_finish_connecting() local
2036 struct sock_xprt *transport = in xs_udp_setup_socket() local
2072 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_shutdown() local
2092 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_set_socket_timeouts() local
2119 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_set_connect_timeout() local
2145 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_finish_connecting() local
2224 struct sock_xprt *transport = in xs_tcp_setup_socket() local
2310 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_connect() local
2334 static void xs_wake_disconnect(struct sock_xprt *transport) in xs_wake_disconnect()
2340 static void xs_wake_write(struct sock_xprt *transport) in xs_wake_write()
2346 static void xs_wake_error(struct sock_xprt *transport) in xs_wake_error()
2364 static void xs_wake_pending(struct sock_xprt *transport) in xs_wake_pending()
2372 struct sock_xprt *transport = container_of(work, in xs_error_handle() local
2418 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_print_stats() local
2442 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_print_stats() local
2510 struct sock_xprt *transport = in bc_sendto() local
2762 struct sock_xprt *transport; in xs_setup_local() local
2832 struct sock_xprt *transport; in xs_setup_udp() local
2908 struct sock_xprt *transport; in xs_setup_tcp() local
2984 struct sock_xprt *transport; in xs_setup_bc_tcp() local