From: Benjamin Coddington <bcodding@redhat.com>
To: Trond Myklebust <trond.myklebust@primarydata.com>
Cc: linux-nfs@vger.kernel.org
Subject: Re: [PATCH 13/14] pNFS: Add flag to track if we've called nfs4_ff_layout_stat_io_start_read/write
Date: Mon, 4 Jan 2016 15:12:31 -0500 (EST) [thread overview]
Message-ID: <alpine.OSX.2.19.9992.1601041453590.87866@planck.local> (raw)
In-Reply-To: <1451172060-28238-13-git-send-email-trond.myklebust@primarydata.com>
Hi Trond, this won't build for me..
On Sat, 26 Dec 2015, Trond Myklebust wrote:
> Signed-off-by: Trond Myklebust <trond.myklebust@primarydata.com>
> ---
> fs/nfs/flexfilelayout/flexfilelayout.c | 95 +++++++++++++++++++++++++---------
> include/linux/nfs_xdr.h | 1 +
> 2 files changed, 71 insertions(+), 25 deletions(-)
>
> diff --git a/fs/nfs/flexfilelayout/flexfilelayout.c b/fs/nfs/flexfilelayout/flexfilelayout.c
> index 14109a82ce84..9257679a15ba 100644
> --- a/fs/nfs/flexfilelayout/flexfilelayout.c
> +++ b/fs/nfs/flexfilelayout/flexfilelayout.c
> @@ -1279,14 +1279,31 @@ ff_layout_reset_to_mds(struct pnfs_layout_segment *lseg, int idx)
> return ff_layout_test_devid_unavailable(node);
> }
>
> -static int ff_layout_read_prepare_common(struct rpc_task *task,
> - struct nfs_pgio_header *hdr)
> +static void ff_layout_read_record_layoutstats_start(struct rpc_task *task,
> + struct nfs_pgio_header *hdr)
> {
> + if (test_and_set_bit(NFS_IOHDR_STAT, &hdr->flags))
> + return;
> nfs4_ff_layout_stat_io_start_read(hdr->inode,
> FF_LAYOUT_COMP(hdr->lseg, hdr->pgio_mirror_idx),
> hdr->args.count,
> task->tk_start);
> +}
> +
> +static void ff_layout_read_record_layoutstats_done(struct rpc_task *task,
> + struct nfs_pgio_header *hdr)
> +{
> + if (!test_and_clear_bit(NFS_IOHDR_STAT, &hdr->flags))
> + return;
> + nfs4_ff_layout_stat_io_end_read(task,
> + FF_LAYOUT_COMP(hdr->lseg, hdr->pgio_mirror_idx),
> + hdr->args.count,
> + hdr->res.count);
> +}
>
> +static int ff_layout_read_prepare_common(struct rpc_task *task,
> + struct nfs_pgio_header *hdr)
> +{
> if (unlikely(test_bit(NFS_CONTEXT_BAD, &hdr->args.context->flags))) {
> rpc_exit(task, -EIO);
> return -EIO;
> @@ -1302,6 +1319,7 @@ static int ff_layout_read_prepare_common(struct rpc_task *task,
> }
> hdr->pgio_done_cb = ff_layout_read_done_cb;
>
> + ff_layout_read_record_layoutstats_start(task, hdr);
> return 0;
> }
>
> @@ -1360,10 +1378,6 @@ static void ff_layout_read_call_done(struct rpc_task *task, void *data)
>
> dprintk("--> %s task->tk_status %d\n", __func__, task->tk_status);
>
> - nfs4_ff_layout_stat_io_end_read(task,
> - FF_LAYOUT_COMP(hdr->lseg, hdr->pgio_mirror_idx),
> - hdr->args.count, hdr->res.count);
> -
> if (test_bit(NFS_IOHDR_REDO, &hdr->flags) &&
> task->tk_status == 0) {
> nfs4_sequence_done(task, &hdr->res.seq_res);
> @@ -1378,6 +1392,7 @@ static void ff_layout_read_count_stats(struct rpc_task *task, void *data)
> {
> struct nfs_pgio_header *hdr = data;
>
> + ff_layout_read_record_layoutstats_done(task, hdr);
> rpc_count_iostats_metrics(task,
> &NFS_CLIENT(hdr->inode)->cl_metrics[NFSPROC4_CLNT_READ]);
> }
> @@ -1453,14 +1468,31 @@ static int ff_layout_commit_done_cb(struct rpc_task *task,
> return 0;
> }
>
> -static int ff_layout_write_prepare_common(struct rpc_task *task,
> - struct nfs_pgio_header *hdr)
> +static void ff_layout_write_record_layoutstats_start(struct rpc_task *task,
> + struct nfs_pgio_header *hdr)
> {
> + if (test_and_set_bit(NFS_IOHDR_STAT, &hdr->flags))
> + return;
> nfs4_ff_layout_stat_io_start_write(hdr->inode,
> FF_LAYOUT_COMP(hdr->lseg, hdr->pgio_mirror_idx),
> hdr->args.count,
> task->tk_start);
> +}
> +
> +static void ff_layout_write_record_layoutstats_done(struct rpc_task *task,
> + struct nfs_pgio_header *hdr)
> +{
> + if (!test_and_clear_bit(NFS_IOHDR_STAT, &hdr->flags))
> + return;
> + nfs4_ff_layout_stat_io_end_write(task,
> + FF_LAYOUT_COMP(hdr->lseg, hdr->pgio_mirror_idx),
> + hdr->args.count, hdr->res.count,
> + hdr->res.verf->committed);
> +}
>
> +static int ff_layout_write_prepare_common(struct rpc_task *task,
> + struct nfs_pgio_header *hdr)
> +{
> if (unlikely(test_bit(NFS_CONTEXT_BAD, &hdr->args.context->flags))) {
> rpc_exit(task, -EIO);
> return -EIO;
> @@ -1477,6 +1509,7 @@ static int ff_layout_write_prepare_common(struct rpc_task *task,
> return -EAGAIN;
> }
>
> + ff_layout_write_record_layoutstats_start(task, hdr);
> return 0;
> }
>
> @@ -1526,23 +1559,45 @@ static void ff_layout_write_count_stats(struct rpc_task *task, void *data)
> {
> struct nfs_pgio_header *hdr = data;
>
> - nfs4_ff_layout_stat_io_end_write(task,
> - FF_LAYOUT_COMP(hdr->lseg, hdr->pgio_mirror_idx),
> - hdr->args.count, hdr->res.count,
> - hdr->res.verf->committed);
> -
> + ff_layout_write_record_layoutstats_done(task, hdr);
> rpc_count_iostats_metrics(task,
> &NFS_CLIENT(hdr->inode)->cl_metrics[NFSPROC4_CLNT_WRITE]);
> }
>
> -static void ff_layout_commit_prepare_common(struct rpc_task *task,
> +static void ff_layout_commit_record_layoutstats_start(struct rpc_task *task,
> struct nfs_commit_data *cdata)
> {
> + if (test_and_set_bit(NFS_IOHDR_STAT, &cdata->flags))
> + return;
..since nfs_commit_data is missing "flags"..
> nfs4_ff_layout_stat_io_start_write(cdata->inode,
> FF_LAYOUT_COMP(cdata->lseg, cdata->ds_commit_index),
> 0, task->tk_start);
> }
>
> +static void ff_layout_commit_record_layoutstats_done(struct rpc_task *task,
> + struct nfs_commit_data *cdata)
> +{
> + struct nfs_page *req;
> + __u64 count = 0;
> +
> + if (!test_and_clear_bit(NFS_IOHDR_STAT, &cdata->flags))
> + return;
.. same here.
Ben
> +
> + if (task->tk_status == 0) {
> + list_for_each_entry(req, &cdata->pages, wb_list)
> + count += req->wb_bytes;
> + }
> + nfs4_ff_layout_stat_io_end_write(task,
> + FF_LAYOUT_COMP(cdata->lseg, cdata->ds_commit_index),
> + count, count, NFS_FILE_SYNC);
> +}
> +
> +static void ff_layout_commit_prepare_common(struct rpc_task *task,
> + struct nfs_commit_data *cdata)
> +{
> + ff_layout_commit_record_layoutstats_start(task, cdata);
> +}
> +
> static void ff_layout_commit_prepare_v3(struct rpc_task *task, void *data)
> {
> ff_layout_commit_prepare_common(task, data);
> @@ -1569,18 +1624,8 @@ static void ff_layout_commit_done(struct rpc_task *task, void *data)
> static void ff_layout_commit_count_stats(struct rpc_task *task, void *data)
> {
> struct nfs_commit_data *cdata = data;
> - struct nfs_page *req;
> - __u64 count = 0;
> -
> - if (task->tk_status == 0) {
> - list_for_each_entry(req, &cdata->pages, wb_list)
> - count += req->wb_bytes;
> - }
> -
> - nfs4_ff_layout_stat_io_end_write(task,
> - FF_LAYOUT_COMP(cdata->lseg, cdata->ds_commit_index),
> - count, count, NFS_FILE_SYNC);
>
> + ff_layout_commit_record_layoutstats_done(task, cdata);
> rpc_count_iostats_metrics(task,
> &NFS_CLIENT(cdata->inode)->cl_metrics[NFSPROC4_CLNT_COMMIT]);
> }
> diff --git a/include/linux/nfs_xdr.h b/include/linux/nfs_xdr.h
> index 29c949bd4462..77b5bc8b5b2b 100644
> --- a/include/linux/nfs_xdr.h
> +++ b/include/linux/nfs_xdr.h
> @@ -1375,6 +1375,7 @@ enum {
> NFS_IOHDR_ERROR = 0,
> NFS_IOHDR_EOF,
> NFS_IOHDR_REDO,
> + NFS_IOHDR_STAT,
> };
>
> struct nfs_pgio_header {
> --
> 2.5.0
>
> --
> To unsubscribe from this list: send the line "unsubscribe linux-nfs" in
> the body of a message to majordomo@vger.kernel.org
> More majordomo info at http://vger.kernel.org/majordomo-info.html
>
next prev parent reply other threads:[~2016-01-04 20:12 UTC|newest]
Thread overview: 17+ messages / expand[flat|nested] mbox.gz Atom feed top
2015-12-26 23:20 [PATCH 01/14] pNFS/flexfiles: Support server-supplied layoutstats sampling period Trond Myklebust
2015-12-26 23:20 ` [PATCH 02/14] NFS41: pop some layoutget errors to application Trond Myklebust
2015-12-26 23:20 ` [PATCH 03/14] nfs: clean up rest of reqs when failing to add one Trond Myklebust
2015-12-26 23:20 ` [PATCH 04/14] nfs: centralize pgio error cleanup Trond Myklebust
2015-12-26 23:20 ` [PATCH 05/14] nfs: handle request add failure properly Trond Myklebust
2015-12-26 23:20 ` [PATCH 06/14] nfs: only remove page from mapping if launder_page fails Trond Myklebust
2015-12-26 23:20 ` [PATCH 07/14] NFS41: map NFS4ERR_LAYOUTUNAVAILABLE to ENODATA Trond Myklebust
2015-12-26 23:20 ` [PATCH 08/14] pnfs/flexfiles: do not mark delay-like status as DS failure Trond Myklebust
2015-12-26 23:20 ` [PATCH 09/14] pnfs/flexfiles: count io stat in rpc_count_stats callback Trond Myklebust
2015-12-26 23:20 ` [PATCH 10/14] pNFS/flexfiles: Don't prevent flexfiles client from retrying LAYOUTGET Trond Myklebust
2015-12-26 23:20 ` [PATCH 11/14] pNFS/flexfiles: Don't mark the entire layout as failed, when returning it Trond Myklebust
2015-12-26 23:20 ` [PATCH 12/14] pNFS/flexfiles: Fix a statistics gathering imbalance Trond Myklebust
2015-12-26 23:20 ` [PATCH 13/14] pNFS: Add flag to track if we've called nfs4_ff_layout_stat_io_start_read/write Trond Myklebust
2015-12-26 23:21 ` [PATCH 14/14] pNFS/flexfiles: Ensure we record layoutstats even if RPC is terminated early Trond Myklebust
2016-01-04 20:12 ` Benjamin Coddington [this message]
2016-01-04 16:29 ` [PATCH 04/14] nfs: centralize pgio error cleanup Benjamin Coddington
2016-01-04 15:48 ` [PATCH 03/14] nfs: clean up rest of reqs when failing to add one Benjamin Coddington
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=alpine.OSX.2.19.9992.1601041453590.87866@planck.local \
--to=bcodding@redhat.com \
--cc=linux-nfs@vger.kernel.org \
--cc=trond.myklebust@primarydata.com \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox