X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Ftests%2Fll_dirstripe_verify.c;h=0cdddeb1bd6e7a78db812fe533514ed5ab91f474;hb=1101120d3258509fa74f952cd8664bfdc17bd97d;hp=310587d5fc7863d9a1ccbd9fbde5f78fb7844325;hpb=fbb7ead129258897f5a5d5c9ce28d31fbbe5bca2;p=fs%2Flustre-release.git diff --git a/lustre/tests/ll_dirstripe_verify.c b/lustre/tests/ll_dirstripe_verify.c index 310587d..0cdddeb 100644 --- a/lustre/tests/ll_dirstripe_verify.c +++ b/lustre/tests/ll_dirstripe_verify.c @@ -1,5 +1,39 @@ -/* -*- 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) 2004, 2010, Oracle and/or its affiliates. All rights reserved. + * Use is subject to license terms. + * + * Copyright (c) 2011, 2014, Intel Corporation. + */ +/* + * This file is part of Lustre, http://www.lustre.org/ + * Lustre is a trademark of Sun Microsystems, Inc. + * + * lustre/tests/ll_dirstripe_verify.c * * ll_dirstripe_verify : * - to verify if the file has the same lov_user_md setting as the parent dir. @@ -10,194 +44,266 @@ #include #include #include +#include #include #include #include #include #include -#include -#include -#include -#include -#include +#include +#include -#include +#define MAX_LOV_UUID_COUNT 1000 +/* Returns bytes read on success and a negative value on failure. + * If zero bytes are read it will be treated as failure as such + * zero cannot be returned from this function. + */ +int read_proc_entry(char *proc_path, char *buf, int len) +{ + int rc, fd; -#define MAX_LOV_UUID_COUNT 1000 + memset(buf, 0, len); -int compare(struct lov_user_md *lum_dir, struct lov_user_md *lum_file1, - struct lov_user_md *lum_file2) + fd = open(proc_path, O_RDONLY); + if (fd < 0) { + llapi_error(LLAPI_MSG_ERROR, -errno, "cannot open '%s'", + proc_path); + return -2; + } + + rc = read(fd, buf, len - 1); + if (rc < 0) { + llapi_error(LLAPI_MSG_ERROR, -errno, + "error reading from '%s'", proc_path); + rc = -3; + } else if (rc == 0) { + llapi_err_noerrno(LLAPI_MSG_ERROR, + "read zero bytes from '%s'", proc_path); + rc = -4; + } else if (buf[rc - 1] == '\n') { + buf[rc - 1] = '\0'; /* Remove trailing newline */ + } + + close(fd); + + return rc; +} + +int compare(struct obd_uuid *puuid, struct lov_user_md *lum_dir, + struct lov_user_md *lum_file1, struct lov_user_md *lum_file2) { - int stripe_count; - int stripe_size; - int stripe_offset; - int ost_count; - int fd; - char buf[32]; - int i; - - stripe_count = (int)lum_dir->lmm_stripe_count; + int stripe_count = 0, min_stripe_count = 0, def_stripe_count = 1; + int stripe_size = 0; + int stripe_offset = -1; + int ost_count; + char buf[128]; + glob_t path; + int i; + + if (cfs_get_param_paths(&path, "lov/%s/stripecount", puuid->uuid) != 0) + return 2; + if (read_proc_entry(path.gl_pathv[0], buf, sizeof(buf)) < 0) { + cfs_free_param_data(&path); + return 5; + } + cfs_free_param_data(&path); + def_stripe_count = (short)atoi(buf); + + if (cfs_get_param_paths(&path, "lov/%s/numobd", puuid->uuid) != 0) + return 2; + if (read_proc_entry(path.gl_pathv[0], buf, sizeof(buf)) < 0) { + cfs_free_param_data(&path); + return 6; + } + cfs_free_param_data(&path); + ost_count = atoi(buf); + + if (lum_dir == NULL) { + stripe_count = def_stripe_count; + min_stripe_count = -1; + } else { + stripe_count = (signed short)lum_dir->lmm_stripe_count; + printf("dir stripe %d, ", stripe_count); + min_stripe_count = 1; + } + + printf("default stripe %d, ost count %d\n", + def_stripe_count, ost_count); + if (stripe_count == 0) { - fd = open("/proc/fs/lustre/llite/fs0/lov/stripecount", O_RDONLY); - if (fd == -1) { - fprintf(stderr, "open proc file error: %s\n", - strerror(errno)); - return -1; - } - if (read(fd, buf, sizeof(buf)) == -1) { - fprintf(stderr, "read proc file error: %s\n", - strerror(errno)); - close(fd); - return -1; - } - - stripe_count = atoi(buf); - stripe_count = stripe_count ? stripe_count : 1; - close(fd); + min_stripe_count = -1; + stripe_count = 1; + } + + stripe_count = (stripe_count > 0 && stripe_count <= ost_count) ? + stripe_count : ost_count; + min_stripe_count = min_stripe_count > 0 ? stripe_count : + ((stripe_count + 1) / 2); + + if (lum_file1->lmm_stripe_count != stripe_count || + lum_file1->lmm_stripe_count < min_stripe_count) { + llapi_err_noerrno(LLAPI_MSG_ERROR, + "file1 stripe count %d != dir %d\n", + lum_file1->lmm_stripe_count, stripe_count); + return 7; } - stripe_size = (int)lum_dir->lmm_stripe_size; + if (lum_file1->lmm_stripe_count < stripe_count) + llapi_err_noerrno(LLAPI_MSG_WARN, + "warning: file1 used fewer stripes" + " %d < dir %d (likely due to bug 4900)\n", + lum_file1->lmm_stripe_count, stripe_count); + + if (lum_dir != NULL) + stripe_size = (int)lum_dir->lmm_stripe_size; if (stripe_size == 0) { - fd = open("/proc/fs/lustre/llite/fs0/lov/stripesize", O_RDONLY); - if (fd == -1) { - fprintf(stderr, "open proc file error: %s\n", - strerror(errno)); - return -1; - } - if (read(fd, buf, sizeof(buf)) == -1) { - fprintf(stderr, "read proc file error: %s\n", - strerror(errno)); - close(fd); - return -1; - } + if (cfs_get_param_paths(&path, "lov/%s/stripesize", + puuid->uuid) != 0) + return 2; + if (read_proc_entry(path.gl_pathv[0], buf, sizeof(buf)) < 0) { + cfs_free_param_data(&path); + return 5; + } + cfs_free_param_data(&path); stripe_size = atoi(buf); - close(fd); } - fd = open("/proc/fs/lustre/llite/fs0/lov/numobd", O_RDONLY); - if(fd == -1) { - fprintf(stderr, "open proc file error: %s\n", - strerror(errno)); - return -1; - } - if (read(fd, buf, sizeof(buf)) == -1) { - fprintf(stderr, "read proc file error: %s\n", - strerror(errno)); - close(fd); - return -1; + if (lum_file1->lmm_stripe_size != stripe_size) { + llapi_err_noerrno(LLAPI_MSG_ERROR, + "file1 stripe size %d != dir %d\n", + lum_file1->lmm_stripe_size, stripe_size); + return 8; } - ost_count = atoi(buf); - close(fd); - - if ((lum_file1->lmm_stripe_count != stripe_count) || - (lum_file1->lmm_stripe_size != stripe_size)) - { - return -1; - } - - stripe_offset = (short int)lum_dir->lmm_stripe_offset; + if (lum_dir != NULL) + stripe_offset = (short int)lum_dir->lmm_stripe_offset; if (stripe_offset != -1) { for (i = 0; i < stripe_count; i++) - if (lum_file1->lmm_objects[i].l_ost_idx != - (stripe_offset + i) % ost_count) - return -1; + if (lum_file1->lmm_objects[i].l_ost_idx != + (stripe_offset + i) % ost_count) { + llapi_err_noerrno(LLAPI_MSG_WARN, + "warning: file1 non-sequential " + "stripe[%d] %d != %d\n", i, + lum_file1->lmm_objects[i].l_ost_idx, + (stripe_offset + i) % ost_count); + } } else if (lum_file2 != NULL) { - int next, idx; - next = (lum_file1->lmm_objects[stripe_count-1].l_ost_idx + 1) - % ost_count; + int next, idx, stripe = stripe_count - 1; + next = (lum_file1->lmm_objects[stripe].l_ost_idx + 1) % + ost_count; idx = lum_file2->lmm_objects[0].l_ost_idx; - if (idx != next) - return -1; + if (idx != next) { + llapi_err_noerrno(LLAPI_MSG_WARN, + "warning: non-sequential " + "file1 stripe[%d] %d != file2 stripe[0] %d\n", + stripe, lum_file1->lmm_objects[stripe].l_ost_idx, + idx); + } } - return 0; + return 0; } int main(int argc, char **argv) { - DIR * dir; - struct lov_user_md *lum_dir, *lum_file1 = NULL, *lum_file2 = NULL; - int rc; - int lum_size; - char *fname; - - if (argc < 3) { - fprintf(stderr, "Usage: %s [filename2]\n", - argv[0]); - exit(1); - } + struct lov_user_md *lum_dir, *lum_file1 = NULL, *lum_file2 = NULL; + struct obd_uuid uuid; + int lum_size, rc; + DIR *dir; - dir = opendir(argv[1]); - if (dir == NULL) { - fprintf(stderr, "%s opendir failed\n", argv[1]); - return errno; - } + if (argc < 3) { + llapi_err_noerrno(LLAPI_MSG_ERROR, + "Usage: %s [filename2]\n", + argv[0]); + return 1; + } - lum_size = lov_mds_md_size(MAX_LOV_UUID_COUNT); - if ((lum_dir = (struct lov_user_md *)malloc(lum_size)) == NULL) { - fprintf(stderr, "unable to allocate memory for ioctl's"); - return errno; - } - - rc = ioctl(dirfd(dir), LL_IOC_LOV_GETSTRIPE, lum_dir); - if (rc) { - if (errno == ENODATA) { - lum_dir->lmm_stripe_size = 0; - lum_dir->lmm_stripe_count = 0; - lum_dir->lmm_stripe_offset = -1; - } else { - rc = errno; - goto cleanup; - } - } + dir = opendir(argv[1]); + if (dir == NULL) { + rc = -errno; + llapi_error(LLAPI_MSG_ERROR, rc, + "error: %s opendir failed", argv[1]); + return rc; + } - if ((lum_file1 = (struct lov_user_md *)malloc(lum_size)) == NULL) { - fprintf(stderr, "unable to allocate memory for ioctl's"); - rc = errno; - goto cleanup; - } + lum_size = lov_user_md_size(MAX_LOV_UUID_COUNT, LOV_USER_MAGIC); + lum_dir = (struct lov_user_md *)malloc(lum_size); + if (lum_dir == NULL) { + rc = -ENOMEM; + llapi_error(LLAPI_MSG_ERROR, rc, + "error: can't allocate %d bytes " + "for dir EA", lum_size); + goto cleanup; + } - fname = strrchr(argv[2], '/'); - fname++; - strncpy((char *)lum_file1, fname, lum_size); - rc = ioctl(dirfd(dir), IOC_MDC_GETSTRIPE, lum_file1); - if (rc) { - rc = errno; - goto cleanup; - } + rc = llapi_file_get_stripe(argv[1], lum_dir); + if (rc) { + if (rc == -ENODATA) { + free(lum_dir); + lum_dir = NULL; + } else { + llapi_error(LLAPI_MSG_ERROR, rc, + "error: can't get EA for %s", argv[1]); + goto cleanup; + } + } - if (argc == 4) { - if ((lum_file2 = (struct lov_user_md *)malloc(lum_size)) - == NULL) { - fprintf(stderr, - "unable to allocate memory for ioctl's"); - rc = errno; - goto cleanup; - } + /* XXX should be llapi_lov_getname() */ + rc = llapi_file_get_lov_uuid(argv[1], &uuid); + if (rc) { + llapi_error(LLAPI_MSG_ERROR, rc, + "error: can't get lov name for %s", + argv[1]); + return rc; + } - fname = strrchr(argv[3], '/'); - fname++; - strncpy((char *)lum_file2, fname, lum_size); - rc = ioctl(dirfd(dir), IOC_MDC_GETSTRIPE, lum_file2); - if (rc) { - rc = errno; - goto cleanup; - } - } + lum_file1 = malloc(lum_size); + if (lum_file1 == NULL) { + rc = -ENOMEM; + llapi_error(LLAPI_MSG_ERROR, rc, + "error: can't allocate %d bytes for EA", + lum_size); + goto cleanup; + } + + rc = llapi_file_get_stripe(argv[2], lum_file1); + if (rc) { + llapi_error(LLAPI_MSG_ERROR, rc, + "error: unable to get EA for %s", argv[2]); + goto cleanup; + } - rc = compare(lum_dir, lum_file1, lum_file2); + if (argc == 4) { + lum_file2 = (struct lov_user_md *)malloc(lum_size); + if (lum_file2 == NULL) { + rc = -ENOMEM; + llapi_error(LLAPI_MSG_ERROR, rc, + "error: can't allocate %d " + "bytes for file2 EA", lum_size); + goto cleanup; + } + + rc = llapi_file_get_stripe(argv[3], lum_file2); + if (rc) { + llapi_error(LLAPI_MSG_ERROR, rc, + "error: can't get EA for %s", argv[3]); + goto cleanup; + } + } + + rc = compare(&uuid, lum_dir, lum_file1, lum_file2); cleanup: - if (lum_dir != NULL) - free(lum_dir); - if (lum_file1 != NULL) - free(lum_file1); - if (lum_file2 != NULL) - free(lum_file2); + closedir(dir); + if (lum_dir != NULL) + free(lum_dir); + if (lum_file1 != NULL) + free(lum_file1); + if (lum_file2 != NULL) + free(lum_file2); - return rc; + return rc; }