From: Jens Axboe Date: Thu, 15 Mar 2007 09:48:13 +0000 (+0100) Subject: Split option handling out of init.c X-Git-Tag: fio-1.15~92 X-Git-Url: https://git.kernel.dk/?p=fio.git;a=commitdiff_plain;h=214e1ecae844a32bf8f66d19132f4948d922dcee Split option handling out of init.c It grew way too large. Signed-off-by: Jens Axboe --- diff --git a/Makefile b/Makefile index 63289e68..0cb82e33 100644 --- a/Makefile +++ b/Makefile @@ -6,7 +6,7 @@ CFLAGS = -Wwrite-strings -Wall -D_GNU_SOURCE -D_LARGEFILE_SOURCE -D_FILE_OFFSET_ PROGS = fio SCRIPTS = fio_generate_plots OBJS = gettime.o fio.o ioengines.o init.o stat.o log.o time.o md5.o crc32.o \ - filesetup.o eta.o verify.o memory.o io_u.o parse.o mutex.o + filesetup.o eta.o verify.o memory.o io_u.o parse.o mutex.o options.o OBJS += engines/cpu.o OBJS += engines/libaio.o diff --git a/Makefile.FreeBSD b/Makefile.FreeBSD index 7eb3ed10..d5e675a4 100644 --- a/Makefile.FreeBSD +++ b/Makefile.FreeBSD @@ -3,7 +3,7 @@ CFLAGS = -Wall -O2 -g -D_GNU_SOURCE -D_LARGEFILE_SOURCE -D_FILE_OFFSET_BITS=64 PROGS = fio SCRIPTS = fio_generate_plots OBJS = gettime.o fio.o ioengines.o init.o stat.o log.o time.o md5.o crc32.o \ - filesetup.o eta.o verify.o memory.o io_u.o parse.o mutex.o + filesetup.o eta.o verify.o memory.o io_u.o parse.o mutex.o options.o OBJS += engines/cpu.o OBJS += engines/mmap.o diff --git a/Makefile.solaris b/Makefile.solaris index 9c3a9671..bdb82740 100644 --- a/Makefile.solaris +++ b/Makefile.solaris @@ -3,7 +3,7 @@ CFLAGS = -Wall -O2 -g -D_GNU_SOURCE -D_LARGEFILE_SOURCE -D_FILE_OFFSET_BITS=64 PROGS = fio SCRIPTS = fio_generate_plots OBJS = gettime.o fio.o ioengines.o init.o stat.o log.o time.o md5.o crc32.o \ - filesetup.o eta.o verify.o memory.o io_u.o parse.o mutex.o + filesetup.o eta.o verify.o memory.o io_u.o parse.o mutex.o options.o OBJS += engines/cpu.o OBJS += engines/mmap.o diff --git a/fio.h b/fio.h index 3f0af656..b7657181 100644 --- a/fio.h +++ b/fio.h @@ -11,6 +11,7 @@ #include #include #include +#include #include "list.h" #include "md5.h" @@ -653,9 +654,16 @@ extern void fio_gettime(struct timeval *, void *); extern void set_genesis_time(void); /* - * Init functions + * Init/option functions */ extern int __must_check parse_options(int, char **); +extern int fio_option_parse(struct thread_data *, const char *); +extern int fio_cmd_option_parse(struct thread_data *, const char *, char *); +extern void fio_fill_default_options(struct thread_data *); +extern int fio_show_option_help(const char *); +extern void fio_options_dup_and_init(struct option *); +#define FIO_GETOPT_JOB 0x89988998 +#define FIO_NR_OPTIONS 128 /* * File setup/shutdown diff --git a/init.c b/init.c index 4af00ff9..b70ccaf8 100644 --- a/init.c +++ b/init.c @@ -9,7 +9,6 @@ #include #include #include -#include #include #include #include @@ -18,644 +17,34 @@ #include "fio.h" #include "parse.h" +static char fio_version_string[] = "fio 1.14a"; + #define FIO_RANDSEED (0xb1899bedUL) -#define td_var_offset(var) ((size_t) &((struct thread_data *)0)->var) +static char **ini_file; +static int max_jobs = MAX_JOBS; -static int str_mem_cb(void *, const char *); -static int str_lockmem_cb(void *, unsigned long *); -#ifdef FIO_HAVE_IOPRIO -static int str_prio_cb(void *, unsigned int *); -static int str_prioclass_cb(void *, unsigned int *); -#endif -static int str_exitall_cb(void); -static int str_cpumask_cb(void *, unsigned int *); -static int str_fst_cb(void *, const char *); -static int str_filename_cb(void *, const char *); -static int str_directory_cb(void *, const char *); -static int str_opendir_cb(void *, const char *); +struct thread_data def_thread; +struct thread_data *threads = NULL; -#define __stringify_1(x) #x -#define __stringify(x) __stringify_1(x) +int exitall_on_terminate = 0; +int terse_output = 0; +unsigned long long mlock_size = 0; +FILE *f_out = NULL; +FILE *f_err = NULL; -/* - * Map of job/command line options - */ -static struct fio_option options[] = { - { - .name = "description", - .type = FIO_OPT_STR_STORE, - .off1 = td_var_offset(description), - .help = "Text job description", - }, - { - .name = "name", - .type = FIO_OPT_STR_STORE, - .off1 = td_var_offset(name), - .help = "Name of this job", - }, - { - .name = "directory", - .type = FIO_OPT_STR_STORE, - .off1 = td_var_offset(directory), - .cb = str_directory_cb, - .help = "Directory to store files in", - }, - { - .name = "filename", - .type = FIO_OPT_STR_STORE, - .off1 = td_var_offset(filename), - .cb = str_filename_cb, - .help = "File(s) to use for the workload", - }, - { - .name = "opendir", - .type = FIO_OPT_STR_STORE, - .off1 = td_var_offset(opendir), - .cb = str_opendir_cb, - .help = "Recursively add files from this directory and down", - }, - { - .name = "rw", - .type = FIO_OPT_STR, - .off1 = td_var_offset(td_ddir), - .help = "IO direction", - .def = "read", - .posval = { - { .ival = "read", - .oval = TD_DDIR_READ, - .help = "Sequential read", - }, - { .ival = "write", - .oval = TD_DDIR_WRITE, - .help = "Sequential write", - }, - { .ival = "randread", - .oval = TD_DDIR_RANDREAD, - .help = "Random read", - }, - { .ival = "randwrite", - .oval = TD_DDIR_RANDWRITE, - .help = "Random write", - }, - { .ival = "rw", - .oval = TD_DDIR_RW, - .help = "Sequential read and write mix", - }, - { .ival = "randrw", - .oval = TD_DDIR_RANDRW, - .help = "Random read and write mix" - }, - }, - }, - { - .name = "ioengine", - .type = FIO_OPT_STR_STORE, - .off1 = td_var_offset(ioengine), - .help = "IO engine to use", - .def = "sync", - .posval = { - { .ival = "sync", - .help = "Use read/write", - }, -#ifdef FIO_HAVE_LIBAIO - { .ival = "libaio", - .help = "Linux native asynchronous IO", - }, -#endif -#ifdef FIO_HAVE_POSIXAIO - { .ival = "posixaio", - .help = "POSIX asynchronous IO", - }, -#endif - { .ival = "mmap", - .help = "Memory mapped IO", - }, -#ifdef FIO_HAVE_SPLICE - { .ival = "splice", - .help = "splice/vmsplice based IO", - }, -#endif -#ifdef FIO_HAVE_SGIO - { .ival = "sg", - .help = "SCSI generic v3 IO", - }, -#endif - { .ival = "null", - .help = "Testing engine (no data transfer)", - }, - { .ival = "net", - .help = "Network IO", - }, -#ifdef FIO_HAVE_SYSLET - { .ival = "syslet-rw", - .help = "syslet enabled async pread/pwrite IO", - }, -#endif - { .ival = "cpuio", - .help = "CPU cycler burner engine", - }, - { .ival = "external", - .help = "Load external engine (append name)", - }, - }, - }, - { - .name = "iodepth", - .type = FIO_OPT_INT, - .off1 = td_var_offset(iodepth), - .help = "Amount of IO buffers to keep in flight", - .def = "1", - }, - { - .name = "iodepth_batch", - .type = FIO_OPT_INT, - .off1 = td_var_offset(iodepth_batch), - .help = "Number of IO to submit in one go", - }, - { - .name = "iodepth_low", - .type = FIO_OPT_INT, - .off1 = td_var_offset(iodepth_low), - .help = "Low water mark for queuing depth", - }, - { - .name = "size", - .type = FIO_OPT_STR_VAL, - .off1 = td_var_offset(total_file_size), - .help = "Total size of device or files", - }, - { - .name = "filesize", - .type = FIO_OPT_STR_VAL, - .off1 = td_var_offset(file_size_low), - .off2 = td_var_offset(file_size_high), - .help = "Size of individual files", - }, - { - .name = "bs", - .type = FIO_OPT_STR_VAL_INT, - .off1 = td_var_offset(bs[DDIR_READ]), - .off2 = td_var_offset(bs[DDIR_WRITE]), - .help = "Block size unit", - .def = "4k", - }, - { - .name = "bsrange", - .type = FIO_OPT_RANGE, - .off1 = td_var_offset(min_bs[DDIR_READ]), - .off2 = td_var_offset(max_bs[DDIR_READ]), - .off3 = td_var_offset(min_bs[DDIR_WRITE]), - .off4 = td_var_offset(max_bs[DDIR_WRITE]), - .help = "Set block size range (in more detail than bs)", - }, - { - .name = "bs_unaligned", - .type = FIO_OPT_STR_SET, - .off1 = td_var_offset(bs_unaligned), - .help = "Don't sector align IO buffer sizes", - }, - { - .name = "offset", - .type = FIO_OPT_STR_VAL, - .off1 = td_var_offset(start_offset), - .help = "Start IO from this offset", - .def = "0", - }, - { - .name = "randrepeat", - .type = FIO_OPT_BOOL, - .off1 = td_var_offset(rand_repeatable), - .help = "Use repeatable random IO pattern", - .def = "1", - }, - { - .name = "norandommap", - .type = FIO_OPT_STR_SET, - .off1 = td_var_offset(norandommap), - .help = "Accept potential duplicate random blocks", - }, - { - .name = "nrfiles", - .type = FIO_OPT_INT, - .off1 = td_var_offset(nr_files), - .help = "Split job workload between this number of files", - .def = "1", - }, - { - .name = "openfiles", - .type = FIO_OPT_INT, - .off1 = td_var_offset(open_files), - .help = "Number of files to keep open at the same time", - }, - { - .name = "file_service_type", - .type = FIO_OPT_STR, - .cb = str_fst_cb, - .off1 = td_var_offset(file_service_type), - .help = "How to select which file to service next", - .def = "roundrobin", - .posval = { - { .ival = "random", - .oval = FIO_FSERVICE_RANDOM, - .help = "Choose a file at random", - }, - { .ival = "roundrobin", - .oval = FIO_FSERVICE_RR, - .help = "Round robin select files", - }, - }, - }, - { - .name = "fsync", - .type = FIO_OPT_INT, - .off1 = td_var_offset(fsync_blocks), - .help = "Issue fsync for writes every given number of blocks", - .def = "0", - }, - { - .name = "direct", - .type = FIO_OPT_BOOL, - .off1 = td_var_offset(odirect), - .help = "Use O_DIRECT IO (negates buffered)", - .def = "0", - }, - { - .name = "buffered", - .type = FIO_OPT_BOOL, - .off1 = td_var_offset(odirect), - .neg = 1, - .help = "Use buffered IO (negates direct)", - .def = "1", - }, - { - .name = "overwrite", - .type = FIO_OPT_BOOL, - .off1 = td_var_offset(overwrite), - .help = "When writing, set whether to overwrite current data", - .def = "0", - }, - { - .name = "loops", - .type = FIO_OPT_INT, - .off1 = td_var_offset(loops), - .help = "Number of times to run the job", - .def = "1", - }, - { - .name = "numjobs", - .type = FIO_OPT_INT, - .off1 = td_var_offset(numjobs), - .help = "Duplicate this job this many times", - .def = "1", - }, - { - .name = "startdelay", - .type = FIO_OPT_INT, - .off1 = td_var_offset(start_delay), - .help = "Only start job when this period has passed", - .def = "0", - }, - { - .name = "runtime", - .alias = "timeout", - .type = FIO_OPT_STR_VAL_TIME, - .off1 = td_var_offset(timeout), - .help = "Stop workload when this amount of time has passed", - .def = "0", - }, - { - .name = "mem", - .type = FIO_OPT_STR, - .cb = str_mem_cb, - .off1 = td_var_offset(mem_type), - .help = "Backing type for IO buffers", - .def = "malloc", - .posval = { - { .ival = "malloc", - .oval = MEM_MALLOC, - .help = "Use malloc(3) for IO buffers", - }, - { .ival = "shm", - .oval = MEM_SHM, - .help = "Use shared memory segments for IO buffers", - }, -#ifdef FIO_HAVE_HUGETLB - { .ival = "shmhuge", - .oval = MEM_SHMHUGE, - .help = "Like shm, but use huge pages", - }, -#endif - { .ival = "mmap", - .oval = MEM_MMAP, - .help = "Use mmap(2) (file or anon) for IO buffers", - }, -#ifdef FIO_HAVE_HUGETLB - { .ival = "mmaphuge", - .oval = MEM_MMAPHUGE, - .help = "Like mmap, but use huge pages", - }, -#endif - }, - }, - { - .name = "verify", - .type = FIO_OPT_STR, - .off1 = td_var_offset(verify), - .help = "Verify data written", - .def = "0", - .posval = { - { .ival = "0", - .oval = VERIFY_NONE, - .help = "Don't do IO verification", - }, - { .ival = "crc32", - .oval = VERIFY_CRC32, - .help = "Use crc32 checksums for verification", - }, - { .ival = "md5", - .oval = VERIFY_MD5, - .help = "Use md5 checksums for verification", - }, - }, - }, - { - .name = "write_iolog", - .type = FIO_OPT_STR_STORE, - .off1 = td_var_offset(write_iolog_file), - .help = "Store IO pattern to file", - }, - { - .name = "read_iolog", - .type = FIO_OPT_STR_STORE, - .off1 = td_var_offset(read_iolog_file), - .help = "Playback IO pattern from file", - }, - { - .name = "exec_prerun", - .type = FIO_OPT_STR_STORE, - .off1 = td_var_offset(exec_prerun), - .help = "Execute this file prior to running job", - }, - { - .name = "exec_postrun", - .type = FIO_OPT_STR_STORE, - .off1 = td_var_offset(exec_postrun), - .help = "Execute this file after running job", - }, -#ifdef FIO_HAVE_IOSCHED_SWITCH - { - .name = "ioscheduler", - .type = FIO_OPT_STR_STORE, - .off1 = td_var_offset(ioscheduler), - .help = "Use this IO scheduler on the backing device", - }, -#endif - { - .name = "zonesize", - .type = FIO_OPT_STR_VAL, - .off1 = td_var_offset(zone_size), - .help = "Give size of an IO zone", - .def = "0", - }, - { - .name = "zoneskip", - .type = FIO_OPT_STR_VAL, - .off1 = td_var_offset(zone_skip), - .help = "Space between IO zones", - .def = "0", - }, - { - .name = "lockmem", - .type = FIO_OPT_STR_VAL, - .cb = str_lockmem_cb, - .help = "Lock down this amount of memory", - .def = "0", - }, - { - .name = "rwmixcycle", - .type = FIO_OPT_INT, - .off1 = td_var_offset(rwmixcycle), - .help = "Cycle period for mixed read/write workloads (msec)", - .def = "500", - }, - { - .name = "rwmixread", - .type = FIO_OPT_INT, - .off1 = td_var_offset(rwmixread), - .maxval = 100, - .help = "Percentage of mixed workload that is reads", - .def = "50", - }, - { - .name = "rwmixwrite", - .type = FIO_OPT_INT, - .off1 = td_var_offset(rwmixwrite), - .maxval = 100, - .help = "Percentage of mixed workload that is writes", - .def = "50", - }, - { - .name = "nice", - .type = FIO_OPT_INT, - .off1 = td_var_offset(nice), - .help = "Set job CPU nice value", - .minval = -19, - .maxval = 20, - .def = "0", - }, -#ifdef FIO_HAVE_IOPRIO - { - .name = "prio", - .type = FIO_OPT_INT, - .cb = str_prio_cb, - .help = "Set job IO priority value", - .minval = 0, - .maxval = 7, - }, - { - .name = "prioclass", - .type = FIO_OPT_INT, - .cb = str_prioclass_cb, - .help = "Set job IO priority class", - .minval = 0, - .maxval = 3, - }, -#endif - { - .name = "thinktime", - .type = FIO_OPT_INT, - .off1 = td_var_offset(thinktime), - .help = "Idle time between IO buffers (usec)", - .def = "0", - }, - { - .name = "thinktime_spin", - .type = FIO_OPT_INT, - .off1 = td_var_offset(thinktime_spin), - .help = "Start think time by spinning this amount (usec)", - .def = "0", - }, - { - .name = "thinktime_blocks", - .type = FIO_OPT_INT, - .off1 = td_var_offset(thinktime_blocks), - .help = "IO buffer period between 'thinktime'", - .def = "1", - }, - { - .name = "rate", - .type = FIO_OPT_INT, - .off1 = td_var_offset(rate), - .help = "Set bandwidth rate", - }, - { - .name = "ratemin", - .type = FIO_OPT_INT, - .off1 = td_var_offset(ratemin), - .help = "The bottom limit accepted", - }, - { - .name = "ratecycle", - .type = FIO_OPT_INT, - .off1 = td_var_offset(ratecycle), - .help = "Window average for rate limits (msec)", - .def = "1000", - }, - { - .name = "invalidate", - .type = FIO_OPT_BOOL, - .off1 = td_var_offset(invalidate_cache), - .help = "Invalidate buffer/page cache prior to running job", - .def = "1", - }, - { - .name = "sync", - .type = FIO_OPT_BOOL, - .off1 = td_var_offset(sync_io), - .help = "Use O_SYNC for buffered writes", - .def = "0", - }, - { - .name = "bwavgtime", - .type = FIO_OPT_INT, - .off1 = td_var_offset(bw_avg_time), - .help = "Time window over which to calculate bandwidth (msec)", - .def = "500", - }, - { - .name = "create_serialize", - .type = FIO_OPT_BOOL, - .off1 = td_var_offset(create_serialize), - .help = "Serialize creating of job files", - .def = "1", - }, - { - .name = "create_fsync", - .type = FIO_OPT_BOOL, - .off1 = td_var_offset(create_fsync), - .help = "Fsync file after creation", - .def = "1", - }, - { - .name = "cpuload", - .type = FIO_OPT_INT, - .off1 = td_var_offset(cpuload), - .help = "Use this percentage of CPU", - }, - { - .name = "cpuchunks", - .type = FIO_OPT_INT, - .off1 = td_var_offset(cpucycle), - .help = "Length of the CPU burn cycles (usecs)", - .def = "50000", - }, -#ifdef FIO_HAVE_CPU_AFFINITY - { - .name = "cpumask", - .type = FIO_OPT_INT, - .cb = str_cpumask_cb, - .help = "CPU affinity mask", - }, -#endif - { - .name = "end_fsync", - .type = FIO_OPT_BOOL, - .off1 = td_var_offset(end_fsync), - .help = "Include fsync at the end of job", - .def = "0", - }, - { - .name = "fsync_on_close", - .type = FIO_OPT_BOOL, - .off1 = td_var_offset(fsync_on_close), - .help = "fsync files on close", - .def = "0", - }, - { - .name = "unlink", - .type = FIO_OPT_BOOL, - .off1 = td_var_offset(unlink), - .help = "Unlink created files after job has completed", - .def = "0", - }, - { - .name = "exitall", - .type = FIO_OPT_STR_SET, - .cb = str_exitall_cb, - .help = "Terminate all jobs when one exits", - }, - { - .name = "stonewall", - .type = FIO_OPT_STR_SET, - .off1 = td_var_offset(stonewall), - .help = "Insert a hard barrier between this job and previous", - }, - { - .name = "thread", - .type = FIO_OPT_STR_SET, - .off1 = td_var_offset(use_thread), - .help = "Use threads instead of forks", - }, - { - .name = "write_bw_log", - .type = FIO_OPT_STR_SET, - .off1 = td_var_offset(write_bw_log), - .help = "Write log of bandwidth during run", - }, - { - .name = "write_lat_log", - .type = FIO_OPT_STR_SET, - .off1 = td_var_offset(write_lat_log), - .help = "Write log of latency during run", - }, - { - .name = "hugepage-size", - .type = FIO_OPT_STR_VAL, - .off1 = td_var_offset(hugepage_size), - .help = "When using hugepages, specify size of each page", - .def = __stringify(FIO_HUGE_PAGE), - }, - { - .name = "group_reporting", - .type = FIO_OPT_STR_SET, - .off1 = td_var_offset(group_reporting), - .help = "Do reporting on a per-group basis", - }, - { - .name = NULL, - }, -}; +int write_bw_log = 0; + +static int def_timeout = 0; +static int write_lat_log = 0; -#define FIO_JOB_OPTS (sizeof(options) / sizeof(struct fio_option)) -#define FIO_CMD_OPTS (16) -#define FIO_GETOPT_JOB (0x89988998) +static int prev_group_jobs; /* * Command line options. These will contain the above, plus a few * extra that only pertain to fio itself and not jobs. */ -static struct option long_options[FIO_JOB_OPTS + FIO_CMD_OPTS] = { +static struct option long_options[FIO_NR_OPTIONS] = { { .name = "output", .has_arg = required_argument, @@ -701,27 +90,6 @@ static struct option long_options[FIO_JOB_OPTS + FIO_CMD_OPTS] = { }, }; -static int def_timeout = 0; - -static char fio_version_string[] = "fio 1.14a"; - -static char **ini_file; -static int max_jobs = MAX_JOBS; - -struct thread_data def_thread; -struct thread_data *threads = NULL; - -int exitall_on_terminate = 0; -int terse_output = 0; -unsigned long long mlock_size = 0; -FILE *f_out = NULL; -FILE *f_err = NULL; - -static int write_lat_log = 0; -int write_bw_log = 0; - -static int prev_group_jobs; - FILE *get_f_out() { return f_out; @@ -1111,20 +479,6 @@ err: return -1; } -static void fill_cpu_mask(os_cpu_mask_t cpumask, int cpu) -{ -#ifdef FIO_HAVE_CPU_AFFINITY - unsigned int i; - - CPU_ZERO(&cpumask); - - for (i = 0; i < sizeof(int) * 8; i++) { - if ((1 << i) & cpu) - CPU_SET(i, &cpumask); - } -#endif -} - static int is_empty_or_comment(char *line) { unsigned int i; @@ -1141,139 +495,6 @@ static int is_empty_or_comment(char *line) return 1; } -/* - * Check if mmap/mmaphuge has a :/foo/bar/file at the end. If so, return that. - */ -static char *get_opt_postfix(const char *str) -{ - char *p = strstr(str, ":"); - - if (!p) - return NULL; - - p++; - strip_blank_front(&p); - strip_blank_end(p); - return strdup(p); -} - -static int str_mem_cb(void *data, const char *mem) -{ - struct thread_data *td = data; - - if (td->mem_type == MEM_MMAPHUGE || td->mem_type == MEM_MMAP) { - td->mmapfile = get_opt_postfix(mem); - if (td->mem_type == MEM_MMAPHUGE && !td->mmapfile) { - log_err("fio: mmaphuge:/path/to/file\n"); - return 1; - } - } - - return 0; -} - -static int str_lockmem_cb(void fio_unused *data, unsigned long *val) -{ - mlock_size = *val; - return 0; -} - -#ifdef FIO_HAVE_IOPRIO -static int str_prioclass_cb(void *data, unsigned int *val) -{ - struct thread_data *td = data; - - td->ioprio |= *val << IOPRIO_CLASS_SHIFT; - return 0; -} - -static int str_prio_cb(void *data, unsigned int *val) -{ - struct thread_data *td = data; - - td->ioprio |= *val; - return 0; -} -#endif - -static int str_exitall_cb(void) -{ - exitall_on_terminate = 1; - return 0; -} - -static int str_cpumask_cb(void *data, unsigned int *val) -{ - struct thread_data *td = data; - - fill_cpu_mask(td->cpumask, *val); - return 0; -} - -static int str_fst_cb(void *data, const char *str) -{ - struct thread_data *td = data; - char *nr = get_opt_postfix(str); - - td->file_service_nr = 1; - if (nr) - td->file_service_nr = atoi(nr); - - return 0; -} - -static int str_filename_cb(void *data, const char *input) -{ - struct thread_data *td = data; - char *fname, *str, *p; - - p = str = strdup(input); - - strip_blank_front(&str); - strip_blank_end(str); - - if (!td->files_index) - td->nr_files = 0; - - while ((fname = strsep(&str, ":")) != NULL) { - if (!strlen(fname)) - break; - add_file(td, fname); - td->nr_files++; - } - - free(p); - return 0; -} - -static int str_directory_cb(void *data, const char fio_unused *str) -{ - struct thread_data *td = data; - struct stat sb; - - if (lstat(td->directory, &sb) < 0) { - log_err("fio: %s is not a directory\n", td->directory); - td_verror(td, errno, "lstat"); - return 1; - } - if (!S_ISDIR(sb.st_mode)) { - log_err("fio: %s is not a directory\n", td->directory); - return 1; - } - - return 0; -} - -static int str_opendir_cb(void *data, const char fio_unused *str) -{ - struct thread_data *td = data; - - if (!td->files_index) - td->nr_files = 0; - - return add_dir_files(td, td->opendir); -} - /* * This is our [ini] type file parser. */ @@ -1344,7 +565,7 @@ static int parse_jobs_ini(char *file, int stonewall_flag) * dump all the bad ones. Makes trial/error fixups * easier on the user. */ - ret |= parse_option(p, options, td); + ret |= fio_option_parse(td, p); } if (!ret) { @@ -1374,7 +595,7 @@ static int fill_def_thread(void) /* * fill default options */ - fill_default_options(&def_thread, options); + fio_fill_default_options(&def_thread); def_thread.timeout = def_timeout; def_thread.write_bw_log = write_bw_log; @@ -1387,6 +608,55 @@ static int fill_def_thread(void) return 0; } +static void free_shm(void) +{ + struct shmid_ds sbuf; + + if (threads) { + shmdt((void *) threads); + threads = NULL; + shmctl(shm_id, IPC_RMID, &sbuf); + } +} + +/* + * The thread area is shared between the main process and the job + * threads/processes. So setup a shared memory segment that will hold + * all the job info. + */ +static int setup_thread_area(void) +{ + /* + * 1024 is too much on some machines, scale max_jobs if + * we get a failure that looks like too large a shm segment + */ + do { + size_t size = max_jobs * sizeof(struct thread_data); + + shm_id = shmget(0, size, IPC_CREAT | 0600); + if (shm_id != -1) + break; + if (errno != EINVAL) { + perror("shmget"); + break; + } + + max_jobs >>= 1; + } while (max_jobs); + + if (shm_id == -1) + return 1; + + threads = shmat(shm_id, NULL, 0); + if (threads == (void *) -1) { + perror("shmat"); + return 1; + } + + atexit(free_shm); + return 0; +} + static void usage(void) { printf("%s\n", fio_version_string); @@ -1431,8 +701,7 @@ static int parse_cmd_line(int argc, char *argv[]) usage(); exit(0); case 'c': - ret = show_cmd_help(options, optarg); - exit(ret); + exit(fio_show_option_help(optarg)); case 'v': printf("%s\n", fio_version_string); exit(0); @@ -1456,7 +725,7 @@ static int parse_cmd_line(int argc, char *argv[]) return 0; } - ret = parse_cmd_option(opt, val, options, td); + ret = fio_cmd_option_parse(td, opt, val); if (ret) dont_add_job = 1; break; @@ -1486,82 +755,6 @@ static int parse_cmd_line(int argc, char *argv[]) return ini_idx; } -static void free_shm(void) -{ - struct shmid_ds sbuf; - - if (threads) { - shmdt((void *) threads); - threads = NULL; - shmctl(shm_id, IPC_RMID, &sbuf); - } -} - -/* - * The thread area is shared between the main process and the job - * threads/processes. So setup a shared memory segment that will hold - * all the job info. - */ -static int setup_thread_area(void) -{ - /* - * 1024 is too much on some machines, scale max_jobs if - * we get a failure that looks like too large a shm segment - */ - do { - size_t size = max_jobs * sizeof(struct thread_data); - - shm_id = shmget(0, size, IPC_CREAT | 0600); - if (shm_id != -1) - break; - if (errno != EINVAL) { - perror("shmget"); - break; - } - - max_jobs >>= 1; - } while (max_jobs); - - if (shm_id == -1) - return 1; - - threads = shmat(shm_id, NULL, 0); - if (threads == (void *) -1) { - perror("shmat"); - return 1; - } - - atexit(free_shm); - return 0; -} - -/* - * Copy the fio options into the long options map, so we mirror - * job and cmd line options. - */ -static void dupe_job_options(void) -{ - struct fio_option *o; - unsigned int i; - - i = 0; - while (long_options[i].name) - i++; - - o = &options[0]; - while (o->name) { - long_options[i].name = o->name; - long_options[i].val = FIO_GETOPT_JOB; - if (o->type == FIO_OPT_STR_SET) - long_options[i].has_arg = no_argument; - else - long_options[i].has_arg = required_argument; - - i++; - o++; - assert(i < FIO_JOB_OPTS + FIO_CMD_OPTS); - } -} int parse_options(int argc, char *argv[]) { @@ -1570,9 +763,7 @@ int parse_options(int argc, char *argv[]) f_out = stdout; f_err = stderr; - options_init(options); - - dupe_job_options(); + fio_options_dup_and_init(long_options); if (setup_thread_area()) return 1; diff --git a/options.c b/options.c new file mode 100644 index 00000000..abd02c8c --- /dev/null +++ b/options.c @@ -0,0 +1,818 @@ +#include +#include +#include +#include +#include +#include +#include + +#include "fio.h" +#include "parse.h" + +#define td_var_offset(var) ((size_t) &((struct thread_data *)0)->var) + +/* + * Check if mmap/mmaphuge has a :/foo/bar/file at the end. If so, return that. + */ +static char *get_opt_postfix(const char *str) +{ + char *p = strstr(str, ":"); + + if (!p) + return NULL; + + p++; + strip_blank_front(&p); + strip_blank_end(p); + return strdup(p); +} + +static int str_mem_cb(void *data, const char *mem) +{ + struct thread_data *td = data; + + if (td->mem_type == MEM_MMAPHUGE || td->mem_type == MEM_MMAP) { + td->mmapfile = get_opt_postfix(mem); + if (td->mem_type == MEM_MMAPHUGE && !td->mmapfile) { + log_err("fio: mmaphuge:/path/to/file\n"); + return 1; + } + } + + return 0; +} + +static int str_lockmem_cb(void fio_unused *data, unsigned long *val) +{ + mlock_size = *val; + return 0; +} + +#ifdef FIO_HAVE_IOPRIO +static int str_prioclass_cb(void *data, unsigned int *val) +{ + struct thread_data *td = data; + + td->ioprio |= *val << IOPRIO_CLASS_SHIFT; + return 0; +} + +static int str_prio_cb(void *data, unsigned int *val) +{ + struct thread_data *td = data; + + td->ioprio |= *val; + return 0; +} +#endif + +static int str_exitall_cb(void) +{ + exitall_on_terminate = 1; + return 0; +} + +static void fill_cpu_mask(os_cpu_mask_t cpumask, int cpu) +{ +#ifdef FIO_HAVE_CPU_AFFINITY + unsigned int i; + + CPU_ZERO(&cpumask); + + for (i = 0; i < sizeof(int) * 8; i++) { + if ((1 << i) & cpu) + CPU_SET(i, &cpumask); + } +#endif +} + +static int str_cpumask_cb(void *data, unsigned int *val) +{ + struct thread_data *td = data; + + fill_cpu_mask(td->cpumask, *val); + return 0; +} + +static int str_fst_cb(void *data, const char *str) +{ + struct thread_data *td = data; + char *nr = get_opt_postfix(str); + + td->file_service_nr = 1; + if (nr) + td->file_service_nr = atoi(nr); + + return 0; +} + +static int str_filename_cb(void *data, const char *input) +{ + struct thread_data *td = data; + char *fname, *str, *p; + + p = str = strdup(input); + + strip_blank_front(&str); + strip_blank_end(str); + + if (!td->files_index) + td->nr_files = 0; + + while ((fname = strsep(&str, ":")) != NULL) { + if (!strlen(fname)) + break; + add_file(td, fname); + td->nr_files++; + } + + free(p); + return 0; +} + +static int str_directory_cb(void *data, const char fio_unused *str) +{ + struct thread_data *td = data; + struct stat sb; + + if (lstat(td->directory, &sb) < 0) { + log_err("fio: %s is not a directory\n", td->directory); + td_verror(td, errno, "lstat"); + return 1; + } + if (!S_ISDIR(sb.st_mode)) { + log_err("fio: %s is not a directory\n", td->directory); + return 1; + } + + return 0; +} + +static int str_opendir_cb(void *data, const char fio_unused *str) +{ + struct thread_data *td = data; + + if (!td->files_index) + td->nr_files = 0; + + return add_dir_files(td, td->opendir); +} + + +#define __stringify_1(x) #x +#define __stringify(x) __stringify_1(x) + +/* + * Map of job/command line options + */ +static struct fio_option options[] = { + { + .name = "description", + .type = FIO_OPT_STR_STORE, + .off1 = td_var_offset(description), + .help = "Text job description", + }, + { + .name = "name", + .type = FIO_OPT_STR_STORE, + .off1 = td_var_offset(name), + .help = "Name of this job", + }, + { + .name = "directory", + .type = FIO_OPT_STR_STORE, + .off1 = td_var_offset(directory), + .cb = str_directory_cb, + .help = "Directory to store files in", + }, + { + .name = "filename", + .type = FIO_OPT_STR_STORE, + .off1 = td_var_offset(filename), + .cb = str_filename_cb, + .help = "File(s) to use for the workload", + }, + { + .name = "opendir", + .type = FIO_OPT_STR_STORE, + .off1 = td_var_offset(opendir), + .cb = str_opendir_cb, + .help = "Recursively add files from this directory and down", + }, + { + .name = "rw", + .type = FIO_OPT_STR, + .off1 = td_var_offset(td_ddir), + .help = "IO direction", + .def = "read", + .posval = { + { .ival = "read", + .oval = TD_DDIR_READ, + .help = "Sequential read", + }, + { .ival = "write", + .oval = TD_DDIR_WRITE, + .help = "Sequential write", + }, + { .ival = "randread", + .oval = TD_DDIR_RANDREAD, + .help = "Random read", + }, + { .ival = "randwrite", + .oval = TD_DDIR_RANDWRITE, + .help = "Random write", + }, + { .ival = "rw", + .oval = TD_DDIR_RW, + .help = "Sequential read and write mix", + }, + { .ival = "randrw", + .oval = TD_DDIR_RANDRW, + .help = "Random read and write mix" + }, + }, + }, + { + .name = "ioengine", + .type = FIO_OPT_STR_STORE, + .off1 = td_var_offset(ioengine), + .help = "IO engine to use", + .def = "sync", + .posval = { + { .ival = "sync", + .help = "Use read/write", + }, +#ifdef FIO_HAVE_LIBAIO + { .ival = "libaio", + .help = "Linux native asynchronous IO", + }, +#endif +#ifdef FIO_HAVE_POSIXAIO + { .ival = "posixaio", + .help = "POSIX asynchronous IO", + }, +#endif + { .ival = "mmap", + .help = "Memory mapped IO", + }, +#ifdef FIO_HAVE_SPLICE + { .ival = "splice", + .help = "splice/vmsplice based IO", + }, +#endif +#ifdef FIO_HAVE_SGIO + { .ival = "sg", + .help = "SCSI generic v3 IO", + }, +#endif + { .ival = "null", + .help = "Testing engine (no data transfer)", + }, + { .ival = "net", + .help = "Network IO", + }, +#ifdef FIO_HAVE_SYSLET + { .ival = "syslet-rw", + .help = "syslet enabled async pread/pwrite IO", + }, +#endif + { .ival = "cpuio", + .help = "CPU cycler burner engine", + }, + { .ival = "external", + .help = "Load external engine (append name)", + }, + }, + }, + { + .name = "iodepth", + .type = FIO_OPT_INT, + .off1 = td_var_offset(iodepth), + .help = "Amount of IO buffers to keep in flight", + .def = "1", + }, + { + .name = "iodepth_batch", + .type = FIO_OPT_INT, + .off1 = td_var_offset(iodepth_batch), + .help = "Number of IO to submit in one go", + }, + { + .name = "iodepth_low", + .type = FIO_OPT_INT, + .off1 = td_var_offset(iodepth_low), + .help = "Low water mark for queuing depth", + }, + { + .name = "size", + .type = FIO_OPT_STR_VAL, + .off1 = td_var_offset(total_file_size), + .help = "Total size of device or files", + }, + { + .name = "filesize", + .type = FIO_OPT_STR_VAL, + .off1 = td_var_offset(file_size_low), + .off2 = td_var_offset(file_size_high), + .help = "Size of individual files", + }, + { + .name = "bs", + .type = FIO_OPT_STR_VAL_INT, + .off1 = td_var_offset(bs[DDIR_READ]), + .off2 = td_var_offset(bs[DDIR_WRITE]), + .help = "Block size unit", + .def = "4k", + }, + { + .name = "bsrange", + .type = FIO_OPT_RANGE, + .off1 = td_var_offset(min_bs[DDIR_READ]), + .off2 = td_var_offset(max_bs[DDIR_READ]), + .off3 = td_var_offset(min_bs[DDIR_WRITE]), + .off4 = td_var_offset(max_bs[DDIR_WRITE]), + .help = "Set block size range (in more detail than bs)", + }, + { + .name = "bs_unaligned", + .type = FIO_OPT_STR_SET, + .off1 = td_var_offset(bs_unaligned), + .help = "Don't sector align IO buffer sizes", + }, + { + .name = "offset", + .type = FIO_OPT_STR_VAL, + .off1 = td_var_offset(start_offset), + .help = "Start IO from this offset", + .def = "0", + }, + { + .name = "randrepeat", + .type = FIO_OPT_BOOL, + .off1 = td_var_offset(rand_repeatable), + .help = "Use repeatable random IO pattern", + .def = "1", + }, + { + .name = "norandommap", + .type = FIO_OPT_STR_SET, + .off1 = td_var_offset(norandommap), + .help = "Accept potential duplicate random blocks", + }, + { + .name = "nrfiles", + .type = FIO_OPT_INT, + .off1 = td_var_offset(nr_files), + .help = "Split job workload between this number of files", + .def = "1", + }, + { + .name = "openfiles", + .type = FIO_OPT_INT, + .off1 = td_var_offset(open_files), + .help = "Number of files to keep open at the same time", + }, + { + .name = "file_service_type", + .type = FIO_OPT_STR, + .cb = str_fst_cb, + .off1 = td_var_offset(file_service_type), + .help = "How to select which file to service next", + .def = "roundrobin", + .posval = { + { .ival = "random", + .oval = FIO_FSERVICE_RANDOM, + .help = "Choose a file at random", + }, + { .ival = "roundrobin", + .oval = FIO_FSERVICE_RR, + .help = "Round robin select files", + }, + }, + }, + { + .name = "fsync", + .type = FIO_OPT_INT, + .off1 = td_var_offset(fsync_blocks), + .help = "Issue fsync for writes every given number of blocks", + .def = "0", + }, + { + .name = "direct", + .type = FIO_OPT_BOOL, + .off1 = td_var_offset(odirect), + .help = "Use O_DIRECT IO (negates buffered)", + .def = "0", + }, + { + .name = "buffered", + .type = FIO_OPT_BOOL, + .off1 = td_var_offset(odirect), + .neg = 1, + .help = "Use buffered IO (negates direct)", + .def = "1", + }, + { + .name = "overwrite", + .type = FIO_OPT_BOOL, + .off1 = td_var_offset(overwrite), + .help = "When writing, set whether to overwrite current data", + .def = "0", + }, + { + .name = "loops", + .type = FIO_OPT_INT, + .off1 = td_var_offset(loops), + .help = "Number of times to run the job", + .def = "1", + }, + { + .name = "numjobs", + .type = FIO_OPT_INT, + .off1 = td_var_offset(numjobs), + .help = "Duplicate this job this many times", + .def = "1", + }, + { + .name = "startdelay", + .type = FIO_OPT_INT, + .off1 = td_var_offset(start_delay), + .help = "Only start job when this period has passed", + .def = "0", + }, + { + .name = "runtime", + .alias = "timeout", + .type = FIO_OPT_STR_VAL_TIME, + .off1 = td_var_offset(timeout), + .help = "Stop workload when this amount of time has passed", + .def = "0", + }, + { + .name = "mem", + .type = FIO_OPT_STR, + .cb = str_mem_cb, + .off1 = td_var_offset(mem_type), + .help = "Backing type for IO buffers", + .def = "malloc", + .posval = { + { .ival = "malloc", + .oval = MEM_MALLOC, + .help = "Use malloc(3) for IO buffers", + }, + { .ival = "shm", + .oval = MEM_SHM, + .help = "Use shared memory segments for IO buffers", + }, +#ifdef FIO_HAVE_HUGETLB + { .ival = "shmhuge", + .oval = MEM_SHMHUGE, + .help = "Like shm, but use huge pages", + }, +#endif + { .ival = "mmap", + .oval = MEM_MMAP, + .help = "Use mmap(2) (file or anon) for IO buffers", + }, +#ifdef FIO_HAVE_HUGETLB + { .ival = "mmaphuge", + .oval = MEM_MMAPHUGE, + .help = "Like mmap, but use huge pages", + }, +#endif + }, + }, + { + .name = "verify", + .type = FIO_OPT_STR, + .off1 = td_var_offset(verify), + .help = "Verify data written", + .def = "0", + .posval = { + { .ival = "0", + .oval = VERIFY_NONE, + .help = "Don't do IO verification", + }, + { .ival = "crc32", + .oval = VERIFY_CRC32, + .help = "Use crc32 checksums for verification", + }, + { .ival = "md5", + .oval = VERIFY_MD5, + .help = "Use md5 checksums for verification", + }, + }, + }, + { + .name = "write_iolog", + .type = FIO_OPT_STR_STORE, + .off1 = td_var_offset(write_iolog_file), + .help = "Store IO pattern to file", + }, + { + .name = "read_iolog", + .type = FIO_OPT_STR_STORE, + .off1 = td_var_offset(read_iolog_file), + .help = "Playback IO pattern from file", + }, + { + .name = "exec_prerun", + .type = FIO_OPT_STR_STORE, + .off1 = td_var_offset(exec_prerun), + .help = "Execute this file prior to running job", + }, + { + .name = "exec_postrun", + .type = FIO_OPT_STR_STORE, + .off1 = td_var_offset(exec_postrun), + .help = "Execute this file after running job", + }, +#ifdef FIO_HAVE_IOSCHED_SWITCH + { + .name = "ioscheduler", + .type = FIO_OPT_STR_STORE, + .off1 = td_var_offset(ioscheduler), + .help = "Use this IO scheduler on the backing device", + }, +#endif + { + .name = "zonesize", + .type = FIO_OPT_STR_VAL, + .off1 = td_var_offset(zone_size), + .help = "Give size of an IO zone", + .def = "0", + }, + { + .name = "zoneskip", + .type = FIO_OPT_STR_VAL, + .off1 = td_var_offset(zone_skip), + .help = "Space between IO zones", + .def = "0", + }, + { + .name = "lockmem", + .type = FIO_OPT_STR_VAL, + .cb = str_lockmem_cb, + .help = "Lock down this amount of memory", + .def = "0", + }, + { + .name = "rwmixcycle", + .type = FIO_OPT_INT, + .off1 = td_var_offset(rwmixcycle), + .help = "Cycle period for mixed read/write workloads (msec)", + .def = "500", + }, + { + .name = "rwmixread", + .type = FIO_OPT_INT, + .off1 = td_var_offset(rwmixread), + .maxval = 100, + .help = "Percentage of mixed workload that is reads", + .def = "50", + }, + { + .name = "rwmixwrite", + .type = FIO_OPT_INT, + .off1 = td_var_offset(rwmixwrite), + .maxval = 100, + .help = "Percentage of mixed workload that is writes", + .def = "50", + }, + { + .name = "nice", + .type = FIO_OPT_INT, + .off1 = td_var_offset(nice), + .help = "Set job CPU nice value", + .minval = -19, + .maxval = 20, + .def = "0", + }, +#ifdef FIO_HAVE_IOPRIO + { + .name = "prio", + .type = FIO_OPT_INT, + .cb = str_prio_cb, + .help = "Set job IO priority value", + .minval = 0, + .maxval = 7, + }, + { + .name = "prioclass", + .type = FIO_OPT_INT, + .cb = str_prioclass_cb, + .help = "Set job IO priority class", + .minval = 0, + .maxval = 3, + }, +#endif + { + .name = "thinktime", + .type = FIO_OPT_INT, + .off1 = td_var_offset(thinktime), + .help = "Idle time between IO buffers (usec)", + .def = "0", + }, + { + .name = "thinktime_spin", + .type = FIO_OPT_INT, + .off1 = td_var_offset(thinktime_spin), + .help = "Start think time by spinning this amount (usec)", + .def = "0", + }, + { + .name = "thinktime_blocks", + .type = FIO_OPT_INT, + .off1 = td_var_offset(thinktime_blocks), + .help = "IO buffer period between 'thinktime'", + .def = "1", + }, + { + .name = "rate", + .type = FIO_OPT_INT, + .off1 = td_var_offset(rate), + .help = "Set bandwidth rate", + }, + { + .name = "ratemin", + .type = FIO_OPT_INT, + .off1 = td_var_offset(ratemin), + .help = "The bottom limit accepted", + }, + { + .name = "ratecycle", + .type = FIO_OPT_INT, + .off1 = td_var_offset(ratecycle), + .help = "Window average for rate limits (msec)", + .def = "1000", + }, + { + .name = "invalidate", + .type = FIO_OPT_BOOL, + .off1 = td_var_offset(invalidate_cache), + .help = "Invalidate buffer/page cache prior to running job", + .def = "1", + }, + { + .name = "sync", + .type = FIO_OPT_BOOL, + .off1 = td_var_offset(sync_io), + .help = "Use O_SYNC for buffered writes", + .def = "0", + }, + { + .name = "bwavgtime", + .type = FIO_OPT_INT, + .off1 = td_var_offset(bw_avg_time), + .help = "Time window over which to calculate bandwidth (msec)", + .def = "500", + }, + { + .name = "create_serialize", + .type = FIO_OPT_BOOL, + .off1 = td_var_offset(create_serialize), + .help = "Serialize creating of job files", + .def = "1", + }, + { + .name = "create_fsync", + .type = FIO_OPT_BOOL, + .off1 = td_var_offset(create_fsync), + .help = "Fsync file after creation", + .def = "1", + }, + { + .name = "cpuload", + .type = FIO_OPT_INT, + .off1 = td_var_offset(cpuload), + .help = "Use this percentage of CPU", + }, + { + .name = "cpuchunks", + .type = FIO_OPT_INT, + .off1 = td_var_offset(cpucycle), + .help = "Length of the CPU burn cycles (usecs)", + .def = "50000", + }, +#ifdef FIO_HAVE_CPU_AFFINITY + { + .name = "cpumask", + .type = FIO_OPT_INT, + .cb = str_cpumask_cb, + .help = "CPU affinity mask", + }, +#endif + { + .name = "end_fsync", + .type = FIO_OPT_BOOL, + .off1 = td_var_offset(end_fsync), + .help = "Include fsync at the end of job", + .def = "0", + }, + { + .name = "fsync_on_close", + .type = FIO_OPT_BOOL, + .off1 = td_var_offset(fsync_on_close), + .help = "fsync files on close", + .def = "0", + }, + { + .name = "unlink", + .type = FIO_OPT_BOOL, + .off1 = td_var_offset(unlink), + .help = "Unlink created files after job has completed", + .def = "0", + }, + { + .name = "exitall", + .type = FIO_OPT_STR_SET, + .cb = str_exitall_cb, + .help = "Terminate all jobs when one exits", + }, + { + .name = "stonewall", + .type = FIO_OPT_STR_SET, + .off1 = td_var_offset(stonewall), + .help = "Insert a hard barrier between this job and previous", + }, + { + .name = "thread", + .type = FIO_OPT_STR_SET, + .off1 = td_var_offset(use_thread), + .help = "Use threads instead of forks", + }, + { + .name = "write_bw_log", + .type = FIO_OPT_STR_SET, + .off1 = td_var_offset(write_bw_log), + .help = "Write log of bandwidth during run", + }, + { + .name = "write_lat_log", + .type = FIO_OPT_STR_SET, + .off1 = td_var_offset(write_lat_log), + .help = "Write log of latency during run", + }, + { + .name = "hugepage-size", + .type = FIO_OPT_STR_VAL, + .off1 = td_var_offset(hugepage_size), + .help = "When using hugepages, specify size of each page", + .def = __stringify(FIO_HUGE_PAGE), + }, + { + .name = "group_reporting", + .type = FIO_OPT_STR_SET, + .off1 = td_var_offset(group_reporting), + .help = "Do reporting on a per-group basis", + }, + { + .name = NULL, + }, +}; + +void fio_options_dup_and_init(struct option *long_options) +{ + struct fio_option *o; + unsigned int i; + + options_init(options); + + i = 0; + while (long_options[i].name) + i++; + + o = &options[0]; + while (o->name) { + long_options[i].name = o->name; + long_options[i].val = FIO_GETOPT_JOB; + if (o->type == FIO_OPT_STR_SET) + long_options[i].has_arg = no_argument; + else + long_options[i].has_arg = required_argument; + + i++; + o++; + assert(i < FIO_NR_OPTIONS); + } +} + +int fio_option_parse(struct thread_data *td, const char *opt) +{ + return parse_option(opt, options, td); +} + +int fio_cmd_option_parse(struct thread_data *td, const char *opt, char *val) +{ + return parse_cmd_option(opt, val, options, td); +} + +void fio_fill_default_options(struct thread_data *td) +{ + fill_default_options(td, options); +} + +int fio_show_option_help(const char *opt) +{ + return show_cmd_help(options, opt); +}