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.sun.com/software/products/lustre/docs/GPLv2.pdf
20 * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
21 * CA 95054 USA or visit www.sun.com if you need additional information or
27 * Copyright (c) 2003, 2010, Oracle and/or its affiliates. All rights reserved.
28 * Use is subject to license terms.
30 * Copyright (c) 2012, 2013, Intel Corporation.
33 * This file is part of Lustre, http://www.lustre.org/
34 * Lustre is a trademark of Sun Microsystems, Inc.
38 #define _GNU_SOURCE /* pull in O_DIRECTORY in bits/fcntl.h */
44 #include <sys/types.h>
48 #include <sys/ioctl.h>
52 #include <semaphore.h>
55 #include <lustre/lustre_idl.h>
56 #include <lustre/lustreapi.h>
58 #define T1 "write data before unlink\n"
59 #define T2 "write data after unlink\n"
60 char msg[] = "yabba dabba doo, I'm coming for you, I live in a shoe, I don't know what to do.\n'Bigger, bigger,and bigger yet!' cried the Creator. 'You are not yet substantial enough for my boundless intents!' And ever greater and greater the object became, until all was lost 'neath its momentus bulk.\n";
61 char *buf, *buf_align;
64 #define ALIGN_LEN 65535
67 "Usage: %s filename command-sequence [path...]\n"
68 " command-sequence items:\n"
70 " B[num] call setstripe ioctl to create stripes\n"
71 " C[num] create with optional stripes\n"
73 " D open(O_DIRECTORY)\n"
76 " G gid get grouplock\n"
77 " g gid put grouplock\n"
78 " K link path to filename\n"
80 " l symlink filename to path\n"
82 " M rw mmap to EOF (must open and stat prior)\n"
83 " n rename path to filename\n"
84 " N rename filename to path\n"
86 " O open(O_CREAT|O_RDWR)\n"
87 " r[num] read [optional length]\n"
88 " R reference entire mmap-ed region\n"
92 " T[num] ftruncate [optional position, default 0]\n"
96 " V open a volatile file\n"
97 " w[num] write optional length\n"
98 " x get file data version\n"
99 " W write entire mmap-ed region\n"
102 " z[num] seek [optional position, default 0]\n"
103 " _ wait for signal\n";
105 void usr1_handler(int unused)
107 int saved_errno = errno;
110 * signal(7): POSIX.1-2004 ...requires an implementation to guarantee
111 * that the following functions can be safely called inside a signal
121 pop_arg(int argc, char *argv[])
123 static int cur_arg = 3;
128 return argv[cur_arg++];
131 struct flag_mapping {
135 {"O_RDONLY", O_RDONLY},
136 {"O_WRONLY", O_WRONLY},
138 {"O_CREAT", O_CREAT},
140 {"O_NOCTTY", O_NOCTTY},
141 {"O_TRUNC", O_TRUNC},
142 {"O_APPEND", O_APPEND},
143 {"O_NONBLOCK", O_NONBLOCK},
144 {"O_NDELAY", O_NDELAY},
147 {"O_DIRECT", O_DIRECT},
149 {"O_LARGEFILE", O_LARGEFILE},
150 {"O_DIRECTORY", O_DIRECTORY},
151 {"O_NOFOLLOW", O_NOFOLLOW},
152 {"O_LOV_DELAY_CREATE", O_LOV_DELAY_CREATE},
156 int get_flags(char *data, int *rflags)
164 cloned_flags = strdup(data);
165 if (cloned_flags == NULL) {
166 fprintf(stderr, "Insufficient memory.\n");
170 for (tmp = strtok(cloned_flags, ":"); tmp;
171 tmp = strtok(NULL, ":")) {
174 size = tmp - cloned_flags;
175 for (i = 0; flag_table[i].flag != -1; i++) {
176 if (!strcmp(tmp, flag_table[i].string)){
177 flags |= flag_table[i].flag;
178 size += strlen(flag_table[i].string);
195 #define POP_ARG() (pop_arg(argc, argv))
197 int main(int argc, char **argv)
199 char *fname, *commands;
204 size_t mmap_len = 0, i;
205 unsigned char *mmap_ptr = NULL, junk = 0;
206 int rc, len, fd = -1;
213 struct lov_user_md_v3 lum;
217 fprintf(stderr, usage, argv[0]);
221 memset(&st, 0, sizeof(st));
222 sem_init(&sem, 0, 0);
223 /* use sigaction instead of signal to avoid SA_ONESHOT semantics */
224 sigaction(SIGUSR1, &(const struct sigaction){.sa_handler = &usr1_handler},
229 for (commands = argv[2]; *commands; commands++) {
236 len = atoi(commands+1);
238 len = 3600; /* 1 hour */
239 ts.tv_sec = time(NULL) + len;
241 while (sem_timedwait(&sem, &ts) < 0 && errno == EINTR);
244 if (close(fd) == -1) {
252 lum = (struct lov_user_md_v3) {
253 .lmm_magic = LOV_USER_MAGIC_V3,
254 .lmm_stripe_count = atoi(commands + 1),
257 if (ioctl(fd, LL_IOC_LOV_SETSTRIPE, &lum) < 0) {
259 perror("LL_IOC_LOV_SETSTRIPE");
264 len = atoi(commands+1);
265 fd = llapi_file_open(fname, O_CREAT | O_WRONLY, 0644,
269 perror("create stripe file");
274 if (mkdir(fname, 0755) == -1) {
276 perror("mkdir(0755)");
281 fd = open(fname, O_DIRECTORY);
284 perror("open(O_DIRECTORY)");
289 if (statfs(fname, &stfs) == -1) {
297 rc = llapi_path2fid(fname, &fid);
299 rc = llapi_fd2fid(fd, &fid);
302 "llapi_path/fd2fid() on %d, rc=%d\n",
305 printf(DFID"\n", PFID(&fid));
308 gid = atoi(commands+1);
309 if (ioctl(fd, LL_IOC_GROUP_LOCK, gid) == -1) {
311 perror("ioctl(GROUP_LOCK)");
316 gid = atoi(commands+1);
317 if (ioctl(fd, LL_IOC_GROUP_UNLOCK, gid) == -1) {
319 perror("ioctl(GROUP_UNLOCK)");
324 len = atoi(commands+1);
325 fd = llapi_file_open(fname, O_CREAT | O_WRONLY,
327 LOV_PATTERN_RAID0 | LOV_PATTERN_F_RELEASED);
330 perror("create stripe file");
339 if (link(oldpath, fname)) {
349 if (symlink(fname, newfile)) {
360 if (link(fname, newfile)) {
367 if (mknod(fname, S_IFREG | 0644, 0) == -1) {
369 perror("mknod(S_IFREG|0644, 0)");
374 if (st.st_size == 0) {
375 fprintf(stderr, "mmap without preceeding stat, or on"
376 " zero length file.\n");
379 mmap_len = st.st_size;
380 mmap_ptr = mmap(NULL, mmap_len, PROT_WRITE | PROT_READ,
382 if (mmap_ptr == MAP_FAILED) {
393 if (rename(oldpath, fname) < 0) {
403 if (rename (fname, newfile)) {
410 fd = open(fname, O_CREAT|O_RDWR, 0644);
413 perror("open(O_RDWR|O_CREAT)");
418 len = get_flags(commands+1, &flags);
421 fd = open(fname, flags, 0666);
423 fd = open(fname, flags);
431 len = atoi(commands+1);
435 buf = realloc(buf, len + ALIGN_LEN);
438 perror("allocating buf for read\n");
442 buf_align = (char *)((long)(buf + ALIGN_LEN) &
446 rc = read(fd, buf_align, len);
453 fprintf(stderr, "short read: %u/%u\n",
460 printf("%.*s\n", rc, buf_align);
464 for (i = 0; i < mmap_len && mmap_ptr; i += 4096)
468 if (stat(fname, &st) == -1) {
475 if (fstat(fd, &st) == -1) {
482 if (fchmod(fd, 0) == -1) {
489 len = atoi(commands+1);
490 if (ftruncate(fd, len) == -1) {
492 printf("ftruncate (%d,%d)\n", fd, len);
498 if (unlink(fname) == -1) {
505 if (munmap(mmap_ptr, mmap_len)) {
515 len = get_flags(commands + 1, &flags);
517 fd = llapi_create_volatile(fname, flags);
519 perror("llapi_create_volatile");
524 len = atoi(commands+1);
528 buf = realloc(buf, len + ALIGN_LEN);
531 perror("allocating buf for write\n");
535 buf_align = (char *)((long)(buf + ALIGN_LEN) &
537 strncpy(buf_align, msg, bufsize);
540 rc = write(fd, buf_align, len);
547 fprintf(stderr, "short write: %u/%u\n",
553 for (i = 0; i < mmap_len && mmap_ptr; i += 4096)
554 mmap_ptr[i] += junk++;
557 rc = llapi_get_data_version(fd, &dv, 0);
559 fprintf(stderr, "cannot get file data version"
563 printf("dataversion is "LPU64"\n", dv);
566 if (fsync(fd) == -1) {
573 if (fdatasync(fd) == -1) {
579 len = atoi(commands+1);
580 if (lseek(fd, len, SEEK_SET) == -1) {
599 fprintf(stderr, "unknown command \"%c\"\n", *commands);
600 fprintf(stderr, usage, argv[0]);