Lines Matching refs:xprt
60 static void xs_close(struct rpc_xprt *xprt);
61 static void xs_tcp_set_socket_timeouts(struct rpc_xprt *xprt,
227 static inline struct sockaddr *xs_addr(struct rpc_xprt *xprt) in xs_addr() argument
229 return (struct sockaddr *) &xprt->addr; in xs_addr()
232 static inline struct sockaddr_un *xs_addr_un(struct rpc_xprt *xprt) in xs_addr_un() argument
234 return (struct sockaddr_un *) &xprt->addr; in xs_addr_un()
237 static inline struct sockaddr_in *xs_addr_in(struct rpc_xprt *xprt) in xs_addr_in() argument
239 return (struct sockaddr_in *) &xprt->addr; in xs_addr_in()
242 static inline struct sockaddr_in6 *xs_addr_in6(struct rpc_xprt *xprt) in xs_addr_in6() argument
244 return (struct sockaddr_in6 *) &xprt->addr; in xs_addr_in6()
247 static void xs_format_common_peer_addresses(struct rpc_xprt *xprt) in xs_format_common_peer_addresses() argument
249 struct sockaddr *sap = xs_addr(xprt); in xs_format_common_peer_addresses()
257 sun = xs_addr_un(xprt); in xs_format_common_peer_addresses()
259 xprt->address_strings[RPC_DISPLAY_ADDR] = in xs_format_common_peer_addresses()
264 xprt->address_strings[RPC_DISPLAY_ADDR] = in xs_format_common_peer_addresses()
266 sin = xs_addr_in(xprt); in xs_format_common_peer_addresses()
271 xprt->address_strings[RPC_DISPLAY_ADDR] = in xs_format_common_peer_addresses()
273 sin6 = xs_addr_in6(xprt); in xs_format_common_peer_addresses()
280 xprt->address_strings[RPC_DISPLAY_HEX_ADDR] = kstrdup(buf, GFP_KERNEL); in xs_format_common_peer_addresses()
283 static void xs_format_common_peer_ports(struct rpc_xprt *xprt) in xs_format_common_peer_ports() argument
285 struct sockaddr *sap = xs_addr(xprt); in xs_format_common_peer_ports()
289 xprt->address_strings[RPC_DISPLAY_PORT] = kstrdup(buf, GFP_KERNEL); in xs_format_common_peer_ports()
292 xprt->address_strings[RPC_DISPLAY_HEX_PORT] = kstrdup(buf, GFP_KERNEL); in xs_format_common_peer_ports()
295 static void xs_format_peer_addresses(struct rpc_xprt *xprt, in xs_format_peer_addresses() argument
299 xprt->address_strings[RPC_DISPLAY_PROTO] = protocol; in xs_format_peer_addresses()
300 xprt->address_strings[RPC_DISPLAY_NETID] = netid; in xs_format_peer_addresses()
301 xs_format_common_peer_addresses(xprt); in xs_format_peer_addresses()
302 xs_format_common_peer_ports(xprt); in xs_format_peer_addresses()
305 static void xs_update_peer_port(struct rpc_xprt *xprt) in xs_update_peer_port() argument
307 kfree(xprt->address_strings[RPC_DISPLAY_HEX_PORT]); in xs_update_peer_port()
308 kfree(xprt->address_strings[RPC_DISPLAY_PORT]); in xs_update_peer_port()
310 xs_format_common_peer_ports(xprt); in xs_update_peer_port()
313 static void xs_free_peer_addresses(struct rpc_xprt *xprt) in xs_free_peer_addresses() argument
323 kfree(xprt->address_strings[i]); in xs_free_peer_addresses()
557 struct rpc_xprt *xprt = &transport->xprt; in xs_read_stream_call() local
562 req = xprt_lookup_bc_request(xprt, transport->recv.xid); in xs_read_stream_call()
589 struct rpc_xprt *xprt = &transport->xprt; in xs_read_stream_reply() local
594 spin_lock(&xprt->queue_lock); in xs_read_stream_reply()
595 req = xprt_lookup_rqst(xprt, transport->recv.xid); in xs_read_stream_reply()
601 spin_unlock(&xprt->queue_lock); in xs_read_stream_reply()
605 spin_lock(&xprt->queue_lock); in xs_read_stream_reply()
612 spin_unlock(&xprt->queue_lock); in xs_read_stream_reply()
723 trace_xs_stream_read_data(&transport->xprt, ret, read); in xs_stream_data_receive()
748 transport->xprt.stat.connect_count++; in xs_stream_start_connect()
749 transport->xprt.stat.connect_start = jiffies; in xs_stream_start_connect()
762 struct rpc_xprt *xprt = &transport->xprt; in xs_nospace() local
769 spin_lock(&xprt->transport_lock); in xs_nospace()
772 if (xprt_connected(xprt)) { in xs_nospace()
783 xprt_wait_for_buffer_space(xprt); in xs_nospace()
787 spin_unlock(&xprt->transport_lock); in xs_nospace()
794 container_of(req->rq_xprt, struct sock_xprt, xprt); in xs_sock_nospace()
808 container_of(req->rq_xprt, struct sock_xprt, xprt); in xs_stream_nospace()
860 struct rpc_xprt *xprt = req->rq_xprt; in xs_local_send_request() local
862 container_of(xprt, struct sock_xprt, xprt); in xs_local_send_request()
874 xprt_force_disconnect(xprt); in xs_local_send_request()
912 xprt_force_disconnect(xprt); in xs_local_send_request()
932 struct rpc_xprt *xprt = req->rq_xprt; in xs_udp_send_request() local
933 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_send_request()
936 .msg_name = xs_addr(xprt), in xs_udp_send_request()
937 .msg_namelen = xprt->addrlen, in xs_udp_send_request()
947 if (!xprt_bound(xprt)) in xs_udp_send_request()
950 if (!xprt_request_get_cong(xprt, req)) in xs_udp_send_request()
1015 struct rpc_xprt *xprt = req->rq_xprt; in xs_tcp_send_request() local
1016 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_send_request()
1039 xs_tcp_set_socket_timeouts(xprt, transport->sock); in xs_tcp_send_request()
1129 static void xs_sock_reset_state_flags(struct rpc_xprt *xprt) in xs_sock_reset_state_flags() argument
1131 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_sock_reset_state_flags()
1145 static void xs_sock_reset_connection_flags(struct rpc_xprt *xprt) in xs_sock_reset_connection_flags() argument
1148 clear_bit(XPRT_CLOSE_WAIT, &xprt->state); in xs_sock_reset_connection_flags()
1149 clear_bit(XPRT_CLOSING, &xprt->state); in xs_sock_reset_connection_flags()
1150 xs_sock_reset_state_flags(xprt); in xs_sock_reset_connection_flags()
1164 struct rpc_xprt *xprt; in xs_error_report() local
1167 if (!(xprt = xprt_from_sock(sk))) in xs_error_report()
1170 transport = container_of(xprt, struct sock_xprt, xprt); in xs_error_report()
1175 xprt, -transport->xprt_err); in xs_error_report()
1176 trace_rpc_socket_error(xprt, sk->sk_socket, transport->xprt_err); in xs_error_report()
1189 struct rpc_xprt *xprt = &transport->xprt; in xs_reset_transport() local
1201 set_bit(XPRT_CLOSE_WAIT, &xprt->state); in xs_reset_transport()
1205 if (atomic_read(&transport->xprt.swapper)) in xs_reset_transport()
1219 xprt_clear_connected(xprt); in xs_reset_transport()
1221 xs_sock_reset_connection_flags(xprt); in xs_reset_transport()
1226 trace_rpc_socket_close(xprt, sock); in xs_reset_transport()
1229 xprt_disconnect_done(xprt); in xs_reset_transport()
1242 static void xs_close(struct rpc_xprt *xprt) in xs_close() argument
1244 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_close()
1246 dprintk("RPC: xs_close xprt %p\n", xprt); in xs_close()
1249 xprt->reestablish_timeout = 0; in xs_close()
1252 static void xs_inject_disconnect(struct rpc_xprt *xprt) in xs_inject_disconnect() argument
1255 xprt); in xs_inject_disconnect()
1256 xprt_disconnect_done(xprt); in xs_inject_disconnect()
1259 static void xs_xprt_free(struct rpc_xprt *xprt) in xs_xprt_free() argument
1261 xs_free_peer_addresses(xprt); in xs_xprt_free()
1262 xprt_free(xprt); in xs_xprt_free()
1270 static void xs_destroy(struct rpc_xprt *xprt) in xs_destroy() argument
1272 struct sock_xprt *transport = container_of(xprt, in xs_destroy()
1273 struct sock_xprt, xprt); in xs_destroy()
1274 dprintk("RPC: xs_destroy xprt %p\n", xprt); in xs_destroy()
1277 xs_close(xprt); in xs_destroy()
1280 xs_xprt_free(xprt); in xs_destroy()
1291 static void xs_udp_data_read_skb(struct rpc_xprt *xprt, in xs_udp_data_read_skb() argument
1313 spin_lock(&xprt->queue_lock); in xs_udp_data_read_skb()
1314 rovr = xprt_lookup_rqst(xprt, *xp); in xs_udp_data_read_skb()
1319 spin_unlock(&xprt->queue_lock); in xs_udp_data_read_skb()
1327 spin_lock(&xprt->queue_lock); in xs_udp_data_read_skb()
1333 spin_lock(&xprt->transport_lock); in xs_udp_data_read_skb()
1334 xprt_adjust_cwnd(xprt, task, copied); in xs_udp_data_read_skb()
1335 spin_unlock(&xprt->transport_lock); in xs_udp_data_read_skb()
1336 spin_lock(&xprt->queue_lock); in xs_udp_data_read_skb()
1342 spin_unlock(&xprt->queue_lock); in xs_udp_data_read_skb()
1359 xs_udp_data_read_skb(&transport->xprt, sk, skb); in xs_udp_data_receive()
1385 struct rpc_xprt *xprt; in xs_data_ready() local
1389 xprt = xprt_from_sock(sk); in xs_data_ready()
1390 if (xprt != NULL) { in xs_data_ready()
1391 struct sock_xprt *transport = container_of(xprt, in xs_data_ready()
1392 struct sock_xprt, xprt); in xs_data_ready()
1397 if (xprt->reestablish_timeout) in xs_data_ready()
1398 xprt->reestablish_timeout = 0; in xs_data_ready()
1409 static void xs_tcp_force_close(struct rpc_xprt *xprt) in xs_tcp_force_close() argument
1411 xprt_force_disconnect(xprt); in xs_tcp_force_close()
1415 static size_t xs_tcp_bc_maxpayload(struct rpc_xprt *xprt) in xs_tcp_bc_maxpayload() argument
1428 struct rpc_xprt *xprt; in xs_tcp_state_change() local
1432 if (!(xprt = xprt_from_sock(sk))) in xs_tcp_state_change()
1434 dprintk("RPC: xs_tcp_state_change client %p...\n", xprt); in xs_tcp_state_change()
1436 sk->sk_state, xprt_connected(xprt), in xs_tcp_state_change()
1441 transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_state_change()
1442 trace_rpc_socket_state_change(xprt, sk->sk_socket); in xs_tcp_state_change()
1445 if (!xprt_test_and_set_connected(xprt)) { in xs_tcp_state_change()
1446 xprt->connect_cookie++; in xs_tcp_state_change()
1448 xprt_clear_connecting(xprt); in xs_tcp_state_change()
1450 xprt->stat.connect_count++; in xs_tcp_state_change()
1451 xprt->stat.connect_time += (long)jiffies - in xs_tcp_state_change()
1452 xprt->stat.connect_start; in xs_tcp_state_change()
1458 xprt->connect_cookie++; in xs_tcp_state_change()
1459 xprt->reestablish_timeout = 0; in xs_tcp_state_change()
1460 set_bit(XPRT_CLOSING, &xprt->state); in xs_tcp_state_change()
1462 clear_bit(XPRT_CONNECTED, &xprt->state); in xs_tcp_state_change()
1463 clear_bit(XPRT_CLOSE_WAIT, &xprt->state); in xs_tcp_state_change()
1468 xprt->connect_cookie++; in xs_tcp_state_change()
1469 clear_bit(XPRT_CONNECTED, &xprt->state); in xs_tcp_state_change()
1477 if (xprt->reestablish_timeout < XS_TCP_INIT_REEST_TO) in xs_tcp_state_change()
1478 xprt->reestablish_timeout = XS_TCP_INIT_REEST_TO; in xs_tcp_state_change()
1481 set_bit(XPRT_CLOSING, &xprt->state); in xs_tcp_state_change()
1483 clear_bit(XPRT_CONNECTED, &xprt->state); in xs_tcp_state_change()
1489 xprt_clear_connecting(xprt); in xs_tcp_state_change()
1490 clear_bit(XPRT_CLOSING, &xprt->state); in xs_tcp_state_change()
1502 struct rpc_xprt *xprt; in xs_write_space() local
1508 if (unlikely(!(xprt = xprt_from_sock(sk)))) in xs_write_space()
1510 transport = container_of(xprt, struct sock_xprt, xprt); in xs_write_space()
1564 static void xs_udp_do_set_buffer_size(struct rpc_xprt *xprt) in xs_udp_do_set_buffer_size() argument
1566 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_do_set_buffer_size()
1571 sk->sk_rcvbuf = transport->rcvsize * xprt->max_reqs * 2; in xs_udp_do_set_buffer_size()
1575 sk->sk_sndbuf = transport->sndsize * xprt->max_reqs * 2; in xs_udp_do_set_buffer_size()
1588 static void xs_udp_set_buffer_size(struct rpc_xprt *xprt, size_t sndsize, size_t rcvsize) in xs_udp_set_buffer_size() argument
1590 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_set_buffer_size()
1599 xs_udp_do_set_buffer_size(xprt); in xs_udp_set_buffer_size()
1609 static void xs_udp_timer(struct rpc_xprt *xprt, struct rpc_task *task) in xs_udp_timer() argument
1611 spin_lock(&xprt->transport_lock); in xs_udp_timer()
1612 xprt_adjust_cwnd(xprt, task, -ETIMEDOUT); in xs_udp_timer()
1613 spin_unlock(&xprt->transport_lock); in xs_udp_timer()
1653 static void xs_set_port(struct rpc_xprt *xprt, unsigned short port) in xs_set_port() argument
1655 dprintk("RPC: setting port for xprt %p to %u\n", xprt, port); in xs_set_port()
1657 rpc_set_port(xs_addr(xprt), port); in xs_set_port()
1658 xs_update_peer_port(xprt); in xs_set_port()
1663 if (transport->srcport == 0 && transport->xprt.reuseport) in xs_set_srcport()
1671 if (port == 0 && transport->xprt.resvport) in xs_get_srcport()
1676 unsigned short get_srcport(struct rpc_xprt *xprt) in get_srcport() argument
1678 struct sock_xprt *sock = container_of(xprt, struct sock_xprt, xprt); in get_srcport()
1687 if (!transport->xprt.resvport) in xs_next_srcport()
1718 memcpy(&myaddr, &transport->srcaddr, transport->xprt.addrlen); in xs_bind()
1722 transport->xprt.addrlen); in xs_bind()
1724 if (transport->xprt.reuseport) in xs_bind()
1753 static void xs_local_set_port(struct rpc_xprt *xprt, unsigned short port) in xs_local_set_port() argument
1812 static struct socket *xs_create_sock(struct rpc_xprt *xprt, in xs_create_sock() argument
1820 err = __sock_create(xprt->xprt_net, family, type, protocol, &sock, 1); in xs_create_sock()
1847 static int xs_local_finish_connecting(struct rpc_xprt *xprt, in xs_local_finish_connecting() argument
1850 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, in xs_local_finish_connecting()
1851 xprt); in xs_local_finish_connecting()
1860 sk->sk_user_data = xprt; in xs_local_finish_connecting()
1866 xprt_clear_connected(xprt); in xs_local_finish_connecting()
1877 return kernel_connect(sock, xs_addr(xprt), xprt->addrlen, 0); in xs_local_finish_connecting()
1886 struct rpc_xprt *xprt = &transport->xprt; in xs_local_setup_socket() local
1891 status = __sock_create(xprt->xprt_net, AF_LOCAL, in xs_local_setup_socket()
1908 xprt, xprt->address_strings[RPC_DISPLAY_ADDR]); in xs_local_setup_socket()
1910 status = xs_local_finish_connecting(xprt, sock); in xs_local_setup_socket()
1911 trace_rpc_socket_connect(xprt, sock, status); in xs_local_setup_socket()
1915 xprt, xprt->address_strings[RPC_DISPLAY_ADDR]); in xs_local_setup_socket()
1916 xprt->stat.connect_count++; in xs_local_setup_socket()
1917 xprt->stat.connect_time += (long)jiffies - in xs_local_setup_socket()
1918 xprt->stat.connect_start; in xs_local_setup_socket()
1919 xprt_set_connected(xprt); in xs_local_setup_socket()
1925 xprt, xprt->address_strings[RPC_DISPLAY_ADDR]); in xs_local_setup_socket()
1929 xprt, xprt->address_strings[RPC_DISPLAY_ADDR]); in xs_local_setup_socket()
1934 xprt->address_strings[RPC_DISPLAY_ADDR]); in xs_local_setup_socket()
1938 xprt_clear_connecting(xprt); in xs_local_setup_socket()
1939 xprt_wake_pending_tasks(xprt, status); in xs_local_setup_socket()
1943 static void xs_local_connect(struct rpc_xprt *xprt, struct rpc_task *task) in xs_local_connect() argument
1945 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_local_connect()
1973 static void xs_set_memalloc(struct rpc_xprt *xprt) in xs_set_memalloc() argument
1975 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, in xs_set_memalloc()
1976 xprt); in xs_set_memalloc()
1984 if (atomic_read(&xprt->swapper)) in xs_set_memalloc()
1996 xs_enable_swap(struct rpc_xprt *xprt) in xs_enable_swap() argument
1998 struct sock_xprt *xs = container_of(xprt, struct sock_xprt, xprt); in xs_enable_swap()
2000 if (atomic_inc_return(&xprt->swapper) != 1) in xs_enable_swap()
2002 if (wait_on_bit_lock(&xprt->state, XPRT_LOCKED, TASK_KILLABLE)) in xs_enable_swap()
2006 xprt_release_xprt(xprt, NULL); in xs_enable_swap()
2018 xs_disable_swap(struct rpc_xprt *xprt) in xs_disable_swap() argument
2020 struct sock_xprt *xs = container_of(xprt, struct sock_xprt, xprt); in xs_disable_swap()
2022 if (!atomic_dec_and_test(&xprt->swapper)) in xs_disable_swap()
2024 if (wait_on_bit_lock(&xprt->state, XPRT_LOCKED, TASK_KILLABLE)) in xs_disable_swap()
2028 xprt_release_xprt(xprt, NULL); in xs_disable_swap()
2031 static void xs_set_memalloc(struct rpc_xprt *xprt) in xs_set_memalloc() argument
2036 xs_enable_swap(struct rpc_xprt *xprt) in xs_enable_swap() argument
2042 xs_disable_swap(struct rpc_xprt *xprt) in xs_disable_swap() argument
2047 static void xs_udp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock) in xs_udp_finish_connecting() argument
2049 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_finish_connecting()
2058 sk->sk_user_data = xprt; in xs_udp_finish_connecting()
2063 xprt_set_connected(xprt); in xs_udp_finish_connecting()
2069 xs_set_memalloc(xprt); in xs_udp_finish_connecting()
2073 xs_udp_do_set_buffer_size(xprt); in xs_udp_finish_connecting()
2075 xprt->stat.connect_start = jiffies; in xs_udp_finish_connecting()
2082 struct rpc_xprt *xprt = &transport->xprt; in xs_udp_setup_socket() local
2086 sock = xs_create_sock(xprt, transport, in xs_udp_setup_socket()
2087 xs_addr(xprt)->sa_family, SOCK_DGRAM, in xs_udp_setup_socket()
2093 "%s (port %s)\n", xprt, in xs_udp_setup_socket()
2094 xprt->address_strings[RPC_DISPLAY_PROTO], in xs_udp_setup_socket()
2095 xprt->address_strings[RPC_DISPLAY_ADDR], in xs_udp_setup_socket()
2096 xprt->address_strings[RPC_DISPLAY_PORT]); in xs_udp_setup_socket()
2098 xs_udp_finish_connecting(xprt, sock); in xs_udp_setup_socket()
2099 trace_rpc_socket_connect(xprt, sock, 0); in xs_udp_setup_socket()
2102 xprt_clear_connecting(xprt); in xs_udp_setup_socket()
2103 xprt_unlock_connect(xprt, transport); in xs_udp_setup_socket()
2104 xprt_wake_pending_tasks(xprt, status); in xs_udp_setup_socket()
2114 static void xs_tcp_shutdown(struct rpc_xprt *xprt) in xs_tcp_shutdown() argument
2116 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_shutdown()
2125 trace_rpc_socket_shutdown(xprt, sock); in xs_tcp_shutdown()
2133 static void xs_tcp_set_socket_timeouts(struct rpc_xprt *xprt, in xs_tcp_set_socket_timeouts() argument
2136 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_set_socket_timeouts()
2141 spin_lock(&xprt->transport_lock); in xs_tcp_set_socket_timeouts()
2142 keepidle = DIV_ROUND_UP(xprt->timeout->to_initval, HZ); in xs_tcp_set_socket_timeouts()
2143 keepcnt = xprt->timeout->to_retries + 1; in xs_tcp_set_socket_timeouts()
2144 timeo = jiffies_to_msecs(xprt->timeout->to_initval) * in xs_tcp_set_socket_timeouts()
2145 (xprt->timeout->to_retries + 1); in xs_tcp_set_socket_timeouts()
2147 spin_unlock(&xprt->transport_lock); in xs_tcp_set_socket_timeouts()
2159 static void xs_tcp_set_connect_timeout(struct rpc_xprt *xprt, in xs_tcp_set_connect_timeout() argument
2163 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_set_connect_timeout()
2167 spin_lock(&xprt->transport_lock); in xs_tcp_set_connect_timeout()
2168 if (reconnect_timeout < xprt->max_reconnect_timeout) in xs_tcp_set_connect_timeout()
2169 xprt->max_reconnect_timeout = reconnect_timeout; in xs_tcp_set_connect_timeout()
2170 if (connect_timeout < xprt->connect_timeout) { in xs_tcp_set_connect_timeout()
2171 memcpy(&to, xprt->timeout, sizeof(to)); in xs_tcp_set_connect_timeout()
2180 xprt->timeout = &transport->tcp_timeout; in xs_tcp_set_connect_timeout()
2181 xprt->connect_timeout = connect_timeout; in xs_tcp_set_connect_timeout()
2184 spin_unlock(&xprt->transport_lock); in xs_tcp_set_connect_timeout()
2187 static int xs_tcp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock) in xs_tcp_finish_connecting() argument
2189 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_finish_connecting()
2202 if (xs_addr(xprt)->sa_family == PF_INET6) { in xs_tcp_finish_connecting()
2207 xs_tcp_set_socket_timeouts(xprt, sock); in xs_tcp_finish_connecting()
2213 sk->sk_user_data = xprt; in xs_tcp_finish_connecting()
2224 xprt_clear_connected(xprt); in xs_tcp_finish_connecting()
2233 if (!xprt_bound(xprt)) in xs_tcp_finish_connecting()
2236 xs_set_memalloc(xprt); in xs_tcp_finish_connecting()
2242 ret = kernel_connect(sock, xs_addr(xprt), xprt->addrlen, O_NONBLOCK); in xs_tcp_finish_connecting()
2249 if (xprt->reestablish_timeout < XS_TCP_INIT_REEST_TO) in xs_tcp_finish_connecting()
2250 xprt->reestablish_timeout = XS_TCP_INIT_REEST_TO; in xs_tcp_finish_connecting()
2271 struct rpc_xprt *xprt = &transport->xprt; in xs_tcp_setup_socket() local
2274 if (xprt_connected(xprt)) in xs_tcp_setup_socket()
2280 sock = xs_create_sock(xprt, transport, xs_addr(xprt)->sa_family, in xs_tcp_setup_socket()
2289 "%s (port %s)\n", xprt, in xs_tcp_setup_socket()
2290 xprt->address_strings[RPC_DISPLAY_PROTO], in xs_tcp_setup_socket()
2291 xprt->address_strings[RPC_DISPLAY_ADDR], in xs_tcp_setup_socket()
2292 xprt->address_strings[RPC_DISPLAY_PORT]); in xs_tcp_setup_socket()
2294 status = xs_tcp_finish_connecting(xprt, sock); in xs_tcp_setup_socket()
2295 trace_rpc_socket_connect(xprt, sock, status); in xs_tcp_setup_socket()
2297 xprt, -status, xprt_connected(xprt), in xs_tcp_setup_socket()
2308 xs_tcp_force_close(xprt); in xs_tcp_setup_socket()
2315 xprt_unlock_connect(xprt, transport); in xs_tcp_setup_socket()
2333 xprt_wake_pending_tasks(xprt, status); in xs_tcp_setup_socket()
2334 xs_tcp_force_close(xprt); in xs_tcp_setup_socket()
2339 xprt_clear_connecting(xprt); in xs_tcp_setup_socket()
2340 xprt_unlock_connect(xprt, transport); in xs_tcp_setup_socket()
2341 xprt_wake_pending_tasks(xprt, status); in xs_tcp_setup_socket()
2358 static void xs_connect(struct rpc_xprt *xprt, struct rpc_task *task) in xs_connect() argument
2360 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_connect()
2363 WARN_ON_ONCE(!xprt_lock_connect(xprt, task, transport)); in xs_connect()
2367 "seconds\n", xprt, xprt->reestablish_timeout / HZ); in xs_connect()
2369 delay = xprt_reconnect_delay(xprt); in xs_connect()
2370 xprt_reconnect_backoff(xprt, XS_TCP_INIT_REEST_TO); in xs_connect()
2373 dprintk("RPC: xs_connect scheduled xprt %p\n", xprt); in xs_connect()
2383 xs_tcp_force_close(&transport->xprt); in xs_wake_disconnect()
2389 xprt_write_space(&transport->xprt); in xs_wake_write()
2405 xprt_wake_pending_tasks(&transport->xprt, sockerr); in xs_wake_error()
2413 xprt_wake_pending_tasks(&transport->xprt, -EAGAIN); in xs_wake_pending()
2433 static void xs_local_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) in xs_local_print_stats() argument
2437 if (xprt_connected(xprt)) in xs_local_print_stats()
2438 idle_time = (long)(jiffies - xprt->last_used) / HZ; in xs_local_print_stats()
2442 xprt->stat.bind_count, in xs_local_print_stats()
2443 xprt->stat.connect_count, in xs_local_print_stats()
2444 xprt->stat.connect_time / HZ, in xs_local_print_stats()
2446 xprt->stat.sends, in xs_local_print_stats()
2447 xprt->stat.recvs, in xs_local_print_stats()
2448 xprt->stat.bad_xids, in xs_local_print_stats()
2449 xprt->stat.req_u, in xs_local_print_stats()
2450 xprt->stat.bklog_u, in xs_local_print_stats()
2451 xprt->stat.max_slots, in xs_local_print_stats()
2452 xprt->stat.sending_u, in xs_local_print_stats()
2453 xprt->stat.pending_u); in xs_local_print_stats()
2462 static void xs_udp_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) in xs_udp_print_stats() argument
2464 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_udp_print_stats()
2469 xprt->stat.bind_count, in xs_udp_print_stats()
2470 xprt->stat.sends, in xs_udp_print_stats()
2471 xprt->stat.recvs, in xs_udp_print_stats()
2472 xprt->stat.bad_xids, in xs_udp_print_stats()
2473 xprt->stat.req_u, in xs_udp_print_stats()
2474 xprt->stat.bklog_u, in xs_udp_print_stats()
2475 xprt->stat.max_slots, in xs_udp_print_stats()
2476 xprt->stat.sending_u, in xs_udp_print_stats()
2477 xprt->stat.pending_u); in xs_udp_print_stats()
2486 static void xs_tcp_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) in xs_tcp_print_stats() argument
2488 struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); in xs_tcp_print_stats()
2491 if (xprt_connected(xprt)) in xs_tcp_print_stats()
2492 idle_time = (long)(jiffies - xprt->last_used) / HZ; in xs_tcp_print_stats()
2497 xprt->stat.bind_count, in xs_tcp_print_stats()
2498 xprt->stat.connect_count, in xs_tcp_print_stats()
2499 xprt->stat.connect_time / HZ, in xs_tcp_print_stats()
2501 xprt->stat.sends, in xs_tcp_print_stats()
2502 xprt->stat.recvs, in xs_tcp_print_stats()
2503 xprt->stat.bad_xids, in xs_tcp_print_stats()
2504 xprt->stat.req_u, in xs_tcp_print_stats()
2505 xprt->stat.bklog_u, in xs_tcp_print_stats()
2506 xprt->stat.max_slots, in xs_tcp_print_stats()
2507 xprt->stat.sending_u, in xs_tcp_print_stats()
2508 xprt->stat.pending_u); in xs_tcp_print_stats()
2557 container_of(req->rq_xprt, struct sock_xprt, xprt); in bc_sendto()
2587 struct svc_xprt *xprt; in bc_send_request() local
2593 xprt = req->rq_xprt->bc_xprt; in bc_send_request()
2599 mutex_lock(&xprt->xpt_mutex); in bc_send_request()
2600 if (test_bit(XPT_DEAD, &xprt->xpt_flags)) in bc_send_request()
2604 mutex_unlock(&xprt->xpt_mutex); in bc_send_request()
2616 static void bc_close(struct rpc_xprt *xprt) in bc_close() argument
2618 xprt_disconnect_done(xprt); in bc_close()
2626 static void bc_destroy(struct rpc_xprt *xprt) in bc_destroy() argument
2628 dprintk("RPC: bc_destroy xprt %p\n", xprt); in bc_destroy()
2630 xs_xprt_free(xprt); in bc_destroy()
2758 struct rpc_xprt *xprt; in xs_setup_xprt() local
2761 if (args->addrlen > sizeof(xprt->addr)) { in xs_setup_xprt()
2766 xprt = xprt_alloc(args->net, sizeof(*new), slot_table_size, in xs_setup_xprt()
2768 if (xprt == NULL) { in xs_setup_xprt()
2774 new = container_of(xprt, struct sock_xprt, xprt); in xs_setup_xprt()
2776 memcpy(&xprt->addr, args->dstaddr, args->addrlen); in xs_setup_xprt()
2777 xprt->addrlen = args->addrlen; in xs_setup_xprt()
2785 xprt_free(xprt); in xs_setup_xprt()
2790 return xprt; in xs_setup_xprt()
2809 struct rpc_xprt *xprt; in xs_setup_local() local
2812 xprt = xs_setup_xprt(args, xprt_tcp_slot_table_entries, in xs_setup_local()
2814 if (IS_ERR(xprt)) in xs_setup_local()
2815 return xprt; in xs_setup_local()
2816 transport = container_of(xprt, struct sock_xprt, xprt); in xs_setup_local()
2818 xprt->prot = 0; in xs_setup_local()
2819 xprt->max_payload = RPC_MAX_FRAGMENT_SIZE; in xs_setup_local()
2821 xprt->bind_timeout = XS_BIND_TO; in xs_setup_local()
2822 xprt->reestablish_timeout = XS_TCP_INIT_REEST_TO; in xs_setup_local()
2823 xprt->idle_timeout = XS_IDLE_DISC_TO; in xs_setup_local()
2825 xprt->ops = &xs_local_ops; in xs_setup_local()
2826 xprt->timeout = &xs_local_default_timeout; in xs_setup_local()
2840 xprt_set_bound(xprt); in xs_setup_local()
2841 xs_format_peer_addresses(xprt, "local", RPCBIND_NETID_LOCAL); in xs_setup_local()
2849 xprt->address_strings[RPC_DISPLAY_ADDR]); in xs_setup_local()
2852 return xprt; in xs_setup_local()
2855 xs_xprt_free(xprt); in xs_setup_local()
2874 struct rpc_xprt *xprt; in xs_setup_udp() local
2878 xprt = xs_setup_xprt(args, xprt_udp_slot_table_entries, in xs_setup_udp()
2880 if (IS_ERR(xprt)) in xs_setup_udp()
2881 return xprt; in xs_setup_udp()
2882 transport = container_of(xprt, struct sock_xprt, xprt); in xs_setup_udp()
2884 xprt->prot = IPPROTO_UDP; in xs_setup_udp()
2886 xprt->max_payload = (1U << 16) - (MAX_HEADER << 3); in xs_setup_udp()
2888 xprt->bind_timeout = XS_BIND_TO; in xs_setup_udp()
2889 xprt->reestablish_timeout = XS_UDP_REEST_TO; in xs_setup_udp()
2890 xprt->idle_timeout = XS_IDLE_DISC_TO; in xs_setup_udp()
2892 xprt->ops = &xs_udp_ops; in xs_setup_udp()
2894 xprt->timeout = &xs_udp_default_timeout; in xs_setup_udp()
2903 xprt_set_bound(xprt); in xs_setup_udp()
2905 xs_format_peer_addresses(xprt, "udp", RPCBIND_NETID_UDP); in xs_setup_udp()
2909 xprt_set_bound(xprt); in xs_setup_udp()
2911 xs_format_peer_addresses(xprt, "udp", RPCBIND_NETID_UDP6); in xs_setup_udp()
2918 if (xprt_bound(xprt)) in xs_setup_udp()
2920 xprt->address_strings[RPC_DISPLAY_ADDR], in xs_setup_udp()
2921 xprt->address_strings[RPC_DISPLAY_PORT], in xs_setup_udp()
2922 xprt->address_strings[RPC_DISPLAY_PROTO]); in xs_setup_udp()
2925 xprt->address_strings[RPC_DISPLAY_ADDR], in xs_setup_udp()
2926 xprt->address_strings[RPC_DISPLAY_PROTO]); in xs_setup_udp()
2929 return xprt; in xs_setup_udp()
2932 xs_xprt_free(xprt); in xs_setup_udp()
2950 struct rpc_xprt *xprt; in xs_setup_tcp() local
2958 xprt = xs_setup_xprt(args, xprt_tcp_slot_table_entries, in xs_setup_tcp()
2960 if (IS_ERR(xprt)) in xs_setup_tcp()
2961 return xprt; in xs_setup_tcp()
2962 transport = container_of(xprt, struct sock_xprt, xprt); in xs_setup_tcp()
2964 xprt->prot = IPPROTO_TCP; in xs_setup_tcp()
2965 xprt->max_payload = RPC_MAX_FRAGMENT_SIZE; in xs_setup_tcp()
2967 xprt->bind_timeout = XS_BIND_TO; in xs_setup_tcp()
2968 xprt->reestablish_timeout = XS_TCP_INIT_REEST_TO; in xs_setup_tcp()
2969 xprt->idle_timeout = XS_IDLE_DISC_TO; in xs_setup_tcp()
2971 xprt->ops = &xs_tcp_ops; in xs_setup_tcp()
2972 xprt->timeout = &xs_tcp_default_timeout; in xs_setup_tcp()
2974 xprt->max_reconnect_timeout = xprt->timeout->to_maxval; in xs_setup_tcp()
2975 xprt->connect_timeout = xprt->timeout->to_initval * in xs_setup_tcp()
2976 (xprt->timeout->to_retries + 1); in xs_setup_tcp()
2985 xprt_set_bound(xprt); in xs_setup_tcp()
2987 xs_format_peer_addresses(xprt, "tcp", RPCBIND_NETID_TCP); in xs_setup_tcp()
2991 xprt_set_bound(xprt); in xs_setup_tcp()
2993 xs_format_peer_addresses(xprt, "tcp", RPCBIND_NETID_TCP6); in xs_setup_tcp()
3000 if (xprt_bound(xprt)) in xs_setup_tcp()
3002 xprt->address_strings[RPC_DISPLAY_ADDR], in xs_setup_tcp()
3003 xprt->address_strings[RPC_DISPLAY_PORT], in xs_setup_tcp()
3004 xprt->address_strings[RPC_DISPLAY_PROTO]); in xs_setup_tcp()
3007 xprt->address_strings[RPC_DISPLAY_ADDR], in xs_setup_tcp()
3008 xprt->address_strings[RPC_DISPLAY_PROTO]); in xs_setup_tcp()
3011 return xprt; in xs_setup_tcp()
3014 xs_xprt_free(xprt); in xs_setup_tcp()
3026 struct rpc_xprt *xprt; in xs_setup_bc_tcp() local
3031 xprt = xs_setup_xprt(args, xprt_tcp_slot_table_entries, in xs_setup_bc_tcp()
3033 if (IS_ERR(xprt)) in xs_setup_bc_tcp()
3034 return xprt; in xs_setup_bc_tcp()
3035 transport = container_of(xprt, struct sock_xprt, xprt); in xs_setup_bc_tcp()
3037 xprt->prot = IPPROTO_TCP; in xs_setup_bc_tcp()
3038 xprt->max_payload = RPC_MAX_FRAGMENT_SIZE; in xs_setup_bc_tcp()
3039 xprt->timeout = &xs_tcp_default_timeout; in xs_setup_bc_tcp()
3042 xprt_set_bound(xprt); in xs_setup_bc_tcp()
3043 xprt->bind_timeout = 0; in xs_setup_bc_tcp()
3044 xprt->reestablish_timeout = 0; in xs_setup_bc_tcp()
3045 xprt->idle_timeout = 0; in xs_setup_bc_tcp()
3047 xprt->ops = &bc_tcp_ops; in xs_setup_bc_tcp()
3051 xs_format_peer_addresses(xprt, "tcp", in xs_setup_bc_tcp()
3055 xs_format_peer_addresses(xprt, "tcp", in xs_setup_bc_tcp()
3064 xprt->address_strings[RPC_DISPLAY_ADDR], in xs_setup_bc_tcp()
3065 xprt->address_strings[RPC_DISPLAY_PORT], in xs_setup_bc_tcp()
3066 xprt->address_strings[RPC_DISPLAY_PROTO]); in xs_setup_bc_tcp()
3074 xprt_get(xprt); in xs_setup_bc_tcp()
3075 args->bc_xprt->xpt_bc_xprt = xprt; in xs_setup_bc_tcp()
3076 xprt->bc_xprt = args->bc_xprt; in xs_setup_bc_tcp()
3085 xprt_set_connected(xprt); in xs_setup_bc_tcp()
3088 return xprt; in xs_setup_bc_tcp()
3092 xprt_put(xprt); in xs_setup_bc_tcp()
3095 xs_xprt_free(xprt); in xs_setup_bc_tcp()