xfs
[Top] [All Lists]

[PATCH 4/8] xfstests: add fallocate support to fsstress

To: linux-fsdevel@xxxxxxxxxxxxxxx
Subject: [PATCH 4/8] xfstests: add fallocate support to fsstress
From: Dmitry Monakhov <dmonakhov@xxxxxxxxxx>
Date: Sat, 29 Oct 2011 04:48:13 +0400
Cc: xfs@xxxxxxxxxxx, hch@xxxxxx, aelder@xxxxxxx, Dmitry Monakhov <dmonakhov@xxxxxxxxxx>
Dkim-signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=sender:from:to:cc:subject:date:message-id:x-mailer:in-reply-to :references; bh=Jh0pT7Vm6WTuuJuA9Mui/CNFKU1QI3JwCAbgT1DVI98=; b=ualdD4pcUNl3oeOxxBPll4LDSJ8zGLJ7eeVpcvuXgDDORsN2b+FF/3XUCo68iWqJFU vOVr0P3KYfuahJKTs0TB6vcIZ9A2rBnzqpphGRxajYk+v1bjJ+pIpq+yAaesgjBhFVwJ Jto94V52oUFyM3uL7XpmjWnwdk32aTtUumP2E=
In-reply-to: <1319849297-3506-1-git-send-email-dmonakhov@xxxxxxxxxx>
References: <1319849297-3506-1-git-send-email-dmonakhov@xxxxxxxxxx>
Sender: Dmitry Monakhov <dmonlist@xxxxxxxxx>
Add tests for fallocate(2) syscall
- fallocate: reserve the disk space
- punch: de-allocates the disk space
Since FALLOC_FL_PUNCH_HOLE is relatively new it's value defined
explicitly if not yet defined. Later we may clear that define.

Signed-off-by: Dmitry Monakhov <dmonakhov@xxxxxxxxxx>
---
 ltp/fsstress.c |  127 +++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 126 insertions(+), 1 deletions(-)

diff --git a/ltp/fsstress.c b/ltp/fsstress.c
index 133a247..547bf30 100644
--- a/ltp/fsstress.c
+++ b/ltp/fsstress.c
@@ -24,7 +24,13 @@
 #ifdef HAVE_ATTR_ATTRIBUTES_H
 #include <attr/attributes.h>
 #endif
-
+#ifdef FALLOCATE
+#include <linux/falloc.h>
+#ifndef FALLOC_FL_PUNCH_HOLE
+/* Copy-paste from linux/falloc.h */
+#define FALLOC_FL_PUNCH_HOLE    0x02 /* de-allocates range */
+#endif
+#endif
 #ifndef HAVE_ATTR_LIST
 #define attr_list(path, buf, size, flags, cursor) (errno = -ENOSYS, -1)
 #endif
@@ -48,6 +54,7 @@ typedef enum {
        OP_CREAT,
        OP_DREAD,
        OP_DWRITE,
+       OP_FALLOCATE,
        OP_FDATASYNC,
        OP_FREESP,
        OP_FSYNC,
@@ -55,6 +62,7 @@ typedef enum {
        OP_LINK,
        OP_MKDIR,
        OP_MKNOD,
+       OP_PUNCH,
        OP_READ,
        OP_READLINK,
        OP_RENAME,
@@ -128,6 +136,7 @@ void        chown_f(int, long);
 void   creat_f(int, long);
 void   dread_f(int, long);
 void   dwrite_f(int, long);
+void   fallocate_f(int, long);
 void   fdatasync_f(int, long);
 void   freesp_f(int, long);
 void   fsync_f(int, long);
@@ -135,6 +144,7 @@ void        getdents_f(int, long);
 void   link_f(int, long);
 void   mkdir_f(int, long);
 void   mknod_f(int, long);
+void   punch_f(int, long);
 void   read_f(int, long);
 void   readlink_f(int, long);
 void   rename_f(int, long);
@@ -159,6 +169,7 @@ opdesc_t    ops[] = {
        { OP_CREAT, "creat", creat_f, 4, 1 },
        { OP_DREAD, "dread", dread_f, 4, 0 },
        { OP_DWRITE, "dwrite", dwrite_f, 4, 1 },
+       { OP_FALLOCATE, "fallocate", fallocate_f, 1, 1 },
        { OP_FDATASYNC, "fdatasync", fdatasync_f, 1, 1 },
        { OP_FREESP, "freesp", freesp_f, 1, 1 },
        { OP_FSYNC, "fsync", fsync_f, 1, 1 },
@@ -166,6 +177,7 @@ opdesc_t    ops[] = {
        { OP_LINK, "link", link_f, 1, 1 },
        { OP_MKDIR, "mkdir", mkdir_f, 2, 1 },
        { OP_MKNOD, "mknod", mknod_f, 2, 1 },
+       { OP_PUNCH, "punch", punch_f, 1, 1 },
        { OP_READ, "read", read_f, 1, 0 },
        { OP_READLINK, "readlink", readlink_f, 1, 0 },
        { OP_RENAME, "rename", rename_f, 2, 1 },
@@ -1998,6 +2010,63 @@ dwrite_f(int opno, long r)
 }
 
 void
+fallocate_f(int opno, long r)
+{
+#ifdef FALLOCATE
+       int             e;
+       pathname_t      f;
+       int             fd;
+       __int64_t       lr;
+       off64_t         off;
+       off64_t         len;
+       struct stat64   stb;
+       int             v;
+       char            st[1024];
+       int mode = 0;
+
+       init_pathname(&f);
+       if (!get_fname(FT_REGFILE, r, &f, NULL, NULL, &v)) {
+               if (v)
+                       printf("%d/%d: fallocate - no filename\n", procid, 
opno);
+               free_pathname(&f);
+               return;
+       }
+       fd = open_path(&f, O_RDWR);
+       e = fd < 0 ? errno : 0;
+       check_cwd();
+       if (fd < 0) {
+               if (v)
+                       printf("%d/%d: fallocate - open %s failed %d\n",
+                               procid, opno, f.path, e);
+               free_pathname(&f);
+               return;
+       }
+       if (fstat64(fd, &stb) < 0) {
+               if (v)
+                       printf("%d/%d: fallocate - fstat64 %s failed %d\n",
+                               procid, opno, f.path, errno);
+               free_pathname(&f);
+               close(fd);
+               return;
+       }
+       inode_info(st, sizeof(st), &stb, v);
+       lr = ((__int64_t)random() << 32) + random();
+       off = (off64_t)(lr % MIN(stb.st_size + (1024 * 1024), MAXFSIZE));
+       off %= maxfsize;
+       len = (off64_t)(random() % (1024 * 1024));
+       mode |= FALLOC_FL_KEEP_SIZE & random();
+       e = fallocate(fd, mode, (loff_t)off, (loff_t)len) < 0 ? errno : 0;
+       if (v)
+               printf("%d/%d: fallocate(%d) %s %st %lld %lld %d\n",
+                      procid, opno, mode,
+                      f.path, st, (long long)off, (long long)len, e);
+       free_pathname(&f);
+       close(fd);
+#endif
+}
+
+
+void
 fdatasync_f(int opno, long r)
 {
        int             e;
@@ -2270,6 +2339,62 @@ mknod_f(int opno, long r)
 }
 
 void
+punch_f(int opno, long r)
+{
+#ifdef FALLOCATE
+       int             e;
+       pathname_t      f;
+       int             fd;
+       __int64_t       lr;
+       off64_t         off;
+       off64_t         len;
+       struct stat64   stb;
+       int             v;
+       char            st[1024];
+       int mode = FALLOC_FL_PUNCH_HOLE;
+
+       init_pathname(&f);
+       if (!get_fname(FT_REGFILE, r, &f, NULL, NULL, &v)) {
+               if (v)
+                       printf("%d/%d: punch hole - no filename\n", procid, 
opno);
+               free_pathname(&f);
+               return;
+       }
+       fd = open_path(&f, O_RDWR);
+       e = fd < 0 ? errno : 0;
+       check_cwd();
+       if (fd < 0) {
+               if (v)
+                       printf("%d/%d: punch hole - open %s failed %d\n",
+                               procid, opno, f.path, e);
+               free_pathname(&f);
+               return;
+       }
+       if (fstat64(fd, &stb) < 0) {
+               if (v)
+                       printf("%d/%d: punch hole - fstat64 %s failed %d\n",
+                               procid, opno, f.path, errno);
+               free_pathname(&f);
+               close(fd);
+               return;
+       }
+       inode_info(st, sizeof(st), &stb, v);
+       lr = ((__int64_t)random() << 32) + random();
+       off = (off64_t)(lr % MIN(stb.st_size + (1024 * 1024), MAXFSIZE));
+       off %= maxfsize;
+       len = (off64_t)(random() % (1024 * 1024));
+       mode |= FALLOC_FL_KEEP_SIZE & random();
+       e = fallocate(fd, mode, (loff_t)off, (loff_t)len) < 0 ? errno : 0;
+       if (v)
+               printf("%d/%d: punch hole(%d) %s %s %lld %lld %d\n",
+                      procid, opno, mode,
+                      f.path, st, (long long)off, (long long)len, e);
+       free_pathname(&f);
+       close(fd);
+#endif
+}
+
+void
 read_f(int opno, long r)
 {
        char            *buf;
-- 
1.7.1

<Prev in Thread] Current Thread [Next in Thread>