Lines Matching refs:rpc_xprt
57 static void xs_close(struct rpc_xprt *xprt);
58 static void xs_tcp_set_socket_timeouts(struct rpc_xprt *xprt,
223 static inline struct rpc_xprt *xprt_from_sock(struct sock *sk) in xprt_from_sock()
225 return (struct rpc_xprt *) sk->sk_user_data; in xprt_from_sock()
228 static inline struct sockaddr *xs_addr(struct rpc_xprt *xprt) in xs_addr()
233 static inline struct sockaddr_un *xs_addr_un(struct rpc_xprt *xprt) in xs_addr_un()
238 static inline struct sockaddr_in *xs_addr_in(struct rpc_xprt *xprt) in xs_addr_in()
243 static inline struct sockaddr_in6 *xs_addr_in6(struct rpc_xprt *xprt) in xs_addr_in6()
248 static void xs_format_common_peer_addresses(struct rpc_xprt *xprt) in xs_format_common_peer_addresses()
284 static void xs_format_common_peer_ports(struct rpc_xprt *xprt) in xs_format_common_peer_ports()
296 static void xs_format_peer_addresses(struct rpc_xprt *xprt, in xs_format_peer_addresses()
306 static void xs_update_peer_port(struct rpc_xprt *xprt) in xs_update_peer_port()
314 static void xs_free_peer_addresses(struct rpc_xprt *xprt) in xs_free_peer_addresses()
458 struct rpc_xprt *xprt = req->rq_xprt; in xs_nospace()
518 struct rpc_xprt *xprt = req->rq_xprt; in xs_local_send_request()
581 struct rpc_xprt *xprt = req->rq_xprt; in xs_udp_send_request()
657 struct rpc_xprt *xprt = req->rq_xprt; in xs_tcp_send_request()
761 static void xs_tcp_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xs_tcp_release_xprt()
797 static void xs_sock_reset_state_flags(struct rpc_xprt *xprt) in xs_sock_reset_state_flags()
804 static void xs_sock_reset_connection_flags(struct rpc_xprt *xprt) in xs_sock_reset_connection_flags()
822 struct rpc_xprt *xprt; in xs_error_report()
844 struct rpc_xprt *xprt = &transport->xprt; in xs_reset_transport()
881 static void xs_close(struct rpc_xprt *xprt) in xs_close()
893 static void xs_inject_disconnect(struct rpc_xprt *xprt) in xs_inject_disconnect()
900 static void xs_xprt_free(struct rpc_xprt *xprt) in xs_xprt_free()
911 static void xs_destroy(struct rpc_xprt *xprt) in xs_destroy()
947 static void xs_local_data_read_skb(struct rpc_xprt *xprt, in xs_local_data_read_skb()
1039 static void xs_udp_data_read_skb(struct rpc_xprt *xprt, in xs_udp_data_read_skb()
1137 struct rpc_xprt *xprt; in xs_data_ready()
1161 static void xs_tcp_force_close(struct rpc_xprt *xprt) in xs_tcp_force_close()
1166 static inline void xs_tcp_read_fraghdr(struct rpc_xprt *xprt, struct xdr_skb_reader *desc) in xs_tcp_read_fraghdr()
1278 static inline void xs_tcp_read_common(struct rpc_xprt *xprt, in xs_tcp_read_common()
1349 static inline int xs_tcp_read_reply(struct rpc_xprt *xprt, in xs_tcp_read_reply()
1388 static int xs_tcp_read_callback(struct rpc_xprt *xprt, in xs_tcp_read_callback()
1412 static inline int _xs_tcp_read_data(struct rpc_xprt *xprt, in _xs_tcp_read_data()
1434 static size_t xs_tcp_bc_maxpayload(struct rpc_xprt *xprt) in xs_tcp_bc_maxpayload()
1439 static inline int _xs_tcp_read_data(struct rpc_xprt *xprt, in _xs_tcp_read_data()
1450 static void xs_tcp_read_data(struct rpc_xprt *xprt, in xs_tcp_read_data()
1483 struct rpc_xprt *xprt = rd_desc->arg.data; in xs_tcp_data_recv()
1531 struct rpc_xprt *xprt = &transport->xprt; in xs_tcp_data_receive()
1584 struct rpc_xprt *xprt; in xs_tcp_state_change()
1665 struct rpc_xprt *xprt; in xs_write_space()
1725 static void xs_udp_do_set_buffer_size(struct rpc_xprt *xprt) in xs_udp_do_set_buffer_size()
1749 static void xs_udp_set_buffer_size(struct rpc_xprt *xprt, size_t sndsize, size_t rcvsize) in xs_udp_set_buffer_size()
1769 static void xs_udp_timer(struct rpc_xprt *xprt, struct rpc_task *task) in xs_udp_timer()
1822 static void xs_set_port(struct rpc_xprt *xprt, unsigned short port) in xs_set_port()
1914 static void xs_local_set_port(struct rpc_xprt *xprt, unsigned short port) in xs_local_set_port()
1973 static struct socket *xs_create_sock(struct rpc_xprt *xprt, in xs_create_sock()
2002 static int xs_local_finish_connecting(struct rpc_xprt *xprt, in xs_local_finish_connecting()
2043 struct rpc_xprt *xprt = &transport->xprt; in xs_local_setup_socket()
2088 static void xs_local_connect(struct rpc_xprt *xprt, struct rpc_task *task) in xs_local_connect()
2117 static void xs_set_memalloc(struct rpc_xprt *xprt) in xs_set_memalloc()
2140 xs_enable_swap(struct rpc_xprt *xprt) in xs_enable_swap()
2162 xs_disable_swap(struct rpc_xprt *xprt) in xs_disable_swap()
2175 static void xs_set_memalloc(struct rpc_xprt *xprt) in xs_set_memalloc()
2180 xs_enable_swap(struct rpc_xprt *xprt) in xs_enable_swap()
2186 xs_disable_swap(struct rpc_xprt *xprt) in xs_disable_swap()
2191 static void xs_udp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock) in xs_udp_finish_connecting()
2227 struct rpc_xprt *xprt = &transport->xprt; in xs_udp_setup_socket()
2259 static void xs_tcp_shutdown(struct rpc_xprt *xprt) in xs_tcp_shutdown()
2278 static void xs_tcp_set_socket_timeouts(struct rpc_xprt *xprt, in xs_tcp_set_socket_timeouts()
2310 static void xs_tcp_set_connect_timeout(struct rpc_xprt *xprt, in xs_tcp_set_connect_timeout()
2338 static int xs_tcp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock) in xs_tcp_finish_connecting()
2421 struct rpc_xprt *xprt = &transport->xprt; in xs_tcp_setup_socket()
2488 static unsigned long xs_reconnect_delay(const struct rpc_xprt *xprt) in xs_reconnect_delay()
2498 static void xs_reconnect_backoff(struct rpc_xprt *xprt) in xs_reconnect_backoff()
2521 static void xs_connect(struct rpc_xprt *xprt, struct rpc_task *task) in xs_connect()
2553 static void xs_local_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) in xs_local_print_stats()
2582 static void xs_udp_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) in xs_udp_print_stats()
2606 static void xs_tcp_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) in xs_tcp_print_stats()
2681 struct rpc_xprt *xprt = req->rq_xprt; in bc_sendto()
2745 static void bc_close(struct rpc_xprt *xprt) in bc_close()
2754 static void bc_destroy(struct rpc_xprt *xprt) in bc_destroy()
2880 static struct rpc_xprt *xs_setup_xprt(struct xprt_create *args, in xs_setup_xprt()
2884 struct rpc_xprt *xprt; in xs_setup_xprt()
2931 static struct rpc_xprt *xs_setup_local(struct xprt_create *args) in xs_setup_local()
2935 struct rpc_xprt *xprt; in xs_setup_local()
2936 struct rpc_xprt *ret; in xs_setup_local()
3001 static struct rpc_xprt *xs_setup_udp(struct xprt_create *args) in xs_setup_udp()
3004 struct rpc_xprt *xprt; in xs_setup_udp()
3006 struct rpc_xprt *ret; in xs_setup_udp()
3077 static struct rpc_xprt *xs_setup_tcp(struct xprt_create *args) in xs_setup_tcp()
3080 struct rpc_xprt *xprt; in xs_setup_tcp()
3082 struct rpc_xprt *ret; in xs_setup_tcp()
3153 static struct rpc_xprt *xs_setup_bc_tcp(struct xprt_create *args) in xs_setup_bc_tcp()
3156 struct rpc_xprt *xprt; in xs_setup_bc_tcp()
3159 struct rpc_xprt *ret; in xs_setup_bc_tcp()