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"
79 " L link filename to path\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 " W write entire mmap-ed region\n"
101 " z[num] seek [optional position, default 0]\n"
102 " _ wait for signal\n";
104 void usr1_handler(int unused)
106 int saved_errno = errno;
109 * signal(7): POSIX.1-2004 ...requires an implementation to guarantee
110 * that the following functions can be safely called inside a signal
120 pop_arg(int argc, char *argv[])
122 static int cur_arg = 3;
127 return argv[cur_arg++];
130 struct flag_mapping {
134 {"O_RDONLY", O_RDONLY},
135 {"O_WRONLY", O_WRONLY},
137 {"O_CREAT", O_CREAT},
139 {"O_NOCTTY", O_NOCTTY},
140 {"O_TRUNC", O_TRUNC},
141 {"O_APPEND", O_APPEND},
142 {"O_NONBLOCK", O_NONBLOCK},
143 {"O_NDELAY", O_NDELAY},
146 {"O_DIRECT", O_DIRECT},
148 {"O_LARGEFILE", O_LARGEFILE},
149 {"O_DIRECTORY", O_DIRECTORY},
150 {"O_NOFOLLOW", O_NOFOLLOW},
151 {"O_LOV_DELAY_CREATE", O_LOV_DELAY_CREATE},
155 int get_flags(char *data, int *rflags)
163 cloned_flags = strdup(data);
164 if (cloned_flags == NULL) {
165 fprintf(stderr, "Insufficient memory.\n");
169 for (tmp = strtok(cloned_flags, ":"); tmp;
170 tmp = strtok(NULL, ":")) {
173 size = tmp - cloned_flags;
174 for (i = 0; flag_table[i].flag != -1; i++) {
175 if (!strcmp(tmp, flag_table[i].string)){
176 flags |= flag_table[i].flag;
177 size += strlen(flag_table[i].string);
194 #define POP_ARG() (pop_arg(argc, argv))
196 int main(int argc, char **argv)
198 char *fname, *commands;
203 size_t mmap_len = 0, i;
204 unsigned char *mmap_ptr = NULL, junk = 0;
205 int rc, len, fd = -1;
212 struct lov_user_md_v3 lum;
215 fprintf(stderr, usage, argv[0]);
219 memset(&st, 0, sizeof(st));
220 sem_init(&sem, 0, 0);
221 /* use sigaction instead of signal to avoid SA_ONESHOT semantics */
222 sigaction(SIGUSR1, &(const struct sigaction){.sa_handler = &usr1_handler},
227 for (commands = argv[2]; *commands; commands++) {
234 len = atoi(commands+1);
236 len = 3600; /* 1 hour */
237 ts.tv_sec = time(NULL) + len;
239 while (sem_timedwait(&sem, &ts) < 0 && errno == EINTR);
242 if (close(fd) == -1) {
250 lum = (struct lov_user_md_v3) {
251 .lmm_magic = LOV_USER_MAGIC_V3,
252 .lmm_stripe_count = atoi(commands + 1),
255 if (ioctl(fd, LL_IOC_LOV_SETSTRIPE, &lum) < 0) {
257 perror("LL_IOC_LOV_SETSTRIPE");
262 len = atoi(commands+1);
263 fd = llapi_file_open(fname, O_CREAT | O_WRONLY, 0644,
267 perror("create stripe file");
272 if (mkdir(fname, 0755) == -1) {
274 perror("mkdir(0755)");
279 fd = open(fname, O_DIRECTORY);
282 perror("open(O_DIRECTORY)");
287 if (statfs(fname, &stfs) == -1) {
295 rc = llapi_path2fid(fname, &fid);
297 rc = llapi_fd2fid(fd, &fid);
300 "llapi_path/fd2fid() on %d, rc=%d\n",
303 printf(DFID"\n", PFID(&fid));
306 gid = atoi(commands+1);
307 if (ioctl(fd, LL_IOC_GROUP_LOCK, gid) == -1) {
309 perror("ioctl(GROUP_LOCK)");
314 gid = atoi(commands+1);
315 if (ioctl(fd, LL_IOC_GROUP_UNLOCK, gid) == -1) {
317 perror("ioctl(GROUP_UNLOCK)");
326 if (link(oldpath, fname)) {
336 if (symlink(fname, newfile)) {
347 if (link(fname, newfile)) {
354 if (mknod(fname, S_IFREG | 0644, 0) == -1) {
356 perror("mknod(S_IFREG|0644, 0)");
361 if (st.st_size == 0) {
362 fprintf(stderr, "mmap without preceeding stat, or on"
363 " zero length file.\n");
366 mmap_len = st.st_size;
367 mmap_ptr = mmap(NULL, mmap_len, PROT_WRITE | PROT_READ,
369 if (mmap_ptr == MAP_FAILED) {
380 if (rename(oldpath, fname) < 0) {
390 if (rename (fname, newfile)) {
397 fd = open(fname, O_CREAT|O_RDWR, 0644);
400 perror("open(O_RDWR|O_CREAT)");
405 len = get_flags(commands+1, &flags);
408 fd = open(fname, flags, 0666);
410 fd = open(fname, flags);
418 len = atoi(commands+1);
422 buf = realloc(buf, len + ALIGN_LEN);
425 perror("allocating buf for read\n");
429 buf_align = (char *)((long)(buf + ALIGN_LEN) &
433 rc = read(fd, buf_align, len);
440 fprintf(stderr, "short read: %u/%u\n",
447 printf("%.*s\n", rc, buf_align);
451 for (i = 0; i < mmap_len && mmap_ptr; i += 4096)
455 if (stat(fname, &st) == -1) {
462 if (fstat(fd, &st) == -1) {
469 if (fchmod(fd, 0) == -1) {
476 len = atoi(commands+1);
477 if (ftruncate(fd, len) == -1) {
479 printf("ftruncate (%d,%d)\n", fd, len);
485 if (unlink(fname) == -1) {
492 if (munmap(mmap_ptr, mmap_len)) {
502 len = get_flags(commands + 1, &flags);
504 fd = llapi_create_volatile(fname, flags);
506 perror("llapi_create_volatile");
511 len = atoi(commands+1);
515 buf = realloc(buf, len + ALIGN_LEN);
518 perror("allocating buf for write\n");
522 buf_align = (char *)((long)(buf + ALIGN_LEN) &
524 strncpy(buf_align, msg, bufsize);
527 rc = write(fd, buf_align, len);
534 fprintf(stderr, "short write: %u/%u\n",
540 for (i = 0; i < mmap_len && mmap_ptr; i += 4096)
541 mmap_ptr[i] += junk++;
544 if (fsync(fd) == -1) {
551 if (fdatasync(fd) == -1) {
557 len = atoi(commands+1);
558 if (lseek(fd, len, SEEK_SET) == -1) {
577 fprintf(stderr, "unknown command \"%c\"\n", *commands);
578 fprintf(stderr, usage, argv[0]);