1 /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
2 * vim:expandtab:shiftwidth=8:tabstop=8:
6 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
8 * This program is free software; you can redistribute it and/or modify
9 * it under the terms of the GNU General Public License version 2 only,
10 * as published by the Free Software Foundation.
12 * This program is distributed in the hope that it will be useful, but
13 * WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * General Public License version 2 for more details (a copy is included
16 * in the LICENSE file that accompanied this code).
18 * You should have received a copy of the GNU General Public License
19 * version 2 along with this program; If not, see
20 * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
22 * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
23 * CA 95054 USA or visit www.sun.com if you need additional information or
29 * Copyright (c) 2003, 2010, Oracle and/or its affiliates. All rights reserved.
30 * Use is subject to license terms.
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>
51 #include <semaphore.h>
52 #include <libcfs/libcfs.h>
53 #include <lustre/liblustreapi.h>
55 #define T1 "write data before unlink\n"
56 #define T2 "write data after unlink\n"
57 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";
58 char *buf, *buf_align;
64 "Usage: %s filename command-sequence\n"
65 " command-sequence items:\n"
67 " C[num] create with optional stripes\n"
69 " D open(O_DIRECTORY)\n"
74 " M rw mmap to EOF (must open and stat prior)\n"
77 " O open(O_CREAT|O_RDWR)\n"
78 " r[num] read [optional length]\n"
79 " R reference entire mmap-ed region\n"
83 " T[num] ftruncate [optional position, default 0]\n"
87 " w[num] write optional length\n"
88 " W write entire mmap-ed region\n"
91 " z[num] seek [optional position, default 0]\n"
92 " _ wait for signal\n";
94 void usr1_handler(int unused)
96 int saved_errno = errno;
99 * signal(7): POSIX.1-2004 ...requires an implementation to guarantee
100 * that the following functions can be safely called inside a signal
110 pop_arg(int argc, char *argv[])
112 static int cur_arg = 3;
117 return argv[cur_arg++];
120 struct flag_mapping {
124 {"O_RDONLY", O_RDONLY},
125 {"O_WRONLY", O_WRONLY},
127 {"O_CREAT", O_CREAT},
129 {"O_NOCTTY", O_NOCTTY},
130 {"O_TRUNC", O_TRUNC},
131 {"O_APPEND", O_APPEND},
132 {"O_NONBLOCK", O_NONBLOCK},
133 {"O_NDELAY", O_NDELAY},
136 {"O_DIRECT", O_DIRECT},
138 {"O_LARGEFILE", O_LARGEFILE},
139 {"O_DIRECTORY", O_DIRECTORY},
140 {"O_NOFOLLOW", O_NOFOLLOW},
144 int get_flags(char *data, int *rflags)
152 cloned_flags = strdup(data);
153 if (cloned_flags == NULL) {
154 fprintf(stderr, "Insufficient memory.\n");
158 for (tmp = strtok(cloned_flags, ":"); tmp;
159 tmp = strtok(NULL, ":")) {
162 size = tmp - cloned_flags;
163 for (i = 0; flag_table[i].flag != -1; i++) {
164 if (!strcmp(tmp, flag_table[i].string)){
165 flags |= flag_table[i].flag;
166 size += strlen(flag_table[i].string);
183 #define POP_ARG() (pop_arg(argc, argv))
185 int main(int argc, char **argv)
187 char *fname, *commands;
191 size_t mmap_len = 0, i;
192 unsigned char *mmap_ptr = NULL, junk = 0;
193 int rc, len, fd = -1;
199 fprintf(stderr, usage, argv[0]);
203 memset(&st, 0, sizeof(st));
204 sem_init(&sem, 0, 0);
205 /* use sigaction instead of signal to avoid SA_ONESHOT semantics */
206 sigaction(SIGUSR1, &(const struct sigaction){.sa_handler = &usr1_handler},
211 for (commands = argv[2]; *commands; commands++) {
218 while (sem_wait(&sem) == -1 && errno == EINTR);
221 if (close(fd) == -1) {
229 len = atoi(commands+1);
230 fd = llapi_file_open(fname, O_CREAT | O_WRONLY, 0644,
234 perror("create stripe file");
239 if (mkdir(fname, 0755) == -1) {
241 perror("mkdir(0755)");
246 fd = open(fname, O_DIRECTORY);
249 perror("open(O_DIRECTORY)");
254 if (statfs(fname, &stfs) == -1) {
264 if (symlink(fname, newfile)) {
274 if (link(fname, newfile)) {
281 if (mknod(fname, S_IFREG | 0644, 0) == -1) {
283 perror("mknod(S_IFREG|0644, 0)");
288 if (st.st_size == 0) {
289 fprintf(stderr, "mmap without preceeding stat, or on"
290 " zero length file.\n");
293 mmap_len = st.st_size;
294 mmap_ptr = mmap(NULL, mmap_len, PROT_WRITE | PROT_READ,
296 if (mmap_ptr == MAP_FAILED) {
306 if (rename (fname, newfile)) {
313 fd = open(fname, O_CREAT|O_RDWR, 0644);
316 perror("open(O_RDWR|O_CREAT)");
321 len = get_flags(commands+1, &flags);
324 fd = open(fname, flags, 0666);
326 fd = open(fname, flags);
334 len = atoi(commands+1);
338 buf = realloc(buf, len + ALIGN);
341 perror("allocating buf for read\n");
345 buf_align = (char *)((long)(buf + ALIGN) &
349 rc = read(fd, buf_align, len);
356 fprintf(stderr, "short read: %u/%u\n",
360 printf("%.*s\n", rc, buf_align);
364 for (i = 0; i < mmap_len && mmap_ptr; i += 4096)
368 if (stat(fname, &st) == -1) {
375 if (fstat(fd, &st) == -1) {
382 if (fchmod(fd, 0) == -1) {
389 len = atoi(commands+1);
390 if (ftruncate(fd, len) == -1) {
392 printf("ftruncate (%d,%d)\n", fd, len);
398 if (unlink(fname) == -1) {
405 if (munmap(mmap_ptr, mmap_len)) {
415 len = atoi(commands+1);
419 buf = realloc(buf, len + ALIGN);
422 perror("allocating buf for write\n");
426 buf_align = (char *)((long)(buf + ALIGN) &
428 strncpy(buf_align, msg, bufsize);
431 rc = write(fd, buf_align, len);
438 fprintf(stderr, "short write: %u/%u\n",
444 for (i = 0; i < mmap_len && mmap_ptr; i += 4096)
445 mmap_ptr[i] += junk++;
448 if (fsync(fd) == -1) {
455 if (fdatasync(fd) == -1) {
461 len = atoi(commands+1);
462 if (lseek(fd, len, SEEK_SET) == -1) {
480 fprintf(stderr, "unknown command \"%c\"\n", *commands);
481 fprintf(stderr, usage, argv[0]);