summaryrefslogtreecommitdiffstats
path: root/net
diff options
context:
space:
mode:
authorChuck Lever <chuck.lever@oracle.com>2018-03-05 15:12:57 -0500
committerAnna Schumaker <Anna.Schumaker@Netapp.com>2018-04-10 16:06:22 -0400
commitecd465ee88bb6648c06c82b1abae6ec28cf5fccb (patch)
tree11fb1c45bb22edd5b772f804d4a3d940da3659bc /net
parent2dd4a012d9e73c423a8c48d7e0f2e427caecce3d (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.c11
-rw-r--r--net/sunrpc/xprtsock.c1
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
892static 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 */
898void 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}
911EXPORT_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