1 /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
2 * vim:expandtab:shiftwidth=8:tabstop=8:
4 * Copyright (C) 2002 Cluster File Systems, Inc.
5 * Author: Peter J. Braam <braam@clusterfs.com>
6 * Author: Phil Schwan <phil@clusterfs.com>
7 * Author: Andreas Dilger <adilger@clusterfs.com>
8 * Author: Robert Read <rread@clusterfs.com>
10 * This file is part of Lustre, http://www.lustre.org.
12 * Lustre is free software; you can redistribute it and/or
13 * modify it under the terms of version 2 of the GNU General Public
14 * License as published by the Free Software Foundation.
16 * Lustre is distributed in the hope that it will be useful,
17 * but WITHOUT ANY WARRANTY; without even the implied warranty of
18 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
19 * GNU General Public License for more details.
21 * You should have received a copy of the GNU General Public License
22 * along with Lustre; if not, write to the Free Software
23 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
29 #include <sys/ioctl.h>
31 #include <sys/socket.h>
32 #include <sys/types.h>
40 #include <linux/lustre_lib.h>
41 #include <linux/lustre_idl.h>
42 #include <linux/lustre_dlm.h>
43 #include <linux/obd_lov.h>
49 #include <netinet/in.h>
53 #include <asm/page.h> /* needed for PAGE_SIZE - rread */
56 #include <linux/list.h>
68 # define MAX_SHMEM_COUNT 1024
69 static long long *shared_counters;
70 static long long counter_snapshot[2][MAX_SHMEM_COUNT];
71 struct timeval prev_time;
75 uint64_t conn_addr = -1;
79 int max = sizeof(rawbuf);
83 static int getfd(char *func);
84 static char *cmdname(char *func);
86 #define IOCINIT(data) \
88 memset(&data, 0, sizeof(data)); \
89 data.ioc_version = OBD_IOCTL_VERSION; \
90 data.ioc_addr = conn_addr; \
91 data.ioc_cookie = conn_cookie; \
92 data.ioc_len = sizeof(data); \
94 fprintf(stderr, "No device open, use device\n"); \
99 char *obdo_print(struct obdo *obd)
103 sprintf(buf, "id: %Ld\ngrp: %Ld\natime: %Ld\nmtime: %Ld\nctime: %Ld\n"
104 "size: %Ld\nblocks: %Ld\nblksize: %d\nmode: %o\nuid: %d\n"
105 "gid: %d\nflags: %x\nobdflags: %x\nnlink: %d,\nvalid %x\n",
117 obd->o_flags, obd->o_obdflags, obd->o_nlink, obd->o_valid);
122 #define BAD_VERBOSE (-999999999)
124 #define N2D_OFF 0x100 /* So we can tell between error codes and devices */
126 static int do_name2dev(char *func, char *name)
128 struct obd_ioctl_data data;
136 data.ioc_inllen1 = strlen(name) + 1;
137 data.ioc_inlbuf1 = name;
139 if (obd_ioctl_pack(&data, &buf, max)) {
140 fprintf(stderr, "error: %s: invalid ioctl\n", cmdname(func));
143 rc = ioctl(fd, OBD_IOC_NAME2DEV, buf);
145 fprintf(stderr, "error: %s: %s - %s\n", cmdname(func),
146 name, strerror(rc = errno));
150 memcpy((char *)(&data), buf, sizeof(data));
152 return data.ioc_dev + N2D_OFF;
156 * resolve a device name to a device number.
157 * supports a number or name.
158 * FIXME: support UUID
160 static int parse_devname(char *func, char *name)
167 if (name[0] == '$') {
168 rc = do_name2dev(func, name + 1);
171 printf("%s is device %d\n", name, ret);
173 fprintf(stderr, "error: %s: %s: %s\n", cmdname(func),
174 name, "device not found");
177 ret = strtoul(name, NULL, 0);
182 static char *cmdname(char *func)
184 static char buf[512];
187 sprintf(buf, "%s-%d", func, thread);
194 static int getfd(char *func)
197 fd = open("/dev/obd", O_RDWR);
199 fprintf(stderr, "error: %s: opening /dev/obd: %s\n"
200 "hint: lustre kernel modules may not be loaded.\n",
201 cmdname(func), strerror(errno));
207 #define difftime(a, b) \
208 ((double)(a)->tv_sec - (b)->tv_sec + \
209 ((double)((a)->tv_usec - (b)->tv_usec) / 1000000))
211 static int be_verbose(int verbose, struct timeval *next_time,
212 __u64 num, __u64 *next_num, int num_total)
219 if (next_time != NULL)
220 gettimeofday(&now, NULL);
222 /* A positive verbosity means to print every X iterations */
224 (next_num == NULL || num >= *next_num || num >= num_total)) {
225 *next_num += verbose;
227 next_time->tv_sec = now.tv_sec - verbose;
228 next_time->tv_usec = now.tv_usec;
233 /* A negative verbosity means to print at most each X seconds */
234 if (verbose < 0 && next_time != NULL && difftime(&now, next_time) >= 0){
235 next_time->tv_sec = now.tv_sec - verbose;
236 next_time->tv_usec = now.tv_usec;
245 static int get_verbose(char *func, const char *arg)
250 if (!arg || arg[0] == 'v')
252 else if (arg[0] == 's' || arg[0] == 'q')
255 verbose = (int)strtoul(arg, &end, 0);
257 fprintf(stderr, "error: %s: bad verbose option '%s'\n",
264 printf("Print status every %d seconds\n", -verbose);
265 else if (verbose == 1)
266 printf("Print status every operation\n");
267 else if (verbose > 1)
268 printf("Print status every %d operations\n", verbose);
273 int do_disconnect(char *func, int verbose)
276 struct obd_ioctl_data data;
283 rc = ioctl(fd, OBD_IOC_DISCONNECT, &data);
285 fprintf(stderr, "error: %s: %x %s\n", cmdname(func),
286 OBD_IOC_DISCONNECT, strerror(errno));
289 printf("%s: disconnected conn %Lx\n", cmdname(func),
298 static void shmem_setup(void)
300 int shmid = shmget(IPC_PRIVATE, sizeof(counter_snapshot[0]), 0600);
303 fprintf(stderr, "Can't create shared memory counters: %s\n",
308 shared_counters = (long long *)shmat(shmid, NULL, 0);
310 if (shared_counters == (long long *)(-1)) {
311 fprintf(stderr, "Can't attach shared memory counters: %s\n",
313 shared_counters = NULL;
318 static inline void shmem_reset(void)
320 if (shared_counters == NULL)
323 memset(shared_counters, 0, sizeof(counter_snapshot[0]));
324 memset(counter_snapshot, 0, sizeof(counter_snapshot));
325 gettimeofday(&prev_time, NULL);
328 static inline void shmem_bump(void)
330 if (shared_counters == NULL || thread <= 0 || thread > MAX_SHMEM_COUNT)
333 shared_counters[thread - 1]++;
336 static void shmem_snap(int n)
338 struct timeval this_time;
344 if (shared_counters == NULL || n > MAX_SHMEM_COUNT)
347 memcpy(counter_snapshot[1], counter_snapshot[0],
348 n * sizeof(counter_snapshot[0][0]));
349 memcpy(counter_snapshot[0], shared_counters,
350 n * sizeof(counter_snapshot[0][0]));
351 gettimeofday(&this_time, NULL);
353 for (i = 0; i < n; i++) {
354 long long this_count =
355 counter_snapshot[0][i] - counter_snapshot[1][i];
357 if (this_count != 0) {
363 secs = (this_time.tv_sec + this_time.tv_usec / 1000000.0) -
364 (prev_time.tv_sec + prev_time.tv_usec / 1000000.0);
366 printf("%d/%d Total: %f/second\n", non_zero, n, total / secs);
368 prev_time = this_time;
371 #define SHMEM_SETUP() shmem_setup()
372 #define SHMEM_RESET() shmem_reset()
373 #define SHMEM_BUMP() shmem_bump()
374 #define SHMEM_SNAP(n) shmem_snap(n)
376 #define SHMEM_SETUP()
377 #define SHMEM_RESET()
379 #define SHMEM_SNAP(n)
382 extern command_t cmdlist[];
384 static int do_device(char *func, int dev)
386 struct obd_ioctl_data data;
388 memset(&data, 0, sizeof(data));
395 if (obd_ioctl_pack(&data, &buf, max)) {
396 fprintf(stderr, "error: %s: invalid ioctl\n", cmdname(func));
400 return ioctl(fd, OBD_IOC_DEVICE, buf);
403 int jt_obd_device(int argc, char **argv)
406 do_disconnect(argv[0], 1);
411 dev = parse_devname(argv[0], argv[1]);
415 rc = do_device(argv[0], dev);
417 fprintf(stderr, "error: %s: %s\n", cmdname(argv[0]),
418 strerror(rc = errno));
423 int jt_obd_connect(int argc, char **argv)
425 struct obd_ioctl_data data;
430 do_disconnect(argv[0], 1);
432 #warning TODO: implement timeout per lctl usage for probe
436 rc = ioctl(fd, OBD_IOC_CONNECT, &data);
438 fprintf(stderr, "error: %s: %x %s\n", cmdname(argv[0]),
439 OBD_IOC_CONNECT, strerror(rc = errno));
441 conn_addr = data.ioc_addr;
442 conn_cookie = data.ioc_cookie;
447 int jt_obd_disconnect(int argc, char **argv)
455 return do_disconnect(argv[0], 0);
458 int jt_opt_device(int argc, char **argv)
467 rc = do_device("device", parse_devname(argv[0], argv[1]));
472 rc = jt_obd_connect(1, arg2);
476 rc = Parser_execarg(argc - 2, argv + 2, cmdlist);
478 ret = do_disconnect(argv[0], 0);
485 int jt_opt_threads(int argc, char **argv)
487 __u64 threads, next_thread;
496 threads = strtoull(argv[1], &end, 0);
498 fprintf(stderr, "error: %s: invalid page count '%s'\n",
499 cmdname(argv[0]), argv[1]);
503 verbose = get_verbose(argv[0], argv[2]);
504 if (verbose == BAD_VERBOSE)
508 printf("%s: starting "LPD64" threads on device %s running %s\n",
509 argv[0], threads, argv[3], argv[4]);
513 for (i = 1, next_thread = verbose; i <= threads; i++) {
516 fprintf(stderr, "error: %s: #%d - %s\n", argv[0], i,
517 strerror(rc = errno));
519 } else if (rc == 0) {
521 argv[2] = "--device";
522 return jt_opt_device(argc - 2, argv + 2);
523 } else if (be_verbose(verbose, NULL, i, &next_thread, threads))
524 printf("%s: thread #%d (PID %d) started\n",
529 if (!thread) { /* parent process */
530 int live_threads = threads;
532 while (live_threads > 0) {
536 ret = waitpid(0, &status, verbose < 0 ? WNOHANG : 0);
547 fprintf(stderr, "error: %s: wait - %s\n",
548 argv[0], strerror(errno));
553 * This is a hack. We _should_ be able to use
554 * WIFEXITED(status) to see if there was an
555 * error, but it appears to be broken and it
556 * always returns 1 (OK). See wait(2).
558 int err = WEXITSTATUS(status);
559 if (err || WIFSIGNALED(status))
561 "%s: PID %d had rc=%d\n",
574 int jt_obd_detach(int argc, char **argv)
576 struct obd_ioctl_data data;
584 if (obd_ioctl_pack(&data, &buf, max)) {
585 fprintf(stderr, "error: %s: invalid ioctl\n", cmdname(argv[0]));
589 rc = ioctl(fd, OBD_IOC_DETACH, buf);
591 fprintf(stderr, "error: %s: %s\n", cmdname(argv[0]),
592 strerror(rc = errno));
597 int jt_obd_cleanup(int argc, char **argv)
599 struct obd_ioctl_data data;
607 rc = ioctl(fd, OBD_IOC_CLEANUP, &data);
609 fprintf(stderr, "error: %s: %s\n", cmdname(argv[0]),
610 strerror(rc = errno));
615 int jt_obd_newdev(int argc, char **argv)
618 struct obd_ioctl_data data;
628 rc = ioctl(fd, OBD_IOC_NEWDEV, &data);
630 fprintf(stderr, "error: %s: %s\n", cmdname(argv[0]),
631 strerror(rc = errno));
633 printf("Current device set to %d\n", data.ioc_dev);
639 int jt_obd_list(int argc, char **argv)
643 struct obd_ioctl_data *data = (struct obd_ioctl_data *)buf;
648 memset(buf, 0, sizeof(buf));
649 data->ioc_version = OBD_IOCTL_VERSION;
650 data->ioc_addr = conn_addr;
651 data->ioc_cookie = conn_addr;
652 data->ioc_len = sizeof(buf);
653 data->ioc_inllen1 = sizeof(buf) - size_round(sizeof(*data));
658 rc = ioctl(fd, OBD_IOC_LIST, data);
660 fprintf(stderr, "error: %s: %s\n", cmdname(argv[0]),
661 strerror(rc = errno));
663 printf("%s", data->ioc_bulk);
669 int jt_obd_attach(int argc, char **argv)
671 struct obd_ioctl_data data;
676 if (argc != 2 && argc != 3 && argc != 4)
679 data.ioc_inllen1 = strlen(argv[1]) + 1;
680 data.ioc_inlbuf1 = argv[1];
682 data.ioc_inllen2 = strlen(argv[2]) + 1;
683 data.ioc_inlbuf2 = argv[2];
687 data.ioc_inllen3 = strlen(argv[3]) + 1;
688 data.ioc_inlbuf3 = argv[3];
691 if (obd_ioctl_pack(&data, &buf, max)) {
692 fprintf(stderr, "error: %s: invalid ioctl\n", cmdname(argv[0]));
696 rc = ioctl(fd, OBD_IOC_ATTACH, buf);
698 fprintf(stderr, "error: %s: %x %s\n", cmdname(argv[0]),
699 OBD_IOC_ATTACH, strerror(rc = errno));
700 else if (argc == 3) {
702 if (strlen(argv[2]) > 128) {
703 printf("Name too long to set environment\n");
706 snprintf(name, 512, "LUSTRE_DEV_%s", argv[2]);
707 rc = setenv(name, argv[1], 1);
709 printf("error setting env variable %s\n", name);
716 int jt_obd_name2dev(int argc, char **argv)
723 rc = do_name2dev(argv[0], argv[1]);
725 int dev = rc - N2D_OFF;
726 rc = do_device(argv[0], dev);
733 int jt_obd_setup(int argc, char **argv)
735 struct obd_ioctl_data data;
745 data.ioc_dev = parse_devname(argv[0], argv[1]);
746 if (data.ioc_dev < 0)
748 data.ioc_inllen1 = strlen(argv[1]) + 1;
749 data.ioc_inlbuf1 = argv[1];
752 data.ioc_inllen2 = strlen(argv[2]) + 1;
753 data.ioc_inlbuf2 = argv[2];
756 if (obd_ioctl_pack(&data, &buf, max)) {
757 fprintf(stderr, "error: %s: invalid ioctl\n", cmdname(argv[0]));
760 rc = ioctl(fd, OBD_IOC_SETUP, buf);
762 fprintf(stderr, "error: %s: %s\n", cmdname(argv[0]),
763 strerror(rc = errno));
769 int jt_obd_create(int argc, char **argv)
771 struct obd_ioctl_data data;
772 struct timeval next_time;
773 __u64 count = 1, next_count;
780 if (argc < 2 || argc > 4)
783 count = strtoull(argv[1], &end, 0);
785 fprintf(stderr, "error: %s: invalid iteration count '%s'\n",
786 cmdname(argv[0]), argv[1]);
791 mode = strtoul(argv[2], &end, 0);
793 fprintf(stderr, "error: %s: invalid mode '%s'\n",
794 cmdname(argv[0]), argv[2]);
797 if (!(mode & S_IFMT))
802 verbose = get_verbose(argv[0], argv[3]);
803 if (verbose == BAD_VERBOSE)
807 printf("%s: "LPD64" objects\n", cmdname(argv[0]), count);
808 gettimeofday(&next_time, NULL);
809 next_time.tv_sec -= verbose;
811 for (i = 1, next_count = verbose; i <= count; i++) {
812 data.ioc_obdo1.o_mode = mode;
813 data.ioc_obdo1.o_id = i;
814 data.ioc_obdo1.o_uid = 0;
815 data.ioc_obdo1.o_gid = 0;
816 data.ioc_obdo1.o_valid = OBD_MD_FLTYPE | OBD_MD_FLMODE |
817 OBD_MD_FLID | OBD_MD_FLUID | OBD_MD_FLGID;;
819 rc = ioctl(fd, OBD_IOC_CREATE, &data);
822 fprintf(stderr, "error: %s: #%d - %s\n",
823 cmdname(argv[0]), i, strerror(rc = errno));
826 if (!(data.ioc_obdo1.o_valid & OBD_MD_FLID)) {
827 fprintf(stderr, "error: %s: objid not valid #%d:%08x\n",
828 cmdname(argv[0]), i, data.ioc_obdo1.o_valid);
833 if (be_verbose(verbose, &next_time, i, &next_count, count))
834 printf("%s: #%d is object id 0x%Lx\n", cmdname(argv[0]),
835 i, (long long)data.ioc_obdo1.o_id);
840 int jt_obd_setattr(int argc, char **argv)
842 struct obd_ioctl_data data;
850 data.ioc_obdo1.o_id = strtoull(argv[1], &end, 0);
852 fprintf(stderr, "error: %s: invalid objid '%s'\n",
853 cmdname(argv[0]), argv[1]);
856 data.ioc_obdo1.o_mode = S_IFREG | strtoul(argv[2], &end, 0);
858 fprintf(stderr, "error: %s: invalid mode '%s'\n",
859 cmdname(argv[0]), argv[2]);
862 data.ioc_obdo1.o_valid = OBD_MD_FLID | OBD_MD_FLTYPE | OBD_MD_FLMODE;
864 rc = ioctl(fd, OBD_IOC_SETATTR, &data);
866 fprintf(stderr, "error: %s: %s\n", cmdname(argv[0]),
867 strerror(rc = errno));
872 int jt_obd_destroy(int argc, char **argv)
874 struct obd_ioctl_data data;
882 data.ioc_obdo1.o_id = strtoull(argv[1], &end, 0);
884 fprintf(stderr, "error: %s: invalid objid '%s'\n",
885 cmdname(argv[0]), argv[1]);
888 data.ioc_obdo1.o_mode = S_IFREG | 0644;
890 rc = ioctl(fd, OBD_IOC_DESTROY, &data);
892 fprintf(stderr, "error: %s: %s\n", cmdname(argv[0]),
893 strerror(rc = errno));
898 int jt_obd_getattr(int argc, char **argv)
900 struct obd_ioctl_data data;
908 data.ioc_obdo1.o_id = strtoull(argv[1], &end, 0);
910 fprintf(stderr, "error: %s: invalid objid '%s'\n",
911 cmdname(argv[0]), argv[1]);
914 /* to help obd filter */
915 data.ioc_obdo1.o_mode = 0100644;
916 data.ioc_obdo1.o_valid = 0xffffffff;
917 printf("%s: object id %Ld\n", cmdname(argv[0]), data.ioc_obdo1.o_id);
919 rc = ioctl(fd, OBD_IOC_GETATTR, &data);
921 fprintf(stderr, "error: %s: %s\n", cmdname(argv[0]),
922 strerror(rc = errno));
924 printf("%s: object id %Ld, mode %o\n", cmdname(argv[0]),
925 data.ioc_obdo1.o_id, data.ioc_obdo1.o_mode);
930 int jt_obd_test_getattr(int argc, char **argv)
932 struct obd_ioctl_data data;
933 struct timeval start, next_time;
934 __u64 i, count, next_count;
940 if (argc < 2 && argc > 4)
944 count = strtoull(argv[1], &end, 0);
946 fprintf(stderr, "error: %s: invalid iteration count '%s'\n",
947 cmdname(argv[0]), argv[1]);
952 verbose = get_verbose(argv[0], argv[2]);
953 if (verbose == BAD_VERBOSE)
958 if (argv[3][0] == 't') {
959 objid = strtoull(argv[3] + 1, &end, 0);
963 objid = strtoull(argv[3], &end, 0);
965 fprintf(stderr, "error: %s: invalid objid '%s'\n",
966 cmdname(argv[0]), argv[3]);
971 gettimeofday(&start, NULL);
972 next_time.tv_sec = start.tv_sec - verbose;
973 next_time.tv_usec = start.tv_usec;
975 printf("%s: getting "LPD64" attrs (objid "LPX64"): %s",
976 cmdname(argv[0]), count, objid, ctime(&start.tv_sec));
978 for (i = 1, next_count = verbose; i <= count; i++) {
979 data.ioc_obdo1.o_id = objid;
980 data.ioc_obdo1.o_mode = S_IFREG;
981 data.ioc_obdo1.o_valid = 0xffffffff;
982 rc = ioctl(fd, OBD_IOC_GETATTR, &data);
985 fprintf(stderr, "error: %s: #"LPD64" - %s\n",
986 cmdname(argv[0]), i, strerror(rc = errno));
990 (verbose, &next_time, i, &next_count, count))
991 printf("%s: got attr #"LPD64"\n",
992 cmdname(argv[0]), i);
1000 gettimeofday(&end, NULL);
1002 diff = difftime(&end, &start);
1006 printf("%s: "LPD64" attrs in %.4gs (%.4g attr/s): %s",
1007 cmdname(argv[0]), i, diff, (double)i / diff,
1008 ctime(&end.tv_sec));
1013 int jt_obd_test_brw(int argc, char **argv)
1015 struct obd_ioctl_data data;
1016 struct timeval start, next_time;
1018 __u64 count, next_count;
1020 int verbose = 1, write = 0, rw;
1027 if (argc < 2 || argc > 6) {
1028 fprintf(stderr, "error: %s: bad number of arguments: %d\n",
1029 cmdname(argv[0]), argc);
1033 /* make each thread write to a different offset */
1034 if (argv[1][0] == 't') {
1035 count = strtoull(argv[1] + 1, &end, 0);
1037 thr_offset = thread - 1;
1039 count = strtoull(argv[1], &end, 0);
1042 fprintf(stderr, "error: %s: bad iteration count '%s'\n",
1043 cmdname(argv[0]), argv[1]);
1048 if (argv[2][0] == 'w' || argv[2][0] == '1')
1050 else if (argv[2][0] == 'r' || argv[2][0] == '0')
1055 verbose = get_verbose(argv[0], argv[3]);
1056 if (verbose == BAD_VERBOSE)
1061 pages = strtoul(argv[4], &end, 0);
1063 fprintf(stderr, "error: %s: bad page count '%s'\n",
1064 cmdname(argv[0]), argv[4]);
1069 if (argv[5][0] == 't') {
1070 objid = strtoull(argv[5] + 1, &end, 0);
1072 objid += thread - 1;
1074 objid = strtoull(argv[5], &end, 0);
1076 fprintf(stderr, "error: %s: bad objid '%s'\n",
1077 cmdname(argv[0]), argv[5]);
1082 len = pages * PAGE_SIZE;
1085 data.ioc_obdo1.o_id = objid;
1086 data.ioc_obdo1.o_mode = S_IFREG;
1087 data.ioc_obdo1.o_valid = OBD_MD_FLID | OBD_MD_FLTYPE | OBD_MD_FLMODE;
1088 data.ioc_count = len;
1089 data.ioc_offset = thr_offset * len * count;
1091 gettimeofday(&start, NULL);
1092 next_time.tv_sec = start.tv_sec - verbose;
1093 next_time.tv_usec = start.tv_usec;
1096 printf("%s: %s "LPU64"x%d pages (obj "LPX64", off "LPU64"): %s",
1097 cmdname(argv[0]), write ? "writing" : "reading", count,
1098 pages, objid, data.ioc_offset, ctime(&start.tv_sec));
1100 rc = ioctl(fd, OBD_IOC_OPEN, &data);
1102 fprintf(stderr, "error: brw_open: %s\n", strerror(rc = errno));
1106 rw = write ? OBD_IOC_BRW_WRITE : OBD_IOC_BRW_READ;
1107 for (i = 1, next_count = verbose; i <= count; i++) {
1108 rc = ioctl(fd, rw, &data);
1111 fprintf(stderr, "error: %s: #%d - %s on %s\n",
1112 cmdname(argv[0]), i, strerror(rc = errno),
1113 write ? "write" : "read");
1115 } else if (be_verbose(verbose, &next_time,i, &next_count,count))
1116 printf("%s: %s number %dx%d\n", cmdname(argv[0]),
1117 write ? "write" : "read", i, pages);
1119 data.ioc_offset += len;
1126 gettimeofday(&end, NULL);
1128 diff = difftime(&end, &start);
1132 printf("%s: %s %dx%d pages in %.4gs (%.4g pg/s): %s",
1133 cmdname(argv[0]), write ? "wrote" : "read",
1134 i, pages, diff, (double)i * pages / diff,
1135 ctime(&end.tv_sec));
1137 rw = ioctl(fd, OBD_IOC_CLOSE, &data);
1139 fprintf(stderr, "error: brw_close: %s\n", strerror(rw = errno));
1147 int jt_obd_lov_setconfig(int argc, char **argv)
1149 struct obd_ioctl_data data;
1150 struct lov_desc desc;
1151 obd_uuid_t *uuidarray, *ptr;
1160 if (strlen(argv[1]) > sizeof(desc.ld_uuid) - 1) {
1162 "error: %s: LOV uuid '%s' longer than %d characters\n",
1163 cmdname(argv[0]), argv[1], sizeof(desc.ld_uuid) - 1);
1167 memset(&desc, 0, sizeof(desc));
1168 strncpy(desc.ld_uuid, argv[1], sizeof(desc.ld_uuid) - 1);
1169 desc.ld_tgt_count = argc - 6;
1170 desc.ld_default_stripe_count = strtoul(argv[2], &end, 0);
1172 fprintf(stderr, "error: %s: bad default stripe count '%s'\n",
1173 cmdname(argv[0]), argv[2]);
1176 if (desc.ld_default_stripe_count > desc.ld_tgt_count) {
1178 "error: %s: default stripe count %u > OST count %u\n",
1179 cmdname(argv[0]), desc.ld_default_stripe_count,
1184 desc.ld_default_stripe_size = strtoull(argv[3], &end, 0);
1186 fprintf(stderr, "error: %s: bad default stripe size '%s'\n",
1187 cmdname(argv[0]), argv[3]);
1190 if (desc.ld_default_stripe_size < 4096) {
1192 "error: %s: default stripe size "LPU64" too small\n",
1193 cmdname(argv[0]), desc.ld_default_stripe_size);
1195 } else if ((long)desc.ld_default_stripe_size <
1196 desc.ld_default_stripe_size) {
1198 "error: %s: default stripe size "LPU64" too large\n",
1199 cmdname(argv[0]), desc.ld_default_stripe_size);
1202 desc.ld_default_stripe_offset = strtoull(argv[4], &end, 0);
1204 fprintf(stderr, "error: %s: bad default stripe offset '%s'\n",
1205 cmdname(argv[0]), argv[4]);
1208 desc.ld_pattern = strtoul(argv[5], &end, 0);
1210 fprintf(stderr, "error: %s: bad stripe pattern '%s'\n",
1211 cmdname(argv[0]), argv[5]);
1215 /* NOTE: it is possible to overwrite the default striping parameters,
1216 * but EXTREME care must be taken when saving the OST UUID list.
1217 * It must be EXACTLY the same, or have only additions at the
1218 * end of the list, or only overwrite individual OST entries
1219 * that are restored from backups of the previous OST.
1221 uuidarray = calloc(desc.ld_tgt_count, sizeof(*uuidarray));
1223 fprintf(stderr, "error: %s: no memory for %d UUIDs\n",
1224 cmdname(argv[0]), desc.ld_tgt_count);
1228 for (i = 6, ptr = uuidarray; i < argc; i++, ptr++) {
1229 if (strlen(argv[i]) >= sizeof(*ptr)) {
1230 fprintf(stderr, "error: %s: arg %d (%s) too long\n",
1231 cmdname(argv[0]), i, argv[i]);
1235 strcpy((char *)ptr, argv[i]);
1238 data.ioc_inllen1 = sizeof(desc);
1239 data.ioc_inlbuf1 = (char *)&desc;
1240 data.ioc_inllen2 = desc.ld_tgt_count * sizeof(*uuidarray);
1241 data.ioc_inlbuf2 = (char *)uuidarray;
1243 if (obd_ioctl_pack(&data, &buf, max)) {
1244 fprintf(stderr, "error: %s: invalid ioctl\n", cmdname(argv[0]));
1249 rc = ioctl(fd, OBD_IOC_LOV_SET_CONFIG, buf);
1251 fprintf(stderr, "error: %s: ioctl error: %s\n",
1252 cmdname(argv[0]), strerror(rc = errno));
1258 #define DEF_UUID_ARRAY_LEN (8192 / 40)
1260 int jt_obd_lov_getconfig(int argc, char **argv)
1262 struct obd_ioctl_data data;
1263 struct lov_desc desc;
1264 obd_uuid_t *uuidarray;
1272 if (strlen(argv[1]) > sizeof(desc.ld_uuid) - 1) {
1274 "error: %s: LOV uuid '%s' longer than %d characters\n",
1275 cmdname(argv[0]), argv[1], sizeof(desc.ld_uuid) - 1);
1279 memset(&desc, 0, sizeof(desc));
1280 strncpy(desc.ld_uuid, argv[1], sizeof(desc.ld_uuid) - 1);
1281 desc.ld_tgt_count = DEF_UUID_ARRAY_LEN;
1283 uuidarray = calloc(desc.ld_tgt_count, sizeof(*uuidarray));
1285 fprintf(stderr, "error: %s: no memory for %d uuid's\n",
1286 cmdname(argv[0]), desc.ld_tgt_count);
1290 data.ioc_inllen1 = sizeof(desc);
1291 data.ioc_inlbuf1 = (char *)&desc;
1292 data.ioc_inllen2 = desc.ld_tgt_count * sizeof(*uuidarray);
1293 data.ioc_inlbuf2 = (char *)uuidarray;
1295 if (obd_ioctl_pack(&data, &buf, max)) {
1296 fprintf(stderr, "error: %s: invalid ioctl\n", cmdname(argv[0]));
1301 rc = ioctl(fd, OBD_IOC_LOV_GET_CONFIG, buf);
1302 if (rc == -ENOSPC) {
1306 fprintf(stderr, "error: %s: ioctl error: %s\n",
1307 cmdname(argv[0]), strerror(rc = errno));
1312 if (obd_ioctl_unpack(&data, buf, max)) {
1313 fprintf(stderr, "error: %s: invalid reply\n",
1318 printf("default_stripe_count: %u\n",
1319 desc.ld_default_stripe_count);
1320 printf("default_stripe_size: "LPU64"\n",
1321 desc.ld_default_stripe_size);
1322 printf("default_stripe_offset: "LPU64"\n",
1323 desc.ld_default_stripe_offset);
1324 printf("default_stripe_pattern: %u\n", desc.ld_pattern);
1325 printf("obd_count: %u\n", desc.ld_tgt_count);
1326 for (i = 0, ptr = uuidarray; i < desc.ld_tgt_count; i++, ptr++)
1327 printf("%u: %s\n", i, (char *)ptr);
1334 int jt_obd_test_ldlm(int argc, char **argv)
1336 struct obd_ioctl_data data;
1343 rc = ioctl(fd, IOC_LDLM_TEST, &data);
1345 fprintf(stderr, "error: %s: test failed: %s\n",
1346 cmdname(argv[0]), strerror(rc = errno));
1350 int jt_obd_dump_ldlm(int argc, char **argv)
1352 struct obd_ioctl_data data;
1359 rc = ioctl(fd, IOC_LDLM_DUMP, &data);
1361 fprintf(stderr, "error: %s failed: %s\n",
1362 cmdname(argv[0]), strerror(rc = errno));
1366 int jt_obd_ldlm_regress_start(int argc, char **argv)
1369 struct obd_ioctl_data data;
1370 char argstring[200];
1371 int i, count = sizeof(argstring) - 1;
1377 argstring[0] = '\0';
1378 for (i = 1; i < argc; i++) {
1379 strncat(argstring, " ", count);
1381 strncat(argstring, argv[i], count);
1382 count -= strlen(argv[i]);
1385 if (strlen(argstring)) {
1386 data.ioc_inlbuf1 = argstring;
1387 data.ioc_inllen1 = strlen(argstring) + 1;
1390 if (obd_ioctl_pack(&data, &buf, max)) {
1391 fprintf(stderr, "error: %s: invalid ioctl\n", cmdname(argv[0]));
1395 rc = ioctl(fd, IOC_LDLM_REGRESS_START, buf);
1398 fprintf(stderr, "error: %s: test failed: %s\n",
1399 cmdname(argv[0]), strerror(rc = errno));
1404 int jt_obd_ldlm_regress_stop(int argc, char **argv)
1407 struct obd_ioctl_data data;
1413 rc = ioctl(fd, IOC_LDLM_REGRESS_STOP, &data);
1416 fprintf(stderr, "error: %s: test failed: %s\n",
1417 cmdname(argv[0]), strerror(rc = errno));
1421 int jt_obd_lov_set_osc_active(int argc, char **argv)
1423 struct obd_ioctl_data data;
1430 data.ioc_inlbuf1 = argv[1];
1431 data.ioc_inllen1 = strlen(argv[1]) + 1;
1433 /* reuse offset for 'active' */
1434 data.ioc_offset = atoi(argv[2]);
1436 if (obd_ioctl_pack(&data, &buf, max)) {
1437 fprintf(stderr, "error: %s: invalid ioctl\n", cmdname(argv[0]));
1441 rc = ioctl(fd, IOC_LOV_SET_OSC_ACTIVE, buf);
1444 fprintf(stderr, "error: %s: failed: %s\n",
1445 cmdname(argv[0]), strerror(rc = errno));
1450 int jt_obd_newconn(int argc, char **argv)
1453 struct obd_ioctl_data data;
1456 if (argc < 2 || argc > 3)
1459 data.ioc_inllen1 = strlen(argv[1]) + 1;
1460 data.ioc_inlbuf1 = argv[1];
1463 data.ioc_inllen2 = strlen(argv[2]) + 1;
1464 data.ioc_inlbuf2 = argv[2];
1467 if (obd_ioctl_pack(&data, &buf, max)) {
1468 fprintf(stderr, "error: %s: invalid ioctl\n", cmdname(argv[0]));
1472 rc = ioctl(fd, OBD_IOC_RECOVD_NEWCONN, buf);
1474 fprintf(stderr, "error: %s: %s\n", cmdname(argv[0]),
1475 strerror(rc = errno));
1480 int jt_obd_failconn(int argc, char **argv)
1483 struct obd_ioctl_data data;
1489 data.ioc_inllen1 = strlen(argv[1]) + 1;
1490 data.ioc_inlbuf1 = argv[1];
1492 if (obd_ioctl_pack(&data, &buf, max)) {
1493 fprintf(stderr, "error: %s: invalid ioctl\n", cmdname(argv[0]));
1497 rc = ioctl(fd, OBD_IOC_RECOVD_FAILCONN, buf);
1499 fprintf(stderr, "error: %s: %s\n", cmdname(argv[0]),
1500 strerror(rc = errno));
1505 static void signal_server(int sig)
1507 if (sig == SIGINT) {
1508 do_disconnect("sigint", 1);
1511 fprintf(stderr, "%s: got signal %d\n", cmdname("sigint"), sig);
1514 int obd_initialize(int argc, char **argv)
1521 void obd_cleanup(int argc, char **argv)
1523 struct sigaction sigact;
1525 sigact.sa_handler = signal_server;
1526 sigfillset(&sigact.sa_mask);
1527 sigact.sa_flags = SA_RESTART;
1528 sigaction(SIGINT, &sigact, NULL);
1530 do_disconnect(argv[0], 1);