X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Ftests%2Ftest_brw.c;h=9d7dacb4de78a06938a89ebb3340976ae39ca9dd;hb=ca62e637647f4d7c68bfb2b9f1b7a1597ae61381;hp=f242eba856362ffbefab4290907e01d7c9dfad61;hpb=c5050e412572b00cbe93d8517d2d1f767bebfa92;p=fs%2Flustre-release.git diff --git a/lustre/tests/test_brw.c b/lustre/tests/test_brw.c index f242eba..9d7dacb 100644 --- a/lustre/tests/test_brw.c +++ b/lustre/tests/test_brw.c @@ -1,10 +1,45 @@ -/* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*- - * vim:expandtab:shiftwidth=8:tabstop=8: +/* + * 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.sun.com/software/products/lustre/docs/GPLv2.pdf + * + * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara, + * CA 95054 USA or visit www.sun.com if you need additional information or + * have any questions. + * + * GPL HEADER END + */ +/* + * Copyright (c) 2002, 2010, Oracle and/or its affiliates. All rights reserved. + * Use is subject to license terms. + * + * Copyright (c) 2014, Intel Corporation. + */ +/* + * This file is part of Lustre, http://www.lustre.org/ + * Lustre is a trademark of Sun Microsystems, Inc. */ /* for O_DIRECT */ -#define _GNU_SOURCE +#ifndef _GNU_SOURCE +#define _GNU_SOURCE +#endif +#include #include #include #include @@ -14,24 +49,15 @@ #include #include #include +#include -#define CERROR(fmt, arg...) fprintf(stderr, fmt, ## arg) -#ifndef __u64 -#define __u64 long long -#define cpu_to_le64(v) (v) -#define le64_to_cpu(v) (v) -#endif - -#ifndef LPU64 -#define LPU64 "%Lu" -#define LPX64 "%#Lx" -#endif +#include #define READ 1 #define WRITE 2 #define LPDS sizeof(__u64) -int page_debug_setup(void *addr, int len, __u64 off, __u64 id) +int block_debug_setup(void *addr, int len, __u64 off, __u64 id) { off = cpu_to_le64(off); id = cpu_to_le64(id); @@ -45,33 +71,33 @@ int page_debug_setup(void *addr, int len, __u64 off, __u64 id) return 0; } -int page_debug_check(char *who, void *addr, int size, __u64 off, __u64 id) +int block_debug_check(char *who, void *addr, int size, uint64_t off, uint64_t id) { - __u64 ne_off; + uint64_t ne_off; int err = 0; ne_off = le64_to_cpu(off); id = le64_to_cpu(id); if (memcmp(addr, (char *)&ne_off, LPDS)) { - CERROR("%s: for offset "LPU64" off: "LPX64" != "LPX64"\n", - who, off, *(__u64 *)addr, ne_off); + fprintf(stderr, "%s: for offset %"PRIu64" off: %"PRIx64" != %"PRIx64"\n", + who, off, *(uint64_t *)addr, ne_off); err = -EINVAL; } if (memcmp(addr + LPDS, (char *)&id, LPDS)) { - CERROR("%s: for offset "LPU64" id: "LPX64" != "LPX64"\n", - who, off, *(__u64 *)(addr + LPDS), id); + fprintf(stderr, "%s: for offset %"PRIu64" id: %"PRIx64" != %"PRIx64"\n", + who, off, *(uint64_t *)(addr + LPDS), id); err = -EINVAL; } addr += size - LPDS - LPDS; if (memcmp(addr, (char *)&ne_off, LPDS)) { - CERROR("%s: for offset "LPU64" end off: "LPX64" != "LPX64"\n", - who, off, *(__u64 *)addr, ne_off); + fprintf(stderr, "%s: for offset %"PRIu64" end off: %"PRIx64" != %"PRIx64"\n", + who, off, *(uint64_t *)addr, ne_off); err = -EINVAL; } if (memcmp(addr + LPDS, (char *)&id, LPDS)) { - CERROR("%s: for offset "LPU64" end id: "LPX64" != "LPX64"\n", - who, off, *(__u64 *)(addr + LPDS), id); + fprintf(stderr, "%s: for offset %"PRIu64" end id: %"PRIx64" != %"PRIx64"\n", + who, off, *(uint64_t *)(addr + LPDS), id); err = -EINVAL; } @@ -93,7 +119,7 @@ int main(int argc, char **argv) char *buf; long long count, last, offset; long pg_vec, len; - long long objid; + uint64_t objid; struct stat st; int flags = 0; int cmd = 0; @@ -118,13 +144,26 @@ int main(int argc, char **argv) flags = O_RDWR | O_CREAT; } if (strchr(argv[3], 'd')) { +#ifdef O_DIRECT flags |= O_DIRECT; +#else + fprintf(stderr, + "%s: O_DIRECT not supported in this build\n", + argv[0]); + exit(1); +#endif } if (!cmd) usage(argv[0]); } else { cmd = READ | WRITE; - flags = O_RDWR | O_CREAT | O_DIRECT; + flags = O_RDWR | O_CREAT; +#ifdef O_DIRECT + flags |= O_DIRECT; +#else + fprintf(stderr, "%s: warning: not setting O_DIRECT\n", + argv[0]); +#endif } if (argc >= 5) { @@ -149,8 +188,13 @@ int main(int argc, char **argv) objid = 3; } - printf("%s: %s on %s(objid "LPX64") for "LPU64"x%ld pages \n", - argv[0], flags & O_DIRECT ? "directio" : "i/o", + printf("%s: %s on %s(objid %"PRIx64") for %llux%ld pages \n", + argv[0], +#ifdef O_DIRECT + flags & O_DIRECT ? "directio" : "i/o", +#else + "i/o", +#endif argv[1], objid, count, pg_vec); fd = open(argv[1], flags | O_LARGEFILE); @@ -181,14 +225,14 @@ int main(int argc, char **argv) int i; for (i = 0; i < len; i += st.st_blksize) - page_debug_setup(buf + i, st.st_blksize, offset + i, - objid); + block_debug_setup(buf + i, st.st_blksize, + offset + i, objid); rc = write(fd, buf, len); for (i = 0; i < len; i += st.st_blksize) { - if (page_debug_check("write", buf + i, st.st_blksize, - offset + i, objid)) + if (block_debug_check("write", buf + i, st.st_blksize, + offset + i, objid)) return 10; } @@ -216,8 +260,8 @@ int main(int argc, char **argv) } for (i = 0; i < len; i += st.st_blksize) { - if (page_debug_check("read", buf + i, st.st_blksize, - offset + i, objid)) + if (block_debug_check("read", buf + i, st.st_blksize, + offset + i, objid)) return 11; } }