#ifdef FIO_HAVE_SYSLET
{ .ival = "syslet-rw", },
#endif
+ { .ival = "external", },
},
},
{
.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,
},
{
.name = "cmdhelp",
- .has_arg = required_argument,
+ .has_arg = optional_argument,
.val = 'c',
},
{
static int def_timeout = 0;
-static char fio_version_string[] = "fio 1.11";
+static char fio_version_string[] = "fio 1.12";
static char **ini_file;
static int max_jobs = MAX_JOBS;
static int write_lat_log = 0;
int write_bw_log = 0;
+FILE *get_f_out()
+{
+ return f_out;
+}
+
+FILE *get_f_err()
+{
+ return f_err;
+}
+
/*
* Return a free job structure.
*/
/*
* The low water mark cannot be bigger than the iodepth
*/
- if (td->iodepth_low > td->iodepth || !td->iodepth_low)
- td->iodepth_low = td->iodepth;
+ if (td->iodepth_low > td->iodepth || !td->iodepth_low) {
+ /*
+ * syslet work around - if the workload is sequential,
+ * we want to let the queue drain all the way down to
+ * avoid seeking between async threads
+ */
+ if (!strcmp(td->io_ops->name, "syslet-rw") && !td_random(td))
+ td->iodepth_low = 1;
+ else
+ td->iodepth_low = td->iodepth;
+ }
+
+ /*
+ * If batch number isn't set, default to the same as iodepth
+ */
+ if (td->iodepth_batch > td->iodepth || !td->iodepth_batch)
+ td->iodepth_batch = td->iodepth;
}
/*
return 0;
}
+/* External engines are specified by "external:name.o") */
+static const char *get_engine_name(const char *str)
+{
+ char *p = strstr(str, ":");
+
+ if (!p)
+ return str;
+
+ p++;
+ strip_blank_front(&p);
+ strip_blank_end(p);
+ return p;
+}
+
static int str_ioengine_cb(void *data, const char *str)
{
struct thread_data *td = data;
+ const char *name = get_engine_name(str);
- td->io_ops = load_ioengine(td, str);
+ td->io_ops = load_ioengine(td, name);
if (td->io_ops)
return 0;