diff options
author | Chuck Lever <chuck.lever@oracle.com> | 2018-03-05 15:12:57 -0500 |
---|---|---|
committer | Anna Schumaker <Anna.Schumaker@Netapp.com> | 2018-04-10 16:06:22 -0400 |
commit | ecd465ee88bb6648c06c82b1abae6ec28cf5fccb (patch) | |
tree | 11fb1c45bb22edd5b772f804d4a3d940da3659bc /net | |
parent | 2dd4a012d9e73c423a8c48d7e0f2e427caecce3d (diff) |
SUNRPC: Move xprt_update_rtt callsite
Since commit 33849792cbcd ("xprtrdma: Detect unreachable NFS/RDMA
servers more reliably"), the xprtrdma transport now has a ->timer
callout. But xprtrdma does not need to compute RTT data, only UDP
needs that. Move the xprt_update_rtt call into the UDP transport
implementation.
Signed-off-by: Chuck Lever <chuck.lever@oracle.com>
Signed-off-by: Anna Schumaker <Anna.Schumaker@Netapp.com>
Diffstat (limited to 'net')
-rw-r--r-- | net/sunrpc/xprt.c | 11 | ||||
-rw-r--r-- | net/sunrpc/xprtsock.c | 1 |
2 files changed, 9 insertions, 3 deletions
diff --git a/net/sunrpc/xprt.c b/net/sunrpc/xprt.c index 8f0ad4f268da..13fbb4849188 100644 --- a/net/sunrpc/xprt.c +++ b/net/sunrpc/xprt.c | |||
@@ -889,7 +889,13 @@ __must_hold(&req->rq_xprt->recv_lock) | |||
889 | } | 889 | } |
890 | } | 890 | } |
891 | 891 | ||
892 | static void xprt_update_rtt(struct rpc_task *task) | 892 | /** |
893 | * xprt_update_rtt - Update RPC RTT statistics | ||
894 | * @task: RPC request that recently completed | ||
895 | * | ||
896 | * Caller holds xprt->recv_lock. | ||
897 | */ | ||
898 | void xprt_update_rtt(struct rpc_task *task) | ||
893 | { | 899 | { |
894 | struct rpc_rqst *req = task->tk_rqstp; | 900 | struct rpc_rqst *req = task->tk_rqstp; |
895 | struct rpc_rtt *rtt = task->tk_client->cl_rtt; | 901 | struct rpc_rtt *rtt = task->tk_client->cl_rtt; |
@@ -902,6 +908,7 @@ static void xprt_update_rtt(struct rpc_task *task) | |||
902 | rpc_set_timeo(rtt, timer, req->rq_ntrans - 1); | 908 | rpc_set_timeo(rtt, timer, req->rq_ntrans - 1); |
903 | } | 909 | } |
904 | } | 910 | } |
911 | EXPORT_SYMBOL_GPL(xprt_update_rtt); | ||
905 | 912 | ||
906 | /** | 913 | /** |
907 | * xprt_complete_rqst - called when reply processing is complete | 914 | * xprt_complete_rqst - called when reply processing is complete |
@@ -921,8 +928,6 @@ void xprt_complete_rqst(struct rpc_task *task, int copied) | |||
921 | 928 | ||
922 | xprt->stat.recvs++; | 929 | xprt->stat.recvs++; |
923 | req->rq_rtt = ktime_sub(ktime_get(), req->rq_xtime); | 930 | req->rq_rtt = ktime_sub(ktime_get(), req->rq_xtime); |
924 | if (xprt->ops->timer != NULL) | ||
925 | xprt_update_rtt(task); | ||
926 | 931 | ||
927 | list_del_init(&req->rq_list); | 932 | list_del_init(&req->rq_list); |
928 | req->rq_private_buf.len = copied; | 933 | req->rq_private_buf.len = copied; |
diff --git a/net/sunrpc/xprtsock.c b/net/sunrpc/xprtsock.c index a6b8c1f8f92a..61df77f41304 100644 --- a/net/sunrpc/xprtsock.c +++ b/net/sunrpc/xprtsock.c | |||
@@ -1060,6 +1060,7 @@ static void xs_udp_data_read_skb(struct rpc_xprt *xprt, | |||
1060 | if (!rovr) | 1060 | if (!rovr) |
1061 | goto out_unlock; | 1061 | goto out_unlock; |
1062 | xprt_pin_rqst(rovr); | 1062 | xprt_pin_rqst(rovr); |
1063 | xprt_update_rtt(rovr->rq_task); | ||
1063 | spin_unlock(&xprt->recv_lock); | 1064 | spin_unlock(&xprt->recv_lock); |
1064 | task = rovr->rq_task; | 1065 | task = rovr->rq_task; |
1065 | 1066 | ||