Lines Matching defs:transport

475 xs_read_header(struct sock_xprt *transport, struct xdr_buf *buf)  in xs_read_header()
487 xs_read_stream_request_done(struct sock_xprt *transport) in xs_read_stream_request_done()
493 xs_read_stream_check_eor(struct sock_xprt *transport, in xs_read_stream_check_eor()
501 xs_read_stream_request(struct sock_xprt *transport, struct msghdr *msg, in xs_read_stream_request()
548 xs_read_stream_header(struct sock_xprt *transport, struct msghdr *msg, in xs_read_stream_header()
560 xs_read_stream_call(struct sock_xprt *transport, struct msghdr *msg, int flags) in xs_read_stream_call()
589 xs_read_stream_call(struct sock_xprt *transport, struct msghdr *msg, int flags) in xs_read_stream_call()
596 xs_read_stream_reply(struct sock_xprt *transport, struct msghdr *msg, int flags) in xs_read_stream_reply()
626 xs_read_stream(struct sock_xprt *transport, int flags) in xs_read_stream()
688 static __poll_t xs_poll_socket(struct sock_xprt *transport) in xs_poll_socket()
694 static bool xs_poll_socket_readable(struct sock_xprt *transport) in xs_poll_socket_readable()
701 static void xs_poll_check_readable(struct sock_xprt *transport) in xs_poll_check_readable()
711 static void xs_stream_data_receive(struct sock_xprt *transport) in xs_stream_data_receive()
737 struct sock_xprt *transport = in xs_stream_data_receive_workfn() local
746 xs_stream_reset_connect(struct sock_xprt *transport) in xs_stream_reset_connect()
755 xs_stream_start_connect(struct sock_xprt *transport) in xs_stream_start_connect()
771 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_nospace() local
816 xs_send_request_was_aborted(struct sock_xprt *transport, struct rpc_rqst *req) in xs_send_request_was_aborted()
846 struct sock_xprt *transport = in xs_local_send_request() local
918 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_send_request() local
1001 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_send_request() local
1103 static void xs_save_old_callbacks(struct sock_xprt *transport, struct sock *sk) in xs_save_old_callbacks()
1111 static void xs_restore_old_callbacks(struct sock_xprt *transport, struct sock *sk) in xs_restore_old_callbacks()
1121 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_sock_reset_state_flags() local
1129 static void xs_run_error_worker(struct sock_xprt *transport, unsigned int nr) in xs_run_error_worker()
1153 struct sock_xprt *transport; in xs_error_report() local
1175 static void xs_reset_transport(struct sock_xprt *transport) in xs_reset_transport()
1224 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_close() local
1252 struct sock_xprt *transport = container_of(xprt, in xs_destroy() local
1325 static void xs_udp_data_receive(struct sock_xprt *transport) in xs_udp_data_receive()
1350 struct sock_xprt *transport = in xs_udp_data_receive_workfn() local
1371 struct sock_xprt *transport = container_of(xprt, in xs_data_ready() local
1409 struct sock_xprt *transport; in xs_tcp_state_change() local
1481 struct sock_xprt *transport; in xs_write_space() local
1546 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_do_set_buffer_size() local
1570 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_set_buffer_size() local
1641 static void xs_set_srcport(struct sock_xprt *transport, struct socket *sock) in xs_set_srcport()
1647 static int xs_get_srcport(struct sock_xprt *transport) in xs_get_srcport()
1663 static unsigned short xs_next_srcport(struct sock_xprt *transport, unsigned short port) in xs_next_srcport()
1673 static int xs_bind(struct sock_xprt *transport, struct socket *sock) in xs_bind()
1793 struct sock_xprt *transport, int family, int type, in xs_create_sock()
1830 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, in xs_local_finish_connecting() local
1864 static int xs_local_setup_socket(struct sock_xprt *transport) in xs_local_setup_socket()
1925 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_local_connect() local
1955 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, in xs_set_memalloc() local
2029 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_finish_connecting() local
2060 struct sock_xprt *transport = in xs_udp_setup_socket() local
2096 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_shutdown() local
2123 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_set_socket_timeouts() local
2150 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_set_connect_timeout() local
2176 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_finish_connecting() local
2255 struct sock_xprt *transport = in xs_tcp_setup_socket() local
2339 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_connect() local
2363 static void xs_wake_disconnect(struct sock_xprt *transport) in xs_wake_disconnect()
2369 static void xs_wake_write(struct sock_xprt *transport) in xs_wake_write()
2375 static void xs_wake_error(struct sock_xprt *transport) in xs_wake_error()
2393 static void xs_wake_pending(struct sock_xprt *transport) in xs_wake_pending()
2401 struct sock_xprt *transport = container_of(work, in xs_error_handle() local
2447 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_print_stats() local
2471 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_print_stats() local
2539 struct sock_xprt *transport = in bc_sendto() local
2791 struct sock_xprt *transport; in xs_setup_local() local
2862 struct sock_xprt *transport; in xs_setup_udp() local
2939 struct sock_xprt *transport; in xs_setup_tcp() local
3016 struct sock_xprt *transport; in xs_setup_bc_tcp() local