X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Ftests%2Fopenunlink.c;h=4a0d8c3a67dd3fdeca7bc1f65acf16c0d070b815;hb=4ecae3cd5af60e389eba1e6eff2913b09f557203;hp=dddf6a81b226de714fc4de53609ab6c2a50b9612;hpb=390e94b1eafeeafef096eff57f2436ef77d1f18c;p=fs%2Flustre-release.git diff --git a/lustre/tests/openunlink.c b/lustre/tests/openunlink.c index dddf6a8..4a0d8c3 100644 --- a/lustre/tests/openunlink.c +++ b/lustre/tests/openunlink.c @@ -1,122 +1,155 @@ +/* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*- + * vim:expandtab:shiftwidth=8:tabstop=8: + */ #include #include #include #include -#include +#include +#include #include #include -#define T1 "write before unlink\n" -#define T2 "write after unlink\n" +#define T1 "write data before unlink\n" +#define T2 "write data after unlink\n" char buf[128]; int main(int argc, char **argv) { + char *fname, *fname2; + struct stat st; int fd, rc; - if (argc != 2) { - fprintf(stderr, "usage: %s filename\n", argv[1]); + if (argc < 2 || argc > 3) { + fprintf(stderr, "usage: %s filename [filename2]\n", argv[0]); exit(1); - } else { - fprintf(stderr, "congratulations - program starting\n"); } + fname = argv[1]; + if (argc == 3) + fname2 = argv[2]; + else + fname2 = argv[1]; + fprintf(stderr, "opening\n"); - fd = open(argv[1], O_RDWR | O_TRUNC | O_CREAT, 0644); - if (fd == -1) { - fprintf(stderr, "open (before) %s\n", strerror(errno)); - exit(1); + fd = open(fname, O_RDWR | O_TRUNC | O_CREAT, 0644); + if (fd == -1) { + fprintf(stderr, "open (normal) %s\n", strerror(errno)); + exit(1); } fprintf(stderr, "writing\n"); - rc = write(fd, T1, strlen(T1) + 1); - if (rc != strlen(T1) + 1) { - fprintf(stderr, "write (before) %s\n", strerror(errno)); - exit(1); + rc = write(fd, T1, strlen(T1) + 1); + if (rc != strlen(T1) + 1) { + fprintf(stderr, "write (normal) %s (rc %d)\n", + strerror(errno), rc); + exit(1); } - fprintf(stderr, "closing\n"); - rc = close(fd); - if (rc ) { - fprintf(stderr, "close (before) %s\n", strerror(errno)); - exit(1); + if (argc == 3) { + fprintf (stderr, "unlinking %s\n", fname2); + rc = unlink(fname2); + if (rc) { + fprintf(stderr, "unlink %s\n", strerror(errno)); + exit(1); + } + } else { + printf("unlink %s and press enter\n", fname); + getc(stdin); } - fprintf(stderr, "opening again\n"); - fd = open(argv[1], O_RDWR ); - if (fd == -1) { - fprintf(stderr, "open (before) %s\n", strerror(errno)); - exit(1); + if (access(fname, F_OK) == 0) { + fprintf(stderr, "%s still exists\n", fname2); + exit(1); } - fprintf(stderr, "unlinking\n"); - rc = unlink(argv[1]); - if (rc ) { - fprintf(stderr, "open %s\n", strerror(errno)); - exit(1); + fprintf(stderr, "resetting fd offset\n"); + rc = lseek(fd, 0, SEEK_SET); + if (rc) { + fprintf(stderr, "seek %s\n", strerror(errno)); + exit(1); + } + + if (access(fname, F_OK) == 0) { + fprintf(stderr, "%s still exists\n", fname); + exit(1); + } + + fprintf(stderr, "fstat...\n"); + rc = fstat(fd, &st); + if (rc) { + fprintf(stderr, "fstat (unlink) %s\n", strerror(errno)); + exit(1); } + if (st.st_nlink != 0) + fprintf(stderr, "st_nlink = %d\n", (int)st.st_nlink); fprintf(stderr, "reading\n"); - rc = read(fd, buf, strlen(T1) + 1); - if (rc != strlen(T1) + 1) { - fprintf(stderr, "read -after %s rc %d\n", strerror(errno), rc); - exit(1); + rc = read(fd, buf, strlen(T1) + 1); + if (rc != strlen(T1) + 1) { + fprintf(stderr, "read (unlink) %s (rc %d)\n", + strerror(errno), rc); + exit(1); } fprintf(stderr, "comparing data\n"); - if (memcmp(buf, T1, strlen(T1) + 1) ) { + if (memcmp(buf, T1, strlen(T1) + 1) ) { fprintf(stderr, "FAILURE: read wrong data after unlink\n"); - exit(1); - } + exit(1); + } fprintf(stderr, "truncating\n"); - rc = ftruncate(fd, 0); - if (rc ) { - fprintf(stderr, "truncate -after unl %s\n", strerror(errno)); - exit(1); + rc = ftruncate(fd, 0); + if (rc) { + fprintf(stderr, "truncate (unlink) %s\n", strerror(errno)); + exit(1); } - + fprintf(stderr, "seeking\n"); rc = lseek(fd, 0, SEEK_SET); - if (rc != 0 ) { - fprintf(stderr, "seek (before write) %s\n", strerror(errno)); - exit(1); + if (rc) { + fprintf(stderr, "seek (after unlink trunc) %s\n", + strerror(errno)); + exit(1); } fprintf(stderr, "writing again\n"); - rc = write(fd, T2, strlen(T2) + 1); - if (rc != strlen(T2) + 1) { - fprintf(stderr, "write (before) %s (rc %d)\n", strerror(errno), rc); - exit(1); + rc = write(fd, T2, strlen(T2) + 1); + if (rc != strlen(T2) + 1) { + fprintf(stderr, "write (after unlink trunc) %s (rc %d)\n", + strerror(errno), rc); + exit(1); } fprintf(stderr, "seeking\n"); rc = lseek(fd, 0, SEEK_SET); - if (rc != 0 ) { - fprintf(stderr, "seek (before read) %s\n", strerror(errno)); - exit(1); + if (rc) { + fprintf(stderr, "seek (before unlink read) %s\n", + strerror(errno)); + exit(1); } fprintf(stderr, "reading again\n"); - rc = read(fd, buf, strlen(T2) + 1); - if (rc != strlen(T2) + 1) { - fprintf(stderr, "read (after trunc) %s\n", strerror(errno)); - exit(1); + rc = read(fd, buf, strlen(T2) + 1); + if (rc != strlen(T2) + 1) { + fprintf(stderr, "read (after unlink rewrite) %s (rc %d)\n", + strerror(errno), rc); + exit(1); } fprintf(stderr, "comparing data again\n"); - if (memcmp(buf, T2, strlen(T2) + 1) ) { - fprintf(stderr, "FAILURE: read wrong data after trunc\n"); - exit(1); - } + if (memcmp(buf, T2, strlen(T2) + 1)) { + fprintf(stderr, "FAILURE: read wrong data after rewrite\n"); + exit(1); + } - fprintf(stderr, "closing again\n"); - rc = close(fd); - if (rc ) { - fprintf(stderr, "close (before) %s\n", strerror(errno)); - exit(1); + fprintf(stderr, "closing\n"); + rc = close(fd); + if (rc) { + fprintf(stderr, "close (unlink) %s\n", strerror(errno)); + exit(1); } - fprintf(stderr, "SUCCESS - goto beer\n"); - return 0; + fprintf(stderr, "SUCCESS - goto beer\n"); + return 0; }