Skip to content

Commit 89d2d9f

Browse files
committed
SUNRPC: Revert e0a912e
Flamegraph analysis showed that the cork/uncork calls consume nearly a third of the CPU time spent in svc_tcp_sendto(). The other two consumers are mutex lock/unlock and svc_tcp_sendmsg(). Now that svc_tcp_sendto() coalesces RPC messages properly, there is no need to introduce artificial delays to prevent sending partial messages. After applying this change, I measured a 1.2K read IOPS increase for 8KB random I/O (several percent) on 56Gb IP over IB. Reviewed-by: David Howells <[email protected]> Signed-off-by: Chuck Lever <[email protected]>
1 parent baabf59 commit 89d2d9f

File tree

2 files changed

+0
-8
lines changed

2 files changed

+0
-8
lines changed

include/linux/sunrpc/svcsock.h

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,8 +35,6 @@ struct svc_sock {
3535
/* Total length of the data (not including fragment headers)
3636
* received so far in the fragments making up this rpc: */
3737
u32 sk_datalen;
38-
/* Number of queued send requests */
39-
atomic_t sk_sendqlen;
4038

4139
struct page_frag_cache sk_frag_cache;
4240

net/sunrpc/svcsock.c

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1268,22 +1268,17 @@ static int svc_tcp_sendto(struct svc_rqst *rqstp)
12681268
svc_tcp_release_ctxt(xprt, rqstp->rq_xprt_ctxt);
12691269
rqstp->rq_xprt_ctxt = NULL;
12701270

1271-
atomic_inc(&svsk->sk_sendqlen);
12721271
mutex_lock(&xprt->xpt_mutex);
12731272
if (svc_xprt_is_dead(xprt))
12741273
goto out_notconn;
1275-
tcp_sock_set_cork(svsk->sk_sk, true);
12761274
err = svc_tcp_sendmsg(svsk, rqstp, marker, &sent);
12771275
trace_svcsock_tcp_send(xprt, err < 0 ? (long)err : sent);
12781276
if (err < 0 || sent != (xdr->len + sizeof(marker)))
12791277
goto out_close;
1280-
if (atomic_dec_and_test(&svsk->sk_sendqlen))
1281-
tcp_sock_set_cork(svsk->sk_sk, false);
12821278
mutex_unlock(&xprt->xpt_mutex);
12831279
return sent;
12841280

12851281
out_notconn:
1286-
atomic_dec(&svsk->sk_sendqlen);
12871282
mutex_unlock(&xprt->xpt_mutex);
12881283
return -ENOTCONN;
12891284
out_close:
@@ -1292,7 +1287,6 @@ static int svc_tcp_sendto(struct svc_rqst *rqstp)
12921287
(err < 0) ? "got error" : "sent",
12931288
(err < 0) ? err : sent, xdr->len);
12941289
svc_xprt_deferred_close(xprt);
1295-
atomic_dec(&svsk->sk_sendqlen);
12961290
mutex_unlock(&xprt->xpt_mutex);
12971291
return -EAGAIN;
12981292
}

0 commit comments

Comments
 (0)