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 *);
#define __stringify_1(x) #x
#define __stringify(x) __stringify_1(x)
.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),
- .help = "Force the use of a specific file",
+ .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",
.help = "IO direction",
.def = "read",
.posval = {
- { .ival = "read", .oval = TD_DDIR_READ },
- { .ival = "write", .oval = TD_DDIR_WRITE },
- { .ival = "randread", .oval = TD_DDIR_RANDREAD },
- { .ival = "randwrite", .oval = TD_DDIR_RANDWRITE },
- { .ival = "rw", .oval = TD_DDIR_RW },
- { .ival = "randrw", .oval = TD_DDIR_RANDRW },
+ { .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",
.help = "IO engine to use",
.def = "sync",
.posval = {
- { .ival = "sync", },
+ { .ival = "sync",
+ .help = "Use read/write",
+ },
#ifdef FIO_HAVE_LIBAIO
- { .ival = "libaio", },
+ { .ival = "libaio",
+ .help = "Linux native asynchronous IO",
+ },
#endif
#ifdef FIO_HAVE_POSIXAIO
- { .ival = "posixaio", },
+ { .ival = "posixaio",
+ .help = "POSIX asynchronous IO",
+ },
#endif
- { .ival = "mmap", },
+ { .ival = "mmap",
+ .help = "Memory mapped IO",
+ },
#ifdef FIO_HAVE_SPLICE
- { .ival = "splice", },
+ { .ival = "splice",
+ .help = "splice/vmsplice based IO",
+ },
#endif
#ifdef FIO_HAVE_SGIO
- { .ival = "sg", },
+ { .ival = "sg",
+ .help = "SCSI generic v3 IO",
+ },
#endif
- { .ival = "null", }, { .ival = "net", },
+ { .ival = "null",
+ .help = "Testing engine (no data transfer)",
+ },
+ { .ival = "net",
+ .help = "Network IO",
+ },
#ifdef FIO_HAVE_SYSLET
- { .ival = "syslet-rw", },
+ { .ival = "syslet-rw",
+ .help = "syslet enabled async pread/pwrite IO",
+ },
#endif
- { .ival = "cpuio", },
- { .ival = "external", },
+ { .ival = "cpuio",
+ .help = "CPU cycler burner engine",
+ },
+ { .ival = "external",
+ .help = "Load external engine (append name)",
},
+ },
},
{
.name = "iodepth",
.help = "How to select which file to service next",
.def = "roundrobin",
.posval = {
- { .ival = "random", .oval = FIO_FSERVICE_RANDOM },
- { .ival = "roundrobin", .oval = FIO_FSERVICE_RR },
+ { .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",
.help = "Backing type for IO buffers",
.def = "malloc",
.posval = {
- { .ival = "malloc", .oval = MEM_MALLOC },
- { .ival = "shm", .oval = MEM_SHM },
+ { .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 },
+ { .ival = "shmhuge",
+ .oval = MEM_SHMHUGE,
+ .help = "Like shm, but use huge pages",
+ },
#endif
- { .ival = "mmap", .oval = MEM_MMAP },
+ { .ival = "mmap",
+ .oval = MEM_MMAP,
+ .help = "Use mmap(2) (file or anon) for IO buffers",
+ },
#ifdef FIO_HAVE_HUGETLB
- { .ival = "mmaphuge", .oval = MEM_MMAPHUGE },
-#endif
+ { .ival = "mmaphuge",
+ .oval = MEM_MMAPHUGE,
+ .help = "Like mmap, but use huge pages",
},
+#endif
+ },
},
{
.name = "verify",
.help = "Verify sum function",
.def = "0",
.posval = {
- { .ival = "0", .oval = VERIFY_NONE },
- { .ival = "crc32", .oval = VERIFY_CRC32 },
- { .ival = "md5", .oval = VERIFY_MD5 },
+ { .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",
.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,
static int def_timeout = 0;
-static char fio_version_string[] = "fio 1.13";
+static char fio_version_string[] = "fio 1.14";
static char **ini_file;
static int max_jobs = MAX_JOBS;
static int write_lat_log = 0;
int write_bw_log = 0;
+static int prev_group_jobs;
+
FILE *get_f_out()
{
return f_out;
if (td->bs_unaligned && (td->odirect || td->io_ops->flags & FIO_RAWIO))
log_err("fio: bs_unaligned may not work with raw io\n");
- /*
- * O_DIRECT and char doesn't mix, clear that flag if necessary.
- */
- if (td->filetype == FIO_TYPE_CHAR && td->odirect)
- td->odirect = 0;
-
/*
* thinktime_spin must be less than thinktime
*/
if (td->iodepth_batch > td->iodepth || !td->iodepth_batch)
td->iodepth_batch = td->iodepth;
+ if (td->nr_files > td->files_index)
+ td->nr_files = td->files_index;
+
if (td->open_files > td->nr_files || !td->open_files)
td->open_files = td->nr_files;
}
{
const char *ddir_str[] = { NULL, "read", "write", "rw", NULL,
"randread", "randwrite", "randrw" };
- struct stat sb;
- int numjobs, i;
+ unsigned int i;
struct fio_file *f;
const char *engine;
- int fn_given;
+ char fname[PATH_MAX];
+ int numjobs;
/*
* the def_thread is just for options, it's not a real job
if (td->odirect)
td->io_ops->flags |= FIO_RAWIO;
- fn_given = (int) td->filename;
- if (!td->filename)
+ if (!td->filename && !td->files_index) {
td->filename = strdup(jobname);
- td->filetype = FIO_TYPE_FILE;
- if (!lstat(td->filename, &sb)) {
- if (S_ISBLK(sb.st_mode))
- td->filetype = FIO_TYPE_BD;
- else if (S_ISCHR(sb.st_mode))
- td->filetype = FIO_TYPE_CHAR;
- }
-
- fixup_options(td);
-
- if (td->filename)
- td->nr_uniq_files = 1;
- else
- td->nr_uniq_files = td->open_files;
-
- if (td->filetype == FIO_TYPE_FILE) {
- char tmp[PATH_MAX];
- int len = 0;
-
- if (td->directory && td->directory[0] != '\0') {
- 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;
+ if (td->nr_files == 1)
+ add_file(td, td->filename);
+ else {
+ for (i = 0; i < td->nr_files; i++) {
+ sprintf(fname, "%s.%d.%d", td->filename, td->thread_number, i);
+ add_file(td, fname);
}
- len = sprintf(tmp, "%s/", td->directory);
- }
-
- td->files = malloc(sizeof(struct fio_file) * td->open_files);
-
- for_each_file(td, f, i) {
- memset(f, 0, sizeof(*f));
- f->fd = -1;
-
- if (fn_given)
- sprintf(tmp + len, "%s", td->filename);
- else
- sprintf(tmp + len, "%s.%d.%d", td->filename, td->thread_number, i);
- f->file_name = strdup(tmp);
}
- } else {
- td->open_files = td->nr_files = 1;
- td->files = malloc(sizeof(struct fio_file));
- f = &td->files[0];
-
- memset(f, 0, sizeof(*f));
- f->fd = -1;
- f->file_name = strdup(jobname);
}
+ fixup_options(td);
+
for_each_file(td, f, i) {
- f->file_size = td->total_file_size / td->nr_files;
- f->file_offset = td->start_offset;
+ if (td->directory && f->filetype == FIO_TYPE_FILE) {
+ sprintf(fname, "%s/%s", td->directory, f->file_name);
+ f->file_name = strdup(fname);
+ }
}
td->mutex = fio_sem_init(0);
td->ts.slat_stat[0].min_val = td->ts.slat_stat[1].min_val = ULONG_MAX;
td->ts.bw_stat[0].min_val = td->ts.bw_stat[1].min_val = ULONG_MAX;
- if (td->stonewall && td->thread_number > 1)
+ if ((td->stonewall || td->numjobs > 1) && prev_group_jobs) {
+ prev_group_jobs = 0;
groupid++;
+ }
td->groupid = groupid;
+ prev_group_jobs++;
if (setup_rate(td))
goto err;
if (add_job(td_new, jobname, job_add_num))
goto err;
}
+
+ if (td->numjobs > 1) {
+ groupid++;
+ prev_group_jobs = 0;
+ }
+
return 0;
err:
put_job(td);
int init_random_state(struct thread_data *td)
{
unsigned long seeds[5];
- int fd, num_maps, blocks, i;
+ int fd, num_maps, blocks;
struct fio_file *f;
+ unsigned int i;
if (td->io_ops->flags & FIO_DISKLESSIO)
return 0;
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.
*/
projects / fio.git / blobdiff