src/locktest: Add truncate lease tests
authorIra Weiny <ira.weiny@intel.com>
Mon, 23 Sep 2019 17:53:34 +0000 (10:53 -0700)
committerEryu Guan <guaneryu@gmail.com>
Sun, 13 Oct 2019 11:10:41 +0000 (19:10 +0800)
Add verification of signal reception on truncate:

/*  9 */"Write lease gets SIGIO on truncate",
/* 10 */"Read lease gets SIGIO on truncate",

Signed-off-by: Ira Weiny <ira.weiny@intel.com>
Reviewed-by: Eryu Guan <guaneryu@gmail.com>
Signed-off-by: Eryu Guan <guaneryu@gmail.com>
src/locktest.c

index be71866860e2480a15260e39c7ec68efdd6392d5..8696966fad97b3588374178e2dbe43a3b7e52f50 100644 (file)
@@ -102,6 +102,7 @@ static HANDLE       f_fd = INVALID_HANDLE;  /* shared file      */
 #define        CMD_GETLEASE    8
 #define                CMD_SIGIO       9
 #define                CMD_WAIT_SIGIO  10
+#define                CMD_TRUNCATE    11
 
 #define                PASS    1
 #define                FAIL    0
@@ -133,6 +134,7 @@ static char *get_cmd_str(int cmd)
                case CMD_GETLEASE: return "Get Lease"; break;
                case CMD_SIGIO:    return "Setup SIGIO"; break;
                case CMD_WAIT_SIGIO: return "Wait for SIGIO"; break;
+               case CMD_TRUNCATE: return "Truncate"; break;
        }
        return "unknown";
 }
@@ -574,6 +576,8 @@ char *lease_descriptions[] = {
     /*  6 */"Write lease gets SIGIO on read open",
     /*  7 */"Read lease does _not_ get SIGIO on read open",
     /*  8 */"Read lease gets SIGIO on write open",
+    /*  9 */"Write lease gets SIGIO on truncate",
+    /* 10 */"Read lease gets SIGIO on truncate",
 };
 
 static int64_t lease_tests[][6] =
@@ -654,6 +658,25 @@ static int64_t lease_tests[][6] =
                {8,     CMD_CLOSE,      0,              0,      PASS,           SERVER  },
                {8,     CMD_CLOSE,      0,              0,      PASS,           CLIENT  },
 
+       /* Get SIGIO when Write lease is broken by Truncate */
+               {9,     CMD_OPEN,       O_RDWR,         0,      PASS,           CLIENT  },
+               {9,     CMD_SETLEASE,   F_WRLCK,        0,      PASS,           CLIENT  },
+               {9,     CMD_GETLEASE,   F_WRLCK,        0,      PASS,           CLIENT  },
+               {9,     CMD_SIGIO,      0,              0,      PASS,           CLIENT  },
+               {9,     CMD_TRUNCATE,   FILE_SIZE/2,    0,      PASS,           CLIENT  },
+               {9,     CMD_WAIT_SIGIO, 5,              0,      PASS,           CLIENT  },
+               {9,     CMD_CLOSE,      0,              0,      PASS,           CLIENT  },
+
+       /* Get SIGIO when Read lease is broken by Truncate */
+               {10,    CMD_OPEN,       O_RDONLY,       0,      PASS,           CLIENT  },
+               {10,    CMD_SETLEASE,   F_RDLCK,        0,      PASS,           CLIENT  },
+               {10,    CMD_GETLEASE,   F_RDLCK,        0,      PASS,           CLIENT  },
+               {10,    CMD_SIGIO,      0,              0,      PASS,           CLIENT  },
+               {10,    CMD_TRUNCATE,   FILE_SIZE/2,    0,      PASS,           SERVER  },
+               {10,    CMD_WAIT_SIGIO, 5,              0,      PASS,           CLIENT  },
+               {10,    CMD_CLOSE,      0,              0,      PASS,           CLIENT  },
+
+
        /* indicate end of array */
                {0,0,0,0,0,SERVER},
                {0,0,0,0,0,CLIENT}
@@ -717,6 +740,27 @@ initialize(HANDLE fd)
     }
 }
 
+static int do_truncate(size_t length)
+{
+    int rc;
+
+    if (debug)
+       fprintf(stderr, "truncating to %ld\n", length);
+
+again:
+    rc = truncate(filename, length);
+    if (rc && errno == EINTR)
+       goto again;
+
+    saved_errno = errno;
+
+    if (rc)
+       fprintf(stderr, "%s %d : %s\n",
+               __FILE__, errno, strerror(errno));
+
+    return (rc == 0 ? PASS:FAIL);
+}
+
 void release_lease(int fd)
 {
        int rc;
@@ -1245,6 +1289,9 @@ int run(int64_t tests[][6], char *descriptions[])
                        case CMD_WAIT_SIGIO:
                            result = do_wait_sigio(tests[index][TIME]);
                            break;
+                       case CMD_TRUNCATE:
+                           result = do_truncate(tests[index][OFFSET]);
+                           break;
                    }
                    if( result != tests[index][RESULT]) {
                        fail_flag++;
@@ -1356,6 +1403,9 @@ int run(int64_t tests[][6], char *descriptions[])
                case CMD_WAIT_SIGIO:
                    result = do_wait_sigio(ctl.offset);
                    break;
+               case CMD_TRUNCATE:
+                   result = do_truncate(ctl.offset);
+                   break;
            }
            if( result != ctl.result ) {
                fprintf(stderr,"Failure in %d:%s\n",