From: Brian Foster Date: Fri, 9 Aug 2013 12:32:26 +0000 (+0000) Subject: xfsprogs/io: add readdir command X-Git-Tag: v3.2.0-alpha1~71 X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=3bc056410ac054e45a61d7f924527eadb2c92c36;p=thirdparty%2Fxfsprogs-dev.git xfsprogs/io: add readdir command readdir reads the directory entries from an open directory from the provided offset (or 0 if not specified). On completion, readdir prints summary information regarding the number of operations and bytes transferred. Options are available to specify the starting offset, length and verbose mode to dump directory entry information. Signed-off-by: Brian Foster Reviewed-by: Mark Tinguely --- diff --git a/configure.ac b/configure.ac index e5fd94e41..da099d8cb 100644 --- a/configure.ac +++ b/configure.ac @@ -112,6 +112,7 @@ AC_HAVE_FIEMAP AC_HAVE_PREADV AC_HAVE_SYNC_FILE_RANGE AC_HAVE_BLKID_TOPO($enable_blkid) +AC_HAVE_READDIR AC_CHECK_SIZEOF([long]) AC_CHECK_SIZEOF([char *]) diff --git a/include/builddefs.in b/include/builddefs.in index 744e8d347..944bcf6c3 100644 --- a/include/builddefs.in +++ b/include/builddefs.in @@ -103,6 +103,7 @@ HAVE_FALLOCATE = @have_fallocate@ HAVE_FIEMAP = @have_fiemap@ HAVE_PREADV = @have_preadv@ HAVE_SYNC_FILE_RANGE = @have_sync_file_range@ +HAVE_READDIR = @have_readdir@ GCCFLAGS = -funsigned-char -fno-strict-aliasing -Wall # -Wbitwise -Wno-transparent-union -Wno-old-initializer -Wno-decl diff --git a/io/Makefile b/io/Makefile index 50edf91b6..d73f9b901 100644 --- a/io/Makefile +++ b/io/Makefile @@ -80,6 +80,11 @@ ifeq ($(HAVE_PREADV),yes) LCFLAGS += -DHAVE_PREADV -DHAVE_PWRITEV endif +ifeq ($(HAVE_READDIR),yes) +CFILES += readdir.c +LCFLAGS += -DHAVE_READDIR +endif + default: depend $(LTCOMMAND) include $(BUILDRULES) diff --git a/io/init.c b/io/init.c index ca3055af3..ee9976168 100644 --- a/io/init.c +++ b/io/init.c @@ -74,6 +74,7 @@ init_commands(void) fiemap_init(); pwrite_init(); quit_init(); + readdir_init(); resblks_init(); sendfile_init(); shutdown_init(); diff --git a/io/io.h b/io/io.h index 91f0e3e97..e1f5328b6 100644 --- a/io/io.h +++ b/io/io.h @@ -149,3 +149,9 @@ extern void sync_range_init(void); #else #define sync_range_init() do { } while (0) #endif + +#ifdef HAVE_READDIR +extern void readdir_init(void); +#else +#define readdir_init() do { } while (0) +#endif diff --git a/io/readdir.c b/io/readdir.c new file mode 100644 index 000000000..822818aec --- /dev/null +++ b/io/readdir.c @@ -0,0 +1,199 @@ +/* + * Copyright (c) 2013 Red Hat, Inc. + * 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 +#include +#include +#include "init.h" +#include "io.h" + +#include +#include + +static struct cmdinfo readdir_cmd; + +const char *d_type_str(unsigned int type) +{ + const char *str; + + switch (type) { + case DT_UNKNOWN: + str = "DT_UNKNOWN"; + break; + case DT_FIFO: + str = "DT_FIFO"; + break; + case DT_CHR: + str = "DT_CHR"; + break; + case DT_DIR: + str = "DT_DIR"; + break; + case DT_BLK: + str = "DT_BLK"; + break; + case DT_REG: + str = "DT_REG"; + break; + case DT_LNK: + str = "DT_LNK"; + break; + case DT_SOCK: + str = "DT_SOCK"; + break; + case DT_WHT: + str = "DT_WHT"; + break; + default: + str = "ERROR!"; + break; + } + + return str; +} + +static void +dump_dirent( + long long offset, + struct dirent *dirent) +{ + printf("%08llx: d_ino: 0x%08lx", offset, dirent->d_ino); +#ifdef _DIRENT_HAVE_D_OFF + printf(" d_off: 0x%08lx", dirent->d_off); +#endif +#ifdef _DIRENT_HAVE_D_RECLEN + printf(" d_reclen: 0x%x", dirent->d_reclen); +#endif +#ifdef _DIRENT_HAVE_D_TYPE + printf(" d_type: %s", d_type_str(dirent->d_type)); +#endif + printf(" d_name: %s\n", dirent->d_name); +} + +static int +read_directory( + DIR *dir, + long long offset, + unsigned long long length, + int dump, + unsigned long long *total) +{ + struct dirent *dirent; + int count = 0; + + seekdir(dir, offset); + + *total = 0; + while (*total < length) { + dirent = readdir(dir); + if (!dirent) + break; + + *total += dirent->d_reclen; + count++; + + if (dump) { + dump_dirent(offset, dirent); + offset = dirent->d_off; + } + } + + return count; +} + +static int +readdir_f( + int argc, + char **argv) +{ + int cnt; + unsigned long long total; + int c; + size_t fsblocksize, fssectsize; + struct timeval t1, t2; + char s1[64], s2[64], ts[64]; + long long offset = -1; + unsigned long long length = -1; /* max length limit */ + int verbose = 0; + DIR *dir; + int dfd; + + init_cvtnum(&fsblocksize, &fssectsize); + + while ((c = getopt(argc, argv, "l:o:v")) != EOF) { + switch (c) { + case 'l': + length = cvtnum(fsblocksize, fssectsize, optarg); + break; + case 'o': + offset = cvtnum(fsblocksize, fssectsize, optarg); + break; + case 'v': + verbose = 1; + break; + default: + return command_usage(&readdir_cmd); + } + } + + dfd = dup(file->fd); + if (dfd < 0) + return -1; + + dir = fdopendir(dfd); + if (!dir) { + close(dfd); + return -1; + } + + if (offset == -1) { + rewinddir(dir); + offset = telldir(dir); + } + + gettimeofday(&t1, NULL); + cnt = read_directory(dir, offset, length, verbose, &total); + gettimeofday(&t2, NULL); + + closedir(dir); + + t2 = tsub(t2, t1); + timestr(&t2, ts, sizeof(ts), 0); + + cvtstr(total, s1, sizeof(s1)); + cvtstr(tdiv(total, t2), s2, sizeof(s2)); + + printf(_("read %llu bytes from offset %lld\n"), total, offset); + printf(_("%s, %d ops, %s (%s/sec and %.4f ops/sec)\n"), + s1, cnt, ts, s2, tdiv(cnt, t2)); + + return 0; +} + +void +readdir_init(void) +{ + readdir_cmd.name = "readdir"; + readdir_cmd.cfunc = readdir_f; + readdir_cmd.argmax = 5; + readdir_cmd.flags = CMD_NOMAP_OK|CMD_FOREIGN_OK; + readdir_cmd.args = _("[-v][-o offset][-l length]"); + readdir_cmd.oneline = _("read directory entries"); + + add_command(&readdir_cmd); +} diff --git a/m4/package_libcdev.m4 b/m4/package_libcdev.m4 index f489f527d..8267ba065 100644 --- a/m4/package_libcdev.m4 +++ b/m4/package_libcdev.m4 @@ -170,3 +170,18 @@ AC_DEFUN([AC_HAVE_SYNC_FILE_RANGE], AC_SUBST(have_sync_file_range) ]) +# +# Check if we have a readdir libc call +# +AC_DEFUN([AC_HAVE_READDIR], + [ AC_MSG_CHECKING([for readdir]) + AC_TRY_LINK([ +#include + ], [ + readdir(0); + ], have_readdir=yes + AC_MSG_RESULT(yes), + AC_MSG_RESULT(no)) + AC_SUBST(have_readdir) + ]) + diff --git a/man/man8/xfs_io.8 b/man/man8/xfs_io.8 index 5e3535b0f..ee7ef4e07 100644 --- a/man/man8/xfs_io.8 +++ b/man/man8/xfs_io.8 @@ -397,6 +397,27 @@ must be specified as another open file .RB ( \-f ) or by path .RB ( \-i ). +.TP +.BI "readdir [ -v ] [ -o " offset " ] [ -l " length " ] " +Read a range of directory entries from a given offset of a directory. +.RS 1.0i +.PD 0 +.TP 0.4i +.B \-v +verbose mode - dump dirent content as defined in +.BR readdir (3) +.TP +.B \-o +specify starting +.I offset +.TP +.B \-l +specify total +.I length +to read (in bytes) +.RE +.PD +.TP .SH MEMORY MAPPED I/O COMMANDS .TP @@ -649,4 +670,5 @@ verbose output will be printed. .BR msync (2), .BR open (2), .BR pread (2), -.BR pwrite (2). +.BR pwrite (2), +.BR readdir (3).