projects / fio.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
engines/ime: various code and style cleanups
[fio.git] / options.c
CommitLineData
214e1eca
JA		 1#include <stdio.h>
2#include <stdlib.h>
3#include <unistd.h>
4#include <ctype.h>
5#include <string.h>
214e1eca 6#include <assert.h>
5921e80c 7#include <sys/stat.h>
e13c3b50 8#include <netinet/in.h>
214e1eca
JA		 9
10#include "fio.h"
4f5af7b2 11#include "verify.h"
214e1eca 12#include "parse.h"
61b9861d 13#include "lib/pattern.h"
9f988e2e 14#include "options.h"
d220c761 15#include "optgroup.h"
214e1eca 16
e13c3b50 17char client_sockaddr_str[INET6_ADDRSTRLEN] = { 0 };
72a703da 18
a609f12a
JA		 19#define cb_data_to_td(data) container_of(data, struct thread_data, o)
20
fc8d6d05 21static struct pattern_fmt_desc fmt_desc[] = {
4205998f
JA		 22 {
23 .fmt = "%o",
24 .len = FIELD_SIZE(struct io_u *, offset),
25 .paste = paste_blockoff
26 }
27};
28
214e1eca
JA		 29/*
30 * Check if mmap/mmaphuge has a :/foo/bar/file at the end. If so, return that.
31 */
32static char *get_opt_postfix(const char *str)
33{
34 char *p = strstr(str, ":");
35
36 if (!p)
37 return NULL;
38
39 p++;
40 strip_blank_front(&p);
41 strip_blank_end(p);
42 return strdup(p);
43}
44
564ca972
JA		 45static int bs_cmp(const void *p1, const void *p2)
46{
47 const struct bssplit *bsp1 = p1;
48 const struct bssplit *bsp2 = p2;
49
a7cd478d 50 return (int) bsp1->perc - (int) bsp2->perc;
564ca972
JA		 51}
52
d2835319
JA		 53struct split {
54 unsigned int nr;
5fff9543 55 unsigned long long val1[ZONESPLIT_MAX];
9d8fc5e4 56 unsigned long long val2[ZONESPLIT_MAX];
d2835319
JA		 57};
58
59static int split_parse_ddir(struct thread_options *o, struct split *split,
517c9c72 60 char *str, bool absolute, unsigned int max_splits)
564ca972 61{
59466396
JA		 62 unsigned long long perc;
63 unsigned int i;
564ca972 64 long long val;
720e84ad 65 char *fname;
564ca972 66
d2835319 67 split->nr = 0;
564ca972
JA		 68
69 i = 0;
564ca972
JA		 70 while ((fname = strsep(&str, ":")) != NULL) {
71 char *perc_str;
72
73 if (!strlen(fname))
74 break;
75
564ca972
JA		 76 perc_str = strstr(fname, "/");
77 if (perc_str) {
78 *perc_str = '\0';
79 perc_str++;
59466396
JA		 80 if (absolute) {
81 if (str_to_decimal(perc_str, &val, 1, o, 0, 0)) {
82 log_err("fio: split conversion failed\n");
83 return 1;
84 }
85 perc = val;
86 } else {
87 perc = atoi(perc_str);
88 if (perc > 100)
89 perc = 100;
90 else if (!perc)
91 perc = -1U;
92 }
93 } else {
94 if (absolute)
95 perc = 0;
96 else
d711cce5 97 perc = -1U;
59466396 98 }
564ca972 99
88038bc7 100 if (str_to_decimal(fname, &val, 1, o, 0, 0)) {
59466396 101 log_err("fio: split conversion failed\n");
564ca972
JA		 102 return 1;
103 }
104
d2835319
JA		 105 split->val1[i] = val;
106 split->val2[i] = perc;
564ca972 107 i++;
c32e1a09
JA		 108 if (i == max_splits) {
109 log_err("fio: hit max of %d split entries\n", i);
d2835319 110 break;
c32e1a09 111 }
564ca972
JA		 112 }
113
d2835319
JA		 114 split->nr = i;
115 return 0;
116}
117
59466396
JA		 118static int bssplit_ddir(struct thread_options *o, enum fio_ddir ddir, char *str,
119 bool data)
d2835319
JA		 120{
121 unsigned int i, perc, perc_missing;
5fff9543 122 unsigned long long max_bs, min_bs;
d2835319
JA		 123 struct split split;
124
125 memset(&split, 0, sizeof(split));
126
517c9c72 127 if (split_parse_ddir(o, &split, str, data, BSSPLIT_MAX))
d2835319
JA		 128 return 1;
129 if (!split.nr)
130 return 0;
131
132 max_bs = 0;
133 min_bs = -1;
134 o->bssplit[ddir] = malloc(split.nr * sizeof(struct bssplit));
135 o->bssplit_nr[ddir] = split.nr;
136 for (i = 0; i < split.nr; i++) {
137 if (split.val1[i] > max_bs)
138 max_bs = split.val1[i];
139 if (split.val1[i] < min_bs)
140 min_bs = split.val1[i];
141
142 o->bssplit[ddir][i].bs = split.val1[i];
143 o->bssplit[ddir][i].perc =split.val2[i];
144 }
564ca972
JA		 145
146 /*
147 * Now check if the percentages add up, and how much is missing
148 */
149 perc = perc_missing = 0;
83ea422a 150 for (i = 0; i < o->bssplit_nr[ddir]; i++) {
d2835319 151 struct bssplit *bsp = &o->bssplit[ddir][i];
564ca972 152
d711cce5 153 if (bsp->perc == -1U)
564ca972
JA		 154 perc_missing++;
155 else
156 perc += bsp->perc;
157 }
158
40bafa33 159 if (perc > 100 && perc_missing > 1) {
564ca972 160 log_err("fio: bssplit percentages add to more than 100%%\n");
d2835319
JA		 161 free(o->bssplit[ddir]);
162 o->bssplit[ddir] = NULL;
564ca972
JA		 163 return 1;
164 }
d711cce5 165
564ca972
JA		 166 /*
167 * If values didn't have a percentage set, divide the remains between
168 * them.
169 */
170 if (perc_missing) {
d711cce5 171 if (perc_missing == 1 && o->bssplit_nr[ddir] == 1)
40bafa33 172 perc = 100;
83ea422a 173 for (i = 0; i < o->bssplit_nr[ddir]; i++) {
d2835319 174 struct bssplit *bsp = &o->bssplit[ddir][i];
564ca972 175
d711cce5 176 if (bsp->perc == -1U)
564ca972
JA		 177 bsp->perc = (100 - perc) / perc_missing;
178 }
179 }
180
83ea422a
JA		 181 o->min_bs[ddir] = min_bs;
182 o->max_bs[ddir] = max_bs;
564ca972
JA		 183
184 /*
185 * now sort based on percentages, for ease of lookup
186 */
d2835319 187 qsort(o->bssplit[ddir], o->bssplit_nr[ddir], sizeof(struct bssplit), bs_cmp);
720e84ad 188 return 0;
720e84ad
JA		 189}
190
59466396 191typedef int (split_parse_fn)(struct thread_options *, enum fio_ddir, char *, bool);
764593c0 192
59466396
JA		 193static int str_split_parse(struct thread_data *td, char *str,
194 split_parse_fn *fn, bool data)
720e84ad 195{
764593c0 196 char *odir, *ddir;
720e84ad
JA		 197 int ret = 0;
198
720e84ad
JA		 199 odir = strchr(str, ',');
200 if (odir) {
6eaf09d6
SL		 201 ddir = strchr(odir + 1, ',');
202 if (ddir) {
59466396 203 ret = fn(&td->o, DDIR_TRIM, ddir + 1, data);
6eaf09d6
SL		 204 if (!ret)
205 *ddir = '\0';
206 } else {
207 char *op;
208
209 op = strdup(odir + 1);
59466396 210 ret = fn(&td->o, DDIR_TRIM, op, data);
6eaf09d6
SL		 211
212 free(op);
213 }
d79db122 214 if (!ret)
59466396 215 ret = fn(&td->o, DDIR_WRITE, odir + 1, data);
720e84ad
JA		 216 if (!ret) {
217 *odir = '\0';
59466396 218 ret = fn(&td->o, DDIR_READ, str, data);
720e84ad
JA		 219 }
220 } else {
221 char *op;
222
223 op = strdup(str);
59466396 224 ret = fn(&td->o, DDIR_WRITE, op, data);
6eaf09d6 225 free(op);
720e84ad 226
6eaf09d6
SL		 227 if (!ret) {
228 op = strdup(str);
59466396 229 ret = fn(&td->o, DDIR_TRIM, op, data);
6eaf09d6
SL		 230 free(op);
231 }
f0c9c217 232 if (!ret)
59466396 233 ret = fn(&td->o, DDIR_READ, str, data);
720e84ad 234 }
564ca972 235
764593c0
JA		 236 return ret;
237}
238
239static int str_bssplit_cb(void *data, const char *input)
240{
a609f12a 241 struct thread_data *td = cb_data_to_td(data);
764593c0
JA		 242 char *str, *p;
243 int ret = 0;
244
764593c0
JA		 245 p = str = strdup(input);
246
247 strip_blank_front(&str);
248 strip_blank_end(str);
249
59466396 250 ret = str_split_parse(td, str, bssplit_ddir, false);
764593c0 251
55baca06
JA		 252 if (parse_dryrun()) {
253 int i;
254
255 for (i = 0; i < DDIR_RWDIR_CNT; i++) {
256 free(td->o.bssplit[i]);
257 td->o.bssplit[i] = NULL;
258 td->o.bssplit_nr[i] = 0;
259 }
260 }
261
564ca972 262 free(p);
720e84ad 263 return ret;
564ca972
JA		 264}
265
8b28bd41
DM		 266static int str2error(char *str)
267{
a94eb99a 268 const char *err[] = { "EPERM", "ENOENT", "ESRCH", "EINTR", "EIO",
8b28bd41
DM		 269 "ENXIO", "E2BIG", "ENOEXEC", "EBADF",
270 "ECHILD", "EAGAIN", "ENOMEM", "EACCES",
271 "EFAULT", "ENOTBLK", "EBUSY", "EEXIST",
272 "EXDEV", "ENODEV", "ENOTDIR", "EISDIR",
273 "EINVAL", "ENFILE", "EMFILE", "ENOTTY",
274 "ETXTBSY","EFBIG", "ENOSPC", "ESPIPE",
a94eb99a 275 "EROFS","EMLINK", "EPIPE", "EDOM", "ERANGE" };
7fe481b4 276 int i = 0, num = sizeof(err) / sizeof(char *);
8b28bd41 277
a94eb99a 278 while (i < num) {
8b28bd41
DM		 279 if (!strcmp(err[i], str))
280 return i + 1;
281 i++;
282 }
283 return 0;
284}
285
3ed673c6
TK		 286static int ignore_error_type(struct thread_data *td, enum error_type_bit etype,
287 char *str)
8b28bd41
DM		 288{
289 unsigned int i;
290 int *error;
291 char *fname;
292
293 if (etype >= ERROR_TYPE_CNT) {
294 log_err("Illegal error type\n");
295 return 1;
296 }
297
298 td->o.ignore_error_nr[etype] = 4;
685ffd57 299 error = calloc(4, sizeof(int));
8b28bd41
DM		 300
301 i = 0;
302 while ((fname = strsep(&str, ":")) != NULL) {
303
304 if (!strlen(fname))
305 break;
306
307 /*
308 * grow struct buffer, if needed
309 */
310 if (i == td->o.ignore_error_nr[etype]) {
311 td->o.ignore_error_nr[etype] <<= 1;
312 error = realloc(error, td->o.ignore_error_nr[etype]
313 * sizeof(int));
314 }
315 if (fname[0] == 'E') {
316 error[i] = str2error(fname);
317 } else {
318 error[i] = atoi(fname);
319 if (error[i] < 0)
1616e025 320 error[i] = -error[i];
8b28bd41
DM		 321 }
322 if (!error[i]) {
d503e281 323 log_err("Unknown error %s, please use number value\n",
8b28bd41 324 fname);
d503e281 325 td->o.ignore_error_nr[etype] = 0;
0fddbf7a 326 free(error);
8b28bd41
DM		 327 return 1;
328 }
329 i++;
330 }
331 if (i) {
332 td->o.continue_on_error |= 1 << etype;
333 td->o.ignore_error_nr[etype] = i;
334 td->o.ignore_error[etype] = error;
d503e281
TK		 335 } else {
336 td->o.ignore_error_nr[etype] = 0;
c7b086be 337 free(error);
d503e281 338 }
c7b086be 339
8b28bd41
DM		 340 return 0;
341
342}
343
d7235efb
JA		 344static int str_replay_skip_cb(void *data, const char *input)
345{
346 struct thread_data *td = cb_data_to_td(data);
347 char *str, *p, *n;
348 int ret = 0;
349
350 if (parse_dryrun())
351 return 0;
352
353 p = str = strdup(input);
354
355 strip_blank_front(&str);
356 strip_blank_end(str);
357
358 while (p) {
359 n = strchr(p, ',');
360 if (n)
361 *n++ = '\0';
362 if (!strcmp(p, "read"))
363 td->o.replay_skip |= 1u << DDIR_READ;
364 else if (!strcmp(p, "write"))
365 td->o.replay_skip |= 1u << DDIR_WRITE;
366 else if (!strcmp(p, "trim"))
367 td->o.replay_skip |= 1u << DDIR_TRIM;
368 else if (!strcmp(p, "sync"))
369 td->o.replay_skip |= 1u << DDIR_SYNC;
370 else {
371 log_err("Unknown skip type: %s\n", p);
372 ret = 1;
373 break;
374 }
375 p = n;
376 }
377 free(str);
378 return ret;
379}
380
8b28bd41
DM		 381static int str_ignore_error_cb(void *data, const char *input)
382{
a609f12a 383 struct thread_data *td = cb_data_to_td(data);
8b28bd41 384 char *str, *p, *n;
3ed673c6
TK		 385 int ret = 1;
386 enum error_type_bit type = 0;
52c0cea3
JA		 387
388 if (parse_dryrun())
389 return 0;
390
8b28bd41
DM		 391 p = str = strdup(input);
392
393 strip_blank_front(&str);
394 strip_blank_end(str);
395
396 while (p) {
397 n = strchr(p, ',');
398 if (n)
399 *n++ = '\0';
400 ret = ignore_error_type(td, type, p);
401 if (ret)
402 break;
403 p = n;
404 type++;
405 }
406 free(str);
407 return ret;
408}
409
211097b2
JA		 410static int str_rw_cb(void *data, const char *str)
411{
a609f12a 412 struct thread_data *td = cb_data_to_td(data);
83ea422a 413 struct thread_options *o = &td->o;
27ca949f 414 char *nr;
211097b2 415
52c0cea3
JA		 416 if (parse_dryrun())
417 return 0;
418
83ea422a
JA		 419 o->ddir_seq_nr = 1;
420 o->ddir_seq_add = 0;
059b0802 421
27ca949f 422 nr = get_opt_postfix(str);
059b0802
JA		 423 if (!nr)
424 return 0;
425
426 if (td_random(td))
83ea422a 427 o->ddir_seq_nr = atoi(nr);
059b0802
JA		 428 else {
429 long long val;
430
88038bc7 431 if (str_to_decimal(nr, &val, 1, o, 0, 0)) {
059b0802
JA		 432 log_err("fio: rw postfix parsing failed\n");
433 free(nr);
434 return 1;
435 }
436
83ea422a 437 o->ddir_seq_add = val;
182ec6ee 438 }
211097b2 439
059b0802 440 free(nr);
211097b2
JA		 441 return 0;
442}
443
214e1eca
JA		 444static int str_mem_cb(void *data, const char *mem)
445{
a609f12a 446 struct thread_data *td = cb_data_to_td(data);
214e1eca 447
217b0f1d
LG		 448 if (td->o.mem_type == MEM_MMAPHUGE || td->o.mem_type == MEM_MMAP ||
449 td->o.mem_type == MEM_MMAPSHARED)
836fcc0f 450 td->o.mmapfile = get_opt_postfix(mem);
214e1eca
JA		 451
452 return 0;
453}
454
c223da83
JA		 455static int fio_clock_source_cb(void *data, const char *str)
456{
a609f12a 457 struct thread_data *td = cb_data_to_td(data);
c223da83
JA		 458
459 fio_clock_source = td->o.clocksource;
fa80feae 460 fio_clock_source_set = 1;
01423eae 461 fio_clock_init();
c223da83
JA		 462 return 0;
463}
464
85bc833b 465static int str_rwmix_read_cb(void *data, unsigned long long *val)
cb499fc4 466{
a609f12a 467 struct thread_data *td = cb_data_to_td(data);
cb499fc4
JA		 468
469 td->o.rwmix[DDIR_READ] = *val;
470 td->o.rwmix[DDIR_WRITE] = 100 - *val;
471 return 0;
472}
473
85bc833b 474static int str_rwmix_write_cb(void *data, unsigned long long *val)
cb499fc4 475{
a609f12a 476 struct thread_data *td = cb_data_to_td(data);
cb499fc4
JA		 477
478 td->o.rwmix[DDIR_WRITE] = *val;
479 td->o.rwmix[DDIR_READ] = 100 - *val;
480 return 0;
481}
482
214e1eca
JA		 483static int str_exitall_cb(void)
484{
485 exitall_on_terminate = 1;
486 return 0;
487}
488
214e1eca 489#ifdef FIO_HAVE_CPU_AFFINITY
50b5860b 490int fio_cpus_split(os_cpu_mask_t *mask, unsigned int cpu_index)
c2acfbac 491{
50b5860b 492 unsigned int i, index, cpus_in_mask;
c2acfbac 493 const long max_cpu = cpus_online();
c2acfbac 494
50b5860b
JA		 495 cpus_in_mask = fio_cpu_count(mask);
496 cpu_index = cpu_index % cpus_in_mask;
497
498 index = 0;
c2acfbac 499 for (i = 0; i < max_cpu; i++) {
50b5860b 500 if (!fio_cpu_isset(mask, i))
c2acfbac 501 continue;
50b5860b
JA		 502
503 if (cpu_index != index)
504 fio_cpu_clear(mask, i);
505
506 index++;
c2acfbac
JA		 507 }
508
509 return fio_cpu_count(mask);
510}
511
85bc833b 512static int str_cpumask_cb(void *data, unsigned long long *val)
d2e268b0 513{
a609f12a 514 struct thread_data *td = cb_data_to_td(data);
214e1eca 515 unsigned int i;
b03daafb 516 long max_cpu;
d2ce18b5
JA		 517 int ret;
518
52c0cea3
JA		 519 if (parse_dryrun())
520 return 0;
521
d2ce18b5
JA		 522 ret = fio_cpuset_init(&td->o.cpumask);
523 if (ret < 0) {
524 log_err("fio: cpuset_init failed\n");
525 td_verror(td, ret, "fio_cpuset_init");
526 return 1;
527 }
214e1eca 528
c00a2289 529 max_cpu = cpus_online();
214e1eca 530
62a7273d
JA		 531 for (i = 0; i < sizeof(int) * 8; i++) {
532 if ((1 << i) & *val) {
b8411399 533 if (i >= max_cpu) {
b03daafb 534 log_err("fio: CPU %d too large (max=%ld)\n", i,
b8411399 535 max_cpu - 1);
b03daafb
JA		 536 return 1;
537 }
62a7273d 538 dprint(FD_PARSE, "set cpu allowed %d\n", i);
6d459ee7 539 fio_cpu_set(&td->o.cpumask, i);
62a7273d
JA		 540 }
541 }
d2e268b0 542
d2e268b0 543 return 0;
214e1eca
JA		 544}
545
e8462bd8
JA		 546static int set_cpus_allowed(struct thread_data *td, os_cpu_mask_t *mask,
547 const char *input)
214e1eca 548{
d2e268b0 549 char *cpu, *str, *p;
b03daafb 550 long max_cpu;
19608d6c 551 int ret = 0;
d2e268b0 552
e8462bd8 553 ret = fio_cpuset_init(mask);
d2ce18b5
JA		 554 if (ret < 0) {
555 log_err("fio: cpuset_init failed\n");
556 td_verror(td, ret, "fio_cpuset_init");
557 return 1;
558 }
d2e268b0
JA		 559
560 p = str = strdup(input);
214e1eca 561
d2e268b0
JA		 562 strip_blank_front(&str);
563 strip_blank_end(str);
564
c00a2289 565 max_cpu = cpus_online();
b03daafb 566
d2e268b0 567 while ((cpu = strsep(&str, ",")) != NULL) {
62a7273d
JA		 568 char *str2, *cpu2;
569 int icpu, icpu2;
570
d2e268b0
JA		 571 if (!strlen(cpu))
572 break;
62a7273d
JA		 573
574 str2 = cpu;
575 icpu2 = -1;
576 while ((cpu2 = strsep(&str2, "-")) != NULL) {
577 if (!strlen(cpu2))
578 break;
579
580 icpu2 = atoi(cpu2);
581 }
582
583 icpu = atoi(cpu);
584 if (icpu2 == -1)
585 icpu2 = icpu;
586 while (icpu <= icpu2) {
6d459ee7 587 if (icpu >= FIO_MAX_CPUS) {
19608d6c 588 log_err("fio: your OS only supports up to"
6d459ee7 589 " %d CPUs\n", (int) FIO_MAX_CPUS);
19608d6c
JA		 590 ret = 1;
591 break;
592 }
9e986889 593 if (icpu >= max_cpu) {
b03daafb 594 log_err("fio: CPU %d too large (max=%ld)\n",
9e986889 595 icpu, max_cpu - 1);
b03daafb
JA		 596 ret = 1;
597 break;
598 }
0b9d69ec 599
62a7273d 600 dprint(FD_PARSE, "set cpu allowed %d\n", icpu);
e8462bd8 601 fio_cpu_set(mask, icpu);
62a7273d
JA		 602 icpu++;
603 }
19608d6c
JA		 604 if (ret)
605 break;
d2e268b0
JA		 606 }
607
608 free(p);
19608d6c 609 return ret;
214e1eca 610}
e8462bd8
JA		 611
612static int str_cpus_allowed_cb(void *data, const char *input)
613{
a609f12a 614 struct thread_data *td = cb_data_to_td(data);
e8462bd8 615
52c0cea3
JA		 616 if (parse_dryrun())
617 return 0;
618
b2a9e649 619 return set_cpus_allowed(td, &td->o.cpumask, input);
e8462bd8
JA		 620}
621
622static int str_verify_cpus_allowed_cb(void *data, const char *input)
623{
a609f12a 624 struct thread_data *td = cb_data_to_td(data);
e8462bd8 625
466155e2
JA		 626 if (parse_dryrun())
627 return 0;
628
b2a9e649 629 return set_cpus_allowed(td, &td->o.verify_cpumask, input);
e8462bd8 630}
c08f9fe2 631
105157ad 632#ifdef CONFIG_ZLIB
c08f9fe2
JA		 633static int str_log_cpus_allowed_cb(void *data, const char *input)
634{
a609f12a 635 struct thread_data *td = cb_data_to_td(data);
c08f9fe2
JA		 636
637 if (parse_dryrun())
638 return 0;
639
640 return set_cpus_allowed(td, &td->o.log_gz_cpumask, input);
641}
105157ad 642#endif /* CONFIG_ZLIB */
c08f9fe2 643
105157ad 644#endif /* FIO_HAVE_CPU_AFFINITY */
214e1eca 645
67bf9823 646#ifdef CONFIG_LIBNUMA
d0b937ed
YR		 647static int str_numa_cpunodes_cb(void *data, char *input)
648{
a609f12a 649 struct thread_data *td = cb_data_to_td(data);
43522848 650 struct bitmask *verify_bitmask;
d0b937ed 651
52c0cea3
JA		 652 if (parse_dryrun())
653 return 0;
654
d0b937ed
YR		 655 /* numa_parse_nodestring() parses a character string list
656 * of nodes into a bit mask. The bit mask is allocated by
657 * numa_allocate_nodemask(), so it should be freed by
658 * numa_free_nodemask().
659 */
43522848
DG		 660 verify_bitmask = numa_parse_nodestring(input);
661 if (verify_bitmask == NULL) {
d0b937ed
YR		 662 log_err("fio: numa_parse_nodestring failed\n");
663 td_verror(td, 1, "str_numa_cpunodes_cb");
664 return 1;
665 }
43522848 666 numa_free_nodemask(verify_bitmask);
d0b937ed 667
43522848 668 td->o.numa_cpunodes = strdup(input);
d0b937ed
YR		 669 return 0;
670}
671
672static int str_numa_mpol_cb(void *data, char *input)
673{
a609f12a 674 struct thread_data *td = cb_data_to_td(data);
d0b937ed 675 const char * const policy_types[] =
05d6f44b 676 { "default", "prefer", "bind", "interleave", "local", NULL };
d0b937ed 677 int i;
52c0cea3 678 char *nodelist;
43522848 679 struct bitmask *verify_bitmask;
52c0cea3
JA		 680
681 if (parse_dryrun())
682 return 0;
d0b937ed 683
52c0cea3 684 nodelist = strchr(input, ':');
d0b937ed
YR		 685 if (nodelist) {
686 /* NUL-terminate mode */
687 *nodelist++ = '\0';
688 }
689
690 for (i = 0; i <= MPOL_LOCAL; i++) {
691 if (!strcmp(input, policy_types[i])) {
692 td->o.numa_mem_mode = i;
693 break;
694 }
695 }
696 if (i > MPOL_LOCAL) {
697 log_err("fio: memory policy should be: default, prefer, bind, interleave, local\n");
698 goto out;
699 }
700
701 switch (td->o.numa_mem_mode) {
702 case MPOL_PREFERRED:
703 /*
704 * Insist on a nodelist of one node only
705 */
706 if (nodelist) {
707 char *rest = nodelist;
708 while (isdigit(*rest))
709 rest++;
710 if (*rest) {
711 log_err("fio: one node only for \'prefer\'\n");
712 goto out;
713 }
714 } else {
715 log_err("fio: one node is needed for \'prefer\'\n");
716 goto out;
717 }
718 break;
719 case MPOL_INTERLEAVE:
720 /*
721 * Default to online nodes with memory if no nodelist
722 */
723 if (!nodelist)
724 nodelist = strdup("all");
725 break;
726 case MPOL_LOCAL:
727 case MPOL_DEFAULT:
728 /*
729 * Don't allow a nodelist
730 */
731 if (nodelist) {
732 log_err("fio: NO nodelist for \'local\'\n");
733 goto out;
734 }
735 break;
736 case MPOL_BIND:
737 /*
738 * Insist on a nodelist
739 */
740 if (!nodelist) {
741 log_err("fio: a nodelist is needed for \'bind\'\n");
742 goto out;
743 }
744 break;
745 }
746
747
748 /* numa_parse_nodestring() parses a character string list
749 * of nodes into a bit mask. The bit mask is allocated by
750 * numa_allocate_nodemask(), so it should be freed by
751 * numa_free_nodemask().
752 */
753 switch (td->o.numa_mem_mode) {
754 case MPOL_PREFERRED:
755 td->o.numa_mem_prefer_node = atoi(nodelist);
756 break;
757 case MPOL_INTERLEAVE:
758 case MPOL_BIND:
43522848
DG		 759 verify_bitmask = numa_parse_nodestring(nodelist);
760 if (verify_bitmask == NULL) {
d0b937ed
YR		 761 log_err("fio: numa_parse_nodestring failed\n");
762 td_verror(td, 1, "str_numa_memnodes_cb");
763 return 1;
764 }
43522848
DG		 765 td->o.numa_memnodes = strdup(nodelist);
766 numa_free_nodemask(verify_bitmask);
b74e419e 767
d0b937ed
YR		 768 break;
769 case MPOL_LOCAL:
770 case MPOL_DEFAULT:
771 default:
772 break;
773 }
774
d0b937ed 775 return 0;
d0b937ed
YR		 776out:
777 return 1;
778}
779#endif
780
214e1eca
JA		 781static int str_fst_cb(void *data, const char *str)
782{
a609f12a 783 struct thread_data *td = cb_data_to_td(data);
8c07860d
JA		 784 double val;
785 bool done = false;
786 char *nr;
214e1eca
JA		 787
788 td->file_service_nr = 1;
8c07860d
JA		 789
790 switch (td->o.file_service_type) {
791 case FIO_FSERVICE_RANDOM:
792 case FIO_FSERVICE_RR:
793 case FIO_FSERVICE_SEQ:
794 nr = get_opt_postfix(str);
795 if (nr) {
796 td->file_service_nr = atoi(nr);
797 free(nr);
798 }
799 done = true;
800 break;
801 case FIO_FSERVICE_ZIPF:
802 val = FIO_DEF_ZIPF;
803 break;
804 case FIO_FSERVICE_PARETO:
805 val = FIO_DEF_PARETO;
806 break;
807 case FIO_FSERVICE_GAUSS:
808 val = 0.0;
809 break;
810 default:
811 log_err("fio: bad file service type: %d\n", td->o.file_service_type);
812 return 1;
813 }
814
815 if (done)
816 return 0;
817
818 nr = get_opt_postfix(str);
819 if (nr && !str_to_float(nr, &val, 0)) {
820 log_err("fio: file service type random postfix parsing failed\n");
182ec6ee 821 free(nr);
8c07860d
JA		 822 return 1;
823 }
824
825 free(nr);
826
827 switch (td->o.file_service_type) {
828 case FIO_FSERVICE_ZIPF:
829 if (val == 1.00) {
830 log_err("fio: zipf theta must be different than 1.0\n");
831 return 1;
832 }
833 if (parse_dryrun())
834 return 0;
835 td->zipf_theta = val;
836 break;
837 case FIO_FSERVICE_PARETO:
838 if (val <= 0.00 || val >= 1.00) {
839 log_err("fio: pareto input out of range (0 < input < 1.0)\n");
840 return 1;
841 }
842 if (parse_dryrun())
843 return 0;
844 td->pareto_h = val;
845 break;
846 case FIO_FSERVICE_GAUSS:
847 if (val < 0.00 || val >= 100.00) {
99c94a6b 848 log_err("fio: normal deviation out of range (0 <= input < 100.0)\n");
8c07860d
JA		 849 return 1;
850 }
851 if (parse_dryrun())
852 return 0;
853 td->gauss_dev = val;
854 break;
182ec6ee 855 }
214e1eca
JA		 856
857 return 0;
858}
859
67bf9823 860#ifdef CONFIG_SYNC_FILE_RANGE
44f29692
JA		 861static int str_sfr_cb(void *data, const char *str)
862{
a609f12a 863 struct thread_data *td = cb_data_to_td(data);
44f29692
JA		 864 char *nr = get_opt_postfix(str);
865
866 td->sync_file_range_nr = 1;
867 if (nr) {
868 td->sync_file_range_nr = atoi(nr);
869 free(nr);
870 }
871
872 return 0;
873}
3ae06371 874#endif
44f29692 875
764593c0 876static int zone_split_ddir(struct thread_options *o, enum fio_ddir ddir,
59466396 877 char *str, bool absolute)
e0a04ac1 878{
e0a04ac1 879 unsigned int i, perc, perc_missing, sperc, sperc_missing;
d2835319 880 struct split split;
e0a04ac1 881
d2835319 882 memset(&split, 0, sizeof(split));
e0a04ac1 883
517c9c72 884 if (split_parse_ddir(o, &split, str, absolute, ZONESPLIT_MAX))
d2835319
JA		 885 return 1;
886 if (!split.nr)
887 return 0;
e0a04ac1 888
d2835319
JA		 889 o->zone_split[ddir] = malloc(split.nr * sizeof(struct zone_split));
890 o->zone_split_nr[ddir] = split.nr;
891 for (i = 0; i < split.nr; i++) {
892 o->zone_split[ddir][i].access_perc = split.val1[i];
59466396
JA		 893 if (absolute)
894 o->zone_split[ddir][i].size = split.val2[i];
895 else
896 o->zone_split[ddir][i].size_perc = split.val2[i];
e0a04ac1
JA		 897 }
898
e0a04ac1
JA		 899 /*
900 * Now check if the percentages add up, and how much is missing
901 */
902 perc = perc_missing = 0;
903 sperc = sperc_missing = 0;
904 for (i = 0; i < o->zone_split_nr[ddir]; i++) {
d2835319 905 struct zone_split *zsp = &o->zone_split[ddir][i];
e0a04ac1
JA		 906
907 if (zsp->access_perc == (uint8_t) -1U)
908 perc_missing++;
909 else
910 perc += zsp->access_perc;
911
59466396
JA		 912 if (!absolute) {
913 if (zsp->size_perc == (uint8_t) -1U)
914 sperc_missing++;
915 else
916 sperc += zsp->size_perc;
917 }
e0a04ac1
JA		 918 }
919
920 if (perc > 100 || sperc > 100) {
921 log_err("fio: zone_split percentages add to more than 100%%\n");
d2835319
JA		 922 free(o->zone_split[ddir]);
923 o->zone_split[ddir] = NULL;
e0a04ac1
JA		 924 return 1;
925 }
926 if (perc < 100) {
927 log_err("fio: access percentage don't add up to 100 for zoned "
928 "random distribution (got=%u)\n", perc);
d2835319
JA		 929 free(o->zone_split[ddir]);
930 o->zone_split[ddir] = NULL;
e0a04ac1
JA		 931 return 1;
932 }
933
934 /*
935 * If values didn't have a percentage set, divide the remains between
936 * them.
937 */
938 if (perc_missing) {
939 if (perc_missing == 1 && o->zone_split_nr[ddir] == 1)
940 perc = 100;
941 for (i = 0; i < o->zone_split_nr[ddir]; i++) {
d2835319 942 struct zone_split *zsp = &o->zone_split[ddir][i];
e0a04ac1
JA		 943
944 if (zsp->access_perc == (uint8_t) -1U)
945 zsp->access_perc = (100 - perc) / perc_missing;
946 }
947 }
948 if (sperc_missing) {
949 if (sperc_missing == 1 && o->zone_split_nr[ddir] == 1)
950 sperc = 100;
951 for (i = 0; i < o->zone_split_nr[ddir]; i++) {
d2835319 952 struct zone_split *zsp = &o->zone_split[ddir][i];
e0a04ac1
JA		 953
954 if (zsp->size_perc == (uint8_t) -1U)
955 zsp->size_perc = (100 - sperc) / sperc_missing;
956 }
957 }
958
e0a04ac1
JA		 959 return 0;
960}
961
59466396
JA		 962static int parse_zoned_distribution(struct thread_data *td, const char *input,
963 bool absolute)
e0a04ac1 964{
59466396 965 const char *pre = absolute ? "zoned_abs:" : "zoned:";
764593c0 966 char *str, *p;
e0a04ac1
JA		 967 int i, ret = 0;
968
969 p = str = strdup(input);
970
971 strip_blank_front(&str);
972 strip_blank_end(str);
973
974 /* We expect it to start like that, bail if not */
59466396 975 if (strncmp(str, pre, strlen(pre))) {
e0a04ac1
JA		 976 log_err("fio: mismatch in zoned input <%s>\n", str);
977 free(p);
978 return 1;
979 }
59466396 980 str += strlen(pre);
e0a04ac1 981
59466396 982 ret = str_split_parse(td, str, zone_split_ddir, absolute);
e0a04ac1
JA		 983
984 free(p);
985
986 for (i = 0; i < DDIR_RWDIR_CNT; i++) {
987 int j;
988
989 dprint(FD_PARSE, "zone ddir %d (nr=%u): \n", i, td->o.zone_split_nr[i]);
990
991 for (j = 0; j < td->o.zone_split_nr[i]; j++) {
992 struct zone_split *zsp = &td->o.zone_split[i][j];
993
59466396
JA		 994 if (absolute) {
995 dprint(FD_PARSE, "\t%d: %u/%llu\n", j,
996 zsp->access_perc,
997 (unsigned long long) zsp->size);
998 } else {
999 dprint(FD_PARSE, "\t%d: %u/%u\n", j,
1000 zsp->access_perc,
1001 zsp->size_perc);
1002 }
e0a04ac1
JA		 1003 }
1004 }
1005
55baca06 1006 if (parse_dryrun()) {
55baca06
JA		 1007 for (i = 0; i < DDIR_RWDIR_CNT; i++) {
1008 free(td->o.zone_split[i]);
1009 td->o.zone_split[i] = NULL;
1010 td->o.zone_split_nr[i] = 0;
1011 }
1012
1013 return ret;
1014 }
1015
81bdb791 1016 if (ret) {
dc4bffb8
JA		 1017 for (i = 0; i < DDIR_RWDIR_CNT; i++)
1018 td->o.zone_split_nr[i] = 0;
1019 }
e0a04ac1
JA		 1020
1021 return ret;
1022}
1023
e25839d4
JA		 1024static int str_random_distribution_cb(void *data, const char *str)
1025{
a609f12a 1026 struct thread_data *td = cb_data_to_td(data);
e25839d4
JA		 1027 double val;
1028 char *nr;
1029
925fee33 1030 if (td->o.random_distribution == FIO_RAND_DIST_ZIPF)
c95f9404 1031 val = FIO_DEF_ZIPF;
925fee33 1032 else if (td->o.random_distribution == FIO_RAND_DIST_PARETO)
c95f9404 1033 val = FIO_DEF_PARETO;
56d9fa4b
JA		 1034 else if (td->o.random_distribution == FIO_RAND_DIST_GAUSS)
1035 val = 0.0;
e0a04ac1 1036 else if (td->o.random_distribution == FIO_RAND_DIST_ZONED)
59466396
JA		 1037 return parse_zoned_distribution(td, str, false);
1038 else if (td->o.random_distribution == FIO_RAND_DIST_ZONED_ABS)
1039 return parse_zoned_distribution(td, str, true);
925fee33 1040 else
e25839d4
JA		 1041 return 0;
1042
1043 nr = get_opt_postfix(str);
88038bc7 1044 if (nr && !str_to_float(nr, &val, 0)) {
e25839d4
JA		 1045 log_err("fio: random postfix parsing failed\n");
1046 free(nr);
1047 return 1;
1048 }
1049
078189c1
JA		 1050 free(nr);
1051
18ded917
JA		 1052 if (td->o.random_distribution == FIO_RAND_DIST_ZIPF) {
1053 if (val == 1.00) {
1054 log_err("fio: zipf theta must different than 1.0\n");
1055 return 1;
1056 }
55baca06
JA		 1057 if (parse_dryrun())
1058 return 0;
1e5324e7 1059 td->o.zipf_theta.u.f = val;
56d9fa4b 1060 } else if (td->o.random_distribution == FIO_RAND_DIST_PARETO) {
078189c1
JA		 1061 if (val <= 0.00 || val >= 1.00) {
1062 log_err("fio: pareto input out of range (0 < input < 1.0)\n");
1063 return 1;
1064 }
55baca06
JA		 1065 if (parse_dryrun())
1066 return 0;
1e5324e7 1067 td->o.pareto_h.u.f = val;
3cdb8cf3 1068 } else {
76527b19 1069 if (val < 0.00 || val >= 100.0) {
99c94a6b 1070 log_err("fio: normal deviation out of range (0 <= input < 100.0)\n");
3cdb8cf3
JA		 1071 return 1;
1072 }
55baca06
JA		 1073 if (parse_dryrun())
1074 return 0;
f88cd222 1075 td->o.gauss_dev.u.f = val;
3cdb8cf3 1076 }
921c766f
JA		 1077
1078 return 0;
1079}
1080
16e56d25
VF		 1081static int str_steadystate_cb(void *data, const char *str)
1082{
94f218f6 1083 struct thread_data *td = cb_data_to_td(data);
16e56d25
VF		 1084 double val;
1085 char *nr;
1086 char *pct;
1087 long long ll;
1088
2c5d94bc
VF		 1089 if (td->o.ss_state != FIO_SS_IOPS && td->o.ss_state != FIO_SS_IOPS_SLOPE &&
1090 td->o.ss_state != FIO_SS_BW && td->o.ss_state != FIO_SS_BW_SLOPE) {
16e56d25
VF		 1091 /* should be impossible to get here */
1092 log_err("fio: unknown steady state criterion\n");
1093 return 1;
1094 }
1095
1096 nr = get_opt_postfix(str);
1097 if (!nr) {
1098 log_err("fio: steadystate threshold must be specified in addition to criterion\n");
1099 free(nr);
1100 return 1;
1101 }
1102
1103 /* ENHANCEMENT Allow fio to understand size=10.2% and use here */
1104 pct = strstr(nr, "%");
1105 if (pct) {
1106 *pct = '\0';
1107 strip_blank_end(nr);
1108 if (!str_to_float(nr, &val, 0)) {
1109 log_err("fio: could not parse steadystate threshold percentage\n");
1110 free(nr);
1111 return 1;
1112 }
1113
1114 dprint(FD_PARSE, "set steady state threshold to %f%%\n", val);
1115 free(nr);
1116 if (parse_dryrun())
1117 return 0;
1118
c8caba48 1119 td->o.ss_state |= FIO_SS_PCT;
16e56d25 1120 td->o.ss_limit.u.f = val;
c8caba48 1121 } else if (td->o.ss_state & FIO_SS_IOPS) {
16e56d25
VF		 1122 if (!str_to_float(nr, &val, 0)) {
1123 log_err("fio: steadystate IOPS threshold postfix parsing failed\n");
1124 free(nr);
1125 return 1;
1126 }
1127
1128 dprint(FD_PARSE, "set steady state IOPS threshold to %f\n", val);
1129 free(nr);
1130 if (parse_dryrun())
1131 return 0;
1132
16e56d25 1133 td->o.ss_limit.u.f = val;
16e56d25
VF		 1134 } else { /* bandwidth criterion */
1135 if (str_to_decimal(nr, &ll, 1, td, 0, 0)) {
1136 log_err("fio: steadystate BW threshold postfix parsing failed\n");
1137 free(nr);
1138 return 1;
1139 }
1140
1141 dprint(FD_PARSE, "set steady state BW threshold to %lld\n", ll);
1142 free(nr);
1143 if (parse_dryrun())
1144 return 0;
1145
16e56d25 1146 td->o.ss_limit.u.f = (double) ll;
16e56d25
VF		 1147 }
1148
2c5d94bc 1149 td->ss.state = td->o.ss_state;
16e56d25
VF		 1150 return 0;
1151}
1152
8e827d35 1153/*
bcbfeefa 1154 * Return next name in the string. Files are separated with ':'. If the ':'
8e827d35
JA		 1155 * is escaped with a '\', then that ':' is part of the filename and does not
1156 * indicate a new file.
1157 */
bcbfeefa 1158static char *get_next_name(char **ptr)
8e827d35
JA		 1159{
1160 char *str = *ptr;
1161 char *p, *start;
1162
1163 if (!str || !strlen(str))
1164 return NULL;
1165
1166 start = str;
1167 do {
1168 /*
1169 * No colon, we are done
1170 */
1171 p = strchr(str, ':');
1172 if (!p) {
1173 *ptr = NULL;
1174 break;
1175 }
1176
1177 /*
1178 * We got a colon, but it's the first character. Skip and
1179 * continue
1180 */
1181 if (p == start) {
1182 str = ++start;
1183 continue;
1184 }
1185
1186 if (*(p - 1) != '\\') {
1187 *p = '\0';
1188 *ptr = p + 1;
1189 break;
1190 }
1191
1192 memmove(p - 1, p, strlen(p) + 1);
1193 str = p;
1194 } while (1);
1195
1196 return start;
1197}
1198
bcbfeefa
CE		 1199
1200static int get_max_name_idx(char *input)
1201{
1202 unsigned int cur_idx;
1203 char *str, *p;
1204
1205 p = str = strdup(input);
1206 for (cur_idx = 0; ; cur_idx++)
1207 if (get_next_name(&str) == NULL)
1208 break;
1209
1210 free(p);
1211 return cur_idx;
1212}
1213
1214/*
1215 * Returns the directory at the index, indexes > entires will be
1216 * assigned via modulo division of the index
1217 */
922a5be8
JA		 1218int set_name_idx(char *target, size_t tlen, char *input, int index,
1219 bool unique_filename)
bcbfeefa
CE		 1220{
1221 unsigned int cur_idx;
1222 int len;
1223 char *fname, *str, *p;
1224
1225 p = str = strdup(input);
1226
1227 index %= get_max_name_idx(input);
1228 for (cur_idx = 0; cur_idx <= index; cur_idx++)
1229 fname = get_next_name(&str);
1230
922a5be8 1231 if (client_sockaddr_str[0] && unique_filename) {
e13c3b50
JA		 1232 len = snprintf(target, tlen, "%s/%s.", fname,
1233 client_sockaddr_str);
1234 } else
1235 len = snprintf(target, tlen, "%s/", fname);
72a703da 1236
e13c3b50 1237 target[tlen - 1] = '\0';
bcbfeefa
CE		 1238 free(p);
1239
1240 return len;
1241}
1242
214e1eca
JA		 1243static int str_filename_cb(void *data, const char *input)
1244{
a609f12a 1245 struct thread_data *td = cb_data_to_td(data);
214e1eca
JA		 1246 char *fname, *str, *p;
1247
1248 p = str = strdup(input);
1249
1250 strip_blank_front(&str);
1251 strip_blank_end(str);
1252
79591fa9
TK		 1253 /*
1254 * Ignore what we may already have from nrfiles option.
1255 */
214e1eca 1256 if (!td->files_index)
2dc1bbeb 1257 td->o.nr_files = 0;
214e1eca 1258
bcbfeefa 1259 while ((fname = get_next_name(&str)) != NULL) {
214e1eca
JA		 1260 if (!strlen(fname))
1261 break;
5903e7b7 1262 add_file(td, fname, 0, 1);
214e1eca
JA		 1263 }
1264
1265 free(p);
1266 return 0;
1267}
1268
bcbfeefa 1269static int str_directory_cb(void *data, const char fio_unused *unused)
214e1eca 1270{
a609f12a 1271 struct thread_data *td = cb_data_to_td(data);
214e1eca 1272 struct stat sb;
bcbfeefa
CE		 1273 char *dirname, *str, *p;
1274 int ret = 0;
214e1eca 1275
f9633d72
JA		 1276 if (parse_dryrun())
1277 return 0;
1278
bcbfeefa
CE		 1279 p = str = strdup(td->o.directory);
1280 while ((dirname = get_next_name(&str)) != NULL) {
1281 if (lstat(dirname, &sb) < 0) {
1282 ret = errno;
921c766f 1283
bcbfeefa
CE		 1284 log_err("fio: %s is not a directory\n", dirname);
1285 td_verror(td, ret, "lstat");
1286 goto out;
1287 }
1288 if (!S_ISDIR(sb.st_mode)) {
1289 log_err("fio: %s is not a directory\n", dirname);
1290 ret = 1;
1291 goto out;
1292 }
214e1eca
JA		 1293 }
1294
bcbfeefa
CE		 1295out:
1296 free(p);
1297 return ret;
214e1eca
JA		 1298}
1299
1300static int str_opendir_cb(void *data, const char fio_unused *str)
1301{
a609f12a 1302 struct thread_data *td = cb_data_to_td(data);
214e1eca 1303
52c0cea3
JA		 1304 if (parse_dryrun())
1305 return 0;
1306
214e1eca 1307 if (!td->files_index)
2dc1bbeb 1308 td->o.nr_files = 0;
214e1eca 1309
2dc1bbeb 1310 return add_dir_files(td, td->o.opendir);
214e1eca
JA		 1311}
1312
ce35b1ec
JA		 1313static int str_buffer_pattern_cb(void *data, const char *input)
1314{
a609f12a 1315 struct thread_data *td = cb_data_to_td(data);
ce35b1ec
JA		 1316 int ret;
1317
61b9861d
RP		 1318 /* FIXME: for now buffer pattern does not support formats */
1319 ret = parse_and_fill_pattern(input, strlen(input), td->o.buffer_pattern,
1320 MAX_PATTERN_SIZE, NULL, 0, NULL, NULL);
1321 if (ret < 0)
1322 return 1;
ce35b1ec 1323
61b9861d
RP		 1324 assert(ret != 0);
1325 td->o.buffer_pattern_bytes = ret;
c55fae03
JA		 1326
1327 /*
1328 * If this job is doing any reading or has compression set,
1329 * ensure that we refill buffers for writes or we could be
1330 * invalidating the pattern through reads.
1331 */
1332 if (!td->o.compress_percentage && !td_read(td))
61b9861d 1333 td->o.refill_buffers = 0;
c55fae03
JA		 1334 else
1335 td->o.refill_buffers = 1;
1336
61b9861d
RP		 1337 td->o.scramble_buffers = 0;
1338 td->o.zero_buffers = 0;
efcd9dcc 1339
61b9861d 1340 return 0;
ce35b1ec
JA		 1341}
1342
bedc9dc2
JA		 1343static int str_buffer_compress_cb(void *data, unsigned long long *il)
1344{
a609f12a 1345 struct thread_data *td = cb_data_to_td(data);
bedc9dc2
JA		 1346
1347 td->flags |= TD_F_COMPRESS;
1348 td->o.compress_percentage = *il;
1349 return 0;
1350}
1351
5c94b008
JA		 1352static int str_dedupe_cb(void *data, unsigned long long *il)
1353{
a609f12a 1354 struct thread_data *td = cb_data_to_td(data);
5c94b008
JA		 1355
1356 td->flags |= TD_F_COMPRESS;
1357 td->o.dedupe_percentage = *il;
1358 td->o.refill_buffers = 1;
1359 return 0;
1360}
1361
ce35b1ec
JA		 1362static int str_verify_pattern_cb(void *data, const char *input)
1363{
a609f12a 1364 struct thread_data *td = cb_data_to_td(data);
ce35b1ec
JA		 1365 int ret;
1366
61b9861d
RP		 1367 td->o.verify_fmt_sz = ARRAY_SIZE(td->o.verify_fmt);
1368 ret = parse_and_fill_pattern(input, strlen(input), td->o.verify_pattern,
4205998f
JA		 1369 MAX_PATTERN_SIZE, fmt_desc, sizeof(fmt_desc),
1370 td->o.verify_fmt, &td->o.verify_fmt_sz);
61b9861d
RP		 1371 if (ret < 0)
1372 return 1;
efcd9dcc 1373
61b9861d
RP		 1374 assert(ret != 0);
1375 td->o.verify_pattern_bytes = ret;
92bf48d5 1376 /*
b638d82f 1377 * VERIFY_* could already be set
92bf48d5 1378 */
61b9861d 1379 if (!fio_option_is_set(&td->o, verify))
92bf48d5 1380 td->o.verify = VERIFY_PATTERN;
efcd9dcc 1381
61b9861d 1382 return 0;
90059d65 1383}
214e1eca 1384
993bf48b
JA		 1385static int str_gtod_reduce_cb(void *data, int *il)
1386{
a609f12a 1387 struct thread_data *td = cb_data_to_td(data);
993bf48b
JA		 1388 int val = *il;
1389
02af0988 1390 td->o.disable_lat = !!val;
993bf48b
JA		 1391 td->o.disable_clat = !!val;
1392 td->o.disable_slat = !!val;
1393 td->o.disable_bw = !!val;
0dc1bc03 1394 td->o.clat_percentiles = !val;
993bf48b 1395 if (val)
8b6a404c 1396 td->ts_cache_mask = 63;
993bf48b
JA		 1397
1398 return 0;
1399}
1400
89978a6b
BW		 1401static int str_offset_cb(void *data, unsigned long long *__val)
1402{
1403 struct thread_data *td = cb_data_to_td(data);
1404 unsigned long long v = *__val;
1405
1406 if (parse_is_percent(v)) {
1407 td->o.start_offset = 0;
1408 td->o.start_offset_percent = -1ULL - v;
872e0415
JA		 1409 dprint(FD_PARSE, "SET start_offset_percent %d\n",
1410 td->o.start_offset_percent);
89978a6b
BW		 1411 } else
1412 td->o.start_offset = v;
1413
1414 return 0;
1415}
1416
7bb59102
JA		 1417static int str_size_cb(void *data, unsigned long long *__val)
1418{
a609f12a 1419 struct thread_data *td = cb_data_to_td(data);
7bb59102
JA		 1420 unsigned long long v = *__val;
1421
1422 if (parse_is_percent(v)) {
1423 td->o.size = 0;
1424 td->o.size_percent = -1ULL - v;
24e4321c
TK		 1425 dprint(FD_PARSE, "SET size_percent %d\n",
1426 td->o.size_percent);
7bb59102
JA		 1427 } else
1428 td->o.size = v;
1429
1430 return 0;
1431}
1432
dded427c
OS		 1433static int str_write_bw_log_cb(void *data, const char *str)
1434{
1435 struct thread_data *td = cb_data_to_td(data);
1436
1437 if (str)
1438 td->o.bw_log_file = strdup(str);
1439
1440 td->o.write_bw_log = 1;
1441 return 0;
1442}
1443
1444static int str_write_lat_log_cb(void *data, const char *str)
1445{
1446 struct thread_data *td = cb_data_to_td(data);
1447
1448 if (str)
1449 td->o.lat_log_file = strdup(str);
1450
1451 td->o.write_lat_log = 1;
1452 return 0;
1453}
1454
1455static int str_write_iops_log_cb(void *data, const char *str)
1456{
1457 struct thread_data *td = cb_data_to_td(data);
1458
1459 if (str)
1460 td->o.iops_log_file = strdup(str);
1461
1462 td->o.write_iops_log = 1;
1463 return 0;
1464}
1465
1466static int str_write_hist_log_cb(void *data, const char *str)
1467{
1468 struct thread_data *td = cb_data_to_td(data);
1469
1470 if (str)
1471 td->o.hist_log_file = strdup(str);
1472
1473 td->o.write_hist_log = 1;
1474 return 0;
1475}
1476
6730b40f
TK		 1477/*
1478 * str is supposed to be a substring of the strdup'd original string,
1479 * and is valid only if it's a regular file path.
1480 * This function keeps the pointer to the path as needed later.
1481 *
1482 * "external:/path/to/so\0" <- original pointer updated with strdup'd
1483 * "external\0" <- above pointer after parsed, i.e. ->ioengine
1484 * "/path/to/so\0" <- str argument, i.e. ->ioengine_so_path
1485 */
1486static int str_ioengine_external_cb(void *data, const char *str)
1487{
1488 struct thread_data *td = cb_data_to_td(data);
1489 struct stat sb;
1490 char *p;
1491
1492 if (!str) {
1493 log_err("fio: null external ioengine path\n");
1494 return 1;
1495 }
1496
1497 p = (char *)str; /* str is mutable */
1498 strip_blank_front(&p);
1499 strip_blank_end(p);
1500
1501 if (stat(p, &sb) || !S_ISREG(sb.st_mode)) {
1502 log_err("fio: invalid external ioengine path \"%s\"\n", p);
1503 return 1;
1504 }
1505
1506 td->o.ioengine_so_path = p;
1507 return 0;
1508}
1509
9109883a 1510static int rw_verify(const struct fio_option *o, void *data)
896cac2a 1511{
a609f12a 1512 struct thread_data *td = cb_data_to_td(data);
896cac2a 1513
d81d0f99
VF		 1514 if (read_only && (td_write(td) || td_trim(td))) {
1515 log_err("fio: job <%s> has write or trim bit set, but"
1516 " fio is in read-only mode\n", td->o.name);
896cac2a
JA		 1517 return 1;
1518 }
1519
1520 return 0;
1521}
1522
9109883a 1523static int gtod_cpu_verify(const struct fio_option *o, void *data)
29d43ff9 1524{
276ca4f7 1525#ifndef FIO_HAVE_CPU_AFFINITY
a609f12a 1526 struct thread_data *td = cb_data_to_td(data);
29d43ff9 1527
29d43ff9
JA		 1528 if (td->o.gtod_cpu) {
1529 log_err("fio: platform must support CPU affinity for"
1530 "gettimeofday() offloading\n");
1531 return 1;
1532 }
1533#endif
1534
1535 return 0;
1536}
1537
214e1eca
JA		 1538/*
1539 * Map of job/command line options
1540 */
9af4a244 1541struct fio_option fio_options[FIO_MAX_OPTS] = {
214e1eca
JA		 1542 {
1543 .name = "description",
e8b0e958 1544 .lname = "Description of job",
214e1eca 1545 .type = FIO_OPT_STR_STORE,
a609f12a 1546 .off1 = offsetof(struct thread_options, description),
214e1eca 1547 .help = "Text job description",
e8b0e958 1548 .category = FIO_OPT_C_GENERAL,
0626037e 1549 .group = FIO_OPT_G_DESC,
214e1eca
JA		 1550 },
1551 {
1552 .name = "name",
e8b0e958 1553 .lname = "Job name",
214e1eca 1554 .type = FIO_OPT_STR_STORE,
a609f12a 1555 .off1 = offsetof(struct thread_options, name),
214e1eca 1556 .help = "Name of this job",
e8b0e958 1557 .category = FIO_OPT_C_GENERAL,
0626037e 1558 .group = FIO_OPT_G_DESC,
214e1eca 1559 },
9cc8cb91
AK		 1560 {
1561 .name = "wait_for",
1562 .lname = "Waitee name",
1563 .type = FIO_OPT_STR_STORE,
a609f12a 1564 .off1 = offsetof(struct thread_options, wait_for),
9cc8cb91
AK		 1565 .help = "Name of the job this one wants to wait for before starting",
1566 .category = FIO_OPT_C_GENERAL,
1567 .group = FIO_OPT_G_DESC,
1568 },
214e1eca
JA		 1569 {
1570 .name = "filename",
e8b0e958 1571 .lname = "Filename(s)",
214e1eca 1572 .type = FIO_OPT_STR_STORE,
a609f12a 1573 .off1 = offsetof(struct thread_options, filename),
214e1eca 1574 .cb = str_filename_cb,
f0d524b0 1575 .prio = -1, /* must come after "directory" */
214e1eca 1576 .help = "File(s) to use for the workload",
e8b0e958 1577 .category = FIO_OPT_C_FILE,
0626037e 1578 .group = FIO_OPT_G_FILENAME,
214e1eca 1579 },
90fef2d1 1580 {
e8b0e958
JA		 1581 .name = "directory",
1582 .lname = "Directory",
1583 .type = FIO_OPT_STR_STORE,
a609f12a 1584 .off1 = offsetof(struct thread_options, directory),
e8b0e958
JA		 1585 .cb = str_directory_cb,
1586 .help = "Directory to store files in",
1587 .category = FIO_OPT_C_FILE,
0626037e 1588 .group = FIO_OPT_G_FILENAME,
90fef2d1 1589 },
de98bd30
JA		 1590 {
1591 .name = "filename_format",
922a5be8 1592 .lname = "Filename Format",
de98bd30 1593 .type = FIO_OPT_STR_STORE,
a609f12a 1594 .off1 = offsetof(struct thread_options, filename_format),
de98bd30
JA		 1595 .prio = -1, /* must come after "directory" */
1596 .help = "Override default $jobname.$jobnum.$filenum naming",
1597 .def = "$jobname.$jobnum.$filenum",
93bb626a
JA		 1598 .category = FIO_OPT_C_FILE,
1599 .group = FIO_OPT_G_FILENAME,
ad705bcb 1600 },
922a5be8
JA		 1601 {
1602 .name = "unique_filename",
1603 .lname = "Unique Filename",
1604 .type = FIO_OPT_BOOL,
a609f12a 1605 .off1 = offsetof(struct thread_options, unique_filename),
922a5be8
JA		 1606 .help = "For network clients, prefix file with source IP",
1607 .def = "1",
1608 .category = FIO_OPT_C_FILE,
1609 .group = FIO_OPT_G_FILENAME,
1610 },
29c1349f
JA		 1611 {
1612 .name = "lockfile",
e8b0e958 1613 .lname = "Lockfile",
4d4e80f2 1614 .type = FIO_OPT_STR,
a609f12a 1615 .off1 = offsetof(struct thread_options, file_lock_mode),
29c1349f 1616 .help = "Lock file when doing IO to it",
bc6a0a5d 1617 .prio = 1,
29c1349f 1618 .parent = "filename",
d71c154c 1619 .hide = 0,
4d4e80f2 1620 .def = "none",
e8b0e958 1621 .category = FIO_OPT_C_FILE,
0626037e 1622 .group = FIO_OPT_G_FILENAME,
4d4e80f2
JA		 1623 .posval = {
1624 { .ival = "none",
1625 .oval = FILE_LOCK_NONE,
1626 .help = "No file locking",
1627 },
1628 { .ival = "exclusive",
1629 .oval = FILE_LOCK_EXCLUSIVE,
1630 .help = "Exclusive file lock",
1631 },
1632 {
1633 .ival = "readwrite",
1634 .oval = FILE_LOCK_READWRITE,
1635 .help = "Read vs write lock",
1636 },
1637 },
29c1349f 1638 },
214e1eca
JA		 1639 {
1640 .name = "opendir",
e8b0e958 1641 .lname = "Open directory",
214e1eca 1642 .type = FIO_OPT_STR_STORE,
a609f12a 1643 .off1 = offsetof(struct thread_options, opendir),
214e1eca
JA		 1644 .cb = str_opendir_cb,
1645 .help = "Recursively add files from this directory and down",
e8b0e958 1646 .category = FIO_OPT_C_FILE,
0626037e 1647 .group = FIO_OPT_G_FILENAME,
214e1eca
JA		 1648 },
1649 {
1650 .name = "rw",
e8b0e958 1651 .lname = "Read/write",
d3aad8f2 1652 .alias = "readwrite",
214e1eca 1653 .type = FIO_OPT_STR,
211097b2 1654 .cb = str_rw_cb,
a609f12a 1655 .off1 = offsetof(struct thread_options, td_ddir),
214e1eca
JA		 1656 .help = "IO direction",
1657 .def = "read",
896cac2a 1658 .verify = rw_verify,
e8b0e958 1659 .category = FIO_OPT_C_IO,
0626037e 1660 .group = FIO_OPT_G_IO_BASIC,
214e1eca
JA		 1661 .posval = {
1662 { .ival = "read",
1663 .oval = TD_DDIR_READ,
1664 .help = "Sequential read",
1665 },
1666 { .ival = "write",
1667 .oval = TD_DDIR_WRITE,
1668 .help = "Sequential write",
1669 },
6eaf09d6
SL		 1670 { .ival = "trim",
1671 .oval = TD_DDIR_TRIM,
1672 .help = "Sequential trim",
1673 },
214e1eca
JA		 1674 { .ival = "randread",
1675 .oval = TD_DDIR_RANDREAD,
1676 .help = "Random read",
1677 },
1678 { .ival = "randwrite",
1679 .oval = TD_DDIR_RANDWRITE,
1680 .help = "Random write",
1681 },
6eaf09d6
SL		 1682 { .ival = "randtrim",
1683 .oval = TD_DDIR_RANDTRIM,
1684 .help = "Random trim",
1685 },
214e1eca
JA		 1686 { .ival = "rw",
1687 .oval = TD_DDIR_RW,
1688 .help = "Sequential read and write mix",
1689 },
10b023db
JA		 1690 { .ival = "readwrite",
1691 .oval = TD_DDIR_RW,
1692 .help = "Sequential read and write mix",
1693 },
214e1eca
JA		 1694 { .ival = "randrw",
1695 .oval = TD_DDIR_RANDRW,
1696 .help = "Random read and write mix"
1697 },
82a90686
JA		 1698 { .ival = "trimwrite",
1699 .oval = TD_DDIR_TRIMWRITE,
1700 .help = "Trim and write mix, trims preceding writes"
0e4dd95c 1701 },
214e1eca
JA		 1702 },
1703 },
38dad62d
JA		 1704 {
1705 .name = "rw_sequencer",
e8b0e958 1706 .lname = "RW Sequencer",
38dad62d 1707 .type = FIO_OPT_STR,
a609f12a 1708 .off1 = offsetof(struct thread_options, rw_seq),
38dad62d
JA		 1709 .help = "IO offset generator modifier",
1710 .def = "sequential",
e8b0e958 1711 .category = FIO_OPT_C_IO,
0626037e 1712 .group = FIO_OPT_G_IO_BASIC,
38dad62d
JA		 1713 .posval = {
1714 { .ival = "sequential",
1715 .oval = RW_SEQ_SEQ,
1716 .help = "Generate sequential offsets",
1717 },
1718 { .ival = "identical",
1719 .oval = RW_SEQ_IDENT,
1720 .help = "Generate identical offsets",
1721 },
1722 },
1723 },
1724
214e1eca
JA		 1725 {
1726 .name = "ioengine",
e8b0e958 1727 .lname = "IO Engine",
214e1eca 1728 .type = FIO_OPT_STR_STORE,
a609f12a 1729 .off1 = offsetof(struct thread_options, ioengine),
214e1eca 1730 .help = "IO engine to use",
58483fa4 1731 .def = FIO_PREFERRED_ENGINE,
e8b0e958 1732 .category = FIO_OPT_C_IO,
0626037e 1733 .group = FIO_OPT_G_IO_BASIC,
214e1eca
JA		 1734 .posval = {
1735 { .ival = "sync",
1736 .help = "Use read/write",
1737 },
a31041ea 1738 { .ival = "psync",
1739 .help = "Use pread/pwrite",
1740 },
1d2af02a 1741 { .ival = "vsync",
03e20d68 1742 .help = "Use readv/writev",
1d2af02a 1743 },
07fc0acd
JA		 1744#ifdef CONFIG_PWRITEV
1745 { .ival = "pvsync",
1746 .help = "Use preadv/pwritev",
1747 },
1748#endif
6562685f 1749#ifdef FIO_HAVE_PWRITEV2
2cafffbe
JA		 1750 { .ival = "pvsync2",
1751 .help = "Use preadv2/pwritev2",
1752 },
1753#endif
67bf9823 1754#ifdef CONFIG_LIBAIO
214e1eca
JA		 1755 { .ival = "libaio",
1756 .help = "Linux native asynchronous IO",
1757 },
1758#endif
67bf9823 1759#ifdef CONFIG_POSIXAIO
214e1eca
JA		 1760 { .ival = "posixaio",
1761 .help = "POSIX asynchronous IO",
1762 },
417f0068 1763#endif
997843cb 1764#ifdef CONFIG_SOLARISAIO
417f0068
JA		 1765 { .ival = "solarisaio",
1766 .help = "Solaris native asynchronous IO",
1767 },
214e1eca 1768#endif
4700b234 1769#ifdef CONFIG_WINDOWSAIO
03e20d68 1770 { .ival = "windowsaio",
3be80071 1771 .help = "Windows native asynchronous IO"
de890a1e 1772 },
fc5c0345
DG		 1773#endif
1774#ifdef CONFIG_RBD
1775 { .ival = "rbd",
1776 .help = "Rados Block Device asynchronous IO"
1777 },
3be80071 1778#endif
214e1eca 1779 { .ival = "mmap",
03e20d68 1780 .help = "Memory mapped IO"
214e1eca 1781 },
67bf9823 1782#ifdef CONFIG_LINUX_SPLICE
214e1eca
JA		 1783 { .ival = "splice",
1784 .help = "splice/vmsplice based IO",
1785 },
9cce02e8
JA		 1786 { .ival = "netsplice",
1787 .help = "splice/vmsplice to/from the network",
1788 },
214e1eca
JA		 1789#endif
1790#ifdef FIO_HAVE_SGIO
1791 { .ival = "sg",
1792 .help = "SCSI generic v3 IO",
1793 },
1794#endif
1795 { .ival = "null",
1796 .help = "Testing engine (no data transfer)",
1797 },
1798 { .ival = "net",
1799 .help = "Network IO",
1800 },
214e1eca 1801 { .ival = "cpuio",
03e20d68 1802 .help = "CPU cycle burner engine",
214e1eca 1803 },
67bf9823 1804#ifdef CONFIG_GUASI
b8c82a46
JA		 1805 { .ival = "guasi",
1806 .help = "GUASI IO engine",
1807 },
79a43187 1808#endif
67bf9823 1809#ifdef CONFIG_RDMA
21b8aee8 1810 { .ival = "rdma",
1811 .help = "RDMA IO engine",
1812 },
8200b8c7 1813#endif
67bf9823 1814#ifdef CONFIG_FUSION_AW
8200b8c7
JA		 1815 { .ival = "fusion-aw-sync",
1816 .help = "Fusion-io atomic write engine",
1817 },
1ecc95ca 1818#endif
997843cb 1819#ifdef CONFIG_LINUX_EXT4_MOVE_EXTENT
1ecc95ca
JA		 1820 { .ival = "e4defrag",
1821 .help = "ext4 defrag engine",
1822 },
1823#endif
997843cb 1824#ifdef CONFIG_LINUX_FALLOCATE
1ecc95ca
JA		 1825 { .ival = "falloc",
1826 .help = "fallocate() file based engine",
1827 },
b8c82a46 1828#endif
a7c386f4 1829#ifdef CONFIG_GFAPI
1830 { .ival = "gfapi",
cc47f094 1831 .help = "Glusterfs libgfapi(sync) based engine"
1832 },
1833 { .ival = "gfapi_async",
1834 .help = "Glusterfs libgfapi(async) based engine"
a7c386f4 1835 },
1836#endif
1b10477b 1837#ifdef CONFIG_LIBHDFS
b74e419e 1838 { .ival = "libhdfs",
1b10477b
MM		 1839 .help = "Hadoop Distributed Filesystem (HDFS) engine"
1840 },
5c4ef02e
JA		 1841#endif
1842#ifdef CONFIG_PMEMBLK
1843 { .ival = "pmemblk",
363a5f65 1844 .help = "PMDK libpmemblk based IO engine",
5c4ef02e
JA		 1845 },
1846
104ee4de 1847#endif
a40e7a59
GB		 1848#ifdef CONFIG_IME
1849 { .ival = "ime_psync",
1850 .help = "DDN's IME synchronous IO engine",
1851 },
1852 { .ival = "ime_psyncv",
1853 .help = "DDN's IME synchronous IO engine using iovecs",
1854 },
1855 { .ival = "ime_aio",
1856 .help = "DDN's IME asynchronous IO engine",
1857 },
1858#endif
104ee4de
DJ		 1859#ifdef CONFIG_LINUX_DEVDAX
1860 { .ival = "dev-dax",
1861 .help = "DAX Device based IO engine",
1862 },
1b10477b 1863#endif
edc5fa12
JA		 1864 {
1865 .ival = "filecreate",
1866 .help = "File creation engine",
1867 },
214e1eca
JA		 1868 { .ival = "external",
1869 .help = "Load external engine (append name)",
6730b40f 1870 .cb = str_ioengine_external_cb,
214e1eca 1871 },
ae0db592
TI		 1872#ifdef CONFIG_LIBPMEM
1873 { .ival = "libpmem",
363a5f65 1874 .help = "PMDK libpmem based IO engine",
ae0db592 1875 },
c2f6a13d
LMB		 1876#endif
1877#ifdef CONFIG_HTTP
1878 { .ival = "http",
1879 .help = "HTTP (WebDAV/S3) IO engine",
1880 },
ae0db592 1881#endif
214e1eca
JA		 1882 },
1883 },
1884 {
1885 .name = "iodepth",
e8b0e958 1886 .lname = "IO Depth",
214e1eca 1887 .type = FIO_OPT_INT,
a609f12a 1888 .off1 = offsetof(struct thread_options, iodepth),
03e20d68 1889 .help = "Number of IO buffers to keep in flight",
757aff4f 1890 .minval = 1,
20eb06bd 1891 .interval = 1,
214e1eca 1892 .def = "1",
e8b0e958 1893 .category = FIO_OPT_C_IO,
0626037e 1894 .group = FIO_OPT_G_IO_BASIC,
214e1eca
JA		 1895 },
1896 {
1897 .name = "iodepth_batch",
e8b0e958 1898 .lname = "IO Depth batch",
4950421a 1899 .alias = "iodepth_batch_submit",
214e1eca 1900 .type = FIO_OPT_INT,
a609f12a 1901 .off1 = offsetof(struct thread_options, iodepth_batch),
d65db441 1902 .help = "Number of IO buffers to submit in one go",
afdf9352 1903 .parent = "iodepth",
d71c154c 1904 .hide = 1,
20eb06bd 1905 .interval = 1,
a2e6f8ac 1906 .def = "1",
e8b0e958 1907 .category = FIO_OPT_C_IO,
0626037e 1908 .group = FIO_OPT_G_IO_BASIC,
4950421a
JA		 1909 },
1910 {
82407585
RP		 1911 .name = "iodepth_batch_complete_min",
1912 .lname = "Min IO depth batch complete",
1913 .alias = "iodepth_batch_complete",
4950421a 1914 .type = FIO_OPT_INT,
a609f12a 1915 .off1 = offsetof(struct thread_options, iodepth_batch_complete_min),
82407585 1916 .help = "Min number of IO buffers to retrieve in one go",
4950421a 1917 .parent = "iodepth",
d71c154c 1918 .hide = 1,
4950421a 1919 .minval = 0,
20eb06bd 1920 .interval = 1,
4950421a 1921 .def = "1",
e8b0e958 1922 .category = FIO_OPT_C_IO,
0626037e 1923 .group = FIO_OPT_G_IO_BASIC,
214e1eca 1924 },
82407585
RP		 1925 {
1926 .name = "iodepth_batch_complete_max",
1927 .lname = "Max IO depth batch complete",
1928 .type = FIO_OPT_INT,
a609f12a 1929 .off1 = offsetof(struct thread_options, iodepth_batch_complete_max),
82407585
RP		 1930 .help = "Max number of IO buffers to retrieve in one go",
1931 .parent = "iodepth",
1932 .hide = 1,
1933 .minval = 0,
1934 .interval = 1,
1935 .category = FIO_OPT_C_IO,
1936 .group = FIO_OPT_G_IO_BASIC,
1937 },
214e1eca
JA		 1938 {
1939 .name = "iodepth_low",
e8b0e958 1940 .lname = "IO Depth batch low",
214e1eca 1941 .type = FIO_OPT_INT,
a609f12a 1942 .off1 = offsetof(struct thread_options, iodepth_low),
214e1eca 1943 .help = "Low water mark for queuing depth",
afdf9352 1944 .parent = "iodepth",
d71c154c 1945 .hide = 1,
20eb06bd 1946 .interval = 1,
e8b0e958 1947 .category = FIO_OPT_C_IO,
0626037e 1948 .group = FIO_OPT_G_IO_BASIC,
214e1eca 1949 },
997b5680
SW		 1950 {
1951 .name = "serialize_overlap",
1952 .lname = "Serialize overlap",
1953 .off1 = offsetof(struct thread_options, serialize_overlap),
1954 .type = FIO_OPT_BOOL,
1955 .help = "Wait for in-flight IOs that collide to complete",
1956 .parent = "iodepth",
1957 .def = "0",
1958 .category = FIO_OPT_C_IO,
1959 .group = FIO_OPT_G_IO_BASIC,
1960 },
a9da8ab2
JA		 1961 {
1962 .name = "io_submit_mode",
1963 .lname = "IO submit mode",
1964 .type = FIO_OPT_STR,
a609f12a 1965 .off1 = offsetof(struct thread_options, io_submit_mode),
a9da8ab2
JA		 1966 .help = "How IO submissions and completions are done",
1967 .def = "inline",
1968 .category = FIO_OPT_C_IO,
1969 .group = FIO_OPT_G_IO_BASIC,
1970 .posval = {
1971 { .ival = "inline",
1972 .oval = IO_MODE_INLINE,
1973 .help = "Submit and complete IO inline",
1974 },
1975 { .ival = "offload",
1976 .oval = IO_MODE_OFFLOAD,
1977 .help = "Offload submit and complete to threads",
1978 },
1979 },
1980 },
214e1eca
JA		 1981 {
1982 .name = "size",
e8b0e958 1983 .lname = "Size",
214e1eca 1984 .type = FIO_OPT_STR_VAL,
7bb59102 1985 .cb = str_size_cb,
a609f12a 1986 .off1 = offsetof(struct thread_options, size),
214e1eca 1987 .help = "Total size of device or files",
20eb06bd 1988 .interval = 1024 * 1024,
e8b0e958
JA		 1989 .category = FIO_OPT_C_IO,
1990 .group = FIO_OPT_G_INVALID,
214e1eca 1991 },
77731b29 1992 {
a4d3b4db
JA		 1993 .name = "io_size",
1994 .alias = "io_limit",
1995 .lname = "IO Size",
77731b29 1996 .type = FIO_OPT_STR_VAL,
5be9bf09 1997 .off1 = offsetof(struct thread_options, io_size),
1684f7fd 1998 .help = "Total size of I/O to be performed",
77731b29
JA		 1999 .interval = 1024 * 1024,
2000 .category = FIO_OPT_C_IO,
2001 .group = FIO_OPT_G_INVALID,
2002 },
aa31f1f1
SL		 2003 {
2004 .name = "fill_device",
e8b0e958 2005 .lname = "Fill device",
74586c1e 2006 .alias = "fill_fs",
aa31f1f1 2007 .type = FIO_OPT_BOOL,
a609f12a 2008 .off1 = offsetof(struct thread_options, fill_device),
aa31f1f1
SL		 2009 .help = "Write until an ENOSPC error occurs",
2010 .def = "0",
e8b0e958
JA		 2011 .category = FIO_OPT_C_FILE,
2012 .group = FIO_OPT_G_INVALID,
aa31f1f1 2013 },
214e1eca
JA		 2014 {
2015 .name = "filesize",
e8b0e958 2016 .lname = "File size",
214e1eca 2017 .type = FIO_OPT_STR_VAL,
a609f12a
JA		 2018 .off1 = offsetof(struct thread_options, file_size_low),
2019 .off2 = offsetof(struct thread_options, file_size_high),
c3edbdba 2020 .minval = 1,
214e1eca 2021 .help = "Size of individual files",
20eb06bd 2022 .interval = 1024 * 1024,
e8b0e958
JA		 2023 .category = FIO_OPT_C_FILE,
2024 .group = FIO_OPT_G_INVALID,
214e1eca 2025 },
bedc9dc2
JA		 2026 {
2027 .name = "file_append",
2028 .lname = "File append",
2029 .type = FIO_OPT_BOOL,
a609f12a 2030 .off1 = offsetof(struct thread_options, file_append),
bedc9dc2
JA		 2031 .help = "IO will start at the end of the file(s)",
2032 .def = "0",
2033 .category = FIO_OPT_C_FILE,
2034 .group = FIO_OPT_G_INVALID,
2035 },
67a1000f
JA		 2036 {
2037 .name = "offset",
e8b0e958 2038 .lname = "IO offset",
67a1000f
JA		 2039 .alias = "fileoffset",
2040 .type = FIO_OPT_STR_VAL,
89978a6b 2041 .cb = str_offset_cb,
a609f12a 2042 .off1 = offsetof(struct thread_options, start_offset),
67a1000f
JA		 2043 .help = "Start IO from this offset",
2044 .def = "0",
20eb06bd 2045 .interval = 1024 * 1024,
e8b0e958
JA		 2046 .category = FIO_OPT_C_IO,
2047 .group = FIO_OPT_G_INVALID,
67a1000f 2048 },
83c8b093
JF		 2049 {
2050 .name = "offset_align",
2051 .lname = "IO offset alignment",
2052 .type = FIO_OPT_INT,
2053 .off1 = offsetof(struct thread_options, start_offset_align),
2054 .help = "Start IO from this offset alignment",
2055 .def = "0",
2056 .interval = 512,
2057 .category = FIO_OPT_C_IO,
2058 .group = FIO_OPT_G_INVALID,
2059 },
2d7cd868
JA		 2060 {
2061 .name = "offset_increment",
e8b0e958 2062 .lname = "IO offset increment",
2d7cd868 2063 .type = FIO_OPT_STR_VAL,
a609f12a 2064 .off1 = offsetof(struct thread_options, offset_increment),
2d7cd868
JA		 2065 .help = "What is the increment from one offset to the next",
2066 .parent = "offset",
d71c154c 2067 .hide = 1,
2d7cd868 2068 .def = "0",
20eb06bd 2069 .interval = 1024 * 1024,
e8b0e958
JA		 2070 .category = FIO_OPT_C_IO,
2071 .group = FIO_OPT_G_INVALID,
2d7cd868 2072 },
ddf24e42
JA		 2073 {
2074 .name = "number_ios",
2075 .lname = "Number of IOs to perform",
2076 .type = FIO_OPT_STR_VAL,
a609f12a 2077 .off1 = offsetof(struct thread_options, number_ios),
be3fec7d 2078 .help = "Force job completion after this number of IOs",
ddf24e42
JA		 2079 .def = "0",
2080 .category = FIO_OPT_C_IO,
2081 .group = FIO_OPT_G_INVALID,
2082 },
214e1eca
JA		 2083 {
2084 .name = "bs",
e8b0e958 2085 .lname = "Block size",
d3aad8f2 2086 .alias = "blocksize",
5fff9543 2087 .type = FIO_OPT_ULL,
a609f12a
JA		 2088 .off1 = offsetof(struct thread_options, bs[DDIR_READ]),
2089 .off2 = offsetof(struct thread_options, bs[DDIR_WRITE]),
2090 .off3 = offsetof(struct thread_options, bs[DDIR_TRIM]),
c3edbdba 2091 .minval = 1,
214e1eca 2092 .help = "Block size unit",
2b9136a3 2093 .def = "4096",
67a1000f 2094 .parent = "rw",
d71c154c 2095 .hide = 1,
20eb06bd 2096 .interval = 512,
e8b0e958
JA		 2097 .category = FIO_OPT_C_IO,
2098 .group = FIO_OPT_G_INVALID,
214e1eca 2099 },
2b7a01d0
JA		 2100 {
2101 .name = "ba",
e8b0e958 2102 .lname = "Block size align",
2b7a01d0 2103 .alias = "blockalign",
5fff9543 2104 .type = FIO_OPT_ULL,
a609f12a
JA		 2105 .off1 = offsetof(struct thread_options, ba[DDIR_READ]),
2106 .off2 = offsetof(struct thread_options, ba[DDIR_WRITE]),
2107 .off3 = offsetof(struct thread_options, ba[DDIR_TRIM]),
2b7a01d0
JA		 2108 .minval = 1,
2109 .help = "IO block offset alignment",
2110 .parent = "rw",
d71c154c 2111 .hide = 1,
20eb06bd 2112 .interval = 512,
e8b0e958
JA		 2113 .category = FIO_OPT_C_IO,
2114 .group = FIO_OPT_G_INVALID,
2b7a01d0 2115 },
214e1eca
JA		 2116 {
2117 .name = "bsrange",
e8b0e958 2118 .lname = "Block size range",
d3aad8f2 2119 .alias = "blocksize_range",
214e1eca 2120 .type = FIO_OPT_RANGE,
a609f12a
JA		 2121 .off1 = offsetof(struct thread_options, min_bs[DDIR_READ]),
2122 .off2 = offsetof(struct thread_options, max_bs[DDIR_READ]),
2123 .off3 = offsetof(struct thread_options, min_bs[DDIR_WRITE]),
2124 .off4 = offsetof(struct thread_options, max_bs[DDIR_WRITE]),
2125 .off5 = offsetof(struct thread_options, min_bs[DDIR_TRIM]),
2126 .off6 = offsetof(struct thread_options, max_bs[DDIR_TRIM]),
c3edbdba 2127 .minval = 1,
214e1eca 2128 .help = "Set block size range (in more detail than bs)",
67a1000f 2129 .parent = "rw",
d71c154c 2130 .hide = 1,
20eb06bd 2131 .interval = 4096,
e8b0e958
JA		 2132 .category = FIO_OPT_C_IO,
2133 .group = FIO_OPT_G_INVALID,
214e1eca 2134 },
564ca972
JA		 2135 {
2136 .name = "bssplit",
e8b0e958 2137 .lname = "Block size split",
5fff9543 2138 .type = FIO_OPT_STR_ULL,
564ca972 2139 .cb = str_bssplit_cb,
a609f12a 2140 .off1 = offsetof(struct thread_options, bssplit),
564ca972
JA		 2141 .help = "Set a specific mix of block sizes",
2142 .parent = "rw",
d71c154c 2143 .hide = 1,
e8b0e958
JA		 2144 .category = FIO_OPT_C_IO,
2145 .group = FIO_OPT_G_INVALID,
564ca972 2146 },
214e1eca
JA		 2147 {
2148 .name = "bs_unaligned",
e8b0e958 2149 .lname = "Block size unaligned",
d3aad8f2 2150 .alias = "blocksize_unaligned",
214e1eca 2151 .type = FIO_OPT_STR_SET,
a609f12a 2152 .off1 = offsetof(struct thread_options, bs_unaligned),
214e1eca 2153 .help = "Don't sector align IO buffer sizes",
67a1000f 2154 .parent = "rw",
d71c154c 2155 .hide = 1,
e8b0e958
JA		 2156 .category = FIO_OPT_C_IO,
2157 .group = FIO_OPT_G_INVALID,
214e1eca 2158 },
6aca9b3d
JA		 2159 {
2160 .name = "bs_is_seq_rand",
2161 .lname = "Block size division is seq/random (not read/write)",
2162 .type = FIO_OPT_BOOL,
a609f12a 2163 .off1 = offsetof(struct thread_options, bs_is_seq_rand),
86d59660 2164 .help = "Consider any blocksize setting to be sequential,random",
6aca9b3d
JA		 2165 .def = "0",
2166 .parent = "blocksize",
2167 .category = FIO_OPT_C_IO,
2168 .group = FIO_OPT_G_INVALID,
2169 },
214e1eca
JA		 2170 {
2171 .name = "randrepeat",
e8b0e958 2172 .lname = "Random repeatable",
214e1eca 2173 .type = FIO_OPT_BOOL,
a609f12a 2174 .off1 = offsetof(struct thread_options, rand_repeatable),
214e1eca
JA		 2175 .help = "Use repeatable random IO pattern",
2176 .def = "1",
67a1000f 2177 .parent = "rw",
d71c154c 2178 .hide = 1,
e8b0e958 2179 .category = FIO_OPT_C_IO,
3ceb458f 2180 .group = FIO_OPT_G_RANDOM,
214e1eca 2181 },
04778baf
JA		 2182 {
2183 .name = "randseed",
2184 .lname = "The random generator seed",
363cffa7 2185 .type = FIO_OPT_STR_VAL,
a609f12a 2186 .off1 = offsetof(struct thread_options, rand_seed),
04778baf 2187 .help = "Set the random generator seed value",
40fe5e7b 2188 .def = "0x89",
04778baf
JA		 2189 .parent = "rw",
2190 .category = FIO_OPT_C_IO,
2191 .group = FIO_OPT_G_RANDOM,
2192 },
2615cc4b
JA		 2193 {
2194 .name = "use_os_rand",
e8b0e958 2195 .lname = "Use OS random",
54a21917 2196 .type = FIO_OPT_DEPRECATED,
a609f12a 2197 .off1 = offsetof(struct thread_options, dep_use_os_rand),
e8b0e958 2198 .category = FIO_OPT_C_IO,
3ceb458f 2199 .group = FIO_OPT_G_RANDOM,
2615cc4b 2200 },
214e1eca
JA		 2201 {
2202 .name = "norandommap",
e8b0e958 2203 .lname = "No randommap",
214e1eca 2204 .type = FIO_OPT_STR_SET,
a609f12a 2205 .off1 = offsetof(struct thread_options, norandommap),
214e1eca 2206 .help = "Accept potential duplicate random blocks",
67a1000f 2207 .parent = "rw",
d71c154c 2208 .hide = 1,
b2452a43 2209 .hide_on_set = 1,
e8b0e958 2210 .category = FIO_OPT_C_IO,
3ceb458f 2211 .group = FIO_OPT_G_RANDOM,
214e1eca 2212 },
2b386d25
JA		 2213 {
2214 .name = "softrandommap",
e8b0e958 2215 .lname = "Soft randommap",
2b386d25 2216 .type = FIO_OPT_BOOL,
a609f12a 2217 .off1 = offsetof(struct thread_options, softrandommap),
f66ab3c8 2218 .help = "Set norandommap if randommap allocation fails",
2b386d25 2219 .parent = "norandommap",
d71c154c 2220 .hide = 1,
2b386d25 2221 .def = "0",
e8b0e958 2222 .category = FIO_OPT_C_IO,
3ceb458f 2223 .group = FIO_OPT_G_RANDOM,
2b386d25 2224 },
8055e41d
JA		 2225 {
2226 .name = "random_generator",
cce2fdfe 2227 .lname = "Random Generator",
8055e41d 2228 .type = FIO_OPT_STR,
a609f12a 2229 .off1 = offsetof(struct thread_options, random_generator),
8055e41d
JA		 2230 .help = "Type of random number generator to use",
2231 .def = "tausworthe",
2232 .posval = {
2233 { .ival = "tausworthe",
2234 .oval = FIO_RAND_GEN_TAUSWORTHE,
2235 .help = "Strong Tausworthe generator",
2236 },
2237 { .ival = "lfsr",
2238 .oval = FIO_RAND_GEN_LFSR,
2239 .help = "Variable length LFSR",
2240 },
c3546b53
JA		 2241 {
2242 .ival = "tausworthe64",
2243 .oval = FIO_RAND_GEN_TAUSWORTHE64,
2244 .help = "64-bit Tausworthe variant",
2245 },
8055e41d 2246 },
48107598
JA		 2247 .category = FIO_OPT_C_IO,
2248 .group = FIO_OPT_G_RANDOM,
8055e41d 2249 },
e25839d4
JA		 2250 {
2251 .name = "random_distribution",
cce2fdfe 2252 .lname = "Random Distribution",
e25839d4 2253 .type = FIO_OPT_STR,
a609f12a 2254 .off1 = offsetof(struct thread_options, random_distribution),
e25839d4
JA		 2255 .cb = str_random_distribution_cb,
2256 .help = "Random offset distribution generator",
2257 .def = "random",
2258 .posval = {
2259 { .ival = "random",
2260 .oval = FIO_RAND_DIST_RANDOM,
2261 .help = "Completely random",
2262 },
2263 { .ival = "zipf",
2264 .oval = FIO_RAND_DIST_ZIPF,
2265 .help = "Zipf distribution",
2266 },
925fee33
JA		 2267 { .ival = "pareto",
2268 .oval = FIO_RAND_DIST_PARETO,
2269 .help = "Pareto distribution",
2270 },
56d9fa4b
JA		 2271 { .ival = "normal",
2272 .oval = FIO_RAND_DIST_GAUSS,
ba2b3b07 2273 .help = "Normal (Gaussian) distribution",
56d9fa4b 2274 },
e0a04ac1
JA		 2275 { .ival = "zoned",
2276 .oval = FIO_RAND_DIST_ZONED,
2277 .help = "Zoned random distribution",
2278 },
59466396
JA		 2279 { .ival = "zoned_abs",
2280 .oval = FIO_RAND_DIST_ZONED_ABS,
2281 .help = "Zoned absolute random distribution",
2282 },
e25839d4 2283 },
48107598
JA		 2284 .category = FIO_OPT_C_IO,
2285 .group = FIO_OPT_G_RANDOM,
e25839d4 2286 },
211c9b89
JA		 2287 {
2288 .name = "percentage_random",
2289 .lname = "Percentage Random",
2290 .type = FIO_OPT_INT,
a609f12a
JA		 2291 .off1 = offsetof(struct thread_options, perc_rand[DDIR_READ]),
2292 .off2 = offsetof(struct thread_options, perc_rand[DDIR_WRITE]),
2293 .off3 = offsetof(struct thread_options, perc_rand[DDIR_TRIM]),
211c9b89
JA		 2294 .maxval = 100,
2295 .help = "Percentage of seq/random mix that should be random",
d9472271 2296 .def = "100,100,100",
211c9b89
JA		 2297 .interval = 5,
2298 .inverse = "percentage_sequential",
2299 .category = FIO_OPT_C_IO,
2300 .group = FIO_OPT_G_RANDOM,
2301 },
2302 {
2303 .name = "percentage_sequential",
2304 .lname = "Percentage Sequential",
d9472271 2305 .type = FIO_OPT_DEPRECATED,
211c9b89
JA		 2306 .category = FIO_OPT_C_IO,
2307 .group = FIO_OPT_G_RANDOM,
2308 },
56e2a5fc
CE		 2309 {
2310 .name = "allrandrepeat",
cce2fdfe 2311 .lname = "All Random Repeat",
56e2a5fc 2312 .type = FIO_OPT_BOOL,
a609f12a 2313 .off1 = offsetof(struct thread_options, allrand_repeatable),
56e2a5fc
CE		 2314 .help = "Use repeatable random numbers for everything",
2315 .def = "0",
a869d9c6
JA		 2316 .category = FIO_OPT_C_IO,
2317 .group = FIO_OPT_G_RANDOM,
56e2a5fc 2318 },
214e1eca
JA		 2319 {
2320 .name = "nrfiles",
e8b0e958 2321 .lname = "Number of files",
d7c8be03 2322 .alias = "nr_files",
214e1eca 2323 .type = FIO_OPT_INT,
a609f12a 2324 .off1 = offsetof(struct thread_options, nr_files),
214e1eca
JA		 2325 .help = "Split job workload between this number of files",
2326 .def = "1",
20eb06bd 2327 .interval = 1,
e8b0e958
JA		 2328 .category = FIO_OPT_C_FILE,
2329 .group = FIO_OPT_G_INVALID,
214e1eca
JA		 2330 },
2331 {
2332 .name = "openfiles",
e8b0e958 2333 .lname = "Number of open files",
214e1eca 2334 .type = FIO_OPT_INT,
a609f12a 2335 .off1 = offsetof(struct thread_options, open_files),
214e1eca 2336 .help = "Number of files to keep open at the same time",
e8b0e958
JA		 2337 .category = FIO_OPT_C_FILE,
2338 .group = FIO_OPT_G_INVALID,
214e1eca
JA		 2339 },
2340 {
2341 .name = "file_service_type",
e8b0e958 2342 .lname = "File service type",
214e1eca
JA		 2343 .type = FIO_OPT_STR,
2344 .cb = str_fst_cb,
a609f12a 2345 .off1 = offsetof(struct thread_options, file_service_type),
214e1eca
JA		 2346 .help = "How to select which file to service next",
2347 .def = "roundrobin",
e8b0e958
JA		 2348 .category = FIO_OPT_C_FILE,
2349 .group = FIO_OPT_G_INVALID,
214e1eca
JA		 2350 .posval = {
2351 { .ival = "random",
2352 .oval = FIO_FSERVICE_RANDOM,
8c07860d
JA		 2353 .help = "Choose a file at random (uniform)",
2354 },
2355 { .ival = "zipf",
2356 .oval = FIO_FSERVICE_ZIPF,
2357 .help = "Zipf randomized",
2358 },
2359 { .ival = "pareto",
2360 .oval = FIO_FSERVICE_PARETO,
2361 .help = "Pareto randomized",
2362 },
dd3503d3
SW		 2363 { .ival = "normal",
2364 .oval = FIO_FSERVICE_GAUSS,
2365 .help = "Normal (Gaussian) randomized",
2366 },
8c07860d
JA		 2367 { .ival = "gauss",
2368 .oval = FIO_FSERVICE_GAUSS,
dd3503d3 2369 .help = "Alias for normal",
214e1eca
JA		 2370 },
2371 { .ival = "roundrobin",
2372 .oval = FIO_FSERVICE_RR,
2373 .help = "Round robin select files",
2374 },
a086c257
JA		 2375 { .ival = "sequential",
2376 .oval = FIO_FSERVICE_SEQ,
2377 .help = "Finish one file before moving to the next",
2378 },
214e1eca 2379 },
67a1000f 2380 .parent = "nrfiles",
d71c154c 2381 .hide = 1,
67a1000f 2382 },
cbbdf1c8 2383#ifdef FIO_HAVE_ANY_FALLOCATE
7bc8c2cf
JA		 2384 {
2385 .name = "fallocate",
e8b0e958 2386 .lname = "Fallocate",
a596f047 2387 .type = FIO_OPT_STR,
a609f12a 2388 .off1 = offsetof(struct thread_options, fallocate_mode),
a596f047 2389 .help = "Whether pre-allocation is performed when laying out files",
2c3e17be 2390 .def = "native",
e8b0e958
JA		 2391 .category = FIO_OPT_C_FILE,
2392 .group = FIO_OPT_G_INVALID,
a596f047
EG		 2393 .posval = {
2394 { .ival = "none",
2395 .oval = FIO_FALLOCATE_NONE,
2396 .help = "Do not pre-allocate space",
2397 },
2c3e17be
SW		 2398 { .ival = "native",
2399 .oval = FIO_FALLOCATE_NATIVE,
2400 .help = "Use native pre-allocation if possible",
2401 },
2402#ifdef CONFIG_POSIX_FALLOCATE
a596f047
EG		 2403 { .ival = "posix",
2404 .oval = FIO_FALLOCATE_POSIX,
2405 .help = "Use posix_fallocate()",
2406 },
2c3e17be 2407#endif
97ac992c 2408#ifdef CONFIG_LINUX_FALLOCATE
a596f047
EG		 2409 { .ival = "keep",
2410 .oval = FIO_FALLOCATE_KEEP_SIZE,
2411 .help = "Use fallocate(..., FALLOC_FL_KEEP_SIZE, ...)",
2412 },
7bc8c2cf 2413#endif
a596f047
EG		 2414 /* Compatibility with former boolean values */
2415 { .ival = "0",
2416 .oval = FIO_FALLOCATE_NONE,
2417 .help = "Alias for 'none'",
2418 },
2c3e17be 2419#ifdef CONFIG_POSIX_FALLOCATE
a596f047
EG		 2420 { .ival = "1",
2421 .oval = FIO_FALLOCATE_POSIX,
2422 .help = "Alias for 'posix'",
2423 },
2c3e17be 2424#endif
a596f047
EG		 2425 },
2426 },
cbbdf1c8 2427#else /* FIO_HAVE_ANY_FALLOCATE */
a275c37a
JA		 2428 {
2429 .name = "fallocate",
2430 .lname = "Fallocate",
2431 .type = FIO_OPT_UNSUPPORTED,
2432 .help = "Your platform does not support fallocate",
2433 },
cbbdf1c8 2434#endif /* FIO_HAVE_ANY_FALLOCATE */
67a1000f
JA		 2435 {
2436 .name = "fadvise_hint",
e8b0e958 2437 .lname = "Fadvise hint",
ecb2083d 2438 .type = FIO_OPT_STR,
a609f12a 2439 .off1 = offsetof(struct thread_options, fadvise_hint),
ecb2083d
JA		 2440 .posval = {
2441 { .ival = "0",
2442 .oval = F_ADV_NONE,
c712c97a 2443 .help = "Don't issue fadvise/madvise",
ecb2083d
JA		 2444 },
2445 { .ival = "1",
2446 .oval = F_ADV_TYPE,
2447 .help = "Advise using fio IO pattern",
2448 },
2449 { .ival = "random",
2450 .oval = F_ADV_RANDOM,
2451 .help = "Advise using FADV_RANDOM",
2452 },
2453 { .ival = "sequential",
2454 .oval = F_ADV_SEQUENTIAL,
2455 .help = "Advise using FADV_SEQUENTIAL",
2456 },
2457 },
67a1000f
JA		 2458 .help = "Use fadvise() to advise the kernel on IO pattern",
2459 .def = "1",
e8b0e958
JA		 2460 .category = FIO_OPT_C_FILE,
2461 .group = FIO_OPT_G_INVALID,
214e1eca
JA		 2462 },
2463 {
2464 .name = "fsync",
e8b0e958 2465 .lname = "Fsync",
214e1eca 2466 .type = FIO_OPT_INT,
a609f12a 2467 .off1 = offsetof(struct thread_options, fsync_blocks),
214e1eca
JA		 2468 .help = "Issue fsync for writes every given number of blocks",
2469 .def = "0",
20eb06bd 2470 .interval = 1,
e8b0e958
JA		 2471 .category = FIO_OPT_C_FILE,
2472 .group = FIO_OPT_G_INVALID,
214e1eca 2473 },
5f9099ea
JA		 2474 {
2475 .name = "fdatasync",
e8b0e958 2476 .lname = "Fdatasync",
5f9099ea 2477 .type = FIO_OPT_INT,
a609f12a 2478 .off1 = offsetof(struct thread_options, fdatasync_blocks),
5f9099ea
JA		 2479 .help = "Issue fdatasync for writes every given number of blocks",
2480 .def = "0",
20eb06bd 2481 .interval = 1,
e8b0e958
JA		 2482 .category = FIO_OPT_C_FILE,
2483 .group = FIO_OPT_G_INVALID,
5f9099ea 2484 },
1ef2b6be
JA		 2485 {
2486 .name = "write_barrier",
e8b0e958 2487 .lname = "Write barrier",
1ef2b6be 2488 .type = FIO_OPT_INT,
a609f12a 2489 .off1 = offsetof(struct thread_options, barrier_blocks),
1ef2b6be
JA		 2490 .help = "Make every Nth write a barrier write",
2491 .def = "0",
20eb06bd 2492 .interval = 1,
e8b0e958
JA		 2493 .category = FIO_OPT_C_IO,
2494 .group = FIO_OPT_G_INVALID,
1ef2b6be 2495 },
67bf9823 2496#ifdef CONFIG_SYNC_FILE_RANGE
44f29692
JA		 2497 {
2498 .name = "sync_file_range",
e8b0e958 2499 .lname = "Sync file range",
44f29692
JA		 2500 .posval = {
2501 { .ival = "wait_before",
2502 .oval = SYNC_FILE_RANGE_WAIT_BEFORE,
2503 .help = "SYNC_FILE_RANGE_WAIT_BEFORE",
ebadc0ce 2504 .orval = 1,
44f29692
JA		 2505 },
2506 { .ival = "write",
2507 .oval = SYNC_FILE_RANGE_WRITE,
2508 .help = "SYNC_FILE_RANGE_WRITE",
ebadc0ce 2509 .orval = 1,
44f29692
JA		 2510 },
2511 {
2512 .ival = "wait_after",
2513 .oval = SYNC_FILE_RANGE_WAIT_AFTER,
2514 .help = "SYNC_FILE_RANGE_WAIT_AFTER",
ebadc0ce 2515 .orval = 1,
44f29692
JA		 2516 },
2517 },
3843deb3 2518 .type = FIO_OPT_STR_MULTI,
44f29692 2519 .cb = str_sfr_cb,
a609f12a 2520 .off1 = offsetof(struct thread_options, sync_file_range),
44f29692 2521 .help = "Use sync_file_range()",
e8b0e958
JA		 2522 .category = FIO_OPT_C_FILE,
2523 .group = FIO_OPT_G_INVALID,
44f29692 2524 },
a275c37a 2525#else
54d0a315 2526 {
a275c37a
JA		 2527 .name = "sync_file_range",
2528 .lname = "Sync file range",
2529 .type = FIO_OPT_UNSUPPORTED,
2530 .help = "Your platform does not support sync_file_range",
2531 },
44f29692 2532#endif
214e1eca
JA		 2533 {
2534 .name = "direct",
e8b0e958 2535 .lname = "Direct I/O",
214e1eca 2536 .type = FIO_OPT_BOOL,
a609f12a 2537 .off1 = offsetof(struct thread_options, odirect),
214e1eca
JA		 2538 .help = "Use O_DIRECT IO (negates buffered)",
2539 .def = "0",
a01a1bc5 2540 .inverse = "buffered",
e8b0e958 2541 .category = FIO_OPT_C_IO,
3ceb458f 2542 .group = FIO_OPT_G_IO_TYPE,
214e1eca 2543 },
d01612f3
CM		 2544 {
2545 .name = "atomic",
2546 .lname = "Atomic I/O",
2547 .type = FIO_OPT_BOOL,
a609f12a 2548 .off1 = offsetof(struct thread_options, oatomic),
d01612f3
CM		 2549 .help = "Use Atomic IO with O_DIRECT (implies O_DIRECT)",
2550 .def = "0",
2551 .category = FIO_OPT_C_IO,
2552 .group = FIO_OPT_G_IO_TYPE,
2553 },
214e1eca
JA		 2554 {
2555 .name = "buffered",
e8b0e958 2556 .lname = "Buffered I/O",
214e1eca 2557 .type = FIO_OPT_BOOL,
a609f12a 2558 .off1 = offsetof(struct thread_options, odirect),
214e1eca
JA		 2559 .neg = 1,
2560 .help = "Use buffered IO (negates direct)",
2561 .def = "1",
a01a1bc5 2562 .inverse = "direct",
e8b0e958 2563 .category = FIO_OPT_C_IO,
3ceb458f 2564 .group = FIO_OPT_G_IO_TYPE,
214e1eca
JA		 2565 },
2566 {
2567 .name = "overwrite",
e8b0e958 2568 .lname = "Overwrite",
214e1eca 2569 .type = FIO_OPT_BOOL,
a609f12a 2570 .off1 = offsetof(struct thread_options, overwrite),
214e1eca
JA		 2571 .help = "When writing, set whether to overwrite current data",
2572 .def = "0",
e8b0e958
JA		 2573 .category = FIO_OPT_C_FILE,
2574 .group = FIO_OPT_G_INVALID,
214e1eca
JA		 2575 },
2576 {
2577 .name = "loops",
e8b0e958 2578 .lname = "Loops",
214e1eca 2579 .type = FIO_OPT_INT,
a609f12a 2580 .off1 = offsetof(struct thread_options, loops),
214e1eca
JA		 2581 .help = "Number of times to run the job",
2582 .def = "1",
20eb06bd 2583 .interval = 1,
e8b0e958 2584 .category = FIO_OPT_C_GENERAL,
a1f6afec 2585 .group = FIO_OPT_G_RUNTIME,
214e1eca
JA		 2586 },
2587 {
2588 .name = "numjobs",
e8b0e958 2589 .lname = "Number of jobs",
214e1eca 2590 .type = FIO_OPT_INT,
a609f12a 2591 .off1 = offsetof(struct thread_options, numjobs),
214e1eca
JA		 2592 .help = "Duplicate this job this many times",
2593 .def = "1",
20eb06bd 2594 .interval = 1,
e8b0e958 2595 .category = FIO_OPT_C_GENERAL,
a1f6afec 2596 .group = FIO_OPT_G_RUNTIME,
214e1eca
JA		 2597 },
2598 {
2599 .name = "startdelay",
e8b0e958 2600 .lname = "Start delay",
a5737c93 2601 .type = FIO_OPT_STR_VAL_TIME,
a609f12a
JA		 2602 .off1 = offsetof(struct thread_options, start_delay),
2603 .off2 = offsetof(struct thread_options, start_delay_high),
214e1eca
JA		 2604 .help = "Only start job when this period has passed",
2605 .def = "0",
0de5b26f 2606 .is_seconds = 1,
88038bc7 2607 .is_time = 1,
e8b0e958 2608 .category = FIO_OPT_C_GENERAL,
a1f6afec 2609 .group = FIO_OPT_G_RUNTIME,
214e1eca
JA		 2610 },
2611 {
2612 .name = "runtime",
e8b0e958 2613 .lname = "Runtime",
214e1eca
JA		 2614 .alias = "timeout",
2615 .type = FIO_OPT_STR_VAL_TIME,
a609f12a 2616 .off1 = offsetof(struct thread_options, timeout),
214e1eca
JA		 2617 .help = "Stop workload when this amount of time has passed",
2618 .def = "0",
0de5b26f 2619 .is_seconds = 1,
88038bc7 2620 .is_time = 1,
e8b0e958 2621 .category = FIO_OPT_C_GENERAL,
a1f6afec 2622 .group = FIO_OPT_G_RUNTIME,
214e1eca 2623 },
cf4464ca
JA		 2624 {
2625 .name = "time_based",
e8b0e958 2626 .lname = "Time based",
cf4464ca 2627 .type = FIO_OPT_STR_SET,
a609f12a 2628 .off1 = offsetof(struct thread_options, time_based),
cf4464ca 2629 .help = "Keep running until runtime/timeout is met",
e8b0e958 2630 .category = FIO_OPT_C_GENERAL,
a1f6afec 2631 .group = FIO_OPT_G_RUNTIME,
cf4464ca 2632 },
62167762
JC		 2633 {
2634 .name = "verify_only",
2635 .lname = "Verify only",
2636 .type = FIO_OPT_STR_SET,
a609f12a 2637 .off1 = offsetof(struct thread_options, verify_only),
62167762
JC		 2638 .help = "Verifies previously written data is still valid",
2639 .category = FIO_OPT_C_GENERAL,
2640 .group = FIO_OPT_G_RUNTIME,
2641 },
721938ae
JA		 2642 {
2643 .name = "ramp_time",
e8b0e958 2644 .lname = "Ramp time",
721938ae 2645 .type = FIO_OPT_STR_VAL_TIME,
a609f12a 2646 .off1 = offsetof(struct thread_options, ramp_time),
721938ae 2647 .help = "Ramp up time before measuring performance",
0de5b26f 2648 .is_seconds = 1,
88038bc7 2649 .is_time = 1,
e8b0e958 2650 .category = FIO_OPT_C_GENERAL,
a1f6afec 2651 .group = FIO_OPT_G_RUNTIME,
721938ae 2652 },
c223da83
JA		 2653 {
2654 .name = "clocksource",
e8b0e958 2655 .lname = "Clock source",
c223da83
JA		 2656 .type = FIO_OPT_STR,
2657 .cb = fio_clock_source_cb,
a609f12a 2658 .off1 = offsetof(struct thread_options, clocksource),
c223da83 2659 .help = "What type of timing source to use",
e8b0e958 2660 .category = FIO_OPT_C_GENERAL,
10860056 2661 .group = FIO_OPT_G_CLOCK,
c223da83 2662 .posval = {
67bf9823 2663#ifdef CONFIG_GETTIMEOFDAY
c223da83
JA		 2664 { .ival = "gettimeofday",
2665 .oval = CS_GTOD,
2666 .help = "Use gettimeofday(2) for timing",
2667 },
67bf9823
JA		 2668#endif
2669#ifdef CONFIG_CLOCK_GETTIME
c223da83
JA		 2670 { .ival = "clock_gettime",
2671 .oval = CS_CGETTIME,
2672 .help = "Use clock_gettime(2) for timing",
2673 },
67bf9823 2674#endif
c223da83
JA		 2675#ifdef ARCH_HAVE_CPU_CLOCK
2676 { .ival = "cpu",
2677 .oval = CS_CPUCLOCK,
2678 .help = "Use CPU private clock",
2679 },
2680#endif
2681 },
2682 },
214e1eca
JA		 2683 {
2684 .name = "mem",
d3aad8f2 2685 .alias = "iomem",
e8b0e958 2686 .lname = "I/O Memory",
214e1eca
JA		 2687 .type = FIO_OPT_STR,
2688 .cb = str_mem_cb,
a609f12a 2689 .off1 = offsetof(struct thread_options, mem_type),
214e1eca
JA		 2690 .help = "Backing type for IO buffers",
2691 .def = "malloc",
e8b0e958
JA		 2692 .category = FIO_OPT_C_IO,
2693 .group = FIO_OPT_G_INVALID,
214e1eca
JA		 2694 .posval = {
2695 { .ival = "malloc",
2696 .oval = MEM_MALLOC,
2697 .help = "Use malloc(3) for IO buffers",
2698 },
c8931876 2699#ifndef CONFIG_NO_SHM
37c8cdfe
JA		 2700 { .ival = "shm",
2701 .oval = MEM_SHM,
2702 .help = "Use shared memory segments for IO buffers",
2703 },
214e1eca
JA		 2704#ifdef FIO_HAVE_HUGETLB
2705 { .ival = "shmhuge",
2706 .oval = MEM_SHMHUGE,
2707 .help = "Like shm, but use huge pages",
2708 },
c8931876 2709#endif
b370e46a 2710#endif
37c8cdfe
JA		 2711 { .ival = "mmap",
2712 .oval = MEM_MMAP,
2713 .help = "Use mmap(2) (file or anon) for IO buffers",
2714 },
217b0f1d
LG		 2715 { .ival = "mmapshared",
2716 .oval = MEM_MMAPSHARED,
2717 .help = "Like mmap, but use the shared flag",
2718 },
214e1eca
JA		 2719#ifdef FIO_HAVE_HUGETLB
2720 { .ival = "mmaphuge",
2721 .oval = MEM_MMAPHUGE,
2722 .help = "Like mmap, but use huge pages",
2723 },
03553853
YR		 2724#endif
2725#ifdef CONFIG_CUDA
2726 { .ival = "cudamalloc",
2727 .oval = MEM_CUDA_MALLOC,
2728 .help = "Allocate GPU device memory for GPUDirect RDMA",
2729 },
214e1eca
JA		 2730#endif
2731 },
2732 },
d529ee19
JA		 2733 {
2734 .name = "iomem_align",
2735 .alias = "mem_align",
e8b0e958 2736 .lname = "I/O memory alignment",
d529ee19 2737 .type = FIO_OPT_INT,
a609f12a 2738 .off1 = offsetof(struct thread_options, mem_align),
d529ee19
JA		 2739 .minval = 0,
2740 .help = "IO memory buffer offset alignment",
2741 .def = "0",
2742 .parent = "iomem",
d71c154c 2743 .hide = 1,
e8b0e958
JA		 2744 .category = FIO_OPT_C_IO,
2745 .group = FIO_OPT_G_INVALID,
d529ee19 2746 },
214e1eca
JA		 2747 {
2748 .name = "verify",
e8b0e958 2749 .lname = "Verify",
214e1eca 2750 .type = FIO_OPT_STR,
a609f12a 2751 .off1 = offsetof(struct thread_options, verify),
214e1eca
JA		 2752 .help = "Verify data written",
2753 .def = "0",
e8b0e958 2754 .category = FIO_OPT_C_IO,
3ceb458f 2755 .group = FIO_OPT_G_VERIFY,
214e1eca
JA		 2756 .posval = {
2757 { .ival = "0",
2758 .oval = VERIFY_NONE,
2759 .help = "Don't do IO verification",
2760 },
fcca4b58
JA		 2761 { .ival = "md5",
2762 .oval = VERIFY_MD5,
2763 .help = "Use md5 checksums for verification",
2764 },
d77a7af3
JA		 2765 { .ival = "crc64",
2766 .oval = VERIFY_CRC64,
2767 .help = "Use crc64 checksums for verification",
2768 },
214e1eca
JA		 2769 { .ival = "crc32",
2770 .oval = VERIFY_CRC32,
2771 .help = "Use crc32 checksums for verification",
2772 },
af497e6a 2773 { .ival = "crc32c-intel",
e3aaafc4
JA		 2774 .oval = VERIFY_CRC32C,
2775 .help = "Use crc32c checksums for verification (hw assisted, if available)",
af497e6a 2776 },
bac39e0e
JA		 2777 { .ival = "crc32c",
2778 .oval = VERIFY_CRC32C,
e3aaafc4 2779 .help = "Use crc32c checksums for verification (hw assisted, if available)",
bac39e0e 2780 },
969f7ed3
JA		 2781 { .ival = "crc16",
2782 .oval = VERIFY_CRC16,
2783 .help = "Use crc16 checksums for verification",
2784 },
1e154bdb
JA		 2785 { .ival = "crc7",
2786 .oval = VERIFY_CRC7,
2787 .help = "Use crc7 checksums for verification",
2788 },
7c353ceb
JA		 2789 { .ival = "sha1",
2790 .oval = VERIFY_SHA1,
2791 .help = "Use sha1 checksums for verification",
2792 },
cd14cc10
JA		 2793 { .ival = "sha256",
2794 .oval = VERIFY_SHA256,
2795 .help = "Use sha256 checksums for verification",
2796 },
2797 { .ival = "sha512",
2798 .oval = VERIFY_SHA512,
2799 .help = "Use sha512 checksums for verification",
ae3a5acc
JA		 2800 },
2801 { .ival = "sha3-224",
2802 .oval = VERIFY_SHA3_224,
2803 .help = "Use sha3-224 checksums for verification",
2804 },
2805 { .ival = "sha3-256",
2806 .oval = VERIFY_SHA3_256,
2807 .help = "Use sha3-256 checksums for verification",
2808 },
2809 { .ival = "sha3-384",
2810 .oval = VERIFY_SHA3_384,
2811 .help = "Use sha3-384 checksums for verification",
2812 },
2813 { .ival = "sha3-512",
2814 .oval = VERIFY_SHA3_512,
2815 .help = "Use sha3-512 checksums for verification",
cd14cc10 2816 },
844ea602
JA		 2817 { .ival = "xxhash",
2818 .oval = VERIFY_XXHASH,
2819 .help = "Use xxhash checksums for verification",
2820 },
b638d82f
RP		 2821 /* Meta information was included into verify_header,
2822 * 'meta' verification is implied by default. */
7437ee87 2823 { .ival = "meta",
b638d82f
RP		 2824 .oval = VERIFY_HDR_ONLY,
2825 .help = "Use io information for verification. "
2826 "Now is implied by default, thus option is obsolete, "
2827 "don't use it",
7437ee87 2828 },
59245381
JA		 2829 { .ival = "pattern",
2830 .oval = VERIFY_PATTERN_NO_HDR,
2831 .help = "Verify strict pattern",
2832 },
36690c9b
JA		 2833 {
2834 .ival = "null",
2835 .oval = VERIFY_NULL,
2836 .help = "Pretend to verify",
2837 },
214e1eca
JA		 2838 },
2839 },
005c565a
JA		 2840 {
2841 .name = "do_verify",
e8b0e958 2842 .lname = "Perform verify step",
68e1f29a 2843 .type = FIO_OPT_BOOL,
a609f12a 2844 .off1 = offsetof(struct thread_options, do_verify),
005c565a
JA		 2845 .help = "Run verification stage after write",
2846 .def = "1",
2847 .parent = "verify",
d71c154c 2848 .hide = 1,
e8b0e958
JA		 2849 .category = FIO_OPT_C_IO,
2850 .group = FIO_OPT_G_VERIFY,
005c565a 2851 },
160b966d
JA		 2852 {
2853 .name = "verifysort",
e8b0e958 2854 .lname = "Verify sort",
f31feaa2 2855 .type = FIO_OPT_SOFT_DEPRECATED,
e8b0e958
JA		 2856 .category = FIO_OPT_C_IO,
2857 .group = FIO_OPT_G_VERIFY,
160b966d 2858 },
1ae83d45
JA		 2859 {
2860 .name = "verifysort_nr",
cce2fdfe 2861 .lname = "Verify Sort Nr",
f31feaa2 2862 .type = FIO_OPT_SOFT_DEPRECATED,
836fcc0f
JA		 2863 .category = FIO_OPT_C_IO,
2864 .group = FIO_OPT_G_VERIFY,
1ae83d45 2865 },
3f9f4e26 2866 {
a59e170d 2867 .name = "verify_interval",
e8b0e958 2868 .lname = "Verify interval",
e01b22b8 2869 .type = FIO_OPT_INT,
a609f12a 2870 .off1 = offsetof(struct thread_options, verify_interval),
819a9680 2871 .minval = 2 * sizeof(struct verify_header),
a59e170d 2872 .help = "Store verify buffer header every N bytes",
afdf9352 2873 .parent = "verify",
d71c154c 2874 .hide = 1,
20eb06bd 2875 .interval = 2 * sizeof(struct verify_header),
e8b0e958
JA		 2876 .category = FIO_OPT_C_IO,
2877 .group = FIO_OPT_G_VERIFY,
3f9f4e26 2878 },
546a9142 2879 {
a59e170d 2880 .name = "verify_offset",
e8b0e958 2881 .lname = "Verify offset",
e01b22b8 2882 .type = FIO_OPT_INT,
a59e170d 2883 .help = "Offset verify header location by N bytes",
a609f12a 2884 .off1 = offsetof(struct thread_options, verify_offset),
203160d5 2885 .minval = sizeof(struct verify_header),
afdf9352 2886 .parent = "verify",
d71c154c 2887 .hide = 1,
e8b0e958
JA		 2888 .category = FIO_OPT_C_IO,
2889 .group = FIO_OPT_G_VERIFY,
546a9142 2890 },
e28218f3
SL		 2891 {
2892 .name = "verify_pattern",
e8b0e958 2893 .lname = "Verify pattern",
0e92f873 2894 .type = FIO_OPT_STR,
e28218f3 2895 .cb = str_verify_pattern_cb,
a609f12a 2896 .off1 = offsetof(struct thread_options, verify_pattern),
e28218f3
SL		 2897 .help = "Fill pattern for IO buffers",
2898 .parent = "verify",
d71c154c 2899 .hide = 1,
e8b0e958
JA		 2900 .category = FIO_OPT_C_IO,
2901 .group = FIO_OPT_G_VERIFY,
e28218f3 2902 },
a12a3b4d
JA		 2903 {
2904 .name = "verify_fatal",
e8b0e958 2905 .lname = "Verify fatal",
68e1f29a 2906 .type = FIO_OPT_BOOL,
a609f12a 2907 .off1 = offsetof(struct thread_options, verify_fatal),
a12a3b4d
JA		 2908 .def = "0",
2909 .help = "Exit on a single verify failure, don't continue",
2910 .parent = "verify",
d71c154c 2911 .hide = 1,
e8b0e958
JA		 2912 .category = FIO_OPT_C_IO,
2913 .group = FIO_OPT_G_VERIFY,
a12a3b4d 2914 },
b463e936
JA		 2915 {
2916 .name = "verify_dump",
e8b0e958 2917 .lname = "Verify dump",
b463e936 2918 .type = FIO_OPT_BOOL,
a609f12a 2919 .off1 = offsetof(struct thread_options, verify_dump),
ef71e317 2920 .def = "0",
b463e936
JA		 2921 .help = "Dump contents of good and bad blocks on failure",
2922 .parent = "verify",
d71c154c 2923 .hide = 1,
e8b0e958
JA		 2924 .category = FIO_OPT_C_IO,
2925 .group = FIO_OPT_G_VERIFY,
b463e936 2926 },
e8462bd8
JA		 2927 {
2928 .name = "verify_async",
e8b0e958 2929 .lname = "Verify asynchronously",
e8462bd8 2930 .type = FIO_OPT_INT,
a609f12a 2931 .off1 = offsetof(struct thread_options, verify_async),
e8462bd8
JA		 2932 .def = "0",
2933 .help = "Number of async verifier threads to use",
2934 .parent = "verify",
d71c154c 2935 .hide = 1,
e8b0e958
JA		 2936 .category = FIO_OPT_C_IO,
2937 .group = FIO_OPT_G_VERIFY,
e8462bd8 2938 },
9e144189
JA		 2939 {
2940 .name = "verify_backlog",
e8b0e958 2941 .lname = "Verify backlog",
9e144189 2942 .type = FIO_OPT_STR_VAL,
a609f12a 2943 .off1 = offsetof(struct thread_options, verify_backlog),
9e144189
JA		 2944 .help = "Verify after this number of blocks are written",
2945 .parent = "verify",
d71c154c 2946 .hide = 1,
e8b0e958
JA		 2947 .category = FIO_OPT_C_IO,
2948 .group = FIO_OPT_G_VERIFY,
9e144189
JA		 2949 },
2950 {
2951 .name = "verify_backlog_batch",
e8b0e958 2952 .lname = "Verify backlog batch",
9e144189 2953 .type = FIO_OPT_INT,
a609f12a 2954 .off1 = offsetof(struct thread_options, verify_batch),
9e144189 2955 .help = "Verify this number of IO blocks",
0d29de83 2956 .parent = "verify",
d71c154c 2957 .hide = 1,
e8b0e958
JA		 2958 .category = FIO_OPT_C_IO,
2959 .group = FIO_OPT_G_VERIFY,
9e144189 2960 },
e8462bd8
JA		 2961#ifdef FIO_HAVE_CPU_AFFINITY
2962 {
2963 .name = "verify_async_cpus",
e8b0e958 2964 .lname = "Async verify CPUs",
e8462bd8
JA		 2965 .type = FIO_OPT_STR,
2966 .cb = str_verify_cpus_allowed_cb,
a609f12a 2967 .off1 = offsetof(struct thread_options, verify_cpumask),
e8462bd8
JA		 2968 .help = "Set CPUs allowed for async verify threads",
2969 .parent = "verify_async",
d71c154c 2970 .hide = 1,
e8b0e958
JA		 2971 .category = FIO_OPT_C_IO,
2972 .group = FIO_OPT_G_VERIFY,
e8462bd8 2973 },
a275c37a
JA		 2974#else
2975 {
2976 .name = "verify_async_cpus",
2977 .lname = "Async verify CPUs",
2978 .type = FIO_OPT_UNSUPPORTED,
54d0a315 2979 .help = "Your platform does not support CPU affinities",
a275c37a 2980 },
0d29de83 2981#endif
51aa2da8
JA		 2982 {
2983 .name = "experimental_verify",
cce2fdfe 2984 .lname = "Experimental Verify",
a609f12a 2985 .off1 = offsetof(struct thread_options, experimental_verify),
51aa2da8 2986 .type = FIO_OPT_BOOL,
b31eaac9 2987 .help = "Enable experimental verification",
ca09be4b
JA		 2988 .parent = "verify",
2989 .category = FIO_OPT_C_IO,
2990 .group = FIO_OPT_G_VERIFY,
2991 },
2992 {
2993 .name = "verify_state_load",
2994 .lname = "Load verify state",
a609f12a 2995 .off1 = offsetof(struct thread_options, verify_state),
ca09be4b
JA		 2996 .type = FIO_OPT_BOOL,
2997 .help = "Load verify termination state",
2998 .parent = "verify",
2999 .category = FIO_OPT_C_IO,
3000 .group = FIO_OPT_G_VERIFY,
3001 },
3002 {
3003 .name = "verify_state_save",
3004 .lname = "Save verify state",
a609f12a 3005 .off1 = offsetof(struct thread_options, verify_state_save),
ca09be4b
JA		 3006 .type = FIO_OPT_BOOL,
3007 .def = "1",
3008 .help = "Save verify state on termination",
3009 .parent = "verify",
836fcc0f
JA		 3010 .category = FIO_OPT_C_IO,
3011 .group = FIO_OPT_G_VERIFY,
51aa2da8 3012 },
0d29de83
JA		 3013#ifdef FIO_HAVE_TRIM
3014 {
3015 .name = "trim_percentage",
e8b0e958 3016 .lname = "Trim percentage",
0d29de83 3017 .type = FIO_OPT_INT,
a609f12a 3018 .off1 = offsetof(struct thread_options, trim_percentage),
20eb06bd 3019 .minval = 0,
0d29de83 3020 .maxval = 100,
169c098d 3021 .help = "Number of verify blocks to trim (i.e., discard)",
0d29de83
JA		 3022 .parent = "verify",
3023 .def = "0",
20eb06bd 3024 .interval = 1,
d71c154c 3025 .hide = 1,
e8b0e958
JA		 3026 .category = FIO_OPT_C_IO,
3027 .group = FIO_OPT_G_TRIM,
0d29de83
JA		 3028 },
3029 {
3030 .name = "trim_verify_zero",
e8b0e958 3031 .lname = "Verify trim zero",
20eb06bd 3032 .type = FIO_OPT_BOOL,
169c098d 3033 .help = "Verify that trimmed (i.e., discarded) blocks are returned as zeroes",
a609f12a 3034 .off1 = offsetof(struct thread_options, trim_zero),
0d29de83 3035 .parent = "trim_percentage",
d71c154c 3036 .hide = 1,
0d29de83 3037 .def = "1",
e8b0e958
JA		 3038 .category = FIO_OPT_C_IO,
3039 .group = FIO_OPT_G_TRIM,
0d29de83
JA		 3040 },
3041 {
3042 .name = "trim_backlog",
e8b0e958 3043 .lname = "Trim backlog",
0d29de83 3044 .type = FIO_OPT_STR_VAL,
a609f12a 3045 .off1 = offsetof(struct thread_options, trim_backlog),
0d29de83
JA		 3046 .help = "Trim after this number of blocks are written",
3047 .parent = "trim_percentage",
d71c154c 3048 .hide = 1,
20eb06bd 3049 .interval = 1,
e8b0e958
JA		 3050 .category = FIO_OPT_C_IO,
3051 .group = FIO_OPT_G_TRIM,
0d29de83
JA		 3052 },
3053 {
3054 .name = "trim_backlog_batch",
e8b0e958 3055 .lname = "Trim backlog batch",
0d29de83 3056 .type = FIO_OPT_INT,
a609f12a 3057 .off1 = offsetof(struct thread_options, trim_batch),
0d29de83
JA		 3058 .help = "Trim this number of IO blocks",
3059 .parent = "trim_percentage",
d71c154c 3060 .hide = 1,
20eb06bd 3061 .interval = 1,
e8b0e958
JA		 3062 .category = FIO_OPT_C_IO,
3063 .group = FIO_OPT_G_TRIM,
0d29de83 3064 },
a275c37a
JA		 3065#else
3066 {
3067 .name = "trim_percentage",
3068 .lname = "Trim percentage",
3069 .type = FIO_OPT_UNSUPPORTED,
3070 .help = "Fio does not support TRIM on your platform",
3071 },
3072 {
3073 .name = "trim_verify_zero",
3074 .lname = "Verify trim zero",
3075 .type = FIO_OPT_UNSUPPORTED,
3076 .help = "Fio does not support TRIM on your platform",
3077 },
3078 {
3079 .name = "trim_backlog",
3080 .lname = "Trim backlog",
3081 .type = FIO_OPT_UNSUPPORTED,
3082 .help = "Fio does not support TRIM on your platform",
3083 },
3084 {
3085 .name = "trim_backlog_batch",
3086 .lname = "Trim backlog batch",
3087 .type = FIO_OPT_UNSUPPORTED,
3088 .help = "Fio does not support TRIM on your platform",
3089 },
e8462bd8 3090#endif
214e1eca
JA		 3091 {
3092 .name = "write_iolog",
e8b0e958 3093 .lname = "Write I/O log",
214e1eca 3094 .type = FIO_OPT_STR_STORE,
a609f12a 3095 .off1 = offsetof(struct thread_options, write_iolog_file),
214e1eca 3096 .help = "Store IO pattern to file",
e8b0e958
JA		 3097 .category = FIO_OPT_C_IO,
3098 .group = FIO_OPT_G_IOLOG,
214e1eca
JA		 3099 },
3100 {
3101 .name = "read_iolog",
e8b0e958 3102 .lname = "Read I/O log",
214e1eca 3103 .type = FIO_OPT_STR_STORE,
a609f12a 3104 .off1 = offsetof(struct thread_options, read_iolog_file),
214e1eca 3105 .help = "Playback IO pattern from file",
e8b0e958
JA		 3106 .category = FIO_OPT_C_IO,
3107 .group = FIO_OPT_G_IOLOG,
214e1eca 3108 },
98e7161c
AK		 3109 {
3110 .name = "read_iolog_chunked",
3111 .lname = "Read I/O log in parts",
3112 .type = FIO_OPT_BOOL,
3113 .off1 = offsetof(struct thread_options, read_iolog_chunked),
3114 .def = "0",
3115 .parent = "read_iolog",
3116 .help = "Parse IO pattern in chunks",
3117 .category = FIO_OPT_C_IO,
3118 .group = FIO_OPT_G_IOLOG,
3119 },
64bbb865
DN		 3120 {
3121 .name = "replay_no_stall",
e8b0e958 3122 .lname = "Don't stall on replay",
20eb06bd 3123 .type = FIO_OPT_BOOL,
a609f12a 3124 .off1 = offsetof(struct thread_options, no_stall),
64bbb865 3125 .def = "0",
87e7a972 3126 .parent = "read_iolog",
d71c154c 3127 .hide = 1,
64bbb865 3128 .help = "Playback IO pattern file as fast as possible without stalls",
e8b0e958
JA		 3129 .category = FIO_OPT_C_IO,
3130 .group = FIO_OPT_G_IOLOG,
64bbb865 3131 },
d1c46c04
DN		 3132 {
3133 .name = "replay_redirect",
e8b0e958 3134 .lname = "Redirect device for replay",
d1c46c04 3135 .type = FIO_OPT_STR_STORE,
a609f12a 3136 .off1 = offsetof(struct thread_options, replay_redirect),
d1c46c04 3137 .parent = "read_iolog",
d71c154c 3138 .hide = 1,
d1c46c04 3139 .help = "Replay all I/O onto this device, regardless of trace device",
e8b0e958
JA		 3140 .category = FIO_OPT_C_IO,
3141 .group = FIO_OPT_G_IOLOG,
d1c46c04 3142 },
0c63576e
JA		 3143 {
3144 .name = "replay_scale",
3145 .lname = "Replace offset scale factor",
3146 .type = FIO_OPT_INT,
a609f12a 3147 .off1 = offsetof(struct thread_options, replay_scale),
0c63576e
JA		 3148 .parent = "read_iolog",
3149 .def = "1",
3150 .help = "Align offsets to this blocksize",
3151 .category = FIO_OPT_C_IO,
3152 .group = FIO_OPT_G_IOLOG,
3153 },
3154 {
3155 .name = "replay_align",
3156 .lname = "Replace alignment",
3157 .type = FIO_OPT_INT,
a609f12a 3158 .off1 = offsetof(struct thread_options, replay_align),
0c63576e
JA		 3159 .parent = "read_iolog",
3160 .help = "Scale offset down by this factor",
3161 .category = FIO_OPT_C_IO,
3162 .group = FIO_OPT_G_IOLOG,
3163 .pow2 = 1,
3164 },
6dd7fa77
JA		 3165 {
3166 .name = "replay_time_scale",
3167 .lname = "Replay Time Scale",
3168 .type = FIO_OPT_INT,
3169 .off1 = offsetof(struct thread_options, replay_time_scale),
3170 .def = "100",
3171 .minval = 1,
3172 .parent = "read_iolog",
3173 .hide = 1,
3174 .help = "Scale time for replay events",
3175 .category = FIO_OPT_C_IO,
3176 .group = FIO_OPT_G_IOLOG,
3177 },
d7235efb
JA		 3178 {
3179 .name = "replay_skip",
3180 .lname = "Replay Skip",
3181 .type = FIO_OPT_STR,
3182 .cb = str_replay_skip_cb,
3183 .off1 = offsetof(struct thread_options, replay_skip),
3184 .parent = "read_iolog",
3185 .help = "Skip certain IO types (read,write,trim,flush)",
3186 .category = FIO_OPT_C_IO,
3187 .group = FIO_OPT_G_IOLOG,
3188 },
214e1eca
JA		 3189 {
3190 .name = "exec_prerun",
e8b0e958 3191 .lname = "Pre-execute runnable",
214e1eca 3192 .type = FIO_OPT_STR_STORE,
a609f12a 3193 .off1 = offsetof(struct thread_options, exec_prerun),
214e1eca 3194 .help = "Execute this file prior to running job",
e8b0e958
JA		 3195 .category = FIO_OPT_C_GENERAL,
3196 .group = FIO_OPT_G_INVALID,
214e1eca
JA		 3197 },
3198 {
3199 .name = "exec_postrun",
e8b0e958 3200 .lname = "Post-execute runnable",
214e1eca 3201 .type = FIO_OPT_STR_STORE,
a609f12a 3202 .off1 = offsetof(struct thread_options, exec_postrun),
214e1eca 3203 .help = "Execute this file after running job",
e8b0e958
JA		 3204 .category = FIO_OPT_C_GENERAL,
3205 .group = FIO_OPT_G_INVALID,
214e1eca
JA		 3206 },
3207#ifdef FIO_HAVE_IOSCHED_SWITCH
3208 {
3209 .name = "ioscheduler",
e8b0e958 3210 .lname = "I/O scheduler",
214e1eca 3211 .type = FIO_OPT_STR_STORE,
a609f12a 3212 .off1 = offsetof(struct thread_options, ioscheduler),
214e1eca 3213 .help = "Use this IO scheduler on the backing device",
e8b0e958
JA		 3214 .category = FIO_OPT_C_FILE,
3215 .group = FIO_OPT_G_INVALID,
214e1eca 3216 },
a275c37a
JA		 3217#else
3218 {
3219 .name = "ioscheduler",
3220 .lname = "I/O scheduler",
3221 .type = FIO_OPT_UNSUPPORTED,
3222 .help = "Your platform does not support IO scheduler switching",
3223 },
214e1eca
JA		 3224#endif
3225 {
3226 .name = "zonesize",
e8b0e958 3227 .lname = "Zone size",
214e1eca 3228 .type = FIO_OPT_STR_VAL,
a609f12a 3229 .off1 = offsetof(struct thread_options, zone_size),
ed335855
SN		 3230 .help = "Amount of data to read per zone",
3231 .def = "0",
20eb06bd 3232 .interval = 1024 * 1024,
e8b0e958
JA		 3233 .category = FIO_OPT_C_IO,
3234 .group = FIO_OPT_G_ZONE,
ed335855
SN		 3235 },
3236 {
3237 .name = "zonerange",
e8b0e958 3238 .lname = "Zone range",
ed335855 3239 .type = FIO_OPT_STR_VAL,
a609f12a 3240 .off1 = offsetof(struct thread_options, zone_range),
214e1eca
JA		 3241 .help = "Give size of an IO zone",
3242 .def = "0",
20eb06bd 3243 .interval = 1024 * 1024,
e8b0e958
JA		 3244 .category = FIO_OPT_C_IO,
3245 .group = FIO_OPT_G_ZONE,
214e1eca
JA		 3246 },
3247 {
3248 .name = "zoneskip",
e8b0e958 3249 .lname = "Zone skip",
214e1eca 3250 .type = FIO_OPT_STR_VAL,
a609f12a 3251 .off1 = offsetof(struct thread_options, zone_skip),
214e1eca
JA		 3252 .help = "Space between IO zones",
3253 .def = "0",
20eb06bd 3254 .interval = 1024 * 1024,
e8b0e958
JA		 3255 .category = FIO_OPT_C_IO,
3256 .group = FIO_OPT_G_ZONE,
214e1eca
JA		 3257 },
3258 {
3259 .name = "lockmem",
e8b0e958 3260 .lname = "Lock memory",
214e1eca 3261 .type = FIO_OPT_STR_VAL,
a609f12a 3262 .off1 = offsetof(struct thread_options, lockmem),
81c6b6cd 3263 .help = "Lock down this amount of memory (per worker)",
214e1eca 3264 .def = "0",
20eb06bd 3265 .interval = 1024 * 1024,
e8b0e958
JA		 3266 .category = FIO_OPT_C_GENERAL,
3267 .group = FIO_OPT_G_INVALID,
214e1eca 3268 },
214e1eca
JA		 3269 {
3270 .name = "rwmixread",
e8b0e958 3271 .lname = "Read/write mix read",
214e1eca 3272 .type = FIO_OPT_INT,
cb499fc4 3273 .cb = str_rwmix_read_cb,
a609f12a 3274 .off1 = offsetof(struct thread_options, rwmix[DDIR_READ]),
214e1eca
JA		 3275 .maxval = 100,
3276 .help = "Percentage of mixed workload that is reads",
3277 .def = "50",
20eb06bd 3278 .interval = 5,
90265353 3279 .inverse = "rwmixwrite",
e8b0e958
JA		 3280 .category = FIO_OPT_C_IO,
3281 .group = FIO_OPT_G_RWMIX,
214e1eca
JA		 3282 },
3283 {
3284 .name = "rwmixwrite",
e8b0e958 3285 .lname = "Read/write mix write",
214e1eca 3286 .type = FIO_OPT_INT,
cb499fc4 3287 .cb = str_rwmix_write_cb,
a609f12a 3288 .off1 = offsetof(struct thread_options, rwmix[DDIR_WRITE]),
214e1eca
JA		 3289 .maxval = 100,
3290 .help = "Percentage of mixed workload that is writes",
3291 .def = "50",
20eb06bd 3292 .interval = 5,
90265353 3293 .inverse = "rwmixread",
e8b0e958
JA		 3294 .category = FIO_OPT_C_IO,
3295 .group = FIO_OPT_G_RWMIX,
214e1eca 3296 },
afdf9352
JA		 3297 {
3298 .name = "rwmixcycle",
e8b0e958 3299 .lname = "Read/write mix cycle",
15ca150e 3300 .type = FIO_OPT_DEPRECATED,
e8b0e958
JA		 3301 .category = FIO_OPT_C_IO,
3302 .group = FIO_OPT_G_RWMIX,
afdf9352 3303 },
214e1eca
JA		 3304 {
3305 .name = "nice",
e8b0e958 3306 .lname = "Nice",
214e1eca 3307 .type = FIO_OPT_INT,
a609f12a 3308 .off1 = offsetof(struct thread_options, nice),
214e1eca 3309 .help = "Set job CPU nice value",
11fd6aa8
RC		 3310 .minval = -20,
3311 .maxval = 19,
214e1eca 3312 .def = "0",
20eb06bd 3313 .interval = 1,
e8b0e958 3314 .category = FIO_OPT_C_GENERAL,
10860056 3315 .group = FIO_OPT_G_CRED,
214e1eca
JA		 3316 },
3317#ifdef FIO_HAVE_IOPRIO
3318 {
3319 .name = "prio",
e8b0e958 3320 .lname = "I/O nice priority",
214e1eca 3321 .type = FIO_OPT_INT,
a609f12a 3322 .off1 = offsetof(struct thread_options, ioprio),
214e1eca 3323 .help = "Set job IO priority value",
1767bd34
TK		 3324 .minval = IOPRIO_MIN_PRIO,
3325 .maxval = IOPRIO_MAX_PRIO,
20eb06bd 3326 .interval = 1,
e8b0e958 3327 .category = FIO_OPT_C_GENERAL,
10860056 3328 .group = FIO_OPT_G_CRED,
214e1eca 3329 },
32ef447a
TK		 3330#else
3331 {
3332 .name = "prio",
3333 .lname = "I/O nice priority",
3334 .type = FIO_OPT_UNSUPPORTED,
3335 .help = "Your platform does not support IO priorities",
3336 },
3337#endif
3338#ifdef FIO_HAVE_IOPRIO_CLASS
3339#ifndef FIO_HAVE_IOPRIO
3340#error "FIO_HAVE_IOPRIO_CLASS requires FIO_HAVE_IOPRIO"
3341#endif
214e1eca
JA		 3342 {
3343 .name = "prioclass",
e8b0e958 3344 .lname = "I/O nice priority class",
214e1eca 3345 .type = FIO_OPT_INT,
a609f12a 3346 .off1 = offsetof(struct thread_options, ioprio_class),
214e1eca 3347 .help = "Set job IO priority class",
1767bd34
TK		 3348 .minval = IOPRIO_MIN_PRIO_CLASS,
3349 .maxval = IOPRIO_MAX_PRIO_CLASS,
20eb06bd 3350 .interval = 1,
e8b0e958 3351 .category = FIO_OPT_C_GENERAL,
10860056 3352 .group = FIO_OPT_G_CRED,
214e1eca 3353 },
a275c37a 3354#else
a275c37a
JA		 3355 {
3356 .name = "prioclass",
3357 .lname = "I/O nice priority class",
3358 .type = FIO_OPT_UNSUPPORTED,
32ef447a 3359 .help = "Your platform does not support IO priority classes",
a275c37a 3360 },
214e1eca
JA		 3361#endif
3362 {
3363 .name = "thinktime",
e8b0e958 3364 .lname = "Thinktime",
214e1eca 3365 .type = FIO_OPT_INT,
a609f12a 3366 .off1 = offsetof(struct thread_options, thinktime),
214e1eca
JA		 3367 .help = "Idle time between IO buffers (usec)",
3368 .def = "0",
88038bc7 3369 .is_time = 1,
e8b0e958 3370 .category = FIO_OPT_C_IO,
3ceb458f 3371 .group = FIO_OPT_G_THINKTIME,
214e1eca
JA		 3372 },
3373 {
3374 .name = "thinktime_spin",
e8b0e958 3375 .lname = "Thinktime spin",
214e1eca 3376 .type = FIO_OPT_INT,
a609f12a 3377 .off1 = offsetof(struct thread_options, thinktime_spin),
214e1eca
JA		 3378 .help = "Start think time by spinning this amount (usec)",
3379 .def = "0",
88038bc7 3380 .is_time = 1,
afdf9352 3381 .parent = "thinktime",
d71c154c 3382 .hide = 1,
e8b0e958 3383 .category = FIO_OPT_C_IO,
3ceb458f 3384 .group = FIO_OPT_G_THINKTIME,
214e1eca
JA		 3385 },
3386 {
3387 .name = "thinktime_blocks",
e8b0e958 3388 .lname = "Thinktime blocks",
214e1eca 3389 .type = FIO_OPT_INT,
a609f12a 3390 .off1 = offsetof(struct thread_options, thinktime_blocks),
214e1eca
JA		 3391 .help = "IO buffer period between 'thinktime'",
3392 .def = "1",
afdf9352 3393 .parent = "thinktime",
d71c154c 3394 .hide = 1,
e8b0e958 3395 .category = FIO_OPT_C_IO,
3ceb458f 3396 .group = FIO_OPT_G_THINKTIME,
214e1eca
JA		 3397 },
3398 {
3399 .name = "rate",
e8b0e958 3400 .lname = "I/O rate",
e01b22b8 3401 .type = FIO_OPT_INT,
a609f12a
JA		 3402 .off1 = offsetof(struct thread_options, rate[DDIR_READ]),
3403 .off2 = offsetof(struct thread_options, rate[DDIR_WRITE]),
3404 .off3 = offsetof(struct thread_options, rate[DDIR_TRIM]),
214e1eca 3405 .help = "Set bandwidth rate",
e8b0e958
JA		 3406 .category = FIO_OPT_C_IO,
3407 .group = FIO_OPT_G_RATE,
214e1eca
JA		 3408 },
3409 {
6d428bcd
JA		 3410 .name = "rate_min",
3411 .alias = "ratemin",
e8b0e958 3412 .lname = "I/O min rate",
e01b22b8 3413 .type = FIO_OPT_INT,
a609f12a
JA		 3414 .off1 = offsetof(struct thread_options, ratemin[DDIR_READ]),
3415 .off2 = offsetof(struct thread_options, ratemin[DDIR_WRITE]),
3416 .off3 = offsetof(struct thread_options, ratemin[DDIR_TRIM]),
4e991c23 3417 .help = "Job must meet this rate or it will be shutdown",
afdf9352 3418 .parent = "rate",
d71c154c 3419 .hide = 1,
e8b0e958
JA		 3420 .category = FIO_OPT_C_IO,
3421 .group = FIO_OPT_G_RATE,
4e991c23
JA		 3422 },
3423 {
3424 .name = "rate_iops",
e8b0e958 3425 .lname = "I/O rate IOPS",
e01b22b8 3426 .type = FIO_OPT_INT,
a609f12a
JA		 3427 .off1 = offsetof(struct thread_options, rate_iops[DDIR_READ]),
3428 .off2 = offsetof(struct thread_options, rate_iops[DDIR_WRITE]),
3429 .off3 = offsetof(struct thread_options, rate_iops[DDIR_TRIM]),
4e991c23 3430 .help = "Limit IO used to this number of IO operations/sec",
d71c154c 3431 .hide = 1,
e8b0e958
JA		 3432 .category = FIO_OPT_C_IO,
3433 .group = FIO_OPT_G_RATE,
4e991c23
JA		 3434 },
3435 {
3436 .name = "rate_iops_min",
e8b0e958 3437 .lname = "I/O min rate IOPS",
e01b22b8 3438 .type = FIO_OPT_INT,
a609f12a
JA		 3439 .off1 = offsetof(struct thread_options, rate_iops_min[DDIR_READ]),
3440 .off2 = offsetof(struct thread_options, rate_iops_min[DDIR_WRITE]),
3441 .off3 = offsetof(struct thread_options, rate_iops_min[DDIR_TRIM]),
03e20d68 3442 .help = "Job must meet this rate or it will be shut down",
afdf9352 3443 .parent = "rate_iops",
d71c154c 3444 .hide = 1,
e8b0e958
JA		 3445 .category = FIO_OPT_C_IO,
3446 .group = FIO_OPT_G_RATE,
214e1eca 3447 },
ff6bb260 3448 {
6de65959
JA		 3449 .name = "rate_process",
3450 .lname = "Rate Process",
3451 .type = FIO_OPT_STR,
a609f12a 3452 .off1 = offsetof(struct thread_options, rate_process),
6de65959
JA		 3453 .help = "What process controls how rated IO is managed",
3454 .def = "linear",
ff6bb260
SL		 3455 .category = FIO_OPT_C_IO,
3456 .group = FIO_OPT_G_RATE,
6de65959
JA		 3457 .posval = {
3458 { .ival = "linear",
3459 .oval = RATE_PROCESS_LINEAR,
3460 .help = "Linear rate of IO",
3461 },
3462 {
3463 .ival = "poisson",
3464 .oval = RATE_PROCESS_POISSON,
3465 .help = "Rate follows Poisson process",
3466 },
3467 },
3468 .parent = "rate",
ff6bb260 3469 },
214e1eca 3470 {
6d428bcd
JA		 3471 .name = "rate_cycle",
3472 .alias = "ratecycle",
e8b0e958 3473 .lname = "I/O rate cycle",
214e1eca 3474 .type = FIO_OPT_INT,
a609f12a 3475 .off1 = offsetof(struct thread_options, ratecycle),
214e1eca
JA		 3476 .help = "Window average for rate limits (msec)",
3477 .def = "1000",
afdf9352 3478 .parent = "rate",
d71c154c 3479 .hide = 1,
e8b0e958
JA		 3480 .category = FIO_OPT_C_IO,
3481 .group = FIO_OPT_G_RATE,
214e1eca 3482 },
1a9bf814
JA		 3483 {
3484 .name = "rate_ignore_thinktime",
3485 .lname = "Rate ignore thinktime",
3486 .type = FIO_OPT_BOOL,
3487 .off1 = offsetof(struct thread_options, rate_ign_think),
3488 .help = "Rated IO ignores thinktime settings",
3489 .parent = "rate",
3490 .category = FIO_OPT_C_IO,
3491 .group = FIO_OPT_G_RATE,
3492 },
15501535
JA		 3493 {
3494 .name = "max_latency",
dd97d866 3495 .lname = "Max Latency (usec)",
6c3fb04c 3496 .type = FIO_OPT_STR_VAL_TIME,
a609f12a 3497 .off1 = offsetof(struct thread_options, max_latency),
15501535 3498 .help = "Maximum tolerated IO latency (usec)",
88038bc7 3499 .is_time = 1,
1e5324e7 3500 .category = FIO_OPT_C_IO,
3e260a46
JA		 3501 .group = FIO_OPT_G_LATPROF,
3502 },
3503 {
3504 .name = "latency_target",
3505 .lname = "Latency Target (usec)",
3506 .type = FIO_OPT_STR_VAL_TIME,
a609f12a 3507 .off1 = offsetof(struct thread_options, latency_target),
3e260a46 3508 .help = "Ramp to max queue depth supporting this latency",
88038bc7 3509 .is_time = 1,
3e260a46
JA		 3510 .category = FIO_OPT_C_IO,
3511 .group = FIO_OPT_G_LATPROF,
3512 },
3513 {
3514 .name = "latency_window",
3515 .lname = "Latency Window (usec)",
3516 .type = FIO_OPT_STR_VAL_TIME,
a609f12a 3517 .off1 = offsetof(struct thread_options, latency_window),
3e260a46 3518 .help = "Time to sustain latency_target",
88038bc7 3519 .is_time = 1,
3e260a46
JA		 3520 .category = FIO_OPT_C_IO,
3521 .group = FIO_OPT_G_LATPROF,
3522 },
3523 {
3524 .name = "latency_percentile",
3525 .lname = "Latency Percentile",
3526 .type = FIO_OPT_FLOAT_LIST,
a609f12a 3527 .off1 = offsetof(struct thread_options, latency_percentile),
3e260a46
JA		 3528 .help = "Percentile of IOs must be below latency_target",
3529 .def = "100",
3530 .maxlen = 1,
3531 .minfp = 0.0,
3532 .maxfp = 100.0,
3533 .category = FIO_OPT_C_IO,
3534 .group = FIO_OPT_G_LATPROF,
15501535 3535 },
214e1eca
JA		 3536 {
3537 .name = "invalidate",
e8b0e958 3538 .lname = "Cache invalidate",
214e1eca 3539 .type = FIO_OPT_BOOL,
a609f12a 3540 .off1 = offsetof(struct thread_options, invalidate_cache),
214e1eca
JA		 3541 .help = "Invalidate buffer/page cache prior to running job",
3542 .def = "1",
e8b0e958 3543 .category = FIO_OPT_C_IO,
3ceb458f 3544 .group = FIO_OPT_G_IO_TYPE,
214e1eca
JA		 3545 },
3546 {
3547 .name = "sync",
e8b0e958 3548 .lname = "Synchronous I/O",
214e1eca 3549 .type = FIO_OPT_BOOL,
a609f12a 3550 .off1 = offsetof(struct thread_options, sync_io),
214e1eca
JA		 3551 .help = "Use O_SYNC for buffered writes",
3552 .def = "0",
67a1000f 3553 .parent = "buffered",
d71c154c 3554 .hide = 1,
e8b0e958 3555 .category = FIO_OPT_C_IO,
3ceb458f 3556 .group = FIO_OPT_G_IO_TYPE,
214e1eca 3557 },
ae8e559e
JA		 3558#ifdef FIO_HAVE_WRITE_HINT
3559 {
3560 .name = "write_hint",
3561 .lname = "Write hint",
3562 .type = FIO_OPT_STR,
3563 .off1 = offsetof(struct thread_options, write_hint),
3564 .help = "Set expected write life time",
3565 .category = FIO_OPT_C_ENGINE,
3566 .group = FIO_OPT_G_INVALID,
3567 .posval = {
3568 { .ival = "none",
3569 .oval = RWH_WRITE_LIFE_NONE,
3570 },
3571 { .ival = "short",
3572 .oval = RWH_WRITE_LIFE_SHORT,
3573 },
3574 { .ival = "medium",
3575 .oval = RWH_WRITE_LIFE_MEDIUM,
3576 },
3577 { .ival = "long",
3578 .oval = RWH_WRITE_LIFE_LONG,
3579 },
3580 { .ival = "extreme",
3581 .oval = RWH_WRITE_LIFE_EXTREME,
3582 },
3583 },
3584 },
3585#endif
214e1eca
JA		 3586 {
3587 .name = "create_serialize",
e8b0e958 3588 .lname = "Create serialize",
214e1eca 3589 .type = FIO_OPT_BOOL,
a609f12a 3590 .off1 = offsetof(struct thread_options, create_serialize),
c2b8035f 3591 .help = "Serialize creation of job files",
214e1eca 3592 .def = "1",
e8b0e958
JA		 3593 .category = FIO_OPT_C_FILE,
3594 .group = FIO_OPT_G_INVALID,
214e1eca
JA		 3595 },
3596 {
3597 .name = "create_fsync",
e8b0e958 3598 .lname = "Create fsync",
214e1eca 3599 .type = FIO_OPT_BOOL,
a609f12a 3600 .off1 = offsetof(struct thread_options, create_fsync),
03e20d68 3601 .help = "fsync file after creation",
214e1eca 3602 .def = "1",
e8b0e958
JA		 3603 .category = FIO_OPT_C_FILE,
3604 .group = FIO_OPT_G_INVALID,
214e1eca 3605 },
814452bd
JA		 3606 {
3607 .name = "create_on_open",
e8b0e958 3608 .lname = "Create on open",
814452bd 3609 .type = FIO_OPT_BOOL,
a609f12a 3610 .off1 = offsetof(struct thread_options, create_on_open),
814452bd
JA		 3611 .help = "Create files when they are opened for IO",
3612 .def = "0",
e8b0e958
JA		 3613 .category = FIO_OPT_C_FILE,
3614 .group = FIO_OPT_G_INVALID,
814452bd 3615 },
25460cf6
JA		 3616 {
3617 .name = "create_only",
cce2fdfe 3618 .lname = "Create Only",
25460cf6 3619 .type = FIO_OPT_BOOL,
a609f12a 3620 .off1 = offsetof(struct thread_options, create_only),
25460cf6 3621 .help = "Only perform file creation phase",
d17fda71 3622 .category = FIO_OPT_C_FILE,
25460cf6
JA		 3623 .def = "0",
3624 },
2378826d
JA		 3625 {
3626 .name = "allow_file_create",
e81ecca3 3627 .lname = "Allow file create",
2378826d 3628 .type = FIO_OPT_BOOL,
a609f12a 3629 .off1 = offsetof(struct thread_options, allow_create),
2378826d
JA		 3630 .help = "Permit fio to create files, if they don't exist",
3631 .def = "1",
3632 .category = FIO_OPT_C_FILE,
3633 .group = FIO_OPT_G_FILENAME,
3634 },
e81ecca3
JA		 3635 {
3636 .name = "allow_mounted_write",
3637 .lname = "Allow mounted write",
3638 .type = FIO_OPT_BOOL,
a609f12a 3639 .off1 = offsetof(struct thread_options, allow_mounted_write),
e81ecca3
JA		 3640 .help = "Allow writes to a mounted partition",
3641 .def = "0",
3642 .category = FIO_OPT_C_FILE,
3643 .group = FIO_OPT_G_FILENAME,
3644 },
0b9d69ec 3645 {
afad68f7 3646 .name = "pre_read",
e8b0e958 3647 .lname = "Pre-read files",
afad68f7 3648 .type = FIO_OPT_BOOL,
a609f12a 3649 .off1 = offsetof(struct thread_options, pre_read),
03e20d68 3650 .help = "Pre-read files before starting official testing",
afad68f7 3651 .def = "0",
e8b0e958
JA		 3652 .category = FIO_OPT_C_FILE,
3653 .group = FIO_OPT_G_INVALID,
afad68f7 3654 },
214e1eca
JA		 3655#ifdef FIO_HAVE_CPU_AFFINITY
3656 {
3657 .name = "cpumask",
e8b0e958 3658 .lname = "CPU mask",
214e1eca
JA		 3659 .type = FIO_OPT_INT,
3660 .cb = str_cpumask_cb,
a609f12a 3661 .off1 = offsetof(struct thread_options, cpumask),
214e1eca 3662 .help = "CPU affinity mask",
e8b0e958 3663 .category = FIO_OPT_C_GENERAL,
10860056 3664 .group = FIO_OPT_G_CRED,
214e1eca 3665 },
d2e268b0
JA		 3666 {
3667 .name = "cpus_allowed",
e8b0e958 3668 .lname = "CPUs allowed",
d2e268b0
JA		 3669 .type = FIO_OPT_STR,
3670 .cb = str_cpus_allowed_cb,
a609f12a 3671 .off1 = offsetof(struct thread_options, cpumask),
d2e268b0 3672 .help = "Set CPUs allowed",
e8b0e958 3673 .category = FIO_OPT_C_GENERAL,
10860056 3674 .group = FIO_OPT_G_CRED,
d2e268b0 3675 },
c2acfbac
JA		 3676 {
3677 .name = "cpus_allowed_policy",
3678 .lname = "CPUs allowed distribution policy",
3679 .type = FIO_OPT_STR,
a609f12a 3680 .off1 = offsetof(struct thread_options, cpus_allowed_policy),
c2acfbac
JA		 3681 .help = "Distribution policy for cpus_allowed",
3682 .parent = "cpus_allowed",
3683 .prio = 1,
3684 .posval = {
3685 { .ival = "shared",
3686 .oval = FIO_CPUS_SHARED,
3687 .help = "Mask shared between threads",
3688 },
3689 { .ival = "split",
3690 .oval = FIO_CPUS_SPLIT,
3691 .help = "Mask split between threads",
3692 },
3693 },
3694 .category = FIO_OPT_C_GENERAL,
3695 .group = FIO_OPT_G_CRED,
3696 },
a275c37a
JA		 3697#else
3698 {
3699 .name = "cpumask",
3700 .lname = "CPU mask",
3701 .type = FIO_OPT_UNSUPPORTED,
3702 .help = "Your platform does not support CPU affinities",
3703 },
3704 {
3705 .name = "cpus_allowed",
3706 .lname = "CPUs allowed",
3707 .type = FIO_OPT_UNSUPPORTED,
3708 .help = "Your platform does not support CPU affinities",
3709 },
3710 {
3711 .name = "cpus_allowed_policy",
3712 .lname = "CPUs allowed distribution policy",
3713 .type = FIO_OPT_UNSUPPORTED,
3714 .help = "Your platform does not support CPU affinities",
3715 },
d0b937ed 3716#endif
67bf9823 3717#ifdef CONFIG_LIBNUMA
d0b937ed
YR		 3718 {
3719 .name = "numa_cpu_nodes",
cce2fdfe 3720 .lname = "NUMA CPU Nodes",
d0b937ed
YR		 3721 .type = FIO_OPT_STR,
3722 .cb = str_numa_cpunodes_cb,
a609f12a 3723 .off1 = offsetof(struct thread_options, numa_cpunodes),
d0b937ed 3724 .help = "NUMA CPU nodes bind",
6be54b2d
JA		 3725 .category = FIO_OPT_C_GENERAL,
3726 .group = FIO_OPT_G_INVALID,
d0b937ed
YR		 3727 },
3728 {
3729 .name = "numa_mem_policy",
cce2fdfe 3730 .lname = "NUMA Memory Policy",
d0b937ed
YR		 3731 .type = FIO_OPT_STR,
3732 .cb = str_numa_mpol_cb,
a609f12a 3733 .off1 = offsetof(struct thread_options, numa_memnodes),
d0b937ed 3734 .help = "NUMA memory policy setup",
6be54b2d
JA		 3735 .category = FIO_OPT_C_GENERAL,
3736 .group = FIO_OPT_G_INVALID,
d0b937ed 3737 },
a275c37a
JA		 3738#else
3739 {
3740 .name = "numa_cpu_nodes",
3741 .lname = "NUMA CPU Nodes",
3742 .type = FIO_OPT_UNSUPPORTED,
3743 .help = "Build fio with libnuma-dev(el) to enable this option",
3744 },
3745 {
3746 .name = "numa_mem_policy",
3747 .lname = "NUMA Memory Policy",
3748 .type = FIO_OPT_UNSUPPORTED,
3749 .help = "Build fio with libnuma-dev(el) to enable this option",
3750 },
03553853
YR		 3751#endif
3752#ifdef CONFIG_CUDA
3753 {
3754 .name = "gpu_dev_id",
3755 .lname = "GPU device ID",
3756 .type = FIO_OPT_INT,
3757 .off1 = offsetof(struct thread_options, gpu_dev_id),
3758 .help = "Set GPU device ID for GPUDirect RDMA",
3759 .def = "0",
3760 .category = FIO_OPT_C_GENERAL,
3761 .group = FIO_OPT_G_INVALID,
3762 },
214e1eca
JA		 3763#endif
3764 {
3765 .name = "end_fsync",
e8b0e958 3766 .lname = "End fsync",
214e1eca 3767 .type = FIO_OPT_BOOL,
a609f12a 3768 .off1 = offsetof(struct thread_options, end_fsync),
214e1eca
JA		 3769 .help = "Include fsync at the end of job",
3770 .def = "0",
e8b0e958
JA		 3771 .category = FIO_OPT_C_FILE,
3772 .group = FIO_OPT_G_INVALID,
214e1eca
JA		 3773 },
3774 {
3775 .name = "fsync_on_close",
e8b0e958 3776 .lname = "Fsync on close",
214e1eca 3777 .type = FIO_OPT_BOOL,
a609f12a 3778 .off1 = offsetof(struct thread_options, fsync_on_close),
214e1eca
JA		 3779 .help = "fsync files on close",
3780 .def = "0",
e8b0e958
JA		 3781 .category = FIO_OPT_C_FILE,
3782 .group = FIO_OPT_G_INVALID,
214e1eca
JA		 3783 },
3784 {
3785 .name = "unlink",
e8b0e958 3786 .lname = "Unlink file",
214e1eca 3787 .type = FIO_OPT_BOOL,
a609f12a 3788 .off1 = offsetof(struct thread_options, unlink),
214e1eca
JA		 3789 .help = "Unlink created files after job has completed",
3790 .def = "0",
e8b0e958
JA		 3791 .category = FIO_OPT_C_FILE,
3792 .group = FIO_OPT_G_INVALID,
214e1eca 3793 },
39c1c323 3794 {
3795 .name = "unlink_each_loop",
3796 .lname = "Unlink file after each loop of a job",
3797 .type = FIO_OPT_BOOL,
a609f12a 3798 .off1 = offsetof(struct thread_options, unlink_each_loop),
39c1c323 3799 .help = "Unlink created files after each loop in a job has completed",
3800 .def = "0",
3801 .category = FIO_OPT_C_FILE,
3802 .group = FIO_OPT_G_INVALID,
3803 },
214e1eca
JA		 3804 {
3805 .name = "exitall",
e8b0e958 3806 .lname = "Exit-all on terminate",
214e1eca
JA		 3807 .type = FIO_OPT_STR_SET,
3808 .cb = str_exitall_cb,
3809 .help = "Terminate all jobs when one exits",
e8b0e958 3810 .category = FIO_OPT_C_GENERAL,
a1f6afec 3811 .group = FIO_OPT_G_PROCESS,
214e1eca 3812 },
f9cafb12
JA		 3813 {
3814 .name = "exitall_on_error",
3815 .lname = "Exit-all on terminate in error",
78abcf9b 3816 .type = FIO_OPT_STR_SET,
a609f12a 3817 .off1 = offsetof(struct thread_options, exitall_error),
f9cafb12
JA		 3818 .help = "Terminate all jobs when one exits in error",
3819 .category = FIO_OPT_C_GENERAL,
3820 .group = FIO_OPT_G_PROCESS,
3821 },
214e1eca
JA		 3822 {
3823 .name = "stonewall",
e8b0e958 3824 .lname = "Wait for previous",
d392365e 3825 .alias = "wait_for_previous",
214e1eca 3826 .type = FIO_OPT_STR_SET,
a609f12a 3827 .off1 = offsetof(struct thread_options, stonewall),
214e1eca 3828 .help = "Insert a hard barrier between this job and previous",
e8b0e958 3829 .category = FIO_OPT_C_GENERAL,
a1f6afec 3830 .group = FIO_OPT_G_PROCESS,
214e1eca 3831 },
b3d62a75
JA		 3832 {
3833 .name = "new_group",
e8b0e958 3834 .lname = "New group",
b3d62a75 3835 .type = FIO_OPT_STR_SET,
a609f12a 3836 .off1 = offsetof(struct thread_options, new_group),
b3d62a75 3837 .help = "Mark the start of a new group (for reporting)",
e8b0e958 3838 .category = FIO_OPT_C_GENERAL,
a1f6afec 3839 .group = FIO_OPT_G_PROCESS,
b3d62a75 3840 },
214e1eca
JA		 3841 {
3842 .name = "thread",
e8b0e958 3843 .lname = "Thread",
214e1eca 3844 .type = FIO_OPT_STR_SET,
a609f12a 3845 .off1 = offsetof(struct thread_options, use_thread),
20eb06bd 3846 .help = "Use threads instead of processes",
c8931876
JA		 3847#ifdef CONFIG_NO_SHM
3848 .def = "1",
3849 .no_warn_def = 1,
3850#endif
e8b0e958 3851 .category = FIO_OPT_C_GENERAL,
a1f6afec 3852 .group = FIO_OPT_G_PROCESS,
214e1eca 3853 },
3a5db920
JA		 3854 {
3855 .name = "per_job_logs",
cce2fdfe 3856 .lname = "Per Job Logs",
3a5db920 3857 .type = FIO_OPT_BOOL,
a609f12a 3858 .off1 = offsetof(struct thread_options, per_job_logs),
3a5db920
JA		 3859 .help = "Include job number in generated log files or not",
3860 .def = "1",
3861 .category = FIO_OPT_C_LOG,
3862 .group = FIO_OPT_G_INVALID,
3863 },
214e1eca
JA		 3864 {
3865 .name = "write_bw_log",
e8b0e958 3866 .lname = "Write bandwidth log",
dded427c 3867 .type = FIO_OPT_STR,
a609f12a 3868 .off1 = offsetof(struct thread_options, bw_log_file),
dded427c 3869 .cb = str_write_bw_log_cb,
214e1eca 3870 .help = "Write log of bandwidth during run",
e8b0e958
JA		 3871 .category = FIO_OPT_C_LOG,
3872 .group = FIO_OPT_G_INVALID,
214e1eca
JA		 3873 },
3874 {
3875 .name = "write_lat_log",
e8b0e958 3876 .lname = "Write latency log",
dded427c 3877 .type = FIO_OPT_STR,
a609f12a 3878 .off1 = offsetof(struct thread_options, lat_log_file),
dded427c 3879 .cb = str_write_lat_log_cb,
214e1eca 3880 .help = "Write log of latency during run",
e8b0e958
JA		 3881 .category = FIO_OPT_C_LOG,
3882 .group = FIO_OPT_G_INVALID,
214e1eca 3883 },
c8eeb9df
JA		 3884 {
3885 .name = "write_iops_log",
e8b0e958 3886 .lname = "Write IOPS log",
dded427c 3887 .type = FIO_OPT_STR,
a609f12a 3888 .off1 = offsetof(struct thread_options, iops_log_file),
dded427c 3889 .cb = str_write_iops_log_cb,
c8eeb9df 3890 .help = "Write log of IOPS during run",
e8b0e958
JA		 3891 .category = FIO_OPT_C_LOG,
3892 .group = FIO_OPT_G_INVALID,
c8eeb9df 3893 },
b8bc8cba
JA		 3894 {
3895 .name = "log_avg_msec",
e8b0e958 3896 .lname = "Log averaging (msec)",
b8bc8cba 3897 .type = FIO_OPT_INT,
a609f12a 3898 .off1 = offsetof(struct thread_options, log_avg_msec),
b8bc8cba
JA		 3899 .help = "Average bw/iops/lat logs over this period of time",
3900 .def = "0",
e8b0e958 3901 .category = FIO_OPT_C_LOG,
1e613c9c
KC		 3902 .group = FIO_OPT_G_INVALID,
3903 },
3904 {
3905 .name = "log_hist_msec",
3906 .lname = "Log histograms (msec)",
3907 .type = FIO_OPT_INT,
a609f12a 3908 .off1 = offsetof(struct thread_options, log_hist_msec),
1e613c9c
KC		 3909 .help = "Dump completion latency histograms at frequency of this time value",
3910 .def = "0",
3911 .category = FIO_OPT_C_LOG,
3912 .group = FIO_OPT_G_INVALID,
3913 },
3914 {
3915 .name = "log_hist_coarseness",
3916 .lname = "Histogram logs coarseness",
3917 .type = FIO_OPT_INT,
a609f12a 3918 .off1 = offsetof(struct thread_options, log_hist_coarseness),
1e613c9c
KC		 3919 .help = "Integer in range [0,6]. Higher coarseness outputs"
3920 " fewer histogram bins per sample. The number of bins for"
3921 " these are [1216, 608, 304, 152, 76, 38, 19] respectively.",
3922 .def = "0",
3923 .category = FIO_OPT_C_LOG,
3924 .group = FIO_OPT_G_INVALID,
3925 },
3926 {
3927 .name = "write_hist_log",
3928 .lname = "Write latency histogram logs",
dded427c 3929 .type = FIO_OPT_STR,
a609f12a 3930 .off1 = offsetof(struct thread_options, hist_log_file),
dded427c 3931 .cb = str_write_hist_log_cb,
1e613c9c
KC		 3932 .help = "Write log of latency histograms during run",
3933 .category = FIO_OPT_C_LOG,
e8b0e958 3934 .group = FIO_OPT_G_INVALID,
b8bc8cba 3935 },
e6989e10
JA		 3936 {
3937 .name = "log_max_value",
3938 .lname = "Log maximum instead of average",
3939 .type = FIO_OPT_BOOL,
a609f12a 3940 .off1 = offsetof(struct thread_options, log_max),
e6989e10
JA		 3941 .help = "Log max sample in a window instead of average",
3942 .def = "0",
3943 .category = FIO_OPT_C_LOG,
3944 .group = FIO_OPT_G_INVALID,
3945 },
ae588852
JA		 3946 {
3947 .name = "log_offset",
3948 .lname = "Log offset of IO",
3949 .type = FIO_OPT_BOOL,
a609f12a 3950 .off1 = offsetof(struct thread_options, log_offset),
ae588852
JA		 3951 .help = "Include offset of IO for each log entry",
3952 .def = "0",
3953 .category = FIO_OPT_C_LOG,
3954 .group = FIO_OPT_G_INVALID,
3955 },
aee2ab67
JA		 3956#ifdef CONFIG_ZLIB
3957 {
3958 .name = "log_compression",
3959 .lname = "Log compression",
3960 .type = FIO_OPT_INT,
a609f12a 3961 .off1 = offsetof(struct thread_options, log_gz),
aee2ab67 3962 .help = "Log in compressed chunks of this size",
9919b27b 3963 .minval = 1024ULL,
aee2ab67
JA		 3964 .maxval = 512 * 1024 * 1024ULL,
3965 .category = FIO_OPT_C_LOG,
3966 .group = FIO_OPT_G_INVALID,
3967 },
c08f9fe2
JA		 3968#ifdef FIO_HAVE_CPU_AFFINITY
3969 {
3970 .name = "log_compression_cpus",
3971 .lname = "Log Compression CPUs",
3972 .type = FIO_OPT_STR,
3973 .cb = str_log_cpus_allowed_cb,
a609f12a 3974 .off1 = offsetof(struct thread_options, log_gz_cpumask),
c08f9fe2
JA		 3975 .parent = "log_compression",
3976 .help = "Limit log compression to these CPUs",
3977 .category = FIO_OPT_C_LOG,
3978 .group = FIO_OPT_G_INVALID,
3979 },
a275c37a
JA		 3980#else
3981 {
3982 .name = "log_compression_cpus",
3983 .lname = "Log Compression CPUs",
3984 .type = FIO_OPT_UNSUPPORTED,
3985 .help = "Your platform does not support CPU affinities",
3986 },
c08f9fe2 3987#endif
b26317c9
JA		 3988 {
3989 .name = "log_store_compressed",
3990 .lname = "Log store compressed",
3991 .type = FIO_OPT_BOOL,
a609f12a 3992 .off1 = offsetof(struct thread_options, log_gz_store),
b26317c9
JA		 3993 .help = "Store logs in a compressed format",
3994 .category = FIO_OPT_C_LOG,
3995 .group = FIO_OPT_G_INVALID,
3996 },
a275c37a
JA		 3997#else
3998 {
3999 .name = "log_compression",
4000 .lname = "Log compression",
4001 .type = FIO_OPT_UNSUPPORTED,
4002 .help = "Install libz-dev(el) to get compression support",
4003 },
4004 {
4005 .name = "log_store_compressed",
4006 .lname = "Log store compressed",
4007 .type = FIO_OPT_UNSUPPORTED,
4008 .help = "Install libz-dev(el) to get compression support",
4009 },
aee2ab67 4010#endif
3aea75b1
KC		 4011 {
4012 .name = "log_unix_epoch",
4013 .lname = "Log epoch unix",
4014 .type = FIO_OPT_BOOL,
4015 .off1 = offsetof(struct thread_options, log_unix_epoch),
4016 .help = "Use Unix time in log files",
4017 .category = FIO_OPT_C_LOG,
4018 .group = FIO_OPT_G_INVALID,
4019 },
66347cfa
DE		 4020 {
4021 .name = "block_error_percentiles",
4022 .lname = "Block error percentiles",
4023 .type = FIO_OPT_BOOL,
a609f12a 4024 .off1 = offsetof(struct thread_options, block_error_hist),
66347cfa
DE		 4025 .help = "Record trim block errors and make a histogram",
4026 .def = "0",
4027 .category = FIO_OPT_C_LOG,
4028 .group = FIO_OPT_G_INVALID,
4029 },
c504ee55
JA		 4030 {
4031 .name = "bwavgtime",
4032 .lname = "Bandwidth average time",
4033 .type = FIO_OPT_INT,
a609f12a 4034 .off1 = offsetof(struct thread_options, bw_avg_time),
c504ee55
JA		 4035 .help = "Time window over which to calculate bandwidth"
4036 " (msec)",
4037 .def = "500",
4038 .parent = "write_bw_log",
4039 .hide = 1,
4040 .interval = 100,
4041 .category = FIO_OPT_C_LOG,
4042 .group = FIO_OPT_G_INVALID,
4043 },
4044 {
4045 .name = "iopsavgtime",
4046 .lname = "IOPS average time",
4047 .type = FIO_OPT_INT,
a609f12a 4048 .off1 = offsetof(struct thread_options, iops_avg_time),
c504ee55
JA		 4049 .help = "Time window over which to calculate IOPS (msec)",
4050 .def = "500",
4051 .parent = "write_iops_log",
4052 .hide = 1,
4053 .interval = 100,
4054 .category = FIO_OPT_C_LOG,
4055 .group = FIO_OPT_G_INVALID,
4056 },
214e1eca
JA		 4057 {
4058 .name = "group_reporting",
e8b0e958 4059 .lname = "Group reporting",
d2507043 4060 .type = FIO_OPT_STR_SET,
a609f12a 4061 .off1 = offsetof(struct thread_options, group_reporting),
214e1eca 4062 .help = "Do reporting on a per-group basis",
10860056 4063 .category = FIO_OPT_C_STAT,
e8b0e958 4064 .group = FIO_OPT_G_INVALID,
214e1eca 4065 },
8243be59
JA		 4066 {
4067 .name = "stats",
4068 .lname = "Stats",
4069 .type = FIO_OPT_BOOL,
4070 .off1 = offsetof(struct thread_options, stats),
4071 .help = "Enable collection of stats",
4072 .def = "1",
4073 .category = FIO_OPT_C_STAT,
4074 .group = FIO_OPT_G_INVALID,
4075 },
e9459e5a
JA		 4076 {
4077 .name = "zero_buffers",
e8b0e958 4078 .lname = "Zero I/O buffers",
e9459e5a 4079 .type = FIO_OPT_STR_SET,
a609f12a 4080 .off1 = offsetof(struct thread_options, zero_buffers),
e9459e5a 4081 .help = "Init IO buffers to all zeroes",
e8b0e958 4082 .category = FIO_OPT_C_IO,
3ceb458f 4083 .group = FIO_OPT_G_IO_BUF,
e9459e5a 4084 },
5973cafb
JA		 4085 {
4086 .name = "refill_buffers",
e8b0e958 4087 .lname = "Refill I/O buffers",
5973cafb 4088 .type = FIO_OPT_STR_SET,
a609f12a 4089 .off1 = offsetof(struct thread_options, refill_buffers),
5973cafb 4090 .help = "Refill IO buffers on every IO submit",
e8b0e958 4091 .category = FIO_OPT_C_IO,
3ceb458f 4092 .group = FIO_OPT_G_IO_BUF,
5973cafb 4093 },
fd68418e
JA		 4094 {
4095 .name = "scramble_buffers",
e8b0e958 4096 .lname = "Scramble I/O buffers",
fd68418e 4097 .type = FIO_OPT_BOOL,
a609f12a 4098 .off1 = offsetof(struct thread_options, scramble_buffers),
fd68418e
JA		 4099 .help = "Slightly scramble buffers on every IO submit",
4100 .def = "1",
e8b0e958 4101 .category = FIO_OPT_C_IO,
3ceb458f 4102 .group = FIO_OPT_G_IO_BUF,
fd68418e 4103 },
ce35b1ec
JA		 4104 {
4105 .name = "buffer_pattern",
4106 .lname = "Buffer pattern",
4107 .type = FIO_OPT_STR,
4108 .cb = str_buffer_pattern_cb,
a609f12a 4109 .off1 = offsetof(struct thread_options, buffer_pattern),
ce35b1ec
JA		 4110 .help = "Fill pattern for IO buffers",
4111 .category = FIO_OPT_C_IO,
4112 .group = FIO_OPT_G_IO_BUF,
4113 },
9c42684e
JA		 4114 {
4115 .name = "buffer_compress_percentage",
e8b0e958 4116 .lname = "Buffer compression percentage",
9c42684e 4117 .type = FIO_OPT_INT,
bedc9dc2 4118 .cb = str_buffer_compress_cb,
a609f12a 4119 .off1 = offsetof(struct thread_options, compress_percentage),
9c42684e 4120 .maxval = 100,
e7f5de90 4121 .minval = 0,
9c42684e 4122 .help = "How compressible the buffer is (approximately)",
20eb06bd 4123 .interval = 5,
e8b0e958 4124 .category = FIO_OPT_C_IO,
3ceb458f 4125 .group = FIO_OPT_G_IO_BUF,
9c42684e 4126 },
f97a43a1
JA		 4127 {
4128 .name = "buffer_compress_chunk",
e8b0e958 4129 .lname = "Buffer compression chunk size",
f97a43a1 4130 .type = FIO_OPT_INT,
a609f12a 4131 .off1 = offsetof(struct thread_options, compress_chunk),
207b18e4 4132 .parent = "buffer_compress_percentage",
d71c154c 4133 .hide = 1,
f97a43a1 4134 .help = "Size of compressible region in buffer",
1de80624 4135 .def = "512",
20eb06bd 4136 .interval = 256,
e8b0e958 4137 .category = FIO_OPT_C_IO,
3ceb458f 4138 .group = FIO_OPT_G_IO_BUF,
f97a43a1 4139 },
5c94b008
JA		 4140 {
4141 .name = "dedupe_percentage",
4142 .lname = "Dedupe percentage",
4143 .type = FIO_OPT_INT,
4144 .cb = str_dedupe_cb,
a609f12a 4145 .off1 = offsetof(struct thread_options, dedupe_percentage),
5c94b008
JA		 4146 .maxval = 100,
4147 .minval = 0,
4148 .help = "Percentage of buffers that are dedupable",
4149 .interval = 1,
4150 .category = FIO_OPT_C_IO,
4151 .group = FIO_OPT_G_IO_BUF,
4152 },
83349190
YH		 4153 {
4154 .name = "clat_percentiles",
e8b0e958 4155 .lname = "Completion latency percentiles",
83349190 4156 .type = FIO_OPT_BOOL,
a609f12a 4157 .off1 = offsetof(struct thread_options, clat_percentiles),
83349190 4158 .help = "Enable the reporting of completion latency percentiles",
467b35ed 4159 .def = "1",
b599759b
JA		 4160 .inverse = "lat_percentiles",
4161 .category = FIO_OPT_C_STAT,
4162 .group = FIO_OPT_G_INVALID,
4163 },
4164 {
4165 .name = "lat_percentiles",
4166 .lname = "IO latency percentiles",
4167 .type = FIO_OPT_BOOL,
4168 .off1 = offsetof(struct thread_options, lat_percentiles),
4169 .help = "Enable the reporting of IO latency percentiles",
4170 .def = "0",
4171 .inverse = "clat_percentiles",
e8b0e958
JA		 4172 .category = FIO_OPT_C_STAT,
4173 .group = FIO_OPT_G_INVALID,
83349190
YH		 4174 },
4175 {
4176 .name = "percentile_list",
66347cfa 4177 .lname = "Percentile list",
83349190 4178 .type = FIO_OPT_FLOAT_LIST,
a609f12a
JA		 4179 .off1 = offsetof(struct thread_options, percentile_list),
4180 .off2 = offsetof(struct thread_options, percentile_precision),
66347cfa
DE		 4181 .help = "Specify a custom list of percentiles to report for "
4182 "completion latency and block errors",
fd112d34 4183 .def = "1:5:10:20:30:40:50:60:70:80:90:95:99:99.5:99.9:99.95:99.99",
83349190
YH		 4184 .maxlen = FIO_IO_U_LIST_MAX_LEN,
4185 .minfp = 0.0,
4186 .maxfp = 100.0,
e8b0e958
JA		 4187 .category = FIO_OPT_C_STAT,
4188 .group = FIO_OPT_G_INVALID,
e883cb35
JF		 4189 },
4190 {
4191 .name = "significant_figures",
4192 .lname = "Significant figures",
4193 .type = FIO_OPT_INT,
4194 .off1 = offsetof(struct thread_options, sig_figs),
4195 .maxval = 10,
4196 .minval = 1,
4197 .help = "Significant figures for output-format set to normal",
4198 .def = "4",
4199 .interval = 1,
4200 .category = FIO_OPT_C_STAT,
4201 .group = FIO_OPT_G_INVALID,
83349190
YH		 4202 },
4203
0a839f30
JA		 4204#ifdef FIO_HAVE_DISK_UTIL
4205 {
4206 .name = "disk_util",
e8b0e958 4207 .lname = "Disk utilization",
0a839f30 4208 .type = FIO_OPT_BOOL,
a609f12a 4209 .off1 = offsetof(struct thread_options, do_disk_util),
f66ab3c8 4210 .help = "Log disk utilization statistics",
0a839f30 4211 .def = "1",
e8b0e958
JA		 4212 .category = FIO_OPT_C_STAT,
4213 .group = FIO_OPT_G_INVALID,
0a839f30 4214 },
a275c37a
JA		 4215#else
4216 {
4217 .name = "disk_util",
4218 .lname = "Disk utilization",
4219 .type = FIO_OPT_UNSUPPORTED,
4220 .help = "Your platform does not support disk utilization",
4221 },
0a839f30 4222#endif
993bf48b
JA		 4223 {
4224 .name = "gtod_reduce",
e8b0e958 4225 .lname = "Reduce gettimeofday() calls",
993bf48b
JA		 4226 .type = FIO_OPT_BOOL,
4227 .help = "Greatly reduce number of gettimeofday() calls",
4228 .cb = str_gtod_reduce_cb,
4229 .def = "0",
a4ed77fe 4230 .hide_on_set = 1,
e8b0e958
JA		 4231 .category = FIO_OPT_C_STAT,
4232 .group = FIO_OPT_G_INVALID,
993bf48b 4233 },
02af0988
JA		 4234 {
4235 .name = "disable_lat",
e8b0e958 4236 .lname = "Disable all latency stats",
02af0988 4237 .type = FIO_OPT_BOOL,
a609f12a 4238 .off1 = offsetof(struct thread_options, disable_lat),
02af0988
JA		 4239 .help = "Disable latency numbers",
4240 .parent = "gtod_reduce",
d71c154c 4241 .hide = 1,
02af0988 4242 .def = "0",
e8b0e958
JA		 4243 .category = FIO_OPT_C_STAT,
4244 .group = FIO_OPT_G_INVALID,
02af0988 4245 },
9520ebb9
JA		 4246 {
4247 .name = "disable_clat",
e8b0e958 4248 .lname = "Disable completion latency stats",
9520ebb9 4249 .type = FIO_OPT_BOOL,
a609f12a 4250 .off1 = offsetof(struct thread_options, disable_clat),
9520ebb9 4251 .help = "Disable completion latency numbers",
993bf48b 4252 .parent = "gtod_reduce",
d71c154c 4253 .hide = 1,
9520ebb9 4254 .def = "0",
e8b0e958
JA		 4255 .category = FIO_OPT_C_STAT,
4256 .group = FIO_OPT_G_INVALID,
9520ebb9
JA		 4257 },
4258 {
4259 .name = "disable_slat",
e8b0e958 4260 .lname = "Disable submission latency stats",
9520ebb9 4261 .type = FIO_OPT_BOOL,
a609f12a 4262 .off1 = offsetof(struct thread_options, disable_slat),
03e20d68 4263 .help = "Disable submission latency numbers",
993bf48b 4264 .parent = "gtod_reduce",
d71c154c 4265 .hide = 1,
9520ebb9 4266 .def = "0",
e8b0e958
JA		 4267 .category = FIO_OPT_C_STAT,
4268 .group = FIO_OPT_G_INVALID,
9520ebb9
JA		 4269 },
4270 {
4271 .name = "disable_bw_measurement",
afd2ceff 4272 .alias = "disable_bw",
e8b0e958 4273 .lname = "Disable bandwidth stats",
9520ebb9 4274 .type = FIO_OPT_BOOL,
a609f12a 4275 .off1 = offsetof(struct thread_options, disable_bw),
9520ebb9 4276 .help = "Disable bandwidth logging",
993bf48b 4277 .parent = "gtod_reduce",
d71c154c 4278 .hide = 1,
9520ebb9 4279 .def = "0",
e8b0e958
JA		 4280 .category = FIO_OPT_C_STAT,
4281 .group = FIO_OPT_G_INVALID,
9520ebb9 4282 },
be4ecfdf
JA		 4283 {
4284 .name = "gtod_cpu",
e8b0e958 4285 .lname = "Dedicated gettimeofday() CPU",
be4ecfdf 4286 .type = FIO_OPT_INT,
a609f12a 4287 .off1 = offsetof(struct thread_options, gtod_cpu),
03e20d68 4288 .help = "Set up dedicated gettimeofday() thread on this CPU",
29d43ff9 4289 .verify = gtod_cpu_verify,
e8b0e958 4290 .category = FIO_OPT_C_GENERAL,
10860056 4291 .group = FIO_OPT_G_CLOCK,
be4ecfdf 4292 },
771e58be
JA		 4293 {
4294 .name = "unified_rw_reporting",
cce2fdfe 4295 .lname = "Unified RW Reporting",
771e58be 4296 .type = FIO_OPT_BOOL,
a609f12a 4297 .off1 = offsetof(struct thread_options, unified_rw_rep),
771e58be
JA		 4298 .help = "Unify reporting across data direction",
4299 .def = "0",
90b7a96d
JA		 4300 .category = FIO_OPT_C_GENERAL,
4301 .group = FIO_OPT_G_INVALID,
771e58be 4302 },
f2bba182
RR		 4303 {
4304 .name = "continue_on_error",
e8b0e958 4305 .lname = "Continue on error",
06842027 4306 .type = FIO_OPT_STR,
a609f12a 4307 .off1 = offsetof(struct thread_options, continue_on_error),
03e20d68 4308 .help = "Continue on non-fatal errors during IO",
06842027 4309 .def = "none",
e8b0e958 4310 .category = FIO_OPT_C_GENERAL,
bc3f552f 4311 .group = FIO_OPT_G_ERR,
06842027
SL		 4312 .posval = {
4313 { .ival = "none",
4314 .oval = ERROR_TYPE_NONE,
4315 .help = "Exit when an error is encountered",
4316 },
4317 { .ival = "read",
4318 .oval = ERROR_TYPE_READ,
4319 .help = "Continue on read errors only",
4320 },
4321 { .ival = "write",
4322 .oval = ERROR_TYPE_WRITE,
4323 .help = "Continue on write errors only",
4324 },
4325 { .ival = "io",
4326 .oval = ERROR_TYPE_READ | ERROR_TYPE_WRITE,
4327 .help = "Continue on any IO errors",
4328 },
4329 { .ival = "verify",
4330 .oval = ERROR_TYPE_VERIFY,
4331 .help = "Continue on verify errors only",
4332 },
4333 { .ival = "all",
4334 .oval = ERROR_TYPE_ANY,
4335 .help = "Continue on all io and verify errors",
4336 },
4337 { .ival = "0",
4338 .oval = ERROR_TYPE_NONE,
4339 .help = "Alias for 'none'",
4340 },
4341 { .ival = "1",
4342 .oval = ERROR_TYPE_ANY,
4343 .help = "Alias for 'all'",
4344 },
4345 },
f2bba182 4346 },
8b28bd41
DM		 4347 {
4348 .name = "ignore_error",
cce2fdfe 4349 .lname = "Ignore Error",
8b28bd41
DM		 4350 .type = FIO_OPT_STR,
4351 .cb = str_ignore_error_cb,
a609f12a 4352 .off1 = offsetof(struct thread_options, ignore_error_nr),
8b28bd41
DM		 4353 .help = "Set a specific list of errors to ignore",
4354 .parent = "rw",
a94eb99a 4355 .category = FIO_OPT_C_GENERAL,
bc3f552f 4356 .group = FIO_OPT_G_ERR,
8b28bd41
DM		 4357 },
4358 {
4359 .name = "error_dump",
cce2fdfe 4360 .lname = "Error Dump",
8b28bd41 4361 .type = FIO_OPT_BOOL,
a609f12a 4362 .off1 = offsetof(struct thread_options, error_dump),
8b28bd41
DM		 4363 .def = "0",
4364 .help = "Dump info on each error",
a94eb99a 4365 .category = FIO_OPT_C_GENERAL,
bc3f552f 4366 .group = FIO_OPT_G_ERR,
8b28bd41 4367 },
9ac8a797
JA		 4368 {
4369 .name = "profile",
e8b0e958 4370 .lname = "Profile",
79d16311 4371 .type = FIO_OPT_STR_STORE,
a609f12a 4372 .off1 = offsetof(struct thread_options, profile),
9ac8a797 4373 .help = "Select a specific builtin performance test",
13fca827 4374 .category = FIO_OPT_C_PROFILE,
e8b0e958 4375 .group = FIO_OPT_G_INVALID,
9ac8a797 4376 },
a696fa2a
JA		 4377 {
4378 .name = "cgroup",
e8b0e958 4379 .lname = "Cgroup",
a696fa2a 4380 .type = FIO_OPT_STR_STORE,
a609f12a 4381 .off1 = offsetof(struct thread_options, cgroup),
a696fa2a 4382 .help = "Add job to cgroup of this name",
e8b0e958 4383 .category = FIO_OPT_C_GENERAL,
a1f6afec
JA		 4384 .group = FIO_OPT_G_CGROUP,
4385 },
4386 {
4387 .name = "cgroup_nodelete",
4388 .lname = "Cgroup no-delete",
4389 .type = FIO_OPT_BOOL,
a609f12a 4390 .off1 = offsetof(struct thread_options, cgroup_nodelete),
a1f6afec
JA		 4391 .help = "Do not delete cgroups after job completion",
4392 .def = "0",
4393 .parent = "cgroup",
4394 .category = FIO_OPT_C_GENERAL,
4395 .group = FIO_OPT_G_CGROUP,
a696fa2a
JA		 4396 },
4397 {
4398 .name = "cgroup_weight",
e8b0e958 4399 .lname = "Cgroup weight",
a696fa2a 4400 .type = FIO_OPT_INT,
a609f12a 4401 .off1 = offsetof(struct thread_options, cgroup_weight),
a696fa2a
JA		 4402 .help = "Use given weight for cgroup",
4403 .minval = 100,
4404 .maxval = 1000,
a1f6afec 4405 .parent = "cgroup",
e8b0e958 4406 .category = FIO_OPT_C_GENERAL,
a1f6afec 4407 .group = FIO_OPT_G_CGROUP,
7de87099 4408 },
e0b0d892
JA		 4409 {
4410 .name = "uid",
e8b0e958 4411 .lname = "User ID",
e0b0d892 4412 .type = FIO_OPT_INT,
a609f12a 4413 .off1 = offsetof(struct thread_options, uid),
e0b0d892 4414 .help = "Run job with this user ID",
e8b0e958 4415 .category = FIO_OPT_C_GENERAL,
10860056 4416 .group = FIO_OPT_G_CRED,
e0b0d892
JA		 4417 },
4418 {
4419 .name = "gid",
e8b0e958 4420 .lname = "Group ID",
e0b0d892 4421 .type = FIO_OPT_INT,
a609f12a 4422 .off1 = offsetof(struct thread_options, gid),
e0b0d892 4423 .help = "Run job with this group ID",
e8b0e958 4424 .category = FIO_OPT_C_GENERAL,
10860056 4425 .group = FIO_OPT_G_CRED,
e0b0d892 4426 },
a1f6afec
JA		 4427 {
4428 .name = "kb_base",
4429 .lname = "KB Base",
4430 .type = FIO_OPT_INT,
a609f12a 4431 .off1 = offsetof(struct thread_options, kb_base),
a1f6afec
JA		 4432 .prio = 1,
4433 .def = "1024",
ba9c7219
JA		 4434 .posval = {
4435 { .ival = "1024",
4436 .oval = 1024,
d694a6a7 4437 .help = "Inputs invert IEC and SI prefixes (for compatibility); outputs prefer binary",
ba9c7219
JA		 4438 },
4439 { .ival = "1000",
4440 .oval = 1000,
d694a6a7 4441 .help = "Inputs use IEC and SI prefixes; outputs prefer SI",
ba9c7219
JA		 4442 },
4443 },
d694a6a7 4444 .help = "Unit prefix interpretation for quantities of data (IEC and SI)",
a1f6afec
JA		 4445 .category = FIO_OPT_C_GENERAL,
4446 .group = FIO_OPT_G_INVALID,
4447 },
cf3a0518
JA		 4448 {
4449 .name = "unit_base",
d694a6a7 4450 .lname = "Unit for quantities of data (Bits or Bytes)",
cf3a0518 4451 .type = FIO_OPT_INT,
a609f12a 4452 .off1 = offsetof(struct thread_options, unit_base),
cf3a0518 4453 .prio = 1,
71a08258
JA		 4454 .posval = {
4455 { .ival = "0",
41a87019 4456 .oval = N2S_NONE,
71a08258
JA		 4457 .help = "Auto-detect",
4458 },
4459 { .ival = "8",
41a87019 4460 .oval = N2S_BYTEPERSEC,
71a08258
JA		 4461 .help = "Normal (byte based)",
4462 },
4463 { .ival = "1",
41a87019 4464 .oval = N2S_BITPERSEC,
71a08258
JA		 4465 .help = "Bit based",
4466 },
4467 },
cf3a0518
JA		 4468 .help = "Bit multiple of result summary data (8 for byte, 1 for bit)",
4469 .category = FIO_OPT_C_GENERAL,
4470 .group = FIO_OPT_G_INVALID,
4471 },
3ceb458f
JA		 4472 {
4473 .name = "hugepage-size",
4474 .lname = "Hugepage size",
4475 .type = FIO_OPT_INT,
a609f12a 4476 .off1 = offsetof(struct thread_options, hugepage_size),
3ceb458f
JA		 4477 .help = "When using hugepages, specify size of each page",
4478 .def = __fio_stringify(FIO_HUGE_PAGE),
4479 .interval = 1024 * 1024,
4480 .category = FIO_OPT_C_GENERAL,
4481 .group = FIO_OPT_G_INVALID,
4482 },
9e684a49
DE		 4483 {
4484 .name = "flow_id",
e8b0e958 4485 .lname = "I/O flow ID",
9e684a49 4486 .type = FIO_OPT_INT,
a609f12a 4487 .off1 = offsetof(struct thread_options, flow_id),
9e684a49
DE		 4488 .help = "The flow index ID to use",
4489 .def = "0",
e8b0e958
JA		 4490 .category = FIO_OPT_C_IO,
4491 .group = FIO_OPT_G_IO_FLOW,
9e684a49
DE		 4492 },
4493 {
4494 .name = "flow",
e8b0e958 4495 .lname = "I/O flow weight",
9e684a49 4496 .type = FIO_OPT_INT,
a609f12a 4497 .off1 = offsetof(struct thread_options, flow),
9e684a49
DE		 4498 .help = "Weight for flow control of this job",
4499 .parent = "flow_id",
d71c154c 4500 .hide = 1,
9e684a49 4501 .def = "0",
e8b0e958
JA		 4502 .category = FIO_OPT_C_IO,
4503 .group = FIO_OPT_G_IO_FLOW,
9e684a49
DE		 4504 },
4505 {
4506 .name = "flow_watermark",
e8b0e958 4507 .lname = "I/O flow watermark",
9e684a49 4508 .type = FIO_OPT_INT,
a609f12a 4509 .off1 = offsetof(struct thread_options, flow_watermark),
9e684a49
DE		 4510 .help = "High watermark for flow control. This option"
4511 " should be set to the same value for all threads"
4512 " with non-zero flow.",
4513 .parent = "flow_id",
d71c154c 4514 .hide = 1,
9e684a49 4515 .def = "1024",
e8b0e958
JA		 4516 .category = FIO_OPT_C_IO,
4517 .group = FIO_OPT_G_IO_FLOW,
9e684a49
DE		 4518 },
4519 {
4520 .name = "flow_sleep",
e8b0e958 4521 .lname = "I/O flow sleep",
9e684a49 4522 .type = FIO_OPT_INT,
a609f12a 4523 .off1 = offsetof(struct thread_options, flow_sleep),
9e684a49
DE		 4524 .help = "How many microseconds to sleep after being held"
4525 " back by the flow control mechanism",
4526 .parent = "flow_id",
d71c154c 4527 .hide = 1,
9e684a49 4528 .def = "0",
e8b0e958
JA		 4529 .category = FIO_OPT_C_IO,
4530 .group = FIO_OPT_G_IO_FLOW,
9e684a49 4531 },
16e56d25
VF		 4532 {
4533 .name = "steadystate",
4534 .lname = "Steady state threshold",
4535 .alias = "ss",
4536 .type = FIO_OPT_STR,
2c5d94bc 4537 .off1 = offsetof(struct thread_options, ss_state),
16e56d25
VF		 4538 .cb = str_steadystate_cb,
4539 .help = "Define the criterion and limit to judge when a job has reached steady state",
4540 .def = "iops_slope:0.01%",
4541 .posval = {
4542 { .ival = "iops",
f0c50c66 4543 .oval = FIO_SS_IOPS,
16e56d25
VF		 4544 .help = "maximum mean deviation of IOPS measurements",
4545 },
4546 { .ival = "iops_slope",
f0c50c66 4547 .oval = FIO_SS_IOPS_SLOPE,
16e56d25
VF		 4548 .help = "slope calculated from IOPS measurements",
4549 },
4550 { .ival = "bw",
f0c50c66 4551 .oval = FIO_SS_BW,
16e56d25
VF		 4552 .help = "maximum mean deviation of bandwidth measurements",
4553 },
4554 {
4555 .ival = "bw_slope",
f0c50c66 4556 .oval = FIO_SS_BW_SLOPE,
16e56d25
VF		 4557 .help = "slope calculated from bandwidth measurements",
4558 },
4559 },
4560 .category = FIO_OPT_C_GENERAL,
4561 .group = FIO_OPT_G_RUNTIME,
4562 },
4563 {
4564 .name = "steadystate_duration",
4565 .lname = "Steady state duration",
4566 .alias = "ss_dur",
915ca980 4567 .parent = "steadystate",
16e56d25
VF		 4568 .type = FIO_OPT_STR_VAL_TIME,
4569 .off1 = offsetof(struct thread_options, ss_dur),
4570 .help = "Stop workload upon attaining steady state for specified duration",
4571 .def = "0",
4572 .is_seconds = 1,
4573 .is_time = 1,
4574 .category = FIO_OPT_C_GENERAL,
4575 .group = FIO_OPT_G_RUNTIME,
4576 },
4577 {
4578 .name = "steadystate_ramp_time",
4579 .lname = "Steady state ramp time",
4580 .alias = "ss_ramp",
915ca980 4581 .parent = "steadystate",
16e56d25
VF		 4582 .type = FIO_OPT_STR_VAL_TIME,
4583 .off1 = offsetof(struct thread_options, ss_ramp_time),
4584 .help = "Delay before initiation of data collection for steady state job termination testing",
4585 .def = "0",
4586 .is_seconds = 1,
4587 .is_time = 1,
4588 .category = FIO_OPT_C_GENERAL,
4589 .group = FIO_OPT_G_RUNTIME,
4590 },
214e1eca
JA		 4591 {
4592 .name = NULL,
4593 },
4594};
4595
17af15d4 4596static void add_to_lopt(struct option *lopt, struct fio_option *o,
de890a1e 4597 const char *name, int val)
9f81736c 4598{
17af15d4 4599 lopt->name = (char *) name;
de890a1e 4600 lopt->val = val;
9f81736c 4601 if (o->type == FIO_OPT_STR_SET)
ff52be3d 4602 lopt->has_arg = optional_argument;
9f81736c
JA		 4603 else
4604 lopt->has_arg = required_argument;
4605}
4606
de890a1e
SL		 4607static void options_to_lopts(struct fio_option *opts,
4608 struct option *long_options,
4609 int i, int option_type)
214e1eca 4610{
de890a1e 4611 struct fio_option *o = &opts[0];
214e1eca 4612 while (o->name) {
de890a1e 4613 add_to_lopt(&long_options[i], o, o->name, option_type);
17af15d4
JA		 4614 if (o->alias) {
4615 i++;
de890a1e 4616 add_to_lopt(&long_options[i], o, o->alias, option_type);
17af15d4 4617 }
214e1eca
JA		 4618
4619 i++;
4620 o++;
4621 assert(i < FIO_NR_OPTIONS);
4622 }
4623}
4624
de890a1e
SL		 4625void fio_options_set_ioengine_opts(struct option *long_options,
4626 struct thread_data *td)
4627{
4628 unsigned int i;
4629
4630 i = 0;
4631 while (long_options[i].name) {
4632 if (long_options[i].val == FIO_GETOPT_IOENGINE) {
4633 memset(&long_options[i], 0, sizeof(*long_options));
4634 break;
4635 }
4636 i++;
4637 }
4638
4639 /*
4640 * Just clear out the prior ioengine options.
4641 */
4642 if (!td || !td->eo)
4643 return;
4644
4645 options_to_lopts(td->io_ops->options, long_options, i,
4646 FIO_GETOPT_IOENGINE);
4647}
4648
4649void fio_options_dup_and_init(struct option *long_options)
4650{
4651 unsigned int i;
4652
9af4a244 4653 options_init(fio_options);
de890a1e
SL		 4654
4655 i = 0;
4656 while (long_options[i].name)
4657 i++;
4658
9af4a244 4659 options_to_lopts(fio_options, long_options, i, FIO_GETOPT_JOB);
de890a1e
SL		 4660}
4661
74929ac2
JA		 4662struct fio_keyword {
4663 const char *word;
4664 const char *desc;
4665 char *replace;
4666};
4667
4668static struct fio_keyword fio_keywords[] = {
4669 {
4670 .word = "$pagesize",
4671 .desc = "Page size in the system",
4672 },
4673 {
4674 .word = "$mb_memory",
4675 .desc = "Megabytes of memory online",
4676 },
4677 {
4678 .word = "$ncpus",
4679 .desc = "Number of CPUs online in the system",
4680 },
4681 {
4682 .word = NULL,
4683 },
4684};
4685
af1dc266
JA		 4686void fio_keywords_exit(void)
4687{
4688 struct fio_keyword *kw;
4689
4690 kw = &fio_keywords[0];
4691 while (kw->word) {
4692 free(kw->replace);
4693 kw->replace = NULL;
4694 kw++;
4695 }
4696}
4697
74929ac2
JA		 4698void fio_keywords_init(void)
4699{
3b2e1464 4700 unsigned long long mb_memory;
74929ac2
JA		 4701 char buf[128];
4702 long l;
4703
a4cfc477 4704 sprintf(buf, "%lu", (unsigned long) page_size);
74929ac2
JA		 4705 fio_keywords[0].replace = strdup(buf);
4706
8eb016d3 4707 mb_memory = os_phys_mem() / (1024 * 1024);
3b2e1464 4708 sprintf(buf, "%llu", mb_memory);
74929ac2
JA		 4709 fio_keywords[1].replace = strdup(buf);
4710
c00a2289 4711 l = cpus_online();
74929ac2
JA		 4712 sprintf(buf, "%lu", l);
4713 fio_keywords[2].replace = strdup(buf);
4714}
4715
892a6ffc
JA		 4716#define BC_APP "bc"
4717
4718static char *bc_calc(char *str)
4719{
d0c814ec 4720 char buf[128], *tmp;
892a6ffc
JA		 4721 FILE *f;
4722 int ret;
4723
4724 /*
4725 * No math, just return string
4726 */
d0c814ec
SL		 4727 if ((!strchr(str, '+') && !strchr(str, '-') && !strchr(str, '*') &&
4728 !strchr(str, '/')) || strchr(str, '\''))
892a6ffc
JA		 4729 return str;
4730
4731 /*
4732 * Split option from value, we only need to calculate the value
4733 */
4734 tmp = strchr(str, '=');
4735 if (!tmp)
4736 return str;
4737
4738 tmp++;
892a6ffc 4739
d0c814ec
SL		 4740 /*
4741 * Prevent buffer overflows; such a case isn't reasonable anyway
4742 */
4743 if (strlen(str) >= 128 || strlen(tmp) > 100)
4744 return str;
892a6ffc
JA		 4745
4746 sprintf(buf, "which %s > /dev/null", BC_APP);
4747 if (system(buf)) {
4748 log_err("fio: bc is needed for performing math\n");
892a6ffc
JA		 4749 return NULL;
4750 }
4751
d0c814ec 4752 sprintf(buf, "echo '%s' | %s", tmp, BC_APP);
892a6ffc 4753 f = popen(buf, "r");
3c3ed070 4754 if (!f)
892a6ffc 4755 return NULL;
892a6ffc 4756
d0c814ec 4757 ret = fread(&buf[tmp - str], 1, 128 - (tmp - str), f);
1d824f37
JA		 4758 if (ret <= 0) {
4759 pclose(f);
892a6ffc 4760 return NULL;
1d824f37 4761 }
892a6ffc 4762
892a6ffc 4763 pclose(f);
d0c814ec
SL		 4764 buf[(tmp - str) + ret - 1] = '\0';
4765 memcpy(buf, str, tmp - str);
892a6ffc 4766 free(str);
d0c814ec
SL		 4767 return strdup(buf);
4768}
4769
4770/*
4771 * Return a copy of the input string with substrings of the form ${VARNAME}
4772 * substituted with the value of the environment variable VARNAME. The
4773 * substitution always occurs, even if VARNAME is empty or the corresponding
4774 * environment variable undefined.
4775 */
b4f5e72f 4776char *fio_option_dup_subs(const char *opt)
d0c814ec
SL		 4777{
4778 char out[OPT_LEN_MAX+1];
4779 char in[OPT_LEN_MAX+1];
4780 char *outptr = out;
4781 char *inptr = in;
4782 char *ch1, *ch2, *env;
4783 ssize_t nchr = OPT_LEN_MAX;
4784 size_t envlen;
4785
4786 if (strlen(opt) + 1 > OPT_LEN_MAX) {
4787 log_err("OPT_LEN_MAX (%d) is too small\n", OPT_LEN_MAX);
4788 return NULL;
4789 }
4790
4791 in[OPT_LEN_MAX] = '\0';
4792 strncpy(in, opt, OPT_LEN_MAX);
4793
4794 while (*inptr && nchr > 0) {
4795 if (inptr[0] == '$' && inptr[1] == '{') {
4796 ch2 = strchr(inptr, '}');
4797 if (ch2 && inptr+1 < ch2) {
4798 ch1 = inptr+2;
4799 inptr = ch2+1;
4800 *ch2 = '\0';
4801
4802 env = getenv(ch1);
4803 if (env) {
4804 envlen = strlen(env);
4805 if (envlen <= nchr) {
4806 memcpy(outptr, env, envlen);
4807 outptr += envlen;
4808 nchr -= envlen;
4809 }
4810 }
4811
4812 continue;
4813 }
4814 }
4815
4816 *outptr++ = *inptr++;
4817 --nchr;
4818 }
4819
4820 *outptr = '\0';
4821 return strdup(out);
892a6ffc
JA		 4822}
4823
74929ac2
JA		 4824/*
4825 * Look for reserved variable names and replace them with real values
4826 */
4827static char *fio_keyword_replace(char *opt)
4828{
4829 char *s;
4830 int i;
d0c814ec 4831 int docalc = 0;
74929ac2
JA		 4832
4833 for (i = 0; fio_keywords[i].word != NULL; i++) {
4834 struct fio_keyword *kw = &fio_keywords[i];
4835
4836 while ((s = strstr(opt, kw->word)) != NULL) {
4837 char *new = malloc(strlen(opt) + 1);
4838 char *o_org = opt;
4839 int olen = s - opt;
4840 int len;
4841
4842 /*
4843 * Copy part of the string before the keyword and
4844 * sprintf() the replacement after it.
4845 */
4846 memcpy(new, opt, olen);
4847 len = sprintf(new + olen, "%s", kw->replace);
4848
4849 /*
4850 * If there's more in the original string, copy that
4851 * in too
4852 */
4853 opt += strlen(kw->word) + olen;
4854 if (strlen(opt))
4855 memcpy(new + olen + len, opt, opt - o_org - 1);
4856
4857 /*
4858 * replace opt and free the old opt
4859 */
4860 opt = new;
d0c814ec 4861 free(o_org);
7a958bd5 4862
d0c814ec 4863 docalc = 1;
74929ac2
JA		 4864 }
4865 }
4866
d0c814ec
SL		 4867 /*
4868 * Check for potential math and invoke bc, if possible
4869 */
4870 if (docalc)
4871 opt = bc_calc(opt);
4872
7a958bd5 4873 return opt;
74929ac2
JA		 4874}
4875
d0c814ec
SL		 4876static char **dup_and_sub_options(char **opts, int num_opts)
4877{
4878 int i;
4879 char **opts_copy = malloc(num_opts * sizeof(*opts));
4880 for (i = 0; i < num_opts; i++) {
b4f5e72f 4881 opts_copy[i] = fio_option_dup_subs(opts[i]);
d0c814ec
SL		 4882 if (!opts_copy[i])
4883 continue;
4884 opts_copy[i] = fio_keyword_replace(opts_copy[i]);
4885 }
4886 return opts_copy;
4887}
4888
e15b023b 4889static void show_closest_option(const char *opt)
a2d027b9
JA		 4890{
4891 int best_option, best_distance;
4892 int i, distance;
e15b023b
JA		 4893 char *name;
4894
4895 if (!strlen(opt))
4896 return;
4897
4898 name = strdup(opt);
4899 i = 0;
4900 while (name[i] != '\0' && name[i] != '=')
4901 i++;
4902 name[i] = '\0';
a2d027b9
JA		 4903
4904 best_option = -1;
4905 best_distance = INT_MAX;
4906 i = 0;
4907 while (fio_options[i].name) {
4908 distance = string_distance(name, fio_options[i].name);
4909 if (distance < best_distance) {
4910 best_distance = distance;
4911 best_option = i;
4912 }
4913 i++;
4914 }
4915
75e6bcba
JA		 4916 if (best_option != -1 && string_distance_ok(name, best_distance) &&
4917 fio_options[best_option].type != FIO_OPT_UNSUPPORTED)
a2d027b9 4918 log_err("Did you mean %s?\n", fio_options[best_option].name);
e15b023b
JA		 4919
4920 free(name);
a2d027b9
JA		 4921}
4922
c2292325 4923int fio_options_parse(struct thread_data *td, char **opts, int num_opts)
214e1eca 4924{
de890a1e 4925 int i, ret, unknown;
d0c814ec 4926 char **opts_copy;
3b8b7135 4927
9af4a244 4928 sort_options(opts, fio_options, num_opts);
d0c814ec 4929 opts_copy = dup_and_sub_options(opts, num_opts);
3b8b7135 4930
de890a1e 4931 for (ret = 0, i = 0, unknown = 0; i < num_opts; i++) {
9109883a 4932 const struct fio_option *o;
9af4a244 4933 int newret = parse_option(opts_copy[i], opts[i], fio_options,
a609f12a 4934 &o, &td->o, &td->opt_list);
d0c814ec 4935
a8523a6a
JA		 4936 if (!newret && o)
4937 fio_option_mark_set(&td->o, o);
4938
de890a1e
SL		 4939 if (opts_copy[i]) {
4940 if (newret && !o) {
4941 unknown++;
4942 continue;
4943 }
d0c814ec 4944 free(opts_copy[i]);
de890a1e
SL		 4945 opts_copy[i] = NULL;
4946 }
4947
4948 ret |= newret;
4949 }
4950
4951 if (unknown) {
4952 ret |= ioengine_load(td);
4953 if (td->eo) {
4954 sort_options(opts_copy, td->io_ops->options, num_opts);
4955 opts = opts_copy;
4956 }
4957 for (i = 0; i < num_opts; i++) {
9109883a 4958 const struct fio_option *o = NULL;
de890a1e 4959 int newret = 1;
a2d027b9 4960
de890a1e
SL		 4961 if (!opts_copy[i])
4962 continue;
4963
4964 if (td->eo)
4965 newret = parse_option(opts_copy[i], opts[i],
4966 td->io_ops->options, &o,
66e19a38 4967 td->eo, &td->opt_list);
de890a1e
SL		 4968
4969 ret |= newret;
a2d027b9 4970 if (!o) {
de890a1e 4971 log_err("Bad option <%s>\n", opts[i]);
a2d027b9
JA		 4972 show_closest_option(opts[i]);
4973 }
de890a1e
SL		 4974 free(opts_copy[i]);
4975 opts_copy[i] = NULL;
4976 }
74929ac2 4977 }
3b8b7135 4978
d0c814ec 4979 free(opts_copy);
3b8b7135 4980 return ret;
214e1eca
JA		 4981}
4982
4983int fio_cmd_option_parse(struct thread_data *td, const char *opt, char *val)
4984{
a8523a6a
JA		 4985 int ret;
4986
a609f12a 4987 ret = parse_cmd_option(opt, val, fio_options, &td->o, &td->opt_list);
a8523a6a 4988 if (!ret) {
9109883a 4989 const struct fio_option *o;
a8523a6a 4990
9109883a 4991 o = find_option_c(fio_options, opt);
a8523a6a
JA		 4992 if (o)
4993 fio_option_mark_set(&td->o, o);
4994 }
4995
4996 return ret;
214e1eca
JA		 4997}
4998
de890a1e
SL		 4999int fio_cmd_ioengine_option_parse(struct thread_data *td, const char *opt,
5000 char *val)
5001{
d8b4f395
JA		 5002 return parse_cmd_option(opt, val, td->io_ops->options, td->eo,
5003 &td->opt_list);
de890a1e
SL		 5004}
5005
214e1eca
JA		 5006void fio_fill_default_options(struct thread_data *td)
5007{
cb1402d6 5008 td->o.magic = OPT_MAGIC;
a609f12a 5009 fill_default_options(&td->o, fio_options);
214e1eca
JA		 5010}
5011
5012int fio_show_option_help(const char *opt)
5013{
9af4a244 5014 return show_cmd_help(fio_options, opt);
214e1eca 5015}
d23bb327 5016
de890a1e
SL		 5017/*
5018 * dupe FIO_OPT_STR_STORE options
5019 */
5020void fio_options_mem_dupe(struct thread_data *td)
5021{
53b5693d 5022 options_mem_dupe(fio_options, &td->o);
1647f592
JA		 5023
5024 if (td->eo && td->io_ops) {
de890a1e 5025 void *oldeo = td->eo;
1647f592 5026
de890a1e
SL		 5027 td->eo = malloc(td->io_ops->option_struct_size);
5028 memcpy(td->eo, oldeo, td->io_ops->option_struct_size);
53b5693d 5029 options_mem_dupe(td->io_ops->options, td->eo);
de890a1e
SL		 5030 }
5031}
5032
d6978a32
JA		 5033unsigned int fio_get_kb_base(void *data)
5034{
a609f12a
JA		 5035 struct thread_data *td = cb_data_to_td(data);
5036 struct thread_options *o = &td->o;
d6978a32
JA		 5037 unsigned int kb_base = 0;
5038
cb1402d6
JA		 5039 /*
5040 * This is a hack... For private options, *data is not holding
5041 * a pointer to the thread_options, but to private data. This means
5042 * we can't safely dereference it, but magic is first so mem wise
5043 * it is valid. But this also means that if the job first sets
5044 * kb_base and expects that to be honored by private options,
5045 * it will be disappointed. We will return the global default
5046 * for this.
5047 */
5048 if (o && o->magic == OPT_MAGIC)
83ea422a 5049 kb_base = o->kb_base;
d6978a32
JA		 5050 if (!kb_base)
5051 kb_base = 1024;
5052
5053 return kb_base;
5054}
9f988e2e 5055
9109883a 5056int add_option(const struct fio_option *o)
9f988e2e 5057{
07b3232d
JA		 5058 struct fio_option *__o;
5059 int opt_index = 0;
5060
9af4a244 5061 __o = fio_options;
07b3232d
JA		 5062 while (__o->name) {
5063 opt_index++;
5064 __o++;
5065 }
5066
7b504edd
JA		 5067 if (opt_index + 1 == FIO_MAX_OPTS) {
5068 log_err("fio: FIO_MAX_OPTS is too small\n");
5069 return 1;
5070 }
5071
9af4a244 5072 memcpy(&fio_options[opt_index], o, sizeof(*o));
7b504edd 5073 fio_options[opt_index + 1].name = NULL;
07b3232d 5074 return 0;
9f988e2e 5075}
e2de69da 5076
07b3232d 5077void invalidate_profile_options(const char *prof_name)
e2de69da 5078{
07b3232d 5079 struct fio_option *o;
e2de69da 5080
9af4a244 5081 o = fio_options;
07b3232d
JA		 5082 while (o->name) {
5083 if (o->prof_name && !strcmp(o->prof_name, prof_name)) {
5084 o->type = FIO_OPT_INVALID;
5085 o->prof_name = NULL;
5086 }
5087 o++;
e2de69da
JA		 5088 }
5089}
f5b6bb85
JA		 5090
5091void add_opt_posval(const char *optname, const char *ival, const char *help)
5092{
5093 struct fio_option *o;
5094 unsigned int i;
5095
9af4a244 5096 o = find_option(fio_options, optname);
f5b6bb85
JA		 5097 if (!o)
5098 return;
5099
5100 for (i = 0; i < PARSE_MAX_VP; i++) {
5101 if (o->posval[i].ival)
5102 continue;
5103
5104 o->posval[i].ival = ival;
5105 o->posval[i].help = help;
5106 break;
5107 }
5108}
5109
5110void del_opt_posval(const char *optname, const char *ival)
5111{
5112 struct fio_option *o;
5113 unsigned int i;
5114
9af4a244 5115 o = find_option(fio_options, optname);
f5b6bb85
JA		 5116 if (!o)
5117 return;
5118
5119 for (i = 0; i < PARSE_MAX_VP; i++) {
5120 if (!o->posval[i].ival)
5121 continue;
5122 if (strcmp(o->posval[i].ival, ival))
5123 continue;
5124
5125 o->posval[i].ival = NULL;
5126 o->posval[i].help = NULL;
5127 }
5128}
7e356b2d
JA		 5129
5130void fio_options_free(struct thread_data *td)
5131{
ca6336a8 5132 options_free(fio_options, &td->o);
de890a1e
SL		 5133 if (td->eo && td->io_ops && td->io_ops->options) {
5134 options_free(td->io_ops->options, td->eo);
5135 free(td->eo);
5136 td->eo = NULL;
5137 }
7e356b2d 5138}
c504ee55
JA		 5139
5140struct fio_option *fio_option_find(const char *name)
5141{
5142 return find_option(fio_options, name);
5143}
5144
517c9c72 5145static struct fio_option *find_next_opt(struct fio_option *from,
f0e7f45a 5146 unsigned int off1)
a8523a6a 5147{
f0e7f45a 5148 struct fio_option *opt;
a8523a6a 5149
f0e7f45a
JA		 5150 if (!from)
5151 from = &fio_options[0];
5152 else
5153 from++;
5154
5155 opt = NULL;
5156 do {
5157 if (off1 == from->off1) {
5158 opt = from;
a8523a6a
JA		 5159 break;
5160 }
f0e7f45a
JA		 5161 from++;
5162 } while (from->name);
a8523a6a 5163
f0e7f45a
JA		 5164 return opt;
5165}
5166
5167static int opt_is_set(struct thread_options *o, struct fio_option *opt)
5168{
5169 unsigned int opt_off, index, offset;
a8523a6a
JA		 5170
5171 opt_off = opt - &fio_options[0];
5172 index = opt_off / (8 * sizeof(uint64_t));
5173 offset = opt_off & ((8 * sizeof(uint64_t)) - 1);
e9d686d6 5174 return (o->set_options[index] & ((uint64_t)1 << offset)) != 0;
a8523a6a
JA		 5175}
5176
72f39748 5177bool __fio_option_is_set(struct thread_options *o, unsigned int off1)
f0e7f45a
JA		 5178{
5179 struct fio_option *opt, *next;
5180
5181 next = NULL;
517c9c72 5182 while ((opt = find_next_opt(next, off1)) != NULL) {
f0e7f45a 5183 if (opt_is_set(o, opt))
72f39748 5184 return true;
f0e7f45a
JA		 5185
5186 next = opt;
5187 }
5188
72f39748 5189 return false;
f0e7f45a
JA		 5190}
5191
9109883a 5192void fio_option_mark_set(struct thread_options *o, const struct fio_option *opt)
a8523a6a
JA		 5193{
5194 unsigned int opt_off, index, offset;
5195
5196 opt_off = opt - &fio_options[0];
5197 index = opt_off / (8 * sizeof(uint64_t));
5198 offset = opt_off & ((8 * sizeof(uint64_t)) - 1);
e9d686d6 5199 o->set_options[index] |= (uint64_t)1 << offset;
a8523a6a 5200}
fio - Flexible IO Tester