Lines Matching refs:sock_xprt
65 static void xs_reset_srcport(struct sock_xprt *transport);
66 static void xs_set_srcport(struct sock_xprt *transport, struct socket *sock);
528 xs_read_header(struct sock_xprt *transport, struct xdr_buf *buf) in xs_read_header()
540 xs_read_stream_request_done(struct sock_xprt *transport) in xs_read_stream_request_done()
546 xs_read_stream_check_eor(struct sock_xprt *transport, in xs_read_stream_check_eor()
554 xs_read_stream_request(struct sock_xprt *transport, struct msghdr *msg, in xs_read_stream_request()
601 xs_read_stream_header(struct sock_xprt *transport, struct msghdr *msg, in xs_read_stream_header()
613 xs_read_stream_call(struct sock_xprt *transport, struct msghdr *msg, int flags) in xs_read_stream_call()
642 xs_read_stream_call(struct sock_xprt *transport, struct msghdr *msg, int flags) in xs_read_stream_call()
649 xs_read_stream_reply(struct sock_xprt *transport, struct msghdr *msg, int flags) in xs_read_stream_reply()
679 xs_read_stream(struct sock_xprt *transport, int flags) in xs_read_stream()
741 static __poll_t xs_poll_socket(struct sock_xprt *transport) in xs_poll_socket()
747 static bool xs_poll_socket_readable(struct sock_xprt *transport) in xs_poll_socket_readable()
754 static void xs_poll_check_readable(struct sock_xprt *transport) in xs_poll_check_readable()
766 static void xs_stream_data_receive(struct sock_xprt *transport) in xs_stream_data_receive()
794 struct sock_xprt *transport = in xs_stream_data_receive_workfn()
795 container_of(work, struct sock_xprt, recv_worker); in xs_stream_data_receive_workfn()
803 xs_stream_reset_connect(struct sock_xprt *transport) in xs_stream_reset_connect()
812 xs_stream_start_connect(struct sock_xprt *transport) in xs_stream_start_connect()
826 static int xs_nospace(struct rpc_rqst *req, struct sock_xprt *transport) in xs_nospace()
853 struct sock_xprt *transport = in xs_sock_nospace()
854 container_of(req->rq_xprt, struct sock_xprt, xprt); in xs_sock_nospace()
867 struct sock_xprt *transport = in xs_stream_nospace()
868 container_of(req->rq_xprt, struct sock_xprt, xprt); in xs_stream_nospace()
889 struct sock_xprt *transport = in xs_stream_abort_send_request()
890 container_of(xprt, struct sock_xprt, xprt); in xs_stream_abort_send_request()
902 xs_send_request_was_aborted(struct sock_xprt *transport, struct rpc_rqst *req) in xs_send_request_was_aborted()
932 struct sock_xprt *transport = in xs_local_send_request()
933 container_of(xprt, struct sock_xprt, xprt); in xs_local_send_request()
1003 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_send_request()
1089 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_send_request()
1175 static void xs_save_old_callbacks(struct sock_xprt *transport, struct sock *sk) in xs_save_old_callbacks()
1183 static void xs_restore_old_callbacks(struct sock_xprt *transport, struct sock *sk) in xs_restore_old_callbacks()
1193 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_sock_reset_state_flags()
1203 static void xs_run_error_worker(struct sock_xprt *transport, unsigned int nr) in xs_run_error_worker()
1228 struct sock_xprt *transport; in xs_error_report()
1234 transport = container_of(xprt, struct sock_xprt, xprt); in xs_error_report()
1247 static void xs_reset_transport(struct sock_xprt *transport) in xs_reset_transport()
1308 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_close()
1338 struct sock_xprt *transport = container_of(xprt, in xs_destroy()
1339 struct sock_xprt, xprt); in xs_destroy()
1411 static void xs_udp_data_receive(struct sock_xprt *transport) in xs_udp_data_receive()
1436 struct sock_xprt *transport = in xs_udp_data_receive_workfn()
1437 container_of(work, struct sock_xprt, recv_worker); in xs_udp_data_receive_workfn()
1457 struct sock_xprt *transport = container_of(xprt, in xs_data_ready()
1458 struct sock_xprt, xprt); in xs_data_ready()
1501 struct sock_xprt *transport; in xs_local_state_change()
1505 transport = container_of(xprt, struct sock_xprt, xprt); in xs_local_state_change()
1521 struct sock_xprt *transport; in xs_tcp_state_change()
1532 transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_state_change()
1591 struct sock_xprt *transport; in xs_write_space()
1600 transport = container_of(xprt, struct sock_xprt, xprt); in xs_write_space()
1643 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_do_set_buffer_size()
1667 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_set_buffer_size()
1738 static void xs_reset_srcport(struct sock_xprt *transport) in xs_reset_srcport()
1743 static void xs_set_srcport(struct sock_xprt *transport, struct socket *sock) in xs_set_srcport()
1749 static int xs_get_srcport(struct sock_xprt *transport) in xs_get_srcport()
1760 struct sock_xprt *sock = container_of(xprt, struct sock_xprt, xprt); in xs_sock_srcport()
1771 struct sock_xprt *sock = container_of(xprt, struct sock_xprt, xprt); in xs_sock_srcaddr()
1788 static unsigned short xs_next_srcport(struct sock_xprt *transport, unsigned short port) in xs_next_srcport()
1798 static int xs_bind(struct sock_xprt *transport, struct socket *sock) in xs_bind()
1918 struct sock_xprt *transport, int family, int type, in xs_create_sock()
1955 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, in xs_local_finish_connecting()
1990 static int xs_local_setup_socket(struct sock_xprt *transport) in xs_local_setup_socket()
2051 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_local_connect()
2089 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, in xs_set_memalloc()
2112 struct sock_xprt *xs = container_of(xprt, struct sock_xprt, xprt); in xs_enable_swap()
2132 struct sock_xprt *xs = container_of(xprt, struct sock_xprt, xprt); in xs_disable_swap()
2159 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_finish_connecting()
2190 struct sock_xprt *transport = in xs_udp_setup_socket()
2191 container_of(work, struct sock_xprt, connect_worker.work); in xs_udp_setup_socket()
2230 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_shutdown()
2258 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_set_socket_timeouts()
2298 struct sock_xprt *transport = in xs_tcp_do_set_connect_timeout()
2299 container_of(xprt, struct sock_xprt, xprt); in xs_tcp_do_set_connect_timeout()
2318 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_set_connect_timeout()
2331 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_finish_connecting()
2394 struct sock_xprt *transport = in xs_tcp_setup_socket()
2395 container_of(work, struct sock_xprt, connect_worker.work); in xs_tcp_setup_socket()
2487 struct sock_xprt *upper_transport) in xs_tcp_tls_finish_connecting()
2489 struct sock_xprt *lower_transport = in xs_tcp_tls_finish_connecting()
2490 container_of(lower_xprt, struct sock_xprt, xprt); in xs_tcp_tls_finish_connecting()
2572 struct sock_xprt *lower_transport = in xs_tls_handshake_done()
2573 container_of(lower_xprt, struct sock_xprt, xprt); in xs_tls_handshake_done()
2582 struct sock_xprt *lower_transport = in xs_tls_handshake_sync()
2583 container_of(lower_xprt, struct sock_xprt, xprt); in xs_tls_handshake_sync()
2655 struct sock_xprt *upper_transport = in xs_tcp_tls_setup_socket()
2656 container_of(work, struct sock_xprt, connect_worker.work); in xs_tcp_tls_setup_socket()
2766 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_connect()
2787 static void xs_wake_disconnect(struct sock_xprt *transport) in xs_wake_disconnect()
2793 static void xs_wake_write(struct sock_xprt *transport) in xs_wake_write()
2799 static void xs_wake_error(struct sock_xprt *transport) in xs_wake_error()
2812 static void xs_wake_pending(struct sock_xprt *transport) in xs_wake_pending()
2820 struct sock_xprt *transport = container_of(work, in xs_error_handle()
2821 struct sock_xprt, error_worker); in xs_error_handle()
2866 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_print_stats()
2890 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_print_stats()
2958 struct sock_xprt *transport = in bc_sendto()
2959 container_of(req->rq_xprt, struct sock_xprt, xprt); in bc_sendto()
3161 struct sock_xprt *new; in xs_setup_xprt()
3176 new = container_of(xprt, struct sock_xprt, xprt); in xs_setup_xprt()
3210 struct sock_xprt *transport; in xs_setup_local()
3218 transport = container_of(xprt, struct sock_xprt, xprt); in xs_setup_local()
3278 struct sock_xprt *transport; in xs_setup_udp()
3285 transport = container_of(xprt, struct sock_xprt, xprt); in xs_setup_udp()
3355 struct sock_xprt *transport; in xs_setup_tcp()
3366 transport = container_of(xprt, struct sock_xprt, xprt); in xs_setup_tcp()
3437 struct sock_xprt *transport; in xs_setup_tcp_tls()
3448 transport = container_of(xprt, struct sock_xprt, xprt); in xs_setup_tcp_tls()
3525 struct sock_xprt *transport; in xs_setup_bc_tcp()
3533 transport = container_of(xprt, struct sock_xprt, xprt); in xs_setup_bc_tcp()