Commit 4f200bd8 authored by Chuck Lever's avatar Chuck Lever

svcrdma: Add a @status parameter to svc_rdma_send_error_msg()

The common "send RDMA_ERR" function should be in svc_rdma_sendto.c,
since that is where the other Send-related functions are located.
So from here, I will beef up svc_rdma_send_error_msg() and deprecate
svc_rdma_send_error().

A generic svc_rdma_send_error_msg() will need to handle both
ERR_CHUNK and ERR_VERS. Copy that logic from svc_rdma_send_error()
to svc_rdma_send_error_msg().
Signed-off-by: default avatarChuck Lever <chuck.lever@oracle.com>
parent d1f6e236
...@@ -812,7 +812,8 @@ static int svc_rdma_send_reply_msg(struct svcxprt_rdma *rdma, ...@@ -812,7 +812,8 @@ static int svc_rdma_send_reply_msg(struct svcxprt_rdma *rdma,
*/ */
static int svc_rdma_send_error_msg(struct svcxprt_rdma *rdma, static int svc_rdma_send_error_msg(struct svcxprt_rdma *rdma,
struct svc_rdma_send_ctxt *sctxt, struct svc_rdma_send_ctxt *sctxt,
struct svc_rdma_recv_ctxt *rctxt) struct svc_rdma_recv_ctxt *rctxt,
int status)
{ {
__be32 *rdma_argp = rctxt->rc_recv_buf; __be32 *rdma_argp = rctxt->rc_recv_buf;
__be32 *p; __be32 *p;
...@@ -821,16 +822,35 @@ static int svc_rdma_send_error_msg(struct svcxprt_rdma *rdma, ...@@ -821,16 +822,35 @@ static int svc_rdma_send_error_msg(struct svcxprt_rdma *rdma,
xdr_init_encode(&sctxt->sc_stream, &sctxt->sc_hdrbuf, xdr_init_encode(&sctxt->sc_stream, &sctxt->sc_hdrbuf,
sctxt->sc_xprt_buf, NULL); sctxt->sc_xprt_buf, NULL);
p = xdr_reserve_space(&sctxt->sc_stream, RPCRDMA_HDRLEN_ERR); p = xdr_reserve_space(&sctxt->sc_stream,
rpcrdma_fixed_maxsz * sizeof(*p));
if (!p) if (!p)
return -ENOMSG; return -ENOMSG;
*p++ = *rdma_argp; *p++ = *rdma_argp;
*p++ = *(rdma_argp + 1); *p++ = *(rdma_argp + 1);
*p++ = rdma->sc_fc_credits; *p++ = rdma->sc_fc_credits;
*p++ = rdma_error; *p = rdma_error;
*p = err_chunk;
trace_svcrdma_err_chunk(*rdma_argp); switch (status) {
case -EPROTONOSUPPORT:
p = xdr_reserve_space(&sctxt->sc_stream, 3 * sizeof(*p));
if (!p)
return -ENOMSG;
*p++ = err_vers;
*p++ = rpcrdma_version;
*p = rpcrdma_version;
trace_svcrdma_err_vers(*rdma_argp);
break;
default:
p = xdr_reserve_space(&sctxt->sc_stream, sizeof(*p));
if (!p)
return -ENOMSG;
*p = err_chunk;
trace_svcrdma_err_chunk(*rdma_argp);
}
sctxt->sc_send_wr.num_sge = 1; sctxt->sc_send_wr.num_sge = 1;
sctxt->sc_send_wr.opcode = IB_WR_SEND; sctxt->sc_send_wr.opcode = IB_WR_SEND;
...@@ -930,7 +950,7 @@ int svc_rdma_sendto(struct svc_rqst *rqstp) ...@@ -930,7 +950,7 @@ int svc_rdma_sendto(struct svc_rqst *rqstp)
* of previously posted RDMA Writes. * of previously posted RDMA Writes.
*/ */
svc_rdma_save_io_pages(rqstp, sctxt); svc_rdma_save_io_pages(rqstp, sctxt);
ret = svc_rdma_send_error_msg(rdma, sctxt, rctxt); ret = svc_rdma_send_error_msg(rdma, sctxt, rctxt, ret);
if (ret < 0) if (ret < 0)
goto err1; goto err1;
return 0; return 0;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment