Lines Matching refs:sock_xprt

470 xs_read_header(struct sock_xprt *transport, struct xdr_buf *buf)  in xs_read_header()
482 xs_read_stream_request_done(struct sock_xprt *transport) in xs_read_stream_request_done()
488 xs_read_stream_check_eor(struct sock_xprt *transport, in xs_read_stream_check_eor()
496 xs_read_stream_request(struct sock_xprt *transport, struct msghdr *msg, in xs_read_stream_request()
543 xs_read_stream_header(struct sock_xprt *transport, struct msghdr *msg, in xs_read_stream_header()
555 xs_read_stream_call(struct sock_xprt *transport, struct msghdr *msg, int flags) in xs_read_stream_call()
580 xs_read_stream_call(struct sock_xprt *transport, struct msghdr *msg, int flags) in xs_read_stream_call()
587 xs_read_stream_reply(struct sock_xprt *transport, struct msghdr *msg, int flags) in xs_read_stream_reply()
617 xs_read_stream(struct sock_xprt *transport, int flags) in xs_read_stream()
679 static __poll_t xs_poll_socket(struct sock_xprt *transport) in xs_poll_socket()
685 static bool xs_poll_socket_readable(struct sock_xprt *transport) in xs_poll_socket_readable()
692 static void xs_poll_check_readable(struct sock_xprt *transport) in xs_poll_check_readable()
702 static void xs_stream_data_receive(struct sock_xprt *transport) in xs_stream_data_receive()
728 struct sock_xprt *transport = in xs_stream_data_receive_workfn()
729 container_of(work, struct sock_xprt, recv_worker); in xs_stream_data_receive_workfn()
737 xs_stream_reset_connect(struct sock_xprt *transport) in xs_stream_reset_connect()
746 xs_stream_start_connect(struct sock_xprt *transport) in xs_stream_start_connect()
760 static int xs_nospace(struct rpc_rqst *req, struct sock_xprt *transport) in xs_nospace()
793 struct sock_xprt *transport = in xs_sock_nospace()
794 container_of(req->rq_xprt, struct sock_xprt, xprt); in xs_sock_nospace()
807 struct sock_xprt *transport = in xs_stream_nospace()
808 container_of(req->rq_xprt, struct sock_xprt, xprt); in xs_stream_nospace()
831 xs_send_request_was_aborted(struct sock_xprt *transport, struct rpc_rqst *req) in xs_send_request_was_aborted()
861 struct sock_xprt *transport = in xs_local_send_request()
862 container_of(xprt, struct sock_xprt, xprt); in xs_local_send_request()
933 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_send_request()
1016 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_send_request()
1113 static void xs_save_old_callbacks(struct sock_xprt *transport, struct sock *sk) in xs_save_old_callbacks()
1121 static void xs_restore_old_callbacks(struct sock_xprt *transport, struct sock *sk) in xs_restore_old_callbacks()
1131 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_sock_reset_state_flags()
1139 static void xs_run_error_worker(struct sock_xprt *transport, unsigned int nr) in xs_run_error_worker()
1163 struct sock_xprt *transport; in xs_error_report()
1170 transport = container_of(xprt, struct sock_xprt, xprt); in xs_error_report()
1185 static void xs_reset_transport(struct sock_xprt *transport) in xs_reset_transport()
1244 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_close()
1272 struct sock_xprt *transport = container_of(xprt, in xs_destroy()
1273 struct sock_xprt, xprt); in xs_destroy()
1345 static void xs_udp_data_receive(struct sock_xprt *transport) in xs_udp_data_receive()
1370 struct sock_xprt *transport = in xs_udp_data_receive_workfn()
1371 container_of(work, struct sock_xprt, recv_worker); in xs_udp_data_receive_workfn()
1391 struct sock_xprt *transport = container_of(xprt, in xs_data_ready()
1392 struct sock_xprt, xprt); in xs_data_ready()
1429 struct sock_xprt *transport; in xs_tcp_state_change()
1441 transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_state_change()
1501 struct sock_xprt *transport; in xs_write_space()
1510 transport = container_of(xprt, struct sock_xprt, xprt); in xs_write_space()
1566 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_do_set_buffer_size()
1590 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_set_buffer_size()
1661 static void xs_set_srcport(struct sock_xprt *transport, struct socket *sock) in xs_set_srcport()
1667 static int xs_get_srcport(struct sock_xprt *transport) in xs_get_srcport()
1678 struct sock_xprt *sock = container_of(xprt, struct sock_xprt, xprt); in get_srcport()
1683 static unsigned short xs_next_srcport(struct sock_xprt *transport, unsigned short port) in xs_next_srcport()
1693 static int xs_bind(struct sock_xprt *transport, struct socket *sock) in xs_bind()
1813 struct sock_xprt *transport, int family, int type, in xs_create_sock()
1850 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, in xs_local_finish_connecting()
1884 static int xs_local_setup_socket(struct sock_xprt *transport) in xs_local_setup_socket()
1945 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_local_connect()
1975 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, in xs_set_memalloc()
1998 struct sock_xprt *xs = container_of(xprt, struct sock_xprt, xprt); in xs_enable_swap()
2020 struct sock_xprt *xs = container_of(xprt, struct sock_xprt, xprt); in xs_disable_swap()
2049 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_finish_connecting()
2080 struct sock_xprt *transport = in xs_udp_setup_socket()
2081 container_of(work, struct sock_xprt, connect_worker.work); in xs_udp_setup_socket()
2116 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_shutdown()
2136 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_set_socket_timeouts()
2163 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_set_connect_timeout()
2189 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_finish_connecting()
2268 struct sock_xprt *transport = in xs_tcp_setup_socket()
2269 container_of(work, struct sock_xprt, connect_worker.work); in xs_tcp_setup_socket()
2360 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_connect()
2380 static void xs_wake_disconnect(struct sock_xprt *transport) in xs_wake_disconnect()
2386 static void xs_wake_write(struct sock_xprt *transport) in xs_wake_write()
2392 static void xs_wake_error(struct sock_xprt *transport) in xs_wake_error()
2410 static void xs_wake_pending(struct sock_xprt *transport) in xs_wake_pending()
2418 struct sock_xprt *transport = container_of(work, in xs_error_handle()
2419 struct sock_xprt, error_worker); in xs_error_handle()
2464 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_print_stats()
2488 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_print_stats()
2556 struct sock_xprt *transport = in bc_sendto()
2557 container_of(req->rq_xprt, struct sock_xprt, xprt); in bc_sendto()
2759 struct sock_xprt *new; in xs_setup_xprt()
2774 new = container_of(xprt, struct sock_xprt, xprt); in xs_setup_xprt()
2808 struct sock_xprt *transport; in xs_setup_local()
2816 transport = container_of(xprt, struct sock_xprt, xprt); in xs_setup_local()
2875 struct sock_xprt *transport; in xs_setup_udp()
2882 transport = container_of(xprt, struct sock_xprt, xprt); in xs_setup_udp()
2951 struct sock_xprt *transport; in xs_setup_tcp()
2962 transport = container_of(xprt, struct sock_xprt, xprt); in xs_setup_tcp()
3027 struct sock_xprt *transport; in xs_setup_bc_tcp()
3035 transport = container_of(xprt, struct sock_xprt, xprt); in xs_setup_bc_tcp()