X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Ftests%2Fopenunlink.c;h=70768b08c5c3cf8eb1744bc0715ae014c61d0993;hb=3afd06e2dc99a0a9a1f267b8a80c8e5208917856;hp=e7671c842bb8d025f7f0479d582997e65358d40c;hpb=93acd158c57c4c5d0fc751d46741231490c04707;p=fs%2Flustre-release.git diff --git a/lustre/tests/openunlink.c b/lustre/tests/openunlink.c index e7671c8..70768b0 100644 --- a/lustre/tests/openunlink.c +++ b/lustre/tests/openunlink.c @@ -1,24 +1,56 @@ +/* + * GPL HEADER START + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License version 2 only, + * as published by the Free Software Foundation. + * + * This program is distributed in the hope that it will 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 version 2 for more details (a copy is included + * in the LICENSE file that accompanied this code). + * + * You should have received a copy of the GNU General Public License + * version 2 along with this program; If not, see + * http://www.gnu.org/licenses/gpl-2.0.html + * + * GPL HEADER END + */ +/* + * Copyright (c) 2002, 2010, Oracle and/or its affiliates. All rights reserved. + * Use is subject to license terms. + */ +/* + * This file is part of Lustre, http://www.lustre.org/ + * Lustre is a trademark of Sun Microsystems, Inc. + */ + #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; - int fd, rc; + struct stat st; + int fd, rc; - if (argc < 2 || argc > 3) { - fprintf(stderr, "usage: %s filename [filename2]\n", argv[0]); - exit(1); - } + if (argc < 2 || argc > 3) { + fprintf(stderr, "usage: %s filename [filename2]\n", argv[0]); + exit(1); + } fname = argv[1]; if (argc == 3) @@ -26,122 +58,127 @@ int main(int argc, char **argv) else fname2 = argv[1]; - fprintf(stderr, "opening\n"); - 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, "opening\n"); + 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 (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 (normal) %s (rc %d)\n", + strerror(errno), rc); + exit(1); + } if (argc == 3) { - fprintf(stderr, "closing %s\n", fname); - rc = close(fd); - if (rc) { - fprintf(stderr, "close (normal) %s\n", strerror(errno)); - exit(1); - } - - fprintf(stderr, "opening %s\n", fname2); - fd = open(fname2, O_RDWR); - if (fd == -1) { - fprintf(stderr, "open (unlink) %s\n", strerror(errno)); - exit(1); - } - - fprintf (stderr, "unlinking %s\n", fname2); + fprintf(stderr, "unlinking %s\n", fname2); rc = unlink(fname2); if (rc) { fprintf(stderr, "unlink %s\n", strerror(errno)); exit(1); } - - if (access(fname2, F_OK) == 0) { - fprintf(stderr, "%s still exists\n", fname2); - exit(1); - } } else { printf("unlink %s and press enter\n", fname); getc(stdin); } + fprintf(stderr, "accessing (1)\n"); if (access(fname, F_OK) == 0) { fprintf(stderr, "%s still exists\n", fname); exit(1); } - fprintf(stderr, "reading\n"); - 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) ) { - fprintf(stderr, "FAILURE: read wrong data after unlink\n"); - exit(1); - } - - fprintf(stderr, "truncating\n"); - 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) { - 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 (after unlink trunc) %s (rc %d)\n", - strerror(errno), rc); - exit(1); - } - - fprintf(stderr, "seeking\n"); - rc = lseek(fd, 0, SEEK_SET); - 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 unlink rewrite) %s\n", - strerror(errno)); - exit(1); - } - - fprintf(stderr, "comparing data again\n"); - 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 (unlink) %s\n", strerror(errno)); - exit(1); - } - - fprintf(stderr, "SUCCESS - goto beer\n"); - return 0; + fprintf(stderr, "seeking (1)\n"); + rc = lseek(fd, 0, SEEK_SET); + if (rc) { + fprintf(stderr, "seek %s\n", strerror(errno)); + exit(1); + } + + fprintf(stderr, "accessing (2)\n"); + 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 (unlink) %s (rc %d)\n", + strerror(errno), rc); + exit(1); + } + + fprintf(stderr, "comparing data\n"); + if (memcmp(buf, T1, strlen(T1) + 1)) { + fprintf(stderr, "FAILURE: read wrong data after unlink\n"); + exit(1); + } + + fprintf(stderr, "truncating\n"); + rc = ftruncate(fd, 0); + if (rc) { + fprintf(stderr, "truncate (unlink) %s\n", strerror(errno)); + exit(1); + } + + fprintf(stderr, "seeking (2)\n"); + rc = lseek(fd, 0, SEEK_SET); + 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 (after unlink trunc) %s (rc %d)\n", + strerror(errno), rc); + exit(1); + } + + fprintf(stderr, "seeking (3)\n"); + rc = lseek(fd, 0, SEEK_SET); + 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 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 rewrite\n"); + 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; }