diff options
Diffstat (limited to 'net/sunrpc/xprtrdma/svc_rdma_recvfrom.c')
-rw-r--r-- | net/sunrpc/xprtrdma/svc_rdma_recvfrom.c | 23 |
1 files changed, 16 insertions, 7 deletions
diff --git a/net/sunrpc/xprtrdma/svc_rdma_recvfrom.c b/net/sunrpc/xprtrdma/svc_rdma_recvfrom.c index f3a108a864ad..5e03d95b25e2 100644 --- a/net/sunrpc/xprtrdma/svc_rdma_recvfrom.c +++ b/net/sunrpc/xprtrdma/svc_rdma_recvfrom.c | |||
@@ -260,11 +260,16 @@ static int rdma_read_max_sge(struct svcxprt_rdma *xprt, int sge_count) | |||
260 | * On our side, we need to read into a pagelist. The first page immediately | 260 | * On our side, we need to read into a pagelist. The first page immediately |
261 | * follows the RPC header. | 261 | * follows the RPC header. |
262 | * | 262 | * |
263 | * This function returns 1 to indicate success. The data is not yet in | 263 | * This function returns: |
264 | * 0 - No error and no read-list found. | ||
265 | * | ||
266 | * 1 - Successful read-list processing. The data is not yet in | ||
264 | * the pagelist and therefore the RPC request must be deferred. The | 267 | * the pagelist and therefore the RPC request must be deferred. The |
265 | * I/O completion will enqueue the transport again and | 268 | * I/O completion will enqueue the transport again and |
266 | * svc_rdma_recvfrom will complete the request. | 269 | * svc_rdma_recvfrom will complete the request. |
267 | * | 270 | * |
271 | * <0 - Error processing/posting read-list. | ||
272 | * | ||
268 | * NOTE: The ctxt must not be touched after the last WR has been posted | 273 | * NOTE: The ctxt must not be touched after the last WR has been posted |
269 | * because the I/O completion processing may occur on another | 274 | * because the I/O completion processing may occur on another |
270 | * processor and free / modify the context. Ne touche pas! | 275 | * processor and free / modify the context. Ne touche pas! |
@@ -398,7 +403,7 @@ next_sge: | |||
398 | svc_rdma_put_context(head, 1); | 403 | svc_rdma_put_context(head, 1); |
399 | head = ctxt; | 404 | head = ctxt; |
400 | } | 405 | } |
401 | return 0; | 406 | return err; |
402 | } | 407 | } |
403 | 408 | ||
404 | return 1; | 409 | return 1; |
@@ -532,14 +537,18 @@ int svc_rdma_recvfrom(struct svc_rqst *rqstp) | |||
532 | goto close_out; | 537 | goto close_out; |
533 | } | 538 | } |
534 | 539 | ||
535 | /* Read read-list data. If we would need to wait, defer | 540 | /* Read read-list data. */ |
536 | * it. Not that in this case, we don't return the RQ credit | 541 | ret = rdma_read_xdr(rdma_xprt, rmsgp, rqstp, ctxt); |
537 | * until after the read completes. | 542 | if (ret > 0) { |
538 | */ | 543 | /* read-list posted, defer until data received from client. */ |
539 | if (rdma_read_xdr(rdma_xprt, rmsgp, rqstp, ctxt)) { | ||
540 | svc_xprt_received(xprt); | 544 | svc_xprt_received(xprt); |
541 | return 0; | 545 | return 0; |
542 | } | 546 | } |
547 | if (ret < 0) { | ||
548 | /* Post of read-list failed, free context. */ | ||
549 | svc_rdma_put_context(ctxt, 1); | ||
550 | return 0; | ||
551 | } | ||
543 | 552 | ||
544 | ret = rqstp->rq_arg.head[0].iov_len | 553 | ret = rqstp->rq_arg.head[0].iov_len |
545 | + rqstp->rq_arg.page_len | 554 | + rqstp->rq_arg.page_len |