| Message ID | 149643312367.15899.5168600768651475925.stgit@birch.djwong.org (mailing list archive) |
|---|---|
| State | Superseded |
| Headers | show |
On 6/2/17 2:52 PM, Darrick J. Wong wrote: > From: Dave Chinner <dchinner@redhat.com> > > Add freespace mapping tool modelled on the xfs_db freesp command. > The advantage of this command over xfs_db is that it can be done > online and is coherent with concurrent modifications to the > filesystem. > > This requires the kernel to support the XFS_IOC_GETFSMAP ioctl to map > free space indexes. > > Signed-off-by: Dave Chinner <dchinner@redhat.com> > [darrick: port from FIEMAPFS to GETFSMAP] > Signed-off-by: Darrick J. Wong <darrick.wong@oracle.com> > --- > spaceman/Makefile | 7 + > spaceman/file.c | 19 ++- > spaceman/freesp.c | 367 +++++++++++++++++++++++++++++++++++++++++++++++++++ > spaceman/init.c | 8 + > spaceman/prealloc.c | 1 > spaceman/space.h | 12 +- > spaceman/trim.c | 1 > 7 files changed, 409 insertions(+), 6 deletions(-) > create mode 100644 spaceman/freesp.c > > > diff --git a/spaceman/Makefile b/spaceman/Makefile > index 6aad746..95ec3c0 100644 > --- a/spaceman/Makefile > +++ b/spaceman/Makefile > @@ -21,6 +21,13 @@ ifeq ($(ENABLE_EDITLINE),yes) > LLDLIBS += $(LIBEDITLINE) $(LIBTERMCAP) > endif > > +# On linux we get fsmap from the system or define it ourselves > +# so include this based on platform type. If this reverts to only > +# the autoconf check w/o local definition, change to testing HAVE_GETFSMAP > +ifeq ($(PKG_PLATFORM),linux) > +CFILES += freesp.c > +endif > + > default: depend $(LTCOMMAND) > > include $(BUILDRULES) > diff --git a/spaceman/file.c b/spaceman/file.c > index 9356066..46b8826 100644 > --- a/spaceman/file.c > +++ b/spaceman/file.c > @@ -22,6 +22,7 @@ > #include "command.h" > #include "input.h" > #include "init.h" > +#include "path.h" > #include "space.h" > > static cmdinfo_t print_cmd; > @@ -69,8 +70,10 @@ openfile( > char *path, > xfs_fsop_geom_t *geom, > int flags, > - mode_t mode) > + mode_t mode, > + struct fs_path *fs_path) > { > + struct fs_path *fsp; > int fd; > > fd = open(path, flags, mode); > @@ -95,6 +98,16 @@ openfile( > close(fd); > return -1; > } > + > + if (fs_path) { > + fsp = fs_table_lookup(path, FS_MOUNT_POINT); > + if (!fsp) { > + fprintf(stderr, _("%s: cannot find mount point."), > + path); > + return -1; > + } > + memcpy(fs_path, fsp, sizeof(struct fs_path)); > + } > return fd; > } > > @@ -103,7 +116,8 @@ addfile( > char *name, > int fd, > xfs_fsop_geom_t *geometry, > - int flags) > + int flags, > + struct fs_path *fs_path) > { > char *filename; > > @@ -131,6 +145,7 @@ addfile( > file->flags = flags; > file->name = filename; > file->geom = *geometry; > + memcpy(&file->fs_path, fs_path, sizeof(file->fs_path)); > return 0; > } > > diff --git a/spaceman/freesp.c b/spaceman/freesp.c > new file mode 100644 > index 0000000..2290a5e > --- /dev/null > +++ b/spaceman/freesp.c > @@ -0,0 +1,367 @@ > +/* > + * Copyright (c) 2000-2001,2005 Silicon Graphics, Inc. > + * Copyright (c) 2012 Red Hat, Inc. > + * Copyright (c) 2017 Oracle. > + * All Rights Reserved. > + * > + * This program is free software; you can redistribute it and/or > + * modify it under the terms of the GNU General Public License as > + * published by the Free Software Foundation. > + * > + * This program is distributed in the hope that it would be useful, > + * but WITHOUT ANY WARRANTY; without even the implied warranty of > + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the > + * GNU General Public License for more details. > + * > + * You should have received a copy of the GNU General Public License > + * along with this program; if not, write the Free Software Foundation, > + * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA > + */ > + > +#include "libxfs.h" > +#include <linux/fiemap.h> > +#include "command.h" > +#include "init.h" > +#include "path.h" > +#include "space.h" > + > +typedef struct histent > +{ > + int low; > + int high; > + long long count; > + long long blocks; > +} histent_t; > + > +static int agcount; > +static xfs_agnumber_t *aglist; > +static int dumpflag; > +static int equalsize; > +static histent_t *hist; > +static int histcount; > +static int multsize; > +static int seen1; > +static int summaryflag; > +static bool rtflag; > +static long long totblocks; > +static long long totexts; > + > +static cmdinfo_t freesp_cmd; > + > +static void > +addhistent( > + int h) > +{ > + hist = realloc(hist, (histcount + 1) * sizeof(*hist)); > + if (h == 0) > + h = 1; > + hist[histcount].low = h; > + hist[histcount].count = hist[histcount].blocks = 0; > + histcount++; > + if (h == 1) > + seen1 = 1; > +} > + > +static void > +addtohist( > + xfs_agnumber_t agno, > + xfs_agblock_t agbno, > + off64_t len) > +{ > + int i; > + > + if (dumpflag) > + printf("%8d %8d %8"PRId64"\n", agno, agbno, len); > + totexts++; > + totblocks += len; > + for (i = 0; i < histcount; i++) { > + if (hist[i].high >= len) { > + hist[i].count++; > + hist[i].blocks += len; > + break; > + } > + } > +} > + > +static int > +hcmp( > + const void *a, > + const void *b) > +{ > + return ((histent_t *)a)->low - ((histent_t *)b)->low; > +} > + > +static void > +histinit( > + int maxlen) > +{ > + int i; > + > + if (equalsize) { > + for (i = 1; i < maxlen; i += equalsize) > + addhistent(i); > + } else if (multsize) { > + for (i = 1; i < maxlen; i *= multsize) > + addhistent(i); > + } else { > + if (!seen1) > + addhistent(1); > + qsort(hist, histcount, sizeof(*hist), hcmp); > + } > + for (i = 0; i < histcount; i++) { > + if (i < histcount - 1) > + hist[i].high = hist[i + 1].low - 1; > + else > + hist[i].high = maxlen; > + } > +} > + > +static void > +printhist(void) > +{ > + int i; > + > + printf("%7s %7s %7s %7s %6s\n", > + _("from"), _("to"), _("extents"), _("blocks"), _("pct")); > + for (i = 0; i < histcount; i++) { > + if (hist[i].count) > + printf("%7d %7d %7lld %7lld %6.2f\n", hist[i].low, > + hist[i].high, hist[i].count, hist[i].blocks, > + hist[i].blocks * 100.0 / totblocks); > + } > +} > + > +static int > +inaglist( > + xfs_agnumber_t agno) > +{ > + int i; > + > + if (agcount == 0) > + return 1; > + for (i = 0; i < agcount; i++) > + if (aglist[i] == agno) > + return 1; > + return 0; > +} > + > +#define NR_EXTENTS 128 > + > +static void > +scan_ag( > + xfs_agnumber_t agno) > +{ > + struct fsmap_head *fsmap; > + struct fsmap *extent; > + struct fsmap *l, *h; > + struct fsmap *p; > + off64_t blocksize = file->geom.blocksize; > + off64_t bperag; > + off64_t aglen; > + xfs_agblock_t agbno; > + int ret; > + int i; > + > + bperag = (off64_t)file->geom.agblocks * blocksize; > + > + fsmap = malloc(fsmap_sizeof(NR_EXTENTS)); > + if (!fsmap) { > + fprintf(stderr, _("%s: fsmap malloc failed.\n"), progname); > + exitcode = 1; > + return; > + } > + > + memset(fsmap, 0, sizeof(*fsmap)); > + fsmap->fmh_count = NR_EXTENTS; > + l = fsmap->fmh_keys; > + h = fsmap->fmh_keys + 1; > + if (agno != NULLAGNUMBER) { > + l->fmr_physical = agno * bperag; > + h->fmr_physical = ((agno + 1) * bperag) - 1; > + l->fmr_device = h->fmr_device = file->fs_path.fs_datadev; > + } else { > + l->fmr_physical = 0; > + h->fmr_physical = ULLONG_MAX; > + l->fmr_device = h->fmr_device = file->fs_path.fs_rtdev; > + } > + h->fmr_owner = ULLONG_MAX; > + h->fmr_flags = UINT_MAX; > + h->fmr_offset = ULLONG_MAX; > + > + while (true) { > + ret = ioctl(file->fd, FS_IOC_GETFSMAP, fsmap); > + if (ret < 0) { > + fprintf(stderr, _("%s: FS_IOC_GETFSMAP [\"%s\"]: %s\n"), > + progname, file->name, strerror(errno)); > + free(fsmap); > + exitcode = 1; > + return; > + } > + > + /* No more extents to map, exit */ > + if (!fsmap->fmh_entries) > + break; > + > + for (i = 0, extent = fsmap->fmh_recs; > + i < fsmap->fmh_entries; > + i++, extent++) { > + if (!(extent->fmr_flags & FMR_OF_SPECIAL_OWNER) || > + extent->fmr_owner != XFS_FMR_OWN_FREE) > + continue; > + agbno = (extent->fmr_physical - (bperag * agno)) / > + blocksize; > + aglen = extent->fmr_length / blocksize; > + > + addtohist(agno, agbno, aglen); > + } > + > + p = &fsmap->fmh_recs[fsmap->fmh_entries - 1]; > + if (p->fmr_flags & FMR_OF_LAST) > + break; > + fsmap_advance(fsmap); > + } > +} > +static void > +aglistadd( > + char *a) > +{ > + aglist = realloc(aglist, (agcount + 1) * sizeof(*aglist)); > + aglist[agcount] = (xfs_agnumber_t)atoi(a); > + agcount++; > +} > + > +static int > +init( > + int argc, > + char **argv) > +{ > + int c; > + int speced = 0; > + > + agcount = dumpflag = equalsize = multsize = optind = 0; > + histcount = seen1 = summaryflag = 0; > + totblocks = totexts = 0; > + aglist = NULL; > + hist = NULL; > + rtflag = false; > + while ((c = getopt(argc, argv, "a:bde:h:m:rs")) != EOF) { > + switch (c) { > + case 'a': > + aglistadd(optarg); > + break; > + case 'b': > + if (speced) > + return 0; > + multsize = 2; > + speced = 1; > + break; > + case 'd': > + dumpflag = 1; > + break; > + case 'e': > + if (speced) > + return 0; > + equalsize = atoi(optarg); > + speced = 1; > + break; > + case 'h': > + if (speced && !histcount) > + return 0; > + addhistent(atoi(optarg)); > + speced = 1; > + break; > + case 'm': > + if (speced) > + return 0; > + multsize = atoi(optarg); > + speced = 1; > + break; > + case 'r': > + rtflag = true; > + break; > + case 's': > + summaryflag = 1; > + break; > + case '?': > + return 0; > + } > + } > + if (optind != argc) > + return 0; > + if (!speced) > + multsize = 2; > + histinit(file->geom.agblocks); > + return 1; > +} > + > +/* > + * Report on freespace usage in xfs filesystem. > + */ > +static int > +freesp_f( > + int argc, > + char **argv) > +{ > + xfs_agnumber_t agno; > + > + if (!init(argc, argv)) > + return 0; > + if (rtflag) > + scan_ag(NULLAGNUMBER); > + for (agno = 0; !rtflag && agno < file->geom.agcount; agno++) { > + if (inaglist(agno)) > + scan_ag(agno); > + } > + if (histcount) > + printhist(); > + if (summaryflag) { > + printf(_("total free extents %lld\n"), totexts); > + printf(_("total free blocks %lld\n"), totblocks); > + printf(_("average free extent size %g\n"), > + (double)totblocks / (double)totexts); > + } > + if (aglist) > + free(aglist); > + if (hist) > + free(hist); > + return 0; > +} > + > +static void > +freesp_help(void) > +{ > + printf(_( > +"\n" > +"Examine filesystem free space\n" > +"\n" > +"Options: [-bdsr] [-a agno] [-e bsize] [-h h1]... [-m bmult]\n" don't restate options ... > +"\n" > +" -a agno -- Scan only the given AG agno.\n" > +" -b -- binary histogram bin size\n" > +" -d -- debug output\n" > +" -e bsize -- Use fixed histogram bin size of bsize\n" > +" -h hbsz -- Use custom histogram bin size of h1.\n" > +" Multiple specifications are allowed.\n" > +" -m bmult -- Use histogram bin size multiplier of bmult.\n" > +" -r -- Display realtime device free space information.\n" > +" -s -- Emit freespace summary information.\n" > +"\n")); > + > +} > + > +void > +freesp_init(void) > +{ > + freesp_cmd.name = "freesp"; > + freesp_cmd.altname = "fsp"; > + freesp_cmd.cfunc = freesp_f; > + freesp_cmd.argmin = 0; > + freesp_cmd.argmax = -1; > + freesp_cmd.args = "[-bdsr] [-a agno] [-e bsize] [-h h1]... [-m bmult]"; [-a agno]... right? Multiple allowed? > + freesp_cmd.flags = CMD_FLAG_ONESHOT; > + freesp_cmd.oneline = _("Examine filesystem free space"); > + freesp_cmd.help = freesp_help; > + > + add_command(&freesp_cmd); > +} > + > diff --git a/spaceman/init.c b/spaceman/init.c > index 93a8a1e..f3c93c3 100644 > --- a/spaceman/init.c > +++ b/spaceman/init.c > @@ -20,6 +20,7 @@ > #include "command.h" > #include "input.h" > #include "init.h" > +#include "path.h" > #include "space.h" > > char *progname; > @@ -38,6 +39,7 @@ static void > init_commands(void) > { > file_init(); > + freesp_init(); > help_init(); > prealloc_init(); > quit_init(); > @@ -71,12 +73,14 @@ init( > int c, flags = 0; > mode_t mode = 0600; > xfs_fsop_geom_t geometry = { 0 }; > + struct fs_path fsp; > > progname = basename(argv[0]); > setlocale(LC_ALL, ""); > bindtextdomain(PACKAGE, LOCALEDIR); > textdomain(PACKAGE); > > + fs_table_initialise(0, NULL, 0, NULL); > while ((c = getopt(argc, argv, "c:V")) != EOF) { > switch (c) { > case 'c': > @@ -93,11 +97,11 @@ init( > if (optind != argc - 1) > usage(); > > - if ((c = openfile(argv[optind], &geometry, flags, mode)) < 0) > + if ((c = openfile(argv[optind], &geometry, flags, mode, &fsp)) < 0) > exit(1); > if (!platform_test_xfs_fd(c)) > printf(_("Not an XFS filesystem!\n")); > - if (addfile(argv[optind], c, &geometry, flags) < 0) > + if (addfile(argv[optind], c, &geometry, flags, &fsp) < 0) > exit(1); > > init_commands(); > diff --git a/spaceman/prealloc.c b/spaceman/prealloc.c > index 71c0d80..55b85ed 100644 > --- a/spaceman/prealloc.c > +++ b/spaceman/prealloc.c > @@ -20,6 +20,7 @@ > #include "command.h" > #include "input.h" > #include "init.h" > +#include "path.h" > #include "space.h" > > static cmdinfo_t prealloc_cmd; > diff --git a/spaceman/space.h b/spaceman/space.h > index 0ae3116..bf9a2df 100644 > --- a/spaceman/space.h > +++ b/spaceman/space.h > @@ -21,6 +21,7 @@ typedef struct fileio { > int flags; /* flags describing file state */ > char *name; /* file name at time of open */ > xfs_fsop_geom_t geom; /* XFS filesystem geometry */ > + struct fs_path fs_path; /* XFS path information */ > } fileio_t; > > extern fileio_t *filetable; /* open file table */ > @@ -28,11 +29,18 @@ extern int filecount; /* number of open files */ > extern fileio_t *file; /* active file in file table */ > extern int filelist_f(void); > > -extern int openfile(char *, xfs_fsop_geom_t *, int, mode_t); > -extern int addfile(char *, int , xfs_fsop_geom_t *, int); > +extern int openfile(char *, xfs_fsop_geom_t *, int, mode_t, > + struct fs_path *); > +extern int addfile(char *, int , xfs_fsop_geom_t *, int, struct fs_path *); > > extern void file_init(void); > extern void help_init(void); > extern void prealloc_init(void); > extern void quit_init(void); > extern void trim_init(void); > + > +#ifdef HAVE_GETFSMAP > +extern void freesp_init(void); > +#else > +# define freesp_init() do { } while (0) > +#endif > diff --git a/spaceman/trim.c b/spaceman/trim.c > index d58f6d1..b5908cc 100644 > --- a/spaceman/trim.c > +++ b/spaceman/trim.c > @@ -20,6 +20,7 @@ > #include <linux/fs.h> > #include "command.h" > #include "init.h" > +#include "path.h" > #include "space.h" > #include "input.h" > > > -- > To unsubscribe from this list: send the line "unsubscribe linux-xfs" in > the body of a message to majordomo@vger.kernel.org > More majordomo info at http://vger.kernel.org/majordomo-info.html > -- To unsubscribe from this list: send the line "unsubscribe linux-xfs" in the body of a message to majordomo@vger.kernel.org More majordomo info at http://vger.kernel.org/majordomo-info.html
On 6/2/17 2:52 PM, Darrick J. Wong wrote: > From: Dave Chinner <dchinner@redhat.com> > > Add freespace mapping tool modelled on the xfs_db freesp command. > The advantage of this command over xfs_db is that it can be done > online and is coherent with concurrent modifications to the > filesystem. > > This requires the kernel to support the XFS_IOC_GETFSMAP ioctl to map > free space indexes. > > Signed-off-by: Dave Chinner <dchinner@redhat.com> > [darrick: port from FIEMAPFS to GETFSMAP] > Signed-off-by: Darrick J. Wong <darrick.wong@oracle.com> > +static int > +init( > + int argc, > + char **argv) > +{ > + int c; > + int speced = 0; > + > + agcount = dumpflag = equalsize = multsize = optind = 0; > + histcount = seen1 = summaryflag = 0; ew, setting histcount to 0 (already done, right? it's global?) and checking it here but never setting it is a little confusing. Maybe the comment below would help. > + totblocks = totexts = 0; > + aglist = NULL; > + hist = NULL; > + rtflag = false; > + while ((c = getopt(argc, argv, "a:bde:h:m:rs")) != EOF) { > + switch (c) { > + case 'a': > + aglistadd(optarg); > + break; > + case 'b': > + if (speced) > + return 0; > + multsize = 2; > + speced = 1; > + break; > + case 'd': > + dumpflag = 1; > + break; > + case 'e': > + if (speced) > + return 0; > + equalsize = atoi(optarg); > + speced = 1; > + break; > + case 'h': > + if (speced && !histcount) > + return 0; maybe: /* increments histcount */ > + addhistent(atoi(optarg)); > + speced = 1; > + break; > + case 'm': > + if (speced) > + return 0; > + multsize = atoi(optarg); > + speced = 1; > + break; > + case 'r': > + rtflag = true; > + break; > + case 's': > + summaryflag = 1; > + break; > + case '?': > + return 0; > + } > + } > + if (optind != argc) > + return 0; > + if (!speced) > + multsize = 2; Manpage indicates that -b, -e, and -h are mutually exclusive, but that's not enforced here (?) Specifying more than one seems to break the command: xfs_spaceman> freesp -b from to extents blocks pct 2 3 1 3 0.00 32768 65536 4 259537 100.00 xfs_spaceman> freesp -e 4096 from to extents blocks pct 1 4096 1 3 0.00 61441 65536 4 259537 100.00 xfs_spaceman> freesp -e 4096 -b xfs_spaceman> Oh I see, if more than one is "speced" init returns 0 (silently). I'd document what speced is for, and I guess print a warning about the exclusive nature of the 3 arguments in each case if re-spec'd before returning. And note the exclusive nature somehow in the help. (hm, looks like -m is in this exclusive group too?) in gneneral need to sanitize behavior w/ built in help as well as manpage... -- To unsubscribe from this list: send the line "unsubscribe linux-xfs" in the body of a message to majordomo@vger.kernel.org More majordomo info at http://vger.kernel.org/majordomo-info.html
On Wed, Jun 14, 2017 at 10:43:06AM -0500, Eric Sandeen wrote: > On 6/2/17 2:52 PM, Darrick J. Wong wrote: > > From: Dave Chinner <dchinner@redhat.com> > > > > Add freespace mapping tool modelled on the xfs_db freesp command. > > The advantage of this command over xfs_db is that it can be done > > online and is coherent with concurrent modifications to the > > filesystem. > > > > This requires the kernel to support the XFS_IOC_GETFSMAP ioctl to map > > free space indexes. > > > > Signed-off-by: Dave Chinner <dchinner@redhat.com> > > [darrick: port from FIEMAPFS to GETFSMAP] > > Signed-off-by: Darrick J. Wong <darrick.wong@oracle.com> > > --- > > spaceman/Makefile | 7 + > > spaceman/file.c | 19 ++- > > spaceman/freesp.c | 367 +++++++++++++++++++++++++++++++++++++++++++++++++++ > > spaceman/init.c | 8 + > > spaceman/prealloc.c | 1 > > spaceman/space.h | 12 +- > > spaceman/trim.c | 1 > > 7 files changed, 409 insertions(+), 6 deletions(-) > > create mode 100644 spaceman/freesp.c > > > > > > diff --git a/spaceman/Makefile b/spaceman/Makefile > > index 6aad746..95ec3c0 100644 > > --- a/spaceman/Makefile > > +++ b/spaceman/Makefile > > @@ -21,6 +21,13 @@ ifeq ($(ENABLE_EDITLINE),yes) > > LLDLIBS += $(LIBEDITLINE) $(LIBTERMCAP) > > endif > > > > +# On linux we get fsmap from the system or define it ourselves > > +# so include this based on platform type. If this reverts to only > > +# the autoconf check w/o local definition, change to testing HAVE_GETFSMAP > > +ifeq ($(PKG_PLATFORM),linux) > > +CFILES += freesp.c > > +endif > > + > > default: depend $(LTCOMMAND) > > > > include $(BUILDRULES) > > diff --git a/spaceman/file.c b/spaceman/file.c > > index 9356066..46b8826 100644 > > --- a/spaceman/file.c > > +++ b/spaceman/file.c > > @@ -22,6 +22,7 @@ > > #include "command.h" > > #include "input.h" > > #include "init.h" > > +#include "path.h" > > #include "space.h" > > > > static cmdinfo_t print_cmd; > > @@ -69,8 +70,10 @@ openfile( > > char *path, > > xfs_fsop_geom_t *geom, > > int flags, > > - mode_t mode) > > + mode_t mode, > > + struct fs_path *fs_path) > > { > > + struct fs_path *fsp; > > int fd; > > > > fd = open(path, flags, mode); > > @@ -95,6 +98,16 @@ openfile( > > close(fd); > > return -1; > > } > > + > > + if (fs_path) { > > + fsp = fs_table_lookup(path, FS_MOUNT_POINT); > > + if (!fsp) { > > + fprintf(stderr, _("%s: cannot find mount point."), > > + path); > > + return -1; > > + } > > + memcpy(fs_path, fsp, sizeof(struct fs_path)); > > + } > > return fd; > > } > > > > @@ -103,7 +116,8 @@ addfile( > > char *name, > > int fd, > > xfs_fsop_geom_t *geometry, > > - int flags) > > + int flags, > > + struct fs_path *fs_path) > > { > > char *filename; > > > > @@ -131,6 +145,7 @@ addfile( > > file->flags = flags; > > file->name = filename; > > file->geom = *geometry; > > + memcpy(&file->fs_path, fs_path, sizeof(file->fs_path)); > > return 0; > > } > > > > diff --git a/spaceman/freesp.c b/spaceman/freesp.c > > new file mode 100644 > > index 0000000..2290a5e > > --- /dev/null > > +++ b/spaceman/freesp.c > > @@ -0,0 +1,367 @@ > > +/* > > + * Copyright (c) 2000-2001,2005 Silicon Graphics, Inc. > > + * Copyright (c) 2012 Red Hat, Inc. > > + * Copyright (c) 2017 Oracle. > > + * All Rights Reserved. > > + * > > + * This program is free software; you can redistribute it and/or > > + * modify it under the terms of the GNU General Public License as > > + * published by the Free Software Foundation. > > + * > > + * This program is distributed in the hope that it would be useful, > > + * but WITHOUT ANY WARRANTY; without even the implied warranty of > > + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the > > + * GNU General Public License for more details. > > + * > > + * You should have received a copy of the GNU General Public License > > + * along with this program; if not, write the Free Software Foundation, > > + * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA > > + */ > > + > > +#include "libxfs.h" > > +#include <linux/fiemap.h> > > +#include "command.h" > > +#include "init.h" > > +#include "path.h" > > +#include "space.h" > > + > > +typedef struct histent > > +{ > > + int low; > > + int high; > > + long long count; > > + long long blocks; > > +} histent_t; > > + > > +static int agcount; > > +static xfs_agnumber_t *aglist; > > +static int dumpflag; > > +static int equalsize; > > +static histent_t *hist; > > +static int histcount; > > +static int multsize; > > +static int seen1; > > +static int summaryflag; > > +static bool rtflag; > > +static long long totblocks; > > +static long long totexts; > > + > > +static cmdinfo_t freesp_cmd; > > + > > +static void > > +addhistent( > > + int h) > > +{ > > + hist = realloc(hist, (histcount + 1) * sizeof(*hist)); > > + if (h == 0) > > + h = 1; > > + hist[histcount].low = h; > > + hist[histcount].count = hist[histcount].blocks = 0; > > + histcount++; > > + if (h == 1) > > + seen1 = 1; > > +} > > + > > +static void > > +addtohist( > > + xfs_agnumber_t agno, > > + xfs_agblock_t agbno, > > + off64_t len) > > +{ > > + int i; > > + > > + if (dumpflag) > > + printf("%8d %8d %8"PRId64"\n", agno, agbno, len); > > + totexts++; > > + totblocks += len; > > + for (i = 0; i < histcount; i++) { > > + if (hist[i].high >= len) { > > + hist[i].count++; > > + hist[i].blocks += len; > > + break; > > + } > > + } > > +} > > + > > +static int > > +hcmp( > > + const void *a, > > + const void *b) > > +{ > > + return ((histent_t *)a)->low - ((histent_t *)b)->low; > > +} > > + > > +static void > > +histinit( > > + int maxlen) > > +{ > > + int i; > > + > > + if (equalsize) { > > + for (i = 1; i < maxlen; i += equalsize) > > + addhistent(i); > > + } else if (multsize) { > > + for (i = 1; i < maxlen; i *= multsize) > > + addhistent(i); > > + } else { > > + if (!seen1) > > + addhistent(1); > > + qsort(hist, histcount, sizeof(*hist), hcmp); > > + } > > + for (i = 0; i < histcount; i++) { > > + if (i < histcount - 1) > > + hist[i].high = hist[i + 1].low - 1; > > + else > > + hist[i].high = maxlen; > > + } > > +} > > + > > +static void > > +printhist(void) > > +{ > > + int i; > > + > > + printf("%7s %7s %7s %7s %6s\n", > > + _("from"), _("to"), _("extents"), _("blocks"), _("pct")); > > + for (i = 0; i < histcount; i++) { > > + if (hist[i].count) > > + printf("%7d %7d %7lld %7lld %6.2f\n", hist[i].low, > > + hist[i].high, hist[i].count, hist[i].blocks, > > + hist[i].blocks * 100.0 / totblocks); > > + } > > +} > > + > > +static int > > +inaglist( > > + xfs_agnumber_t agno) > > +{ > > + int i; > > + > > + if (agcount == 0) > > + return 1; > > + for (i = 0; i < agcount; i++) > > + if (aglist[i] == agno) > > + return 1; > > + return 0; > > +} > > + > > +#define NR_EXTENTS 128 > > + > > +static void > > +scan_ag( > > + xfs_agnumber_t agno) > > +{ > > + struct fsmap_head *fsmap; > > + struct fsmap *extent; > > + struct fsmap *l, *h; > > + struct fsmap *p; > > + off64_t blocksize = file->geom.blocksize; > > + off64_t bperag; > > + off64_t aglen; > > + xfs_agblock_t agbno; > > + int ret; > > + int i; > > + > > + bperag = (off64_t)file->geom.agblocks * blocksize; > > + > > + fsmap = malloc(fsmap_sizeof(NR_EXTENTS)); > > + if (!fsmap) { > > + fprintf(stderr, _("%s: fsmap malloc failed.\n"), progname); > > + exitcode = 1; > > + return; > > + } > > + > > + memset(fsmap, 0, sizeof(*fsmap)); > > + fsmap->fmh_count = NR_EXTENTS; > > + l = fsmap->fmh_keys; > > + h = fsmap->fmh_keys + 1; > > + if (agno != NULLAGNUMBER) { > > + l->fmr_physical = agno * bperag; > > + h->fmr_physical = ((agno + 1) * bperag) - 1; > > + l->fmr_device = h->fmr_device = file->fs_path.fs_datadev; > > + } else { > > + l->fmr_physical = 0; > > + h->fmr_physical = ULLONG_MAX; > > + l->fmr_device = h->fmr_device = file->fs_path.fs_rtdev; > > + } > > + h->fmr_owner = ULLONG_MAX; > > + h->fmr_flags = UINT_MAX; > > + h->fmr_offset = ULLONG_MAX; > > + > > + while (true) { > > + ret = ioctl(file->fd, FS_IOC_GETFSMAP, fsmap); > > + if (ret < 0) { > > + fprintf(stderr, _("%s: FS_IOC_GETFSMAP [\"%s\"]: %s\n"), > > + progname, file->name, strerror(errno)); > > + free(fsmap); > > + exitcode = 1; > > + return; > > + } > > + > > + /* No more extents to map, exit */ > > + if (!fsmap->fmh_entries) > > + break; > > + > > + for (i = 0, extent = fsmap->fmh_recs; > > + i < fsmap->fmh_entries; > > + i++, extent++) { > > + if (!(extent->fmr_flags & FMR_OF_SPECIAL_OWNER) || > > + extent->fmr_owner != XFS_FMR_OWN_FREE) > > + continue; > > + agbno = (extent->fmr_physical - (bperag * agno)) / > > + blocksize; > > + aglen = extent->fmr_length / blocksize; > > + > > + addtohist(agno, agbno, aglen); > > + } > > + > > + p = &fsmap->fmh_recs[fsmap->fmh_entries - 1]; > > + if (p->fmr_flags & FMR_OF_LAST) > > + break; > > + fsmap_advance(fsmap); > > + } > > +} > > +static void > > +aglistadd( > > + char *a) > > +{ > > + aglist = realloc(aglist, (agcount + 1) * sizeof(*aglist)); > > + aglist[agcount] = (xfs_agnumber_t)atoi(a); > > + agcount++; > > +} > > + > > +static int > > +init( > > + int argc, > > + char **argv) > > +{ > > + int c; > > + int speced = 0; > > + > > + agcount = dumpflag = equalsize = multsize = optind = 0; > > + histcount = seen1 = summaryflag = 0; > > + totblocks = totexts = 0; > > + aglist = NULL; > > + hist = NULL; > > + rtflag = false; > > + while ((c = getopt(argc, argv, "a:bde:h:m:rs")) != EOF) { > > + switch (c) { > > + case 'a': > > + aglistadd(optarg); > > + break; > > + case 'b': > > + if (speced) > > + return 0; > > + multsize = 2; > > + speced = 1; > > + break; > > + case 'd': > > + dumpflag = 1; > > + break; > > + case 'e': > > + if (speced) > > + return 0; > > + equalsize = atoi(optarg); > > + speced = 1; > > + break; > > + case 'h': > > + if (speced && !histcount) > > + return 0; > > + addhistent(atoi(optarg)); > > + speced = 1; > > + break; > > + case 'm': > > + if (speced) > > + return 0; > > + multsize = atoi(optarg); > > + speced = 1; > > + break; > > + case 'r': > > + rtflag = true; > > + break; > > + case 's': > > + summaryflag = 1; > > + break; > > + case '?': > > + return 0; > > + } > > + } > > + if (optind != argc) > > + return 0; > > + if (!speced) > > + multsize = 2; > > + histinit(file->geom.agblocks); > > + return 1; > > +} > > + > > +/* > > + * Report on freespace usage in xfs filesystem. > > + */ > > +static int > > +freesp_f( > > + int argc, > > + char **argv) > > +{ > > + xfs_agnumber_t agno; > > + > > + if (!init(argc, argv)) > > + return 0; > > + if (rtflag) > > + scan_ag(NULLAGNUMBER); > > + for (agno = 0; !rtflag && agno < file->geom.agcount; agno++) { > > + if (inaglist(agno)) > > + scan_ag(agno); > > + } > > + if (histcount) > > + printhist(); > > + if (summaryflag) { > > + printf(_("total free extents %lld\n"), totexts); > > + printf(_("total free blocks %lld\n"), totblocks); > > + printf(_("average free extent size %g\n"), > > + (double)totblocks / (double)totexts); > > + } > > + if (aglist) > > + free(aglist); > > + if (hist) > > + free(hist); > > + return 0; > > +} > > + > > +static void > > +freesp_help(void) > > +{ > > + printf(_( > > +"\n" > > +"Examine filesystem free space\n" > > +"\n" > > +"Options: [-bdsr] [-a agno] [-e bsize] [-h h1]... [-m bmult]\n" > > don't restate options ... Fixed. > > +"\n" > > +" -a agno -- Scan only the given AG agno.\n" > > +" -b -- binary histogram bin size\n" > > +" -d -- debug output\n" > > +" -e bsize -- Use fixed histogram bin size of bsize\n" > > +" -h hbsz -- Use custom histogram bin size of h1.\n" > > +" Multiple specifications are allowed.\n" > > +" -m bmult -- Use histogram bin size multiplier of bmult.\n" > > +" -r -- Display realtime device free space information.\n" > > +" -s -- Emit freespace summary information.\n" > > +"\n")); > > + > > +} > > + > > +void > > +freesp_init(void) > > +{ > > + freesp_cmd.name = "freesp"; > > + freesp_cmd.altname = "fsp"; > > + freesp_cmd.cfunc = freesp_f; > > + freesp_cmd.argmin = 0; > > + freesp_cmd.argmax = -1; > > + freesp_cmd.args = "[-bdsr] [-a agno] [-e bsize] [-h h1]... [-m bmult]"; > > [-a agno]... right? Multiple allowed? Yes, and fixed. --D > > + freesp_cmd.flags = CMD_FLAG_ONESHOT; > > + freesp_cmd.oneline = _("Examine filesystem free space"); > > + freesp_cmd.help = freesp_help; > > + > > + add_command(&freesp_cmd); > > +} > > + > > diff --git a/spaceman/init.c b/spaceman/init.c > > index 93a8a1e..f3c93c3 100644 > > --- a/spaceman/init.c > > +++ b/spaceman/init.c > > @@ -20,6 +20,7 @@ > > #include "command.h" > > #include "input.h" > > #include "init.h" > > +#include "path.h" > > #include "space.h" > > > > char *progname; > > @@ -38,6 +39,7 @@ static void > > init_commands(void) > > { > > file_init(); > > + freesp_init(); > > help_init(); > > prealloc_init(); > > quit_init(); > > @@ -71,12 +73,14 @@ init( > > int c, flags = 0; > > mode_t mode = 0600; > > xfs_fsop_geom_t geometry = { 0 }; > > + struct fs_path fsp; > > > > progname = basename(argv[0]); > > setlocale(LC_ALL, ""); > > bindtextdomain(PACKAGE, LOCALEDIR); > > textdomain(PACKAGE); > > > > + fs_table_initialise(0, NULL, 0, NULL); > > while ((c = getopt(argc, argv, "c:V")) != EOF) { > > switch (c) { > > case 'c': > > @@ -93,11 +97,11 @@ init( > > if (optind != argc - 1) > > usage(); > > > > - if ((c = openfile(argv[optind], &geometry, flags, mode)) < 0) > > + if ((c = openfile(argv[optind], &geometry, flags, mode, &fsp)) < 0) > > exit(1); > > if (!platform_test_xfs_fd(c)) > > printf(_("Not an XFS filesystem!\n")); > > - if (addfile(argv[optind], c, &geometry, flags) < 0) > > + if (addfile(argv[optind], c, &geometry, flags, &fsp) < 0) > > exit(1); > > > > init_commands(); > > diff --git a/spaceman/prealloc.c b/spaceman/prealloc.c > > index 71c0d80..55b85ed 100644 > > --- a/spaceman/prealloc.c > > +++ b/spaceman/prealloc.c > > @@ -20,6 +20,7 @@ > > #include "command.h" > > #include "input.h" > > #include "init.h" > > +#include "path.h" > > #include "space.h" > > > > static cmdinfo_t prealloc_cmd; > > diff --git a/spaceman/space.h b/spaceman/space.h > > index 0ae3116..bf9a2df 100644 > > --- a/spaceman/space.h > > +++ b/spaceman/space.h > > @@ -21,6 +21,7 @@ typedef struct fileio { > > int flags; /* flags describing file state */ > > char *name; /* file name at time of open */ > > xfs_fsop_geom_t geom; /* XFS filesystem geometry */ > > + struct fs_path fs_path; /* XFS path information */ > > } fileio_t; > > > > extern fileio_t *filetable; /* open file table */ > > @@ -28,11 +29,18 @@ extern int filecount; /* number of open files */ > > extern fileio_t *file; /* active file in file table */ > > extern int filelist_f(void); > > > > -extern int openfile(char *, xfs_fsop_geom_t *, int, mode_t); > > -extern int addfile(char *, int , xfs_fsop_geom_t *, int); > > +extern int openfile(char *, xfs_fsop_geom_t *, int, mode_t, > > + struct fs_path *); > > +extern int addfile(char *, int , xfs_fsop_geom_t *, int, struct fs_path *); > > > > extern void file_init(void); > > extern void help_init(void); > > extern void prealloc_init(void); > > extern void quit_init(void); > > extern void trim_init(void); > > + > > +#ifdef HAVE_GETFSMAP > > +extern void freesp_init(void); > > +#else > > +# define freesp_init() do { } while (0) > > +#endif > > diff --git a/spaceman/trim.c b/spaceman/trim.c > > index d58f6d1..b5908cc 100644 > > --- a/spaceman/trim.c > > +++ b/spaceman/trim.c > > @@ -20,6 +20,7 @@ > > #include <linux/fs.h> > > #include "command.h" > > #include "init.h" > > +#include "path.h" > > #include "space.h" > > #include "input.h" > > > > > > -- > > To unsubscribe from this list: send the line "unsubscribe linux-xfs" in > > the body of a message to majordomo@vger.kernel.org > > More majordomo info at http://vger.kernel.org/majordomo-info.html > > > -- > To unsubscribe from this list: send the line "unsubscribe linux-xfs" in > the body of a message to majordomo@vger.kernel.org > More majordomo info at http://vger.kernel.org/majordomo-info.html -- To unsubscribe from this list: send the line "unsubscribe linux-xfs" in the body of a message to majordomo@vger.kernel.org More majordomo info at http://vger.kernel.org/majordomo-info.html
On Wed, Jun 14, 2017 at 11:04:11AM -0500, Eric Sandeen wrote: > > On 6/2/17 2:52 PM, Darrick J. Wong wrote: > > From: Dave Chinner <dchinner@redhat.com> > > > > Add freespace mapping tool modelled on the xfs_db freesp command. > > The advantage of this command over xfs_db is that it can be done > > online and is coherent with concurrent modifications to the > > filesystem. > > > > This requires the kernel to support the XFS_IOC_GETFSMAP ioctl to map > > free space indexes. > > > > Signed-off-by: Dave Chinner <dchinner@redhat.com> > > [darrick: port from FIEMAPFS to GETFSMAP] > > Signed-off-by: Darrick J. Wong <darrick.wong@oracle.com> > > > > +static int > > +init( > > + int argc, > > + char **argv) > > +{ > > + int c; > > + int speced = 0; > > + > > + agcount = dumpflag = equalsize = multsize = optind = 0; > > + histcount = seen1 = summaryflag = 0; > > ew, setting histcount to 0 (already done, right? it's global?) > and checking it here but never setting it is a little confusing. Yes, I'll get rid of the redundant initializers. > Maybe the comment below would help. Ok. > > + totblocks = totexts = 0; > > + aglist = NULL; > > + hist = NULL; > > + rtflag = false; > > + while ((c = getopt(argc, argv, "a:bde:h:m:rs")) != EOF) { > > + switch (c) { > > + case 'a': > > + aglistadd(optarg); > > + break; > > + case 'b': > > + if (speced) > > + return 0; > > + multsize = 2; > > + speced = 1; > > + break; > > + case 'd': > > + dumpflag = 1; > > + break; > > + case 'e': > > + if (speced) > > + return 0; > > + equalsize = atoi(optarg); > > + speced = 1; > > + break; > > + case 'h': > > + if (speced && !histcount) > > + return 0; > > maybe: /* increments histcount */ Fixed. > > + addhistent(atoi(optarg)); > > + speced = 1; > > + break; > > + case 'm': > > + if (speced) > > + return 0; > > + multsize = atoi(optarg); > > + speced = 1; > > + break; > > + case 'r': > > + rtflag = true; > > + break; > > + case 's': > > + summaryflag = 1; > > + break; > > + case '?': > > + return 0; > > + } > > + } > > + if (optind != argc) > > + return 0; > > + if (!speced) > > + multsize = 2; > > Manpage indicates that -b, -e, and -h are mutually exclusive, but that's > not enforced here (?) > > Specifying more than one seems to break the command: > > xfs_spaceman> freesp -b > from to extents blocks pct > 2 3 1 3 0.00 > 32768 65536 4 259537 100.00 > xfs_spaceman> freesp -e 4096 > from to extents blocks pct > 1 4096 1 3 0.00 > 61441 65536 4 259537 100.00 > xfs_spaceman> freesp -e 4096 -b > xfs_spaceman> > > Oh I see, if more than one is "speced" init returns 0 (silently). > > I'd document what speced is for, and I guess print a warning about > the exclusive nature of the 3 arguments in each case if re-spec'd > before returning. I made a note of that in the help screen and redirected all the overspec cases to print the help screen instead of silently returning. > And note the exclusive nature somehow in the help. > (hm, looks like -m is in this exclusive group too?) > > in gneneral need to sanitize behavior w/ built in help as well > as manpage... Ok. --D > -- > To unsubscribe from this list: send the line "unsubscribe linux-xfs" in > the body of a message to majordomo@vger.kernel.org > More majordomo info at http://vger.kernel.org/majordomo-info.html -- To unsubscribe from this list: send the line "unsubscribe linux-xfs" in the body of a message to majordomo@vger.kernel.org More majordomo info at http://vger.kernel.org/majordomo-info.html
diff --git a/spaceman/Makefile b/spaceman/Makefile index 6aad746..95ec3c0 100644 --- a/spaceman/Makefile +++ b/spaceman/Makefile @@ -21,6 +21,13 @@ ifeq ($(ENABLE_EDITLINE),yes) LLDLIBS += $(LIBEDITLINE) $(LIBTERMCAP) endif +# On linux we get fsmap from the system or define it ourselves +# so include this based on platform type. If this reverts to only +# the autoconf check w/o local definition, change to testing HAVE_GETFSMAP +ifeq ($(PKG_PLATFORM),linux) +CFILES += freesp.c +endif + default: depend $(LTCOMMAND) include $(BUILDRULES) diff --git a/spaceman/file.c b/spaceman/file.c index 9356066..46b8826 100644 --- a/spaceman/file.c +++ b/spaceman/file.c @@ -22,6 +22,7 @@ #include "command.h" #include "input.h" #include "init.h" +#include "path.h" #include "space.h" static cmdinfo_t print_cmd; @@ -69,8 +70,10 @@ openfile( char *path, xfs_fsop_geom_t *geom, int flags, - mode_t mode) + mode_t mode, + struct fs_path *fs_path) { + struct fs_path *fsp; int fd; fd = open(path, flags, mode); @@ -95,6 +98,16 @@ openfile( close(fd); return -1; } + + if (fs_path) { + fsp = fs_table_lookup(path, FS_MOUNT_POINT); + if (!fsp) { + fprintf(stderr, _("%s: cannot find mount point."), + path); + return -1; + } + memcpy(fs_path, fsp, sizeof(struct fs_path)); + } return fd; } @@ -103,7 +116,8 @@ addfile( char *name, int fd, xfs_fsop_geom_t *geometry, - int flags) + int flags, + struct fs_path *fs_path) { char *filename; @@ -131,6 +145,7 @@ addfile( file->flags = flags; file->name = filename; file->geom = *geometry; + memcpy(&file->fs_path, fs_path, sizeof(file->fs_path)); return 0; } diff --git a/spaceman/freesp.c b/spaceman/freesp.c new file mode 100644 index 0000000..2290a5e --- /dev/null +++ b/spaceman/freesp.c @@ -0,0 +1,367 @@ +/* + * Copyright (c) 2000-2001,2005 Silicon Graphics, Inc. + * Copyright (c) 2012 Red Hat, Inc. + * Copyright (c) 2017 Oracle. + * All Rights Reserved. + * + * This program is free software; you can redistribute it and/or + * modify it under the terms of the GNU General Public License as + * published by the Free Software Foundation. + * + * This program is distributed in the hope that it would be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write the Free Software Foundation, + * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA + */ + +#include "libxfs.h" +#include <linux/fiemap.h> +#include "command.h" +#include "init.h" +#include "path.h" +#include "space.h" + +typedef struct histent +{ + int low; + int high; + long long count; + long long blocks; +} histent_t; + +static int agcount; +static xfs_agnumber_t *aglist; +static int dumpflag; +static int equalsize; +static histent_t *hist; +static int histcount; +static int multsize; +static int seen1; +static int summaryflag; +static bool rtflag; +static long long totblocks; +static long long totexts; + +static cmdinfo_t freesp_cmd; + +static void +addhistent( + int h) +{ + hist = realloc(hist, (histcount + 1) * sizeof(*hist)); + if (h == 0) + h = 1; + hist[histcount].low = h; + hist[histcount].count = hist[histcount].blocks = 0; + histcount++; + if (h == 1) + seen1 = 1; +} + +static void +addtohist( + xfs_agnumber_t agno, + xfs_agblock_t agbno, + off64_t len) +{ + int i; + + if (dumpflag) + printf("%8d %8d %8"PRId64"\n", agno, agbno, len); + totexts++; + totblocks += len; + for (i = 0; i < histcount; i++) { + if (hist[i].high >= len) { + hist[i].count++; + hist[i].blocks += len; + break; + } + } +} + +static int +hcmp( + const void *a, + const void *b) +{ + return ((histent_t *)a)->low - ((histent_t *)b)->low; +} + +static void +histinit( + int maxlen) +{ + int i; + + if (equalsize) { + for (i = 1; i < maxlen; i += equalsize) + addhistent(i); + } else if (multsize) { + for (i = 1; i < maxlen; i *= multsize) + addhistent(i); + } else { + if (!seen1) + addhistent(1); + qsort(hist, histcount, sizeof(*hist), hcmp); + } + for (i = 0; i < histcount; i++) { + if (i < histcount - 1) + hist[i].high = hist[i + 1].low - 1; + else + hist[i].high = maxlen; + } +} + +static void +printhist(void) +{ + int i; + + printf("%7s %7s %7s %7s %6s\n", + _("from"), _("to"), _("extents"), _("blocks"), _("pct")); + for (i = 0; i < histcount; i++) { + if (hist[i].count) + printf("%7d %7d %7lld %7lld %6.2f\n", hist[i].low, + hist[i].high, hist[i].count, hist[i].blocks, + hist[i].blocks * 100.0 / totblocks); + } +} + +static int +inaglist( + xfs_agnumber_t agno) +{ + int i; + + if (agcount == 0) + return 1; + for (i = 0; i < agcount; i++) + if (aglist[i] == agno) + return 1; + return 0; +} + +#define NR_EXTENTS 128 + +static void +scan_ag( + xfs_agnumber_t agno) +{ + struct fsmap_head *fsmap; + struct fsmap *extent; + struct fsmap *l, *h; + struct fsmap *p; + off64_t blocksize = file->geom.blocksize; + off64_t bperag; + off64_t aglen; + xfs_agblock_t agbno; + int ret; + int i; + + bperag = (off64_t)file->geom.agblocks * blocksize; + + fsmap = malloc(fsmap_sizeof(NR_EXTENTS)); + if (!fsmap) { + fprintf(stderr, _("%s: fsmap malloc failed.\n"), progname); + exitcode = 1; + return; + } + + memset(fsmap, 0, sizeof(*fsmap)); + fsmap->fmh_count = NR_EXTENTS; + l = fsmap->fmh_keys; + h = fsmap->fmh_keys + 1; + if (agno != NULLAGNUMBER) { + l->fmr_physical = agno * bperag; + h->fmr_physical = ((agno + 1) * bperag) - 1; + l->fmr_device = h->fmr_device = file->fs_path.fs_datadev; + } else { + l->fmr_physical = 0; + h->fmr_physical = ULLONG_MAX; + l->fmr_device = h->fmr_device = file->fs_path.fs_rtdev; + } + h->fmr_owner = ULLONG_MAX; + h->fmr_flags = UINT_MAX; + h->fmr_offset = ULLONG_MAX; + + while (true) { + ret = ioctl(file->fd, FS_IOC_GETFSMAP, fsmap); + if (ret < 0) { + fprintf(stderr, _("%s: FS_IOC_GETFSMAP [\"%s\"]: %s\n"), + progname, file->name, strerror(errno)); + free(fsmap); + exitcode = 1; + return; + } + + /* No more extents to map, exit */ + if (!fsmap->fmh_entries) + break; + + for (i = 0, extent = fsmap->fmh_recs; + i < fsmap->fmh_entries; + i++, extent++) { + if (!(extent->fmr_flags & FMR_OF_SPECIAL_OWNER) || + extent->fmr_owner != XFS_FMR_OWN_FREE) + continue; + agbno = (extent->fmr_physical - (bperag * agno)) / + blocksize; + aglen = extent->fmr_length / blocksize; + + addtohist(agno, agbno, aglen); + } + + p = &fsmap->fmh_recs[fsmap->fmh_entries - 1]; + if (p->fmr_flags & FMR_OF_LAST) + break; + fsmap_advance(fsmap); + } +} +static void +aglistadd( + char *a) +{ + aglist = realloc(aglist, (agcount + 1) * sizeof(*aglist)); + aglist[agcount] = (xfs_agnumber_t)atoi(a); + agcount++; +} + +static int +init( + int argc, + char **argv) +{ + int c; + int speced = 0; + + agcount = dumpflag = equalsize = multsize = optind = 0; + histcount = seen1 = summaryflag = 0; + totblocks = totexts = 0; + aglist = NULL; + hist = NULL; + rtflag = false; + while ((c = getopt(argc, argv, "a:bde:h:m:rs")) != EOF) { + switch (c) { + case 'a': + aglistadd(optarg); + break; + case 'b': + if (speced) + return 0; + multsize = 2; + speced = 1; + break; + case 'd': + dumpflag = 1; + break; + case 'e': + if (speced) + return 0; + equalsize = atoi(optarg); + speced = 1; + break; + case 'h': + if (speced && !histcount) + return 0; + addhistent(atoi(optarg)); + speced = 1; + break; + case 'm': + if (speced) + return 0; + multsize = atoi(optarg); + speced = 1; + break; + case 'r': + rtflag = true; + break; + case 's': + summaryflag = 1; + break; + case '?': + return 0; + } + } + if (optind != argc) + return 0; + if (!speced) + multsize = 2; + histinit(file->geom.agblocks); + return 1; +} + +/* + * Report on freespace usage in xfs filesystem. + */ +static int +freesp_f( + int argc, + char **argv) +{ + xfs_agnumber_t agno; + + if (!init(argc, argv)) + return 0; + if (rtflag) + scan_ag(NULLAGNUMBER); + for (agno = 0; !rtflag && agno < file->geom.agcount; agno++) { + if (inaglist(agno)) + scan_ag(agno); + } + if (histcount) + printhist(); + if (summaryflag) { + printf(_("total free extents %lld\n"), totexts); + printf(_("total free blocks %lld\n"), totblocks); + printf(_("average free extent size %g\n"), + (double)totblocks / (double)totexts); + } + if (aglist) + free(aglist); + if (hist) + free(hist); + return 0; +} + +static void +freesp_help(void) +{ + printf(_( +"\n" +"Examine filesystem free space\n" +"\n" +"Options: [-bdsr] [-a agno] [-e bsize] [-h h1]... [-m bmult]\n" +"\n" +" -a agno -- Scan only the given AG agno.\n" +" -b -- binary histogram bin size\n" +" -d -- debug output\n" +" -e bsize -- Use fixed histogram bin size of bsize\n" +" -h hbsz -- Use custom histogram bin size of h1.\n" +" Multiple specifications are allowed.\n" +" -m bmult -- Use histogram bin size multiplier of bmult.\n" +" -r -- Display realtime device free space information.\n" +" -s -- Emit freespace summary information.\n" +"\n")); + +} + +void +freesp_init(void) +{ + freesp_cmd.name = "freesp"; + freesp_cmd.altname = "fsp"; + freesp_cmd.cfunc = freesp_f; + freesp_cmd.argmin = 0; + freesp_cmd.argmax = -1; + freesp_cmd.args = "[-bdsr] [-a agno] [-e bsize] [-h h1]... [-m bmult]"; + freesp_cmd.flags = CMD_FLAG_ONESHOT; + freesp_cmd.oneline = _("Examine filesystem free space"); + freesp_cmd.help = freesp_help; + + add_command(&freesp_cmd); +} + diff --git a/spaceman/init.c b/spaceman/init.c index 93a8a1e..f3c93c3 100644 --- a/spaceman/init.c +++ b/spaceman/init.c @@ -20,6 +20,7 @@ #include "command.h" #include "input.h" #include "init.h" +#include "path.h" #include "space.h" char *progname; @@ -38,6 +39,7 @@ static void init_commands(void) { file_init(); + freesp_init(); help_init(); prealloc_init(); quit_init(); @@ -71,12 +73,14 @@ init( int c, flags = 0; mode_t mode = 0600; xfs_fsop_geom_t geometry = { 0 }; + struct fs_path fsp; progname = basename(argv[0]); setlocale(LC_ALL, ""); bindtextdomain(PACKAGE, LOCALEDIR); textdomain(PACKAGE); + fs_table_initialise(0, NULL, 0, NULL); while ((c = getopt(argc, argv, "c:V")) != EOF) { switch (c) { case 'c': @@ -93,11 +97,11 @@ init( if (optind != argc - 1) usage(); - if ((c = openfile(argv[optind], &geometry, flags, mode)) < 0) + if ((c = openfile(argv[optind], &geometry, flags, mode, &fsp)) < 0) exit(1); if (!platform_test_xfs_fd(c)) printf(_("Not an XFS filesystem!\n")); - if (addfile(argv[optind], c, &geometry, flags) < 0) + if (addfile(argv[optind], c, &geometry, flags, &fsp) < 0) exit(1); init_commands(); diff --git a/spaceman/prealloc.c b/spaceman/prealloc.c index 71c0d80..55b85ed 100644 --- a/spaceman/prealloc.c +++ b/spaceman/prealloc.c @@ -20,6 +20,7 @@ #include "command.h" #include "input.h" #include "init.h" +#include "path.h" #include "space.h" static cmdinfo_t prealloc_cmd; diff --git a/spaceman/space.h b/spaceman/space.h index 0ae3116..bf9a2df 100644 --- a/spaceman/space.h +++ b/spaceman/space.h @@ -21,6 +21,7 @@ typedef struct fileio { int flags; /* flags describing file state */ char *name; /* file name at time of open */ xfs_fsop_geom_t geom; /* XFS filesystem geometry */ + struct fs_path fs_path; /* XFS path information */ } fileio_t; extern fileio_t *filetable; /* open file table */ @@ -28,11 +29,18 @@ extern int filecount; /* number of open files */ extern fileio_t *file; /* active file in file table */ extern int filelist_f(void); -extern int openfile(char *, xfs_fsop_geom_t *, int, mode_t); -extern int addfile(char *, int , xfs_fsop_geom_t *, int); +extern int openfile(char *, xfs_fsop_geom_t *, int, mode_t, + struct fs_path *); +extern int addfile(char *, int , xfs_fsop_geom_t *, int, struct fs_path *); extern void file_init(void); extern void help_init(void); extern void prealloc_init(void); extern void quit_init(void); extern void trim_init(void); + +#ifdef HAVE_GETFSMAP +extern void freesp_init(void); +#else +# define freesp_init() do { } while (0) +#endif diff --git a/spaceman/trim.c b/spaceman/trim.c index d58f6d1..b5908cc 100644 --- a/spaceman/trim.c +++ b/spaceman/trim.c @@ -20,6 +20,7 @@ #include <linux/fs.h> #include "command.h" #include "init.h" +#include "path.h" #include "space.h" #include "input.h"