]> git.apps.os.sepia.ceph.com Git - xfstests-dev.git/commitdiff
fsync-tester: reopen files with correct flags
authorDave Chinner <dchinner@redhat.com>
Sun, 7 Feb 2016 22:27:10 +0000 (09:27 +1100)
committerDave Chinner <david@fromorbit.com>
Sun, 7 Feb 2016 22:27:10 +0000 (09:27 +1100)
When "drop caches" tests are run, the test_fd is closed and
re-opened. It is reopened O_RDWR, so dropping O_DIRECT and any other
open flag that was set for test_fd. This fixes a random generic/311
failure due to file data corruption I've been seeing on subtests 11
and 13 when direct IO was specified.

Signed-off-by: Dave Chinner <dchinner@redhat.com>
Reviewed-by: Eric Sandeen <sandeen@redhat.com>
Signed-off-by: Dave Chinner <david@fromorbit.com>
src/fsync-tester.c

index 657e00f104ad8d110e8f0b054cb85a1fc38d1fa6..417187491c6d92483d0cda56e0cd7d44fea01795 100644 (file)
@@ -12,6 +12,7 @@
 static int test_fd;
 static char *buf;
 static char *fname;
+static int openflags = O_RDWR;
 
 /*
  * Just creates a random file, overwriting the file in a random number of loops
@@ -139,7 +140,7 @@ static int test_three(int *max_blocks, int prealloc, int rand_fsync,
                        if (drop_caches) {
                                close(test_fd);
                                drop_all_caches();
-                               test_fd = open(fname, O_RDWR);
+                               test_fd = open(fname, openflags);
                                if (test_fd < 0) {
                                        test_fd = 0;
                                        fprintf(stderr, "Error re-opening file: %d\n",
@@ -381,7 +382,6 @@ int main(int argc, char **argv)
        long int test = 1;
        long int tmp;
        int ret = 0;
-       int flags = O_RDWR|O_CREAT|O_TRUNC;
 
        if (argc < 2)
                usage();
@@ -435,7 +435,7 @@ int main(int argc, char **argv)
        srandom(seed);
 
        if (direct_io) {
-               flags |= O_DIRECT;
+               openflags |= O_DIRECT;
                ret = posix_memalign((void **)&buf, getpagesize(), 4096);
                if (ret) {
                        fprintf(stderr, "Error allocating buf: %d\n", ret);
@@ -449,7 +449,7 @@ int main(int argc, char **argv)
                }
        }
 
-       test_fd = open(fname, flags, 0644);
+       test_fd = open(fname, openflags | O_CREAT | O_TRUNC, 0644);
        if (test_fd < 0) {
                fprintf(stderr, "Error opening file %d (%s)\n", errno,
                        strerror(errno));