| From 59a065a4a04ea24393841d10f4885883c6b3bcd8 Mon Sep 17 00:00:00 2001 |
| From: Trond Myklebust <trondmy@gmail.com> |
| Date: Mon, 16 Sep 2019 09:12:19 -0400 |
| Subject: [PATCH] SUNRPC: Don't try to parse incomplete RPC messages |
| |
| commit 9ba828861c56a21d211d5d10f5643774b1ea330d upstream. |
| |
| If the copy of the RPC reply into our buffers did not complete, and |
| we could end up with a truncated message. In that case, just resend |
| the call. |
| |
| Fixes: a0584ee9aed80 ("SUNRPC: Use struct xdr_stream when decoding...") |
| Signed-off-by: Trond Myklebust <trond.myklebust@hammerspace.com> |
| Signed-off-by: Anna Schumaker <Anna.Schumaker@Netapp.com> |
| Signed-off-by: Paul Gortmaker <paul.gortmaker@windriver.com> |
| |
| diff --git a/net/sunrpc/clnt.c b/net/sunrpc/clnt.c |
| index c94d6f0881c3..d504d3a895d1 100644 |
| --- a/net/sunrpc/clnt.c |
| +++ b/net/sunrpc/clnt.c |
| @@ -2401,6 +2401,7 @@ call_decode(struct rpc_task *task) |
| struct rpc_clnt *clnt = task->tk_client; |
| struct rpc_rqst *req = task->tk_rqstp; |
| struct xdr_stream xdr; |
| + int err; |
| |
| dprint_status(task); |
| |
| @@ -2423,6 +2424,15 @@ call_decode(struct rpc_task *task) |
| * before it changed req->rq_reply_bytes_recvd. |
| */ |
| smp_rmb(); |
| + |
| + /* |
| + * Did we ever call xprt_complete_rqst()? If not, we should assume |
| + * the message is incomplete. |
| + */ |
| + err = -EAGAIN; |
| + if (!req->rq_reply_bytes_recvd) |
| + goto out; |
| + |
| req->rq_rcv_buf.len = req->rq_private_buf.len; |
| |
| /* Check that the softirq receive buffer is valid */ |
| @@ -2431,7 +2441,9 @@ call_decode(struct rpc_task *task) |
| |
| xdr_init_decode(&xdr, &req->rq_rcv_buf, |
| req->rq_rcv_buf.head[0].iov_base, req); |
| - switch (rpc_decode_header(task, &xdr)) { |
| + err = rpc_decode_header(task, &xdr); |
| +out: |
| + switch (err) { |
| case 0: |
| task->tk_action = rpc_exit_task; |
| task->tk_status = rpcauth_unwrap_resp(task, &xdr); |
| -- |
| 2.7.4 |
| |