svcrdma: Add @rctxt parameter to svc_rdma_send_error() functions

Another step towards making svc_rdma_send_error_msg() and
svc_rdma_send_error() similar enough to eliminate one of them.

Signed-off-by: Chuck Lever <chuck.lever@oracle.com>

diff --git a/net/sunrpc/xprtrdma/svc_rdma_recvfrom.c b/net/sunrpc/xprtrdma/svc_rdma_recvfrom.c
index e426fedb9524f9490a46b2fcb612b28b7ea299d1..60d855116ae7c3aaf900ba06251e6e5574998ae7 100644 (file)
--- a/net/sunrpc/xprtrdma/svc_rdma_recvfrom.c
+++ b/net/sunrpc/xprtrdma/svc_rdma_recvfrom.c
@@ -715,10 +715,11 @@ static void rdma_read_complete(struct svc_rqst *rqstp,
 }
 
 static void svc_rdma_send_error(struct svcxprt_rdma *xprt,
-                               __be32 *rdma_argp, int status)
+                               struct svc_rdma_recv_ctxt *rctxt,
+                               int status)
 {
+       __be32 *p, *rdma_argp = rctxt->rc_recv_buf;
        struct svc_rdma_send_ctxt *ctxt;
-       __be32 *p;
        int ret;
 
        ctxt = svc_rdma_send_ctxt_get(xprt);
@@ -900,13 +901,13 @@ out_readchunk:
        return 0;
 
 out_err:
-       svc_rdma_send_error(rdma_xprt, p, ret);
+       svc_rdma_send_error(rdma_xprt, ctxt, ret);
        svc_rdma_recv_ctxt_put(rdma_xprt, ctxt);
        return 0;
 
 out_postfail:
        if (ret == -EINVAL)
-               svc_rdma_send_error(rdma_xprt, p, ret);
+               svc_rdma_send_error(rdma_xprt, ctxt, ret);
        svc_rdma_recv_ctxt_put(rdma_xprt, ctxt);
        return ret;
 

diff --git a/net/sunrpc/xprtrdma/svc_rdma_sendto.c b/net/sunrpc/xprtrdma/svc_rdma_sendto.c
index 2f88d01e8d270092748c1702af79343e1d71debc..47ada61411c3f4ad930002a58d5316a79293f42e 100644 (file)
--- a/net/sunrpc/xprtrdma/svc_rdma_sendto.c
+++ b/net/sunrpc/xprtrdma/svc_rdma_sendto.c
@@ -811,18 +811,17 @@ static int svc_rdma_send_reply_msg(struct svcxprt_rdma *rdma,
  * Remote Invalidation is skipped for simplicity.
  */
 static int svc_rdma_send_error_msg(struct svcxprt_rdma *rdma,
-                                  struct svc_rdma_send_ctxt *ctxt,
-                                  struct svc_rqst *rqstp)
+                                  struct svc_rdma_send_ctxt *sctxt,
+                                  struct svc_rdma_recv_ctxt *rctxt)
 {
-       struct svc_rdma_recv_ctxt *rctxt = rqstp->rq_xprt_ctxt;
        __be32 *rdma_argp = rctxt->rc_recv_buf;
        __be32 *p;
 
-       rpcrdma_set_xdrlen(&ctxt->sc_hdrbuf, 0);
-       xdr_init_encode(&ctxt->sc_stream, &ctxt->sc_hdrbuf, ctxt->sc_xprt_buf,
-                       NULL);
+       rpcrdma_set_xdrlen(&sctxt->sc_hdrbuf, 0);
+       xdr_init_encode(&sctxt->sc_stream, &sctxt->sc_hdrbuf,
+                       sctxt->sc_xprt_buf, NULL);
 
-       p = xdr_reserve_space(&ctxt->sc_stream, RPCRDMA_HDRLEN_ERR);
+       p = xdr_reserve_space(&sctxt->sc_stream, RPCRDMA_HDRLEN_ERR);
        if (!p)
                return -ENOMSG;
 
@@ -833,10 +832,10 @@ static int svc_rdma_send_error_msg(struct svcxprt_rdma *rdma,
        *p   = err_chunk;
        trace_svcrdma_err_chunk(*rdma_argp);
 
-       ctxt->sc_send_wr.num_sge = 1;
-       ctxt->sc_send_wr.opcode = IB_WR_SEND;
-       ctxt->sc_sges[0].length = ctxt->sc_hdrbuf.len;
-       return svc_rdma_send(rdma, &ctxt->sc_send_wr);
+       sctxt->sc_send_wr.num_sge = 1;
+       sctxt->sc_send_wr.opcode = IB_WR_SEND;
+       sctxt->sc_sges[0].length = sctxt->sc_hdrbuf.len;
+       return svc_rdma_send(rdma, &sctxt->sc_send_wr);
 }
 
 /**
@@ -931,7 +930,7 @@ int svc_rdma_sendto(struct svc_rqst *rqstp)
         * of previously posted RDMA Writes.
         */
        svc_rdma_save_io_pages(rqstp, sctxt);
-       ret = svc_rdma_send_error_msg(rdma, sctxt, rqstp);
+       ret = svc_rdma_send_error_msg(rdma, sctxt, rctxt);
        if (ret < 0)
                goto err1;
        return 0;