4 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License version 2 only,
8 * as published by the Free Software Foundation.
10 * This program is distributed in the hope that it will be useful, but
11 * WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * General Public License version 2 for more details (a copy is included
14 * in the LICENSE file that accompanied this code).
16 * You should have received a copy of the GNU General Public License
17 * version 2 along with this program; If not, see
18 * http://www.gnu.org/licenses/gpl-2.0.html
23 * Copyright (c) 2004, 2010, Oracle and/or its affiliates. All rights reserved.
24 * Use is subject to license terms.
26 * Copyright (c) 2011, 2014, Intel Corporation.
29 * This file is part of Lustre, http://www.lustre.org/
30 * Lustre is a trademark of Sun Microsystems, Inc.
32 * lustre/tests/ll_dirstripe_verify.c
34 * ll_dirstripe_verify <dir> <file>:
35 * - to verify if the file has the same lov_user_md setting as the parent dir.
36 * - if dir's offset is set -1, ll_dirstripe_verify <dir> <file1> <file2>
37 * is used to further verify if file1 and file2's obdidx is continuous.
44 #include <sys/ioctl.h>
50 #include <libcfs/util/param.h>
51 #include <lustre/lustreapi.h>
53 #define MAX_LOV_UUID_COUNT 1000
55 /* Returns bytes read on success and a negative value on failure.
56 * If zero bytes are read it will be treated as failure as such
57 * zero cannot be returned from this function.
59 int read_proc_entry(char *proc_path, char *buf, int len)
65 fd = open(proc_path, O_RDONLY);
67 llapi_error(LLAPI_MSG_ERROR, -errno, "cannot open '%s'",
72 rc = read(fd, buf, len - 1);
74 llapi_error(LLAPI_MSG_ERROR, -errno,
75 "error reading from '%s'", proc_path);
78 llapi_err_noerrno(LLAPI_MSG_ERROR,
79 "read zero bytes from '%s'", proc_path);
81 } else if (buf[rc - 1] == '\n') {
82 buf[rc - 1] = '\0'; /* Remove trailing newline */
90 int compare(struct obd_uuid *puuid, struct lov_user_md *lum_dir,
91 struct lov_user_md *lum_file1, struct lov_user_md *lum_file2)
93 int stripe_count = 0, min_stripe_count = 0, def_stripe_count = 1;
95 int stripe_offset = -1;
101 if (cfs_get_param_paths(&path, "lov/%s/stripecount", puuid->uuid) != 0)
103 if (read_proc_entry(path.gl_pathv[0], buf, sizeof(buf)) < 0) {
104 cfs_free_param_data(&path);
107 cfs_free_param_data(&path);
108 def_stripe_count = (short)atoi(buf);
110 if (cfs_get_param_paths(&path, "lov/%s/numobd", puuid->uuid) != 0)
112 if (read_proc_entry(path.gl_pathv[0], buf, sizeof(buf)) < 0) {
113 cfs_free_param_data(&path);
116 cfs_free_param_data(&path);
117 ost_count = atoi(buf);
119 if (lum_dir == NULL) {
120 stripe_count = def_stripe_count;
121 min_stripe_count = -1;
123 stripe_count = (signed short)lum_dir->lmm_stripe_count;
124 printf("dir stripe %d, ", stripe_count);
125 min_stripe_count = 1;
128 printf("default stripe %d, ost count %d\n",
129 def_stripe_count, ost_count);
131 if (stripe_count == 0) {
132 min_stripe_count = -1;
136 stripe_count = (stripe_count > 0 && stripe_count <= ost_count) ?
137 stripe_count : ost_count;
138 min_stripe_count = min_stripe_count > 0 ? stripe_count :
139 ((stripe_count + 1) / 2);
141 if (lum_file1->lmm_stripe_count != stripe_count ||
142 lum_file1->lmm_stripe_count < min_stripe_count) {
143 llapi_err_noerrno(LLAPI_MSG_ERROR,
144 "file1 stripe count %d != dir %d\n",
145 lum_file1->lmm_stripe_count, stripe_count);
149 if (lum_file1->lmm_stripe_count < stripe_count)
150 llapi_err_noerrno(LLAPI_MSG_WARN,
151 "warning: file1 used fewer stripes"
152 " %d < dir %d (likely due to bug 4900)\n",
153 lum_file1->lmm_stripe_count, stripe_count);
156 stripe_size = (int)lum_dir->lmm_stripe_size;
157 if (stripe_size == 0) {
158 if (cfs_get_param_paths(&path, "lov/%s/stripesize",
161 if (read_proc_entry(path.gl_pathv[0], buf, sizeof(buf)) < 0) {
162 cfs_free_param_data(&path);
165 cfs_free_param_data(&path);
167 stripe_size = atoi(buf);
170 if (lum_file1->lmm_stripe_size != stripe_size) {
171 llapi_err_noerrno(LLAPI_MSG_ERROR,
172 "file1 stripe size %d != dir %d\n",
173 lum_file1->lmm_stripe_size, stripe_size);
178 stripe_offset = (short int)lum_dir->lmm_stripe_offset;
179 if (stripe_offset != -1) {
180 for (i = 0; i < stripe_count; i++)
181 if (lum_file1->lmm_objects[i].l_ost_idx !=
182 (stripe_offset + i) % ost_count) {
183 llapi_err_noerrno(LLAPI_MSG_WARN,
184 "warning: file1 non-sequential "
185 "stripe[%d] %d != %d\n", i,
186 lum_file1->lmm_objects[i].l_ost_idx,
187 (stripe_offset + i) % ost_count);
189 } else if (lum_file2 != NULL) {
190 int next, idx, stripe = stripe_count - 1;
191 next = (lum_file1->lmm_objects[stripe].l_ost_idx + 1) %
193 idx = lum_file2->lmm_objects[0].l_ost_idx;
195 llapi_err_noerrno(LLAPI_MSG_WARN,
196 "warning: non-sequential "
197 "file1 stripe[%d] %d != file2 stripe[0] %d\n",
198 stripe, lum_file1->lmm_objects[stripe].l_ost_idx,
206 int main(int argc, char **argv)
208 struct lov_user_md *lum_dir, *lum_file1 = NULL, *lum_file2 = NULL;
209 struct obd_uuid uuid;
214 llapi_err_noerrno(LLAPI_MSG_ERROR,
215 "Usage: %s <dirname> <filename1> [filename2]\n",
220 dir = opendir(argv[1]);
223 llapi_error(LLAPI_MSG_ERROR, rc,
224 "error: %s opendir failed", argv[1]);
228 lum_size = lov_user_md_size(MAX_LOV_UUID_COUNT, LOV_USER_MAGIC);
229 lum_dir = (struct lov_user_md *)malloc(lum_size);
230 if (lum_dir == NULL) {
232 llapi_error(LLAPI_MSG_ERROR, rc,
233 "error: can't allocate %d bytes "
234 "for dir EA", lum_size);
238 rc = llapi_file_get_stripe(argv[1], lum_dir);
240 if (rc == -ENODATA) {
244 llapi_error(LLAPI_MSG_ERROR, rc,
245 "error: can't get EA for %s", argv[1]);
250 /* XXX should be llapi_lov_getname() */
251 rc = llapi_file_get_lov_uuid(argv[1], &uuid);
253 llapi_error(LLAPI_MSG_ERROR, rc,
254 "error: can't get lov name for %s",
259 lum_file1 = malloc(lum_size);
260 if (lum_file1 == NULL) {
262 llapi_error(LLAPI_MSG_ERROR, rc,
263 "error: can't allocate %d bytes for EA",
268 rc = llapi_file_get_stripe(argv[2], lum_file1);
270 llapi_error(LLAPI_MSG_ERROR, rc,
271 "error: unable to get EA for %s", argv[2]);
276 lum_file2 = (struct lov_user_md *)malloc(lum_size);
277 if (lum_file2 == NULL) {
279 llapi_error(LLAPI_MSG_ERROR, rc,
280 "error: can't allocate %d "
281 "bytes for file2 EA", lum_size);
285 rc = llapi_file_get_stripe(argv[3], lum_file2);
287 llapi_error(LLAPI_MSG_ERROR, rc,
288 "error: can't get EA for %s", argv[3]);
293 rc = compare(&uuid, lum_dir, lum_file1, lum_file2);
299 if (lum_file1 != NULL)
301 if (lum_file2 != NULL)