diff options
author | Trond Myklebust <trondmy@gmail.com> | 2019-04-07 13:58:46 -0400 |
---|---|---|
committer | Anna Schumaker <Anna.Schumaker@Netapp.com> | 2019-04-25 14:18:12 -0400 |
commit | 8ba6a92d0182091e0c2fa15c1a5b5458bac25fc3 (patch) | |
tree | cbe5c89703f141e3ec75f79ad6c59c9fd3727512 /net/sunrpc/xprtsock.c | |
parent | 9e6fa0bb84beeff4dddb17d7c23e35135fe977c5 (diff) |
SUNRPC: Refactor xprt_request_wait_receive()
Convert the transport callback to actually put the request to sleep
instead of just setting a timeout. This is in preparation for
rpc_sleep_on_timeout().
Signed-off-by: Trond Myklebust <trond.myklebust@hammerspace.com>
Signed-off-by: Anna Schumaker <Anna.Schumaker@Netapp.com>
Diffstat (limited to 'net/sunrpc/xprtsock.c')
-rw-r--r-- | net/sunrpc/xprtsock.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/net/sunrpc/xprtsock.c b/net/sunrpc/xprtsock.c index 732d4b57411a..b4b4b8db143c 100644 --- a/net/sunrpc/xprtsock.c +++ b/net/sunrpc/xprtsock.c | |||
@@ -2690,7 +2690,7 @@ static const struct rpc_xprt_ops xs_local_ops = { | |||
2690 | .buf_free = rpc_free, | 2690 | .buf_free = rpc_free, |
2691 | .prepare_request = xs_stream_prepare_request, | 2691 | .prepare_request = xs_stream_prepare_request, |
2692 | .send_request = xs_local_send_request, | 2692 | .send_request = xs_local_send_request, |
2693 | .set_retrans_timeout = xprt_set_retrans_timeout_def, | 2693 | .wait_for_reply_request = xprt_wait_for_reply_request_def, |
2694 | .close = xs_close, | 2694 | .close = xs_close, |
2695 | .destroy = xs_destroy, | 2695 | .destroy = xs_destroy, |
2696 | .print_stats = xs_local_print_stats, | 2696 | .print_stats = xs_local_print_stats, |
@@ -2710,7 +2710,7 @@ static const struct rpc_xprt_ops xs_udp_ops = { | |||
2710 | .buf_alloc = rpc_malloc, | 2710 | .buf_alloc = rpc_malloc, |
2711 | .buf_free = rpc_free, | 2711 | .buf_free = rpc_free, |
2712 | .send_request = xs_udp_send_request, | 2712 | .send_request = xs_udp_send_request, |
2713 | .set_retrans_timeout = xprt_set_retrans_timeout_rtt, | 2713 | .wait_for_reply_request = xprt_wait_for_reply_request_rtt, |
2714 | .timer = xs_udp_timer, | 2714 | .timer = xs_udp_timer, |
2715 | .release_request = xprt_release_rqst_cong, | 2715 | .release_request = xprt_release_rqst_cong, |
2716 | .close = xs_close, | 2716 | .close = xs_close, |
@@ -2733,7 +2733,7 @@ static const struct rpc_xprt_ops xs_tcp_ops = { | |||
2733 | .buf_free = rpc_free, | 2733 | .buf_free = rpc_free, |
2734 | .prepare_request = xs_stream_prepare_request, | 2734 | .prepare_request = xs_stream_prepare_request, |
2735 | .send_request = xs_tcp_send_request, | 2735 | .send_request = xs_tcp_send_request, |
2736 | .set_retrans_timeout = xprt_set_retrans_timeout_def, | 2736 | .wait_for_reply_request = xprt_wait_for_reply_request_def, |
2737 | .close = xs_tcp_shutdown, | 2737 | .close = xs_tcp_shutdown, |
2738 | .destroy = xs_destroy, | 2738 | .destroy = xs_destroy, |
2739 | .set_connect_timeout = xs_tcp_set_connect_timeout, | 2739 | .set_connect_timeout = xs_tcp_set_connect_timeout, |
@@ -2761,7 +2761,7 @@ static const struct rpc_xprt_ops bc_tcp_ops = { | |||
2761 | .buf_alloc = bc_malloc, | 2761 | .buf_alloc = bc_malloc, |
2762 | .buf_free = bc_free, | 2762 | .buf_free = bc_free, |
2763 | .send_request = bc_send_request, | 2763 | .send_request = bc_send_request, |
2764 | .set_retrans_timeout = xprt_set_retrans_timeout_def, | 2764 | .wait_for_reply_request = xprt_wait_for_reply_request_def, |
2765 | .close = bc_close, | 2765 | .close = bc_close, |
2766 | .destroy = bc_destroy, | 2766 | .destroy = bc_destroy, |
2767 | .print_stats = xs_tcp_print_stats, | 2767 | .print_stats = xs_tcp_print_stats, |