pNFS/flexfiles: Support server-supplied layoutstats sampling period
authorTrond Myklebust <trond.myklebust@primarydata.com>
Mon, 16 Nov 2015 16:26:07 +0000 (11:26 -0500)
committerTrond Myklebust <trond.myklebust@primarydata.com>
Mon, 28 Dec 2015 19:32:36 +0000 (14:32 -0500)
Some servers want to be able to control the frequency with which clients
report layoutstats, for instance, in order to monitor QoS for a particular
file or set of file. In order to support this, the flexfiles layout allows
the server to pass this info as a hint in the layout payload.

Signed-off-by: Trond Myklebust <trond.myklebust@primarydata.com>
fs/nfs/flexfilelayout/flexfilelayout.c
fs/nfs/flexfilelayout/flexfilelayout.h

index 03516c80855a02b7513370e8f5b21d420f3327d7..616817a464106b531c4291d1c8a1618a6f63fc75 100644 (file)
@@ -505,9 +505,17 @@ ff_layout_alloc_lseg(struct pnfs_layout_hdr *lh,
        }
 
        p = xdr_inline_decode(&stream, 4);
-       if (p)
-               fls->flags = be32_to_cpup(p);
+       if (!p)
+               goto out_sort_mirrors;
+       fls->flags = be32_to_cpup(p);
+
+       p = xdr_inline_decode(&stream, 4);
+       if (!p)
+               goto out_sort_mirrors;
+       for (i=0; i < fls->mirror_array_cnt; i++)
+               fls->mirror_array[i]->report_interval = be32_to_cpup(p);
 
+out_sort_mirrors:
        ff_layout_sort_mirrors(fls);
        rc = ff_layout_check_layout(lgr);
        if (rc)
@@ -603,7 +611,9 @@ nfs4_ff_layoutstat_start_io(struct nfs4_ff_layout_mirror *mirror,
                mirror->start_time = now;
        if (ktime_equal(mirror->last_report_time, notime))
                mirror->last_report_time = now;
-       if (layoutstats_timer != 0)
+       if (mirror->report_interval != 0)
+               report_interval = (s64)mirror->report_interval * 1000LL;
+       else if (layoutstats_timer != 0)
                report_interval = (s64)layoutstats_timer * 1000LL;
        if (ktime_to_ms(ktime_sub(now, mirror->last_report_time)) >=
                        report_interval) {
index 2bb08bc6aaf0cc36e20c98dc37061fc9b07fa642..dd353bb7dc0a01ddb76eabdca99a77b75193fe82 100644 (file)
@@ -85,6 +85,7 @@ struct nfs4_ff_layout_mirror {
        struct nfs4_ff_layoutstat       write_stat;
        ktime_t                         start_time;
        ktime_t                         last_report_time;
+       u32                             report_interval;
 };
 
 struct nfs4_ff_layout_segment {