github-mirror/linux
1
0
Fork 0
mirror of https://github.com/torvalds/linux.git synced 2026-06-02 19:43:40 +02:00
Code Issues Actions Packages Projects Releases Wiki Activity Graph

svcrdma: Move svc_rdma_read_info::ri_pageno to struct svc_rdma_recv_ctxt

Browse Source 
Further clean up: move the page index field into svc_rdma_recv_ctxt.

Signed-off-by: Chuck Lever <chuck.lever@oracle.com>
This commit is contained in:
Chuck Lever 2023-12-04 09:57:22 -05:00
parent b1818412d0
commit 8e12258268
2 changed files with 10 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
include/linux/sunrpc/svc_rdma.h
View File

@ -157,6 +157,7 @@ struct svc_rdma_recv_ctxt {
__be32 rc_msgtype; __be32 rc_msgtype;
/* State for pulling a Read chunk */ /* State for pulling a Read chunk */
unsigned int rc_curpage;
unsigned int rc_readbytes; unsigned int rc_readbytes;
struct svc_rdma_chunk_ctxt rc_cc; struct svc_rdma_chunk_ctxt rc_cc;

21
net/sunrpc/xprtrdma/svc_rdma_rw.c
View File

@ -292,7 +292,6 @@ static void svc_rdma_write_done(struct ib_cq *cq, struct ib_wc *wc)
struct svc_rdma_read_info { struct svc_rdma_read_info {
struct svc_rqst *ri_rqst; struct svc_rqst *ri_rqst;
struct svc_rdma_recv_ctxt *ri_readctxt; struct svc_rdma_recv_ctxt *ri_readctxt;
unsigned int ri_pageno;
unsigned int ri_pageoff; unsigned int ri_pageoff;
}; };
@ -720,20 +719,18 @@ static int svc_rdma_build_read_segment(struct svcxprt_rdma *rdma,
if (!info->ri_pageoff) if (!info->ri_pageoff)
head->rc_page_count++; head->rc_page_count++;
sg_set_page(sg, rqstp->rq_pages[info->ri_pageno], sg_set_page(sg, rqstp->rq_pages[head->rc_curpage],
seg_len, info->ri_pageoff); seg_len, info->ri_pageoff);
sg = sg_next(sg); sg = sg_next(sg);
info->ri_pageoff += seg_len; info->ri_pageoff += seg_len;
if (info->ri_pageoff == PAGE_SIZE) { if (info->ri_pageoff == PAGE_SIZE) {
info->ri_pageno++; head->rc_curpage++;
info->ri_pageoff = 0; info->ri_pageoff = 0;
} }
len -= seg_len; len -= seg_len;
/* Safety check */ if (len && ((head->rc_curpage + 1) > ARRAY_SIZE(rqstp->rq_pages)))
if (len &&
&rqstp->rq_pages[info->ri_pageno + 1] > rqstp->rq_page_end)
goto out_overrun; goto out_overrun;
} }
@ -748,7 +745,7 @@ static int svc_rdma_build_read_segment(struct svcxprt_rdma *rdma,
return 0; return 0;
out_overrun: out_overrun:
trace_svcrdma_page_overrun_err(&cc->cc_cid, info->ri_pageno); trace_svcrdma_page_overrun_err(&cc->cc_cid, head->rc_curpage);
return -EINVAL; return -EINVAL;
} }
@ -790,7 +787,7 @@ static int svc_rdma_build_read_chunk(struct svcxprt_rdma *rdma,
* *
* Take a page at a time from rqstp->rq_pages and copy the inline * Take a page at a time from rqstp->rq_pages and copy the inline
* content from the Receive buffer into that page. Update * content from the Receive buffer into that page. Update
* info->ri_pageno and info->ri_pageoff so that the next RDMA Read * head->rc_curpage and info->ri_pageoff so that the next RDMA Read
* result will land contiguously with the copied content. * result will land contiguously with the copied content.
* *
* Return values: * Return values:
@ -816,13 +813,13 @@ static int svc_rdma_copy_inline_range(struct svc_rdma_read_info *info,
if (!info->ri_pageoff) if (!info->ri_pageoff)
head->rc_page_count++; head->rc_page_count++;
dst = page_address(rqstp->rq_pages[info->ri_pageno]); dst = page_address(rqstp->rq_pages[head->rc_curpage]);
memcpy(dst + info->ri_pageno, src + offset, page_len); memcpy(dst + head->rc_curpage, src + offset, page_len);
head->rc_readbytes += page_len; head->rc_readbytes += page_len;
info->ri_pageoff += page_len; info->ri_pageoff += page_len;
if (info->ri_pageoff == PAGE_SIZE) { if (info->ri_pageoff == PAGE_SIZE) {
info->ri_pageno++; head->rc_curpage++;
info->ri_pageoff = 0; info->ri_pageoff = 0;
} }
remaining -= page_len; remaining -= page_len;
@ -1137,10 +1134,10 @@ int svc_rdma_process_read_list(struct svcxprt_rdma *rdma,
return -ENOMEM; return -ENOMEM;
info->ri_rqst = rqstp; info->ri_rqst = rqstp;
info->ri_readctxt = head; info->ri_readctxt = head;
info->ri_pageno = 0;
info->ri_pageoff = 0; info->ri_pageoff = 0;
svc_rdma_cc_init(rdma, cc); svc_rdma_cc_init(rdma, cc);
cc->cc_cqe.done = svc_rdma_wc_read_done; cc->cc_cqe.done = svc_rdma_wc_read_done;
head->rc_curpage = 0;
head->rc_readbytes = 0; head->rc_readbytes = 0;
if (pcl_is_empty(&head->rc_call_pcl)) { if (pcl_is_empty(&head->rc_call_pcl)) {