Commit 0f9c429e authored by Weston Andros Adamson's avatar Weston Andros Adamson Committed by Trond Myklebust

nfs: chain calls to pg_test

Now that pg_test can change the size of the request (by returning a non-zero
size smaller than the request), pg_test functions that call other
pg_test functions must return the minimum of the result - or 0 if any fail.

Also clean up the logic of some pg_test functions so that all checks are
for contitions where coalescing is not possible.
Signed-off-by: default avatarWeston Andros Adamson <dros@primarydata.com>
Signed-off-by: default avatarTrond Myklebust <trond.myklebust@primarydata.com>
parent 6094f838
...@@ -928,16 +928,16 @@ static size_t ...@@ -928,16 +928,16 @@ static size_t
filelayout_pg_test(struct nfs_pageio_descriptor *pgio, struct nfs_page *prev, filelayout_pg_test(struct nfs_pageio_descriptor *pgio, struct nfs_page *prev,
struct nfs_page *req) struct nfs_page *req)
{ {
unsigned int size;
u64 p_stripe, r_stripe; u64 p_stripe, r_stripe;
u32 stripe_unit; u32 stripe_unit;
if (!pnfs_generic_pg_test(pgio, prev, req) || /* calls nfs_generic_pg_test */
!nfs_generic_pg_test(pgio, prev, req)) size = pnfs_generic_pg_test(pgio, prev, req);
if (!size)
return 0; return 0;
if (!prev) if (prev) {
return req->wb_bytes;
p_stripe = (u64)req_offset(prev); p_stripe = (u64)req_offset(prev);
r_stripe = (u64)req_offset(req); r_stripe = (u64)req_offset(req);
stripe_unit = FILELAYOUT_LSEG(pgio->pg_lseg)->stripe_unit; stripe_unit = FILELAYOUT_LSEG(pgio->pg_lseg)->stripe_unit;
...@@ -945,9 +945,10 @@ filelayout_pg_test(struct nfs_pageio_descriptor *pgio, struct nfs_page *prev, ...@@ -945,9 +945,10 @@ filelayout_pg_test(struct nfs_pageio_descriptor *pgio, struct nfs_page *prev,
do_div(p_stripe, stripe_unit); do_div(p_stripe, stripe_unit);
do_div(r_stripe, stripe_unit); do_div(r_stripe, stripe_unit);
if (p_stripe == r_stripe) if (p_stripe != r_stripe)
return req->wb_bytes;
return 0; return 0;
}
return min(size, req->wb_bytes);
} }
static void static void
......
...@@ -571,12 +571,15 @@ int objio_write_pagelist(struct nfs_pgio_data *wdata, int how) ...@@ -571,12 +571,15 @@ int objio_write_pagelist(struct nfs_pgio_data *wdata, int how)
static size_t objio_pg_test(struct nfs_pageio_descriptor *pgio, static size_t objio_pg_test(struct nfs_pageio_descriptor *pgio,
struct nfs_page *prev, struct nfs_page *req) struct nfs_page *prev, struct nfs_page *req)
{ {
if (!pnfs_generic_pg_test(pgio, prev, req) || unsigned int size;
pgio->pg_count + req->wb_bytes >
size = pnfs_generic_pg_test(pgio, prev, req);
if (!size || pgio->pg_count + req->wb_bytes >
(unsigned long)pgio->pg_layout_private) (unsigned long)pgio->pg_layout_private)
return 0; return 0;
return req->wb_bytes; return min(size, req->wb_bytes);
} }
static void objio_init_read(struct nfs_pageio_descriptor *pgio, struct nfs_page *req) static void objio_init_read(struct nfs_pageio_descriptor *pgio, struct nfs_page *req)
......
...@@ -1442,8 +1442,12 @@ size_t ...@@ -1442,8 +1442,12 @@ size_t
pnfs_generic_pg_test(struct nfs_pageio_descriptor *pgio, struct nfs_page *prev, pnfs_generic_pg_test(struct nfs_pageio_descriptor *pgio, struct nfs_page *prev,
struct nfs_page *req) struct nfs_page *req)
{ {
if (pgio->pg_lseg == NULL) unsigned int size;
return nfs_generic_pg_test(pgio, prev, req);
size = nfs_generic_pg_test(pgio, prev, req);
if (!size)
return 0;
/* /*
* Test if a nfs_page is fully contained in the pnfs_layout_range. * Test if a nfs_page is fully contained in the pnfs_layout_range.
...@@ -1459,10 +1463,11 @@ pnfs_generic_pg_test(struct nfs_pageio_descriptor *pgio, struct nfs_page *prev, ...@@ -1459,10 +1463,11 @@ pnfs_generic_pg_test(struct nfs_pageio_descriptor *pgio, struct nfs_page *prev,
* first byte that lies outside the pnfs_layout_range. FIXME? * first byte that lies outside the pnfs_layout_range. FIXME?
* *
*/ */
if (req_offset(req) < end_offset(pgio->pg_lseg->pls_range.offset, if (req_offset(req) >= end_offset(pgio->pg_lseg->pls_range.offset,
pgio->pg_lseg->pls_range.length)) pgio->pg_lseg->pls_range.length))
return req->wb_bytes;
return 0; return 0;
return min(size, req->wb_bytes);
} }
EXPORT_SYMBOL_GPL(pnfs_generic_pg_test); EXPORT_SYMBOL_GPL(pnfs_generic_pg_test);
......
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