Improve latency_target runs
[fio.git] / parse.c
CommitLineData
cb2c86fd
JA
1/*
2 * This file contains the ini and command liner parser main.
3 */
4#include <stdio.h>
5#include <stdlib.h>
6#include <unistd.h>
7#include <ctype.h>
8#include <string.h>
9#include <errno.h>
10#include <limits.h>
88b5a391 11#include <stdlib.h>
83349190 12#include <math.h>
ab9461ea 13#include <float.h>
cb2c86fd
JA
14
15#include "parse.h"
a3d741fa 16#include "debug.h"
9f988e2e 17#include "options.h"
e25839d4 18#include "minmax.h"
fd112d34 19#include "lib/ieee754.h"
cb2c86fd 20
9af4a244 21static struct fio_option *__fio_options;
3b8b7135 22
f085737f
JA
23static int vp_cmp(const void *p1, const void *p2)
24{
25 const struct value_pair *vp1 = p1;
26 const struct value_pair *vp2 = p2;
27
28 return strlen(vp2->ival) - strlen(vp1->ival);
29}
30
ce952ab6 31static void posval_sort(struct fio_option *o, struct value_pair *vpmap)
f085737f
JA
32{
33 const struct value_pair *vp;
34 int entries;
35
36 memset(vpmap, 0, PARSE_MAX_VP * sizeof(struct value_pair));
37
38 for (entries = 0; entries < PARSE_MAX_VP; entries++) {
39 vp = &o->posval[entries];
40 if (!vp->ival || vp->ival[0] == '\0')
41 break;
42
43 memcpy(&vpmap[entries], vp, sizeof(*vp));
44 }
45
46 qsort(vpmap, entries, sizeof(struct value_pair), vp_cmp);
47}
48
06b0be6e
JA
49static void show_option_range(struct fio_option *o,
50 int (*logger)(const char *format, ...))
b1ec1da6 51{
3c037bcf 52 if (o->type == FIO_OPT_FLOAT_LIST) {
ab9461ea 53 if (o->minfp == DBL_MIN && o->maxfp == DBL_MAX)
83349190
YH
54 return;
55
06b0be6e 56 logger("%20s: min=%f", "range", o->minfp);
ab9461ea 57 if (o->maxfp != DBL_MAX)
06b0be6e
JA
58 logger(", max=%f", o->maxfp);
59 logger("\n");
3c037bcf 60 } else if (!o->posval[0].ival) {
83349190
YH
61 if (!o->minval && !o->maxval)
62 return;
b1ec1da6 63
06b0be6e 64 logger("%20s: min=%d", "range", o->minval);
83349190 65 if (o->maxval)
06b0be6e
JA
66 logger(", max=%d", o->maxval);
67 logger("\n");
83349190 68 }
b1ec1da6
JA
69}
70
71static void show_option_values(struct fio_option *o)
72{
a3073f4a 73 int i;
b1ec1da6 74
a3073f4a 75 for (i = 0; i < PARSE_MAX_VP; i++) {
7837213b 76 const struct value_pair *vp = &o->posval[i];
b1ec1da6 77
7837213b 78 if (!vp->ival)
a3073f4a 79 continue;
b1ec1da6 80
06b0be6e 81 log_info("%20s: %-10s", i == 0 ? "valid values" : "", vp->ival);
7837213b 82 if (vp->help)
06b0be6e
JA
83 log_info(" %s", vp->help);
84 log_info("\n");
a3073f4a 85 }
b1ec1da6
JA
86
87 if (i)
06b0be6e 88 log_info("\n");
b1ec1da6
JA
89}
90
06b0be6e 91static void show_option_help(struct fio_option *o, int is_err)
d447a8c2
JA
92{
93 const char *typehelp[] = {
07b3232d 94 "invalid",
d447a8c2 95 "string (opt=bla)",
ae3fb6fb 96 "string (opt=bla)",
d447a8c2
JA
97 "string with possible k/m/g postfix (opt=4k)",
98 "string with time postfix (opt=10s)",
99 "string (opt=bla)",
100 "string with dual range (opt=1k-4k,4k-8k)",
101 "integer value (opt=100)",
102 "boolean value (opt=1)",
83349190 103 "list of floating point values separated by ':' (opt=5.9:7.8)",
d447a8c2 104 "no argument (opt)",
07b3232d 105 "deprecated",
d447a8c2 106 };
06b0be6e
JA
107 int (*logger)(const char *format, ...);
108
109 if (is_err)
110 logger = log_err;
111 else
112 logger = log_info;
d447a8c2
JA
113
114 if (o->alias)
06b0be6e 115 logger("%20s: %s\n", "alias", o->alias);
d447a8c2 116
06b0be6e
JA
117 logger("%20s: %s\n", "type", typehelp[o->type]);
118 logger("%20s: %s\n", "default", o->def ? o->def : "no default");
07b3232d 119 if (o->prof_name)
06b0be6e
JA
120 logger("%20s: only for profile '%s'\n", "valid", o->prof_name);
121 show_option_range(o, logger);
d447a8c2
JA
122 show_option_values(o);
123}
124
74454ce4 125static unsigned long long get_mult_time(const char *str, int len)
cb2c86fd 126{
74454ce4
CE
127 const char *p = str;
128 char *c;
e4668264 129 unsigned long long mult = 1;
74454ce4
CE
130
131 /*
132 * Go forward until we hit a non-digit, or +/- sign
133 */
134 while ((p - str) <= len) {
135 if (!isdigit((int) *p) && (*p != '+') && (*p != '-'))
136 break;
137 p++;
cb2c86fd 138 }
74454ce4
CE
139
140 if (!isalpha((int) *p))
e4668264 141 return mult;
74454ce4
CE
142
143 c = strdup(p);
144 for (int i = 0; i < strlen(c); i++)
145 c[i] = tolower(c[i]);
146
e4668264 147 if (!strncmp("us", c, 2) || !strncmp("usec", c, 4))
74454ce4 148 mult = 1;
e4668264 149 else if (!strncmp("ms", c, 2) || !strncmp("msec", c, 4))
74454ce4 150 mult = 1000;
e4668264
JA
151 else if (!strcmp("s", c))
152 mult = 1000000;
74454ce4 153 else if (!strcmp("m", c))
e4668264 154 mult = 60 * 1000000UL;
74454ce4 155 else if (!strcmp("h", c))
e4668264 156 mult = 60 * 60 * 1000000UL;
74454ce4 157 else if (!strcmp("d", c))
e4668264 158 mult = 24 * 60 * 60 * 1000000UL;
74454ce4
CE
159
160 free(c);
161 return mult;
cb2c86fd
JA
162}
163
a03fb65f
JA
164static int is_separator(char c)
165{
166 switch (c) {
167 case ':':
168 case '-':
169 case ',':
170 case '/':
171 return 1;
172 default:
173 return 0;
174 }
175}
176
7bb59102
JA
177static unsigned long long __get_mult_bytes(const char *p, void *data,
178 int *percent)
cb2c86fd 179{
d6978a32 180 unsigned int kb_base = fio_get_kb_base(data);
a639f0bb 181 unsigned long long ret = 1;
57fc29fa
JA
182 unsigned int i, pow = 0, mult = kb_base;
183 char *c;
a639f0bb 184
57fc29fa
JA
185 if (!p)
186 return 1;
a639f0bb 187
57fc29fa
JA
188 c = strdup(p);
189
a03fb65f 190 for (i = 0; i < strlen(c); i++) {
57fc29fa 191 c[i] = tolower(c[i]);
a03fb65f
JA
192 if (is_separator(c[i])) {
193 c[i] = '\0';
194 break;
195 }
196 }
57fc29fa 197
a04f158d 198 if (!strncmp("pib", c, 3)) {
57fc29fa
JA
199 pow = 5;
200 mult = 1000;
a04f158d 201 } else if (!strncmp("tib", c, 3)) {
57fc29fa
JA
202 pow = 4;
203 mult = 1000;
a04f158d 204 } else if (!strncmp("gib", c, 3)) {
57fc29fa
JA
205 pow = 3;
206 mult = 1000;
a04f158d 207 } else if (!strncmp("mib", c, 3)) {
57fc29fa
JA
208 pow = 2;
209 mult = 1000;
a04f158d 210 } else if (!strncmp("kib", c, 3)) {
57fc29fa
JA
211 pow = 1;
212 mult = 1000;
a04f158d 213 } else if (!strncmp("p", c, 1) || !strncmp("pb", c, 2))
57fc29fa 214 pow = 5;
a04f158d 215 else if (!strncmp("t", c, 1) || !strncmp("tb", c, 2))
57fc29fa 216 pow = 4;
a04f158d 217 else if (!strncmp("g", c, 1) || !strncmp("gb", c, 2))
57fc29fa 218 pow = 3;
a04f158d 219 else if (!strncmp("m", c, 1) || !strncmp("mb", c, 2))
57fc29fa 220 pow = 2;
a04f158d 221 else if (!strncmp("k", c, 1) || !strncmp("kb", c, 2))
57fc29fa 222 pow = 1;
a04f158d 223 else if (!strncmp("%", c, 1)) {
7bb59102 224 *percent = 1;
e721c57f 225 free(c);
7bb59102
JA
226 return ret;
227 }
57fc29fa
JA
228
229 while (pow--)
230 ret *= (unsigned long long) mult;
231
232 free(c);
a639f0bb 233 return ret;
cb2c86fd
JA
234}
235
7bb59102 236static unsigned long long get_mult_bytes(const char *str, int len, void *data,
6925dd35 237 int *percent)
57fc29fa 238{
55ed9636 239 const char *p = str;
ba4ddd69 240 int digit_seen = 0;
57fc29fa 241
1d1c187b 242 if (len < 2)
7bb59102 243 return __get_mult_bytes(str, data, percent);
1d1c187b 244
d0c814ec
SL
245 /*
246 * Go forward until we hit a non-digit, or +/- sign
247 */
55ed9636 248 while ((p - str) <= len) {
ba4ddd69
JA
249 if (!isdigit((int) *p) &&
250 (((*p != '+') && (*p != '-')) || digit_seen))
55ed9636 251 break;
3c703d13 252 digit_seen |= isdigit((int) *p);
55ed9636
JA
253 p++;
254 }
255
7bb59102 256 if (!isalpha((int) *p) && (*p != '%'))
57fc29fa
JA
257 p = NULL;
258
7bb59102 259 return __get_mult_bytes(p, data, percent);
57fc29fa
JA
260}
261
83349190
YH
262/*
263 * Convert string into a floating number. Return 1 for success and 0 otherwise.
264 */
e25839d4 265int str_to_float(const char *str, double *val)
83349190
YH
266{
267 return (1 == sscanf(str, "%lf", val));
268}
269
cb2c86fd 270/*
e1f36503 271 * convert string into decimal value, noting any size suffix
cb2c86fd 272 */
6925dd35 273int str_to_decimal(const char *str, long long *val, int kilo, void *data)
cb2c86fd 274{
b347f9da 275 int len, base;
cb2c86fd 276
cb2c86fd 277 len = strlen(str);
f90eff5a
JA
278 if (!len)
279 return 1;
cb2c86fd 280
b347f9da
JA
281 if (strstr(str, "0x") || strstr(str, "0X"))
282 base = 16;
283 else
284 base = 10;
285
286 *val = strtoll(str, NULL, base);
cda866ca 287 if (*val == LONG_MAX && errno == ERANGE)
cb2c86fd
JA
288 return 1;
289
7bb59102
JA
290 if (kilo) {
291 unsigned long long mult;
292 int perc = 0;
293
6925dd35 294 mult = get_mult_bytes(str, len, data, &perc);
7bb59102
JA
295 if (perc)
296 *val = -1ULL - *val;
297 else
298 *val *= mult;
299 } else
74454ce4 300 *val *= get_mult_time(str, len);
787f7e95 301
cb2c86fd
JA
302 return 0;
303}
304
9af4a244 305int check_str_bytes(const char *p, long long *val, void *data)
cb2c86fd 306{
6925dd35 307 return str_to_decimal(p, val, 1, data);
cb2c86fd
JA
308}
309
06464907 310int check_str_time(const char *p, long long *val)
cb2c86fd 311{
6925dd35 312 return str_to_decimal(p, val, 0, NULL);
cb2c86fd
JA
313}
314
315void strip_blank_front(char **p)
316{
317 char *s = *p;
318
4c8e9640
JA
319 if (!strlen(s))
320 return;
76cd9378 321 while (isspace((int) *s))
cb2c86fd 322 s++;
4d651dad
JA
323
324 *p = s;
cb2c86fd
JA
325}
326
327void strip_blank_end(char *p)
328{
853ee7fc 329 char *start = p, *s;
523bfadb 330
4c8e9640
JA
331 if (!strlen(p))
332 return;
333
523bfadb
JA
334 s = strchr(p, ';');
335 if (s)
336 *s = '\0';
337 s = strchr(p, '#');
338 if (s)
339 *s = '\0';
340 if (s)
341 p = s;
342
7f7e6e59 343 s = p + strlen(p);
76cd9378 344 while ((isspace((int) *s) || iscntrl((int) *s)) && (s > start))
cb2c86fd
JA
345 s--;
346
347 *(s + 1) = '\0';
348}
349
d6978a32 350static int check_range_bytes(const char *str, long *val, void *data)
cb2c86fd 351{
57fc29fa 352 long long __val;
cb2c86fd 353
6925dd35 354 if (!str_to_decimal(str, &__val, 1, data)) {
57fc29fa 355 *val = __val;
cb2c86fd
JA
356 return 0;
357 }
358
cb2c86fd
JA
359 return 1;
360}
361
63f29372 362static int check_int(const char *p, int *val)
cb2c86fd 363{
787f7e95
JA
364 if (!strlen(p))
365 return 1;
d78ee463 366 if (strstr(p, "0x") || strstr(p, "0X")) {
a61bdfd8
JA
367 if (sscanf(p, "%x", val) == 1)
368 return 0;
369 } else {
370 if (sscanf(p, "%u", val) == 1)
371 return 0;
372 }
cb2c86fd 373
e1f36503
JA
374 return 1;
375}
cb2c86fd 376
808def70
JA
377static int opt_len(const char *str)
378{
379 char *postfix;
380
381 postfix = strchr(str, ':');
382 if (!postfix)
383 return strlen(str);
384
385 return (int)(postfix - str);
386}
387
119cd939
JA
388static int str_match_len(const struct value_pair *vp, const char *str)
389{
390 return max(strlen(vp->ival), opt_len(str));
391}
392
f0fdbcaf
JA
393#define val_store(ptr, val, off, or, data, o) \
394 do { \
395 ptr = td_var((data), (o), (off)); \
396 if ((or)) \
397 *ptr |= (val); \
398 else \
399 *ptr = (val); \
17abbe89
JA
400 } while (0)
401
f90eff5a 402static int __handle_option(struct fio_option *o, const char *ptr, void *data,
83349190 403 int first, int more, int curr)
cb2c86fd 404{
2fdbefdd 405 int il=0, *ilp;
fd112d34 406 fio_fp64_t *flp;
63f29372
JA
407 long long ull, *ullp;
408 long ul1, ul2;
83349190 409 double uf;
bfe1d592 410 char **cp = NULL;
e42b01eb 411 int ret = 0, is_time = 0;
c44b1ff5
JA
412 const struct value_pair *vp;
413 struct value_pair posval[PARSE_MAX_VP];
414 int i, all_skipped = 1;
cb2c86fd 415
a3d741fa
JA
416 dprint(FD_PARSE, "__handle_option=%s, type=%d, ptr=%s\n", o->name,
417 o->type, ptr);
418
e3cedca7 419 if (!ptr && o->type != FIO_OPT_STR_SET && o->type != FIO_OPT_STR) {
28d7c363 420 log_err("Option %s requires an argument\n", o->name);
08e26e35
JA
421 return 1;
422 }
423
e1f36503 424 switch (o->type) {
5f6ddf1e
JA
425 case FIO_OPT_STR:
426 case FIO_OPT_STR_MULTI: {
e1f36503 427 fio_opt_str_fn *fn = o->cb;
b1ec1da6 428
f085737f
JA
429 posval_sort(o, posval);
430
5f6ddf1e 431 ret = 1;
b1ec1da6 432 for (i = 0; i < PARSE_MAX_VP; i++) {
f085737f 433 vp = &posval[i];
b1ec1da6 434 if (!vp->ival || vp->ival[0] == '\0')
a3073f4a 435 continue;
ae2ddba4 436 all_skipped = 0;
119cd939 437 if (!strncmp(vp->ival, ptr, str_match_len(vp, ptr))) {
b1ec1da6 438 ret = 0;
7b504edd 439 if (o->off1)
ebadc0ce 440 val_store(ilp, vp->oval, o->off1, vp->orval, data, o);
5f6ddf1e 441 continue;
b1ec1da6
JA
442 }
443 }
cb2c86fd 444
ae2ddba4 445 if (ret && !all_skipped)
b1ec1da6
JA
446 show_option_values(o);
447 else if (fn)
448 ret = fn(data, ptr);
e1f36503
JA
449 break;
450 }
e42b01eb
JA
451 case FIO_OPT_STR_VAL_TIME:
452 is_time = 1;
1a1137d9 453 case FIO_OPT_INT:
e42b01eb
JA
454 case FIO_OPT_STR_VAL: {
455 fio_opt_str_val_fn *fn = o->cb;
6eaf09d6
SL
456 char tmp[128], *p;
457
458 strncpy(tmp, ptr, sizeof(tmp) - 1);
459 p = strchr(tmp, ',');
460 if (p)
461 *p = '\0';
e42b01eb
JA
462
463 if (is_time)
6eaf09d6 464 ret = check_str_time(tmp, &ull);
e42b01eb 465 else
6eaf09d6 466 ret = check_str_bytes(tmp, &ull, data);
e1f36503 467
ae3fcb5a
JA
468 dprint(FD_PARSE, " ret=%d, out=%llu\n", ret, ull);
469
e1f36503
JA
470 if (ret)
471 break;
472
db8e0165 473 if (o->maxval && ull > o->maxval) {
d4fc2f04
JA
474 log_err("max value out of range: %llu"
475 " (%u max)\n", ull, o->maxval);
db8e0165
JA
476 return 1;
477 }
478 if (o->minval && ull < o->minval) {
d4fc2f04
JA
479 log_err("min value out of range: %llu"
480 " (%u min)\n", ull, o->minval);
db8e0165
JA
481 return 1;
482 }
d926d535
JA
483 if (o->posval[0].ival) {
484 posval_sort(o, posval);
485
486 ret = 1;
487 for (i = 0; i < PARSE_MAX_VP; i++) {
488 vp = &posval[i];
489 if (!vp->ival || vp->ival[0] == '\0')
490 continue;
491 if (vp->oval == ull) {
492 ret = 0;
493 break;
494 }
495 }
496 if (ret) {
128e4caf
JA
497 log_err("fio: value %llu not allowed:\n", ull);
498 show_option_values(o);
d926d535
JA
499 return 1;
500 }
501 }
e1f36503
JA
502
503 if (fn)
504 ret = fn(data, &ull);
505 else {
e01b22b8 506 if (o->type == FIO_OPT_INT) {
7b504edd
JA
507 if (first)
508 val_store(ilp, ull, o->off1, 0, data, o);
6eaf09d6 509 if (curr == 1) {
7b504edd
JA
510 if (o->off2)
511 val_store(ilp, ull, o->off2, 0, data, o);
02c6aad5 512 }
6eaf09d6 513 if (curr == 2) {
7b504edd
JA
514 if (o->off3)
515 val_store(ilp, ull, o->off3, 0, data, o);
6eaf09d6
SL
516 }
517 if (!more) {
518 if (curr < 1) {
7b504edd
JA
519 if (o->off2)
520 val_store(ilp, ull, o->off2, 0, data, o);
6eaf09d6
SL
521 }
522 if (curr < 2) {
7b504edd
JA
523 if (o->off3)
524 val_store(ilp, ull, o->off3, 0, data, o);
6eaf09d6
SL
525 }
526 }
75e6f36f 527 } else {
7b504edd
JA
528 if (first)
529 val_store(ullp, ull, o->off1, 0, data, o);
02c6aad5 530 if (!more) {
7b504edd
JA
531 if (o->off2)
532 val_store(ullp, ull, o->off2, 0, data, o);
02c6aad5 533 }
75e6f36f 534 }
e1f36503
JA
535 }
536 break;
537 }
83349190 538 case FIO_OPT_FLOAT_LIST: {
eef02441
JA
539 char *cp2;
540
435d195a
VKF
541 if (first) {
542 /*
543 ** Initialize precision to 0 and zero out list
544 ** in case specified list is shorter than default
545 */
3e260a46
JA
546 if (o->off2) {
547 ul2 = 0;
f0fdbcaf 548 ilp = td_var(data, o, o->off2);
3e260a46
JA
549 *ilp = ul2;
550 }
435d195a 551
f0fdbcaf 552 flp = td_var(data, o, o->off1);
435d195a
VKF
553 for(i = 0; i < o->maxlen; i++)
554 flp[i].u.f = 0.0;
555 }
83349190 556 if (curr >= o->maxlen) {
28d7c363 557 log_err("the list exceeding max length %d\n",
83349190
YH
558 o->maxlen);
559 return 1;
560 }
3c3ed070 561 if (!str_to_float(ptr, &uf)) {
28d7c363 562 log_err("not a floating point value: %s\n", ptr);
83349190
YH
563 return 1;
564 }
26650695 565 if (uf > o->maxfp) {
28d7c363 566 log_err("value out of range: %f"
83349190
YH
567 " (range max: %f)\n", uf, o->maxfp);
568 return 1;
569 }
26650695 570 if (uf < o->minfp) {
28d7c363 571 log_err("value out of range: %f"
83349190
YH
572 " (range min: %f)\n", uf, o->minfp);
573 return 1;
574 }
575
f0fdbcaf 576 flp = td_var(data, o, o->off1);
fd112d34 577 flp[curr].u.f = uf;
83349190 578
ae3fcb5a
JA
579 dprint(FD_PARSE, " out=%f\n", uf);
580
435d195a
VKF
581 /*
582 ** Calculate precision for output by counting
583 ** number of digits after period. Find first
584 ** period in entire remaining list each time
585 */
586 cp2 = strchr(ptr, '.');
587 if (cp2 != NULL) {
eef02441 588 int len = 0;
435d195a
VKF
589
590 while (*++cp2 != '\0' && *cp2 >= '0' && *cp2 <= '9')
591 len++;
592
3e260a46 593 if (o->off2) {
f0fdbcaf 594 ilp = td_var(data, o, o->off2);
3e260a46
JA
595 if (len > *ilp)
596 *ilp = len;
597 }
435d195a
VKF
598 }
599
83349190
YH
600 break;
601 }
af52b345
JA
602 case FIO_OPT_STR_STORE: {
603 fio_opt_str_fn *fn = o->cb;
604
7b504edd 605 if (o->off1) {
f0fdbcaf 606 cp = td_var(data, o, o->off1);
184b4098 607 *cp = strdup(ptr);
1c964ce5 608 }
02c6aad5 609
184b4098
SL
610 if (fn)
611 ret = fn(data, ptr);
612 else if (o->posval[0].ival) {
613 posval_sort(o, posval);
614
615 ret = 1;
616 for (i = 0; i < PARSE_MAX_VP; i++) {
617 vp = &posval[i];
618 if (!vp->ival || vp->ival[0] == '\0')
619 continue;
620 all_skipped = 0;
119cd939 621 if (!strncmp(vp->ival, ptr, str_match_len(vp, ptr))) {
184b4098
SL
622 char *rest;
623
624 ret = 0;
625 if (vp->cb)
626 fn = vp->cb;
627 rest = strstr(*cp ?: ptr, ":");
628 if (rest) {
629 if (*cp)
630 *rest = '\0';
631 ptr = rest + 1;
632 } else
633 ptr = NULL;
634 break;
635 }
af52b345
JA
636 }
637 }
c44b1ff5 638
184b4098
SL
639 if (!all_skipped) {
640 if (ret && !*cp)
641 show_option_values(o);
642 else if (ret && *cp)
643 ret = 0;
644 else if (fn && ptr)
645 ret = fn(data, ptr);
646 }
c44b1ff5 647
e1f36503 648 break;
af52b345 649 }
e1f36503 650 case FIO_OPT_RANGE: {
b765a372 651 char tmp[128];
e1f36503
JA
652 char *p1, *p2;
653
0bbab0e7 654 strncpy(tmp, ptr, sizeof(tmp) - 1);
b765a372 655
31d23f47
DE
656 /* Handle bsrange with separate read,write values: */
657 p1 = strchr(tmp, ',');
658 if (p1)
659 *p1 = '\0';
660
b765a372 661 p1 = strchr(tmp, '-');
e1f36503 662 if (!p1) {
0c9baf91
JA
663 p1 = strchr(tmp, ':');
664 if (!p1) {
665 ret = 1;
666 break;
667 }
e1f36503
JA
668 }
669
670 p2 = p1 + 1;
671 *p1 = '\0';
b765a372 672 p1 = tmp;
e1f36503
JA
673
674 ret = 1;
d6978a32
JA
675 if (!check_range_bytes(p1, &ul1, data) &&
676 !check_range_bytes(p2, &ul2, data)) {
e1f36503 677 ret = 0;
e1f36503 678 if (ul1 > ul2) {
f90eff5a
JA
679 unsigned long foo = ul1;
680
681 ul1 = ul2;
682 ul2 = foo;
683 }
684
685 if (first) {
7b504edd
JA
686 val_store(ilp, ul1, o->off1, 0, data, o);
687 val_store(ilp, ul2, o->off2, 0, data, o);
17abbe89 688 }
6eaf09d6 689 if (curr == 1) {
7b504edd
JA
690 if (o->off3 && o->off4) {
691 val_store(ilp, ul1, o->off3, 0, data, o);
692 val_store(ilp, ul2, o->off4, 0, data, o);
6eaf09d6
SL
693 }
694 }
695 if (curr == 2) {
7b504edd
JA
696 if (o->off5 && o->off6) {
697 val_store(ilp, ul1, o->off5, 0, data, o);
698 val_store(ilp, ul2, o->off6, 0, data, o);
6eaf09d6
SL
699 }
700 }
701 if (!more) {
702 if (curr < 1) {
7b504edd
JA
703 if (o->off3 && o->off4) {
704 val_store(ilp, ul1, o->off3, 0, data, o);
705 val_store(ilp, ul2, o->off4, 0, data, o);
6eaf09d6
SL
706 }
707 }
708 if (curr < 2) {
7b504edd
JA
709 if (o->off5 && o->off6) {
710 val_store(ilp, ul1, o->off5, 0, data, o);
711 val_store(ilp, ul2, o->off6, 0, data, o);
6eaf09d6
SL
712 }
713 }
e1f36503 714 }
17abbe89
JA
715 }
716
e1f36503
JA
717 break;
718 }
74ba1808
JA
719 case FIO_OPT_BOOL:
720 case FIO_OPT_STR_SET: {
e1f36503
JA
721 fio_opt_int_fn *fn = o->cb;
722
74ba1808
JA
723 if (ptr)
724 ret = check_int(ptr, &il);
725 else if (o->type == FIO_OPT_BOOL)
726 ret = 1;
727 else
728 il = 1;
729
ae3fcb5a
JA
730 dprint(FD_PARSE, " ret=%d, out=%d\n", ret, il);
731
e1f36503
JA
732 if (ret)
733 break;
734
db8e0165 735 if (o->maxval && il > (int) o->maxval) {
28d7c363 736 log_err("max value out of range: %d (%d max)\n",
5ec10eaa 737 il, o->maxval);
db8e0165
JA
738 return 1;
739 }
740 if (o->minval && il < o->minval) {
28d7c363 741 log_err("min value out of range: %d (%d min)\n",
5ec10eaa 742 il, o->minval);
db8e0165
JA
743 return 1;
744 }
e1f36503 745
76a43db4
JA
746 if (o->neg)
747 il = !il;
748
e1f36503
JA
749 if (fn)
750 ret = fn(data, &il);
751 else {
7b504edd
JA
752 if (first)
753 val_store(ilp, il, o->off1, 0, data, o);
02c6aad5 754 if (!more) {
7b504edd
JA
755 if (o->off2)
756 val_store(ilp, il, o->off2, 0, data, o);
02c6aad5 757 }
e1f36503
JA
758 }
759 break;
760 }
15ca150e 761 case FIO_OPT_DEPRECATED:
06b0be6e 762 log_info("Option %s is deprecated\n", o->name);
d9472271 763 ret = 1;
15ca150e 764 break;
e1f36503 765 default:
06b0be6e 766 log_err("Bad option type %u\n", o->type);
e1f36503
JA
767 ret = 1;
768 }
cb2c86fd 769
70a4c0c8
JA
770 if (ret)
771 return ret;
772
d447a8c2 773 if (o->verify) {
70a4c0c8 774 ret = o->verify(o, data);
d447a8c2 775 if (ret) {
28d7c363
JA
776 log_err("Correct format for offending option\n");
777 log_err("%20s: %s\n", o->name, o->help);
06b0be6e 778 show_option_help(o, 1);
d447a8c2
JA
779 }
780 }
70a4c0c8 781
e1f36503 782 return ret;
cb2c86fd
JA
783}
784
7c8f1a5c 785static int handle_option(struct fio_option *o, const char *__ptr, void *data)
f90eff5a 786{
b62bdf2c
JA
787 char *o_ptr, *ptr, *ptr2;
788 int ret, done;
f90eff5a 789
7c8f1a5c
JA
790 dprint(FD_PARSE, "handle_option=%s, ptr=%s\n", o->name, __ptr);
791
b62bdf2c 792 o_ptr = ptr = NULL;
7c8f1a5c 793 if (__ptr)
b62bdf2c 794 o_ptr = ptr = strdup(__ptr);
a3d741fa 795
f90eff5a 796 /*
b62bdf2c
JA
797 * See if we have another set of parameters, hidden after a comma.
798 * Do this before parsing this round, to check if we should
787f7e95 799 * copy set 1 options to set 2.
f90eff5a 800 */
b62bdf2c
JA
801 done = 0;
802 ret = 1;
803 do {
804 int __ret;
805
806 ptr2 = NULL;
807 if (ptr &&
808 (o->type != FIO_OPT_STR_STORE) &&
83349190
YH
809 (o->type != FIO_OPT_STR) &&
810 (o->type != FIO_OPT_FLOAT_LIST)) {
b62bdf2c
JA
811 ptr2 = strchr(ptr, ',');
812 if (ptr2 && *(ptr2 + 1) == '\0')
813 *ptr2 = '\0';
6eaf09d6 814 if (o->type != FIO_OPT_STR_MULTI && o->type != FIO_OPT_RANGE) {
b62bdf2c
JA
815 if (!ptr2)
816 ptr2 = strchr(ptr, ':');
817 if (!ptr2)
818 ptr2 = strchr(ptr, '-');
819 }
83349190
YH
820 } else if (ptr && o->type == FIO_OPT_FLOAT_LIST) {
821 ptr2 = strchr(ptr, ':');
b62bdf2c 822 }
787f7e95 823
b62bdf2c
JA
824 /*
825 * Don't return early if parsing the first option fails - if
826 * we are doing multiple arguments, we can allow the first one
827 * being empty.
828 */
83349190 829 __ret = __handle_option(o, ptr, data, !done, !!ptr2, done);
b62bdf2c
JA
830 if (ret)
831 ret = __ret;
787f7e95 832
b62bdf2c
JA
833 if (!ptr2)
834 break;
f90eff5a 835
b62bdf2c
JA
836 ptr = ptr2 + 1;
837 done++;
838 } while (1);
787f7e95 839
b62bdf2c
JA
840 if (o_ptr)
841 free(o_ptr);
842 return ret;
f90eff5a
JA
843}
844
de890a1e 845static struct fio_option *get_option(char *opt,
07b3232d 846 struct fio_option *options, char **post)
3b8b7135
JA
847{
848 struct fio_option *o;
849 char *ret;
850
851 ret = strchr(opt, '=');
852 if (ret) {
853 *post = ret;
854 *ret = '\0';
de890a1e 855 ret = opt;
3b8b7135 856 (*post)++;
43c129b4 857 strip_blank_end(ret);
07b3232d 858 o = find_option(options, ret);
3b8b7135 859 } else {
07b3232d 860 o = find_option(options, opt);
3b8b7135
JA
861 *post = NULL;
862 }
863
864 return o;
865}
866
867static int opt_cmp(const void *p1, const void *p2)
868{
de890a1e
SL
869 struct fio_option *o;
870 char *s, *foo;
8cdabc1d 871 int prio1, prio2;
3b8b7135 872
8cdabc1d 873 prio1 = prio2 = 0;
3b8b7135 874
de890a1e
SL
875 if (*(char **)p1) {
876 s = strdup(*((char **) p1));
9af4a244 877 o = get_option(s, __fio_options, &foo);
de890a1e
SL
878 if (o)
879 prio1 = o->prio;
880 free(s);
881 }
882 if (*(char **)p2) {
883 s = strdup(*((char **) p2));
9af4a244 884 o = get_option(s, __fio_options, &foo);
de890a1e
SL
885 if (o)
886 prio2 = o->prio;
887 free(s);
888 }
889
8cdabc1d 890 return prio2 - prio1;
3b8b7135
JA
891}
892
893void sort_options(char **opts, struct fio_option *options, int num_opts)
894{
9af4a244 895 __fio_options = options;
3b8b7135 896 qsort(opts, num_opts, sizeof(char *), opt_cmp);
9af4a244 897 __fio_options = NULL;
3b8b7135
JA
898}
899
b4692828 900int parse_cmd_option(const char *opt, const char *val,
07b3232d 901 struct fio_option *options, void *data)
b4692828
JA
902{
903 struct fio_option *o;
904
07b3232d 905 o = find_option(options, opt);
b4692828 906 if (!o) {
06b0be6e 907 log_err("Bad option <%s>\n", opt);
b4692828
JA
908 return 1;
909 }
910
b1508cf9
JA
911 if (!handle_option(o, val, data))
912 return 0;
913
06b0be6e 914 log_err("fio: failed parsing %s=%s\n", opt, val);
b1508cf9 915 return 1;
b4692828
JA
916}
917
de890a1e 918int parse_option(char *opt, const char *input,
292cc475
JA
919 struct fio_option *options, struct fio_option **o, void *data,
920 int dump_cmdline)
cb2c86fd 921{
d0c814ec 922 char *post;
e1f36503 923
d0c814ec
SL
924 if (!opt) {
925 log_err("fio: failed parsing %s\n", input);
de890a1e 926 *o = NULL;
38789b58 927 return 1;
d0c814ec 928 }
e1f36503 929
de890a1e
SL
930 *o = get_option(opt, options, &post);
931 if (!*o) {
932 if (post) {
933 int len = strlen(opt);
934 if (opt + len + 1 != post)
935 memmove(opt + len + 1, post, strlen(post));
936 opt[len] = '=';
937 }
e1f36503
JA
938 return 1;
939 }
940
292cc475
JA
941 if (handle_option(*o, post, data)) {
942 log_err("fio: failed parsing %s\n", input);
943 return 1;
944 }
b1508cf9 945
292cc475
JA
946 if (dump_cmdline) {
947 const char *delim;
948
949 if (!strcmp("description", (*o)->name))
950 delim = "\"";
951 else
952 delim = "";
953
954 log_info("--%s%s", (*o)->name, post ? "" : " ");
955 if (post)
956 log_info("=%s%s%s ", delim, post, delim);
957 }
958
959 return 0;
e1f36503 960}
fd28ca49 961
0e9f7fac
JA
962/*
963 * Option match, levenshtein distance. Handy for not quite remembering what
964 * the option name is.
965 */
966static int string_distance(const char *s1, const char *s2)
967{
968 unsigned int s1_len = strlen(s1);
969 unsigned int s2_len = strlen(s2);
970 unsigned int *p, *q, *r;
971 unsigned int i, j;
972
973 p = malloc(sizeof(unsigned int) * (s2_len + 1));
974 q = malloc(sizeof(unsigned int) * (s2_len + 1));
975
976 p[0] = 0;
977 for (i = 1; i <= s2_len; i++)
978 p[i] = p[i - 1] + 1;
979
980 for (i = 1; i <= s1_len; i++) {
981 q[0] = p[0] + 1;
982 for (j = 1; j <= s2_len; j++) {
983 unsigned int sub = p[j - 1];
984
985 if (s1[i - 1] != s2[j - 1])
986 sub++;
987
988 q[j] = min(p[j] + 1, min(q[j - 1] + 1, sub));
989 }
990 r = p;
991 p = q;
992 q = r;
993 }
994
995 i = p[s2_len];
996 free(p);
997 free(q);
998 return i;
999}
1000
afdf9352
JA
1001static struct fio_option *find_child(struct fio_option *options,
1002 struct fio_option *o)
1003{
1004 struct fio_option *__o;
1005
fdf28744
JA
1006 for (__o = options + 1; __o->name; __o++)
1007 if (__o->parent && !strcmp(__o->parent, o->name))
afdf9352
JA
1008 return __o;
1009
1010 return NULL;
1011}
1012
323d9113
JA
1013static void __print_option(struct fio_option *o, struct fio_option *org,
1014 int level)
afdf9352
JA
1015{
1016 char name[256], *p;
323d9113 1017 int depth;
afdf9352
JA
1018
1019 if (!o)
1020 return;
ef9aff52
JA
1021 if (!org)
1022 org = o;
5ec10eaa 1023
afdf9352 1024 p = name;
323d9113
JA
1025 depth = level;
1026 while (depth--)
1027 p += sprintf(p, "%s", " ");
afdf9352
JA
1028
1029 sprintf(p, "%s", o->name);
1030
28d7c363 1031 log_info("%-24s: %s\n", name, o->help);
323d9113
JA
1032}
1033
1034static void print_option(struct fio_option *o)
1035{
1036 struct fio_option *parent;
1037 struct fio_option *__o;
1038 unsigned int printed;
1039 unsigned int level;
1040
1041 __print_option(o, NULL, 0);
1042 parent = o;
1043 level = 0;
1044 do {
1045 level++;
1046 printed = 0;
1047
1048 while ((__o = find_child(o, parent)) != NULL) {
1049 __print_option(__o, o, level);
1050 o = __o;
1051 printed++;
1052 }
1053
1054 parent = o;
1055 } while (printed);
afdf9352
JA
1056}
1057
07b3232d 1058int show_cmd_help(struct fio_option *options, const char *name)
0e9f7fac
JA
1059{
1060 struct fio_option *o, *closest;
d091d099 1061 unsigned int best_dist = -1U;
29fc6afe 1062 int found = 0;
320beefe
JA
1063 int show_all = 0;
1064
1065 if (!name || !strcmp(name, "all"))
1066 show_all = 1;
fd28ca49 1067
0e9f7fac
JA
1068 closest = NULL;
1069 best_dist = -1;
4945ba12 1070 for (o = &options[0]; o->name; o++) {
320beefe
JA
1071 int match = 0;
1072
15ca150e
JA
1073 if (o->type == FIO_OPT_DEPRECATED)
1074 continue;
07b3232d
JA
1075 if (!exec_profile && o->prof_name)
1076 continue;
4ac23d27
JA
1077 if (exec_profile && !(o->prof_name && !strcmp(exec_profile, o->prof_name)))
1078 continue;
15ca150e 1079
0e9f7fac 1080 if (name) {
7f9348f8
JA
1081 if (!strcmp(name, o->name) ||
1082 (o->alias && !strcmp(name, o->alias)))
0e9f7fac
JA
1083 match = 1;
1084 else {
1085 unsigned int dist;
1086
1087 dist = string_distance(name, o->name);
1088 if (dist < best_dist) {
1089 best_dist = dist;
1090 closest = o;
1091 }
1092 }
1093 }
fd28ca49
JA
1094
1095 if (show_all || match) {
29fc6afe 1096 found = 1;
c167dedc 1097 if (match)
28d7c363 1098 log_info("%20s: %s\n", o->name, o->help);
c167dedc 1099 if (show_all) {
afdf9352 1100 if (!o->parent)
323d9113 1101 print_option(o);
4945ba12 1102 continue;
c167dedc 1103 }
fd28ca49
JA
1104 }
1105
70df2f19
JA
1106 if (!match)
1107 continue;
1108
06b0be6e 1109 show_option_help(o, 0);
fd28ca49
JA
1110 }
1111
29fc6afe
JA
1112 if (found)
1113 return 0;
fd28ca49 1114
28d7c363 1115 log_err("No such command: %s", name);
d091d099
JA
1116
1117 /*
1118 * Only print an appropriately close option, one where the edit
1119 * distance isn't too big. Otherwise we get crazy matches.
1120 */
1121 if (closest && best_dist < 3) {
28d7c363
JA
1122 log_info(" - showing closest match\n");
1123 log_info("%20s: %s\n", closest->name, closest->help);
06b0be6e 1124 show_option_help(closest, 0);
0e9f7fac 1125 } else
28d7c363 1126 log_info("\n");
0e9f7fac 1127
29fc6afe 1128 return 1;
fd28ca49 1129}
ee738499 1130
13335ddb
JA
1131/*
1132 * Handle parsing of default parameters.
1133 */
ee738499
JA
1134void fill_default_options(void *data, struct fio_option *options)
1135{
4945ba12 1136 struct fio_option *o;
ee738499 1137
a3d741fa
JA
1138 dprint(FD_PARSE, "filling default options\n");
1139
4945ba12 1140 for (o = &options[0]; o->name; o++)
ee738499
JA
1141 if (o->def)
1142 handle_option(o, o->def, data);
ee738499 1143}
13335ddb 1144
9f988e2e
JA
1145void option_init(struct fio_option *o)
1146{
1147 if (o->type == FIO_OPT_DEPRECATED)
1148 return;
1149 if (o->type == FIO_OPT_BOOL) {
1150 o->minval = 0;
1151 o->maxval = 1;
1152 }
d4fc2f04
JA
1153 if (o->type == FIO_OPT_INT) {
1154 if (!o->maxval)
1155 o->maxval = UINT_MAX;
1156 }
83349190 1157 if (o->type == FIO_OPT_FLOAT_LIST) {
ab9461ea
BC
1158 o->minfp = DBL_MIN;
1159 o->maxfp = DBL_MAX;
83349190 1160 }
9f988e2e 1161 if (o->type == FIO_OPT_STR_SET && o->def) {
06b0be6e 1162 log_err("Option %s: string set option with"
9f988e2e
JA
1163 " default will always be true\n", o->name);
1164 }
7b504edd 1165 if (!o->cb && !o->off1)
06b0be6e 1166 log_err("Option %s: neither cb nor offset given\n", o->name);
22754746 1167 if (!o->category) {
cca5b5bc 1168 log_info("Option %s: no category defined. Setting to misc\n", o->name);
22754746 1169 o->category = FIO_OPT_C_GENERAL;
ffd7821f 1170 o->group = FIO_OPT_G_INVALID;
22754746 1171 }
5f6ddf1e
JA
1172 if (o->type == FIO_OPT_STR || o->type == FIO_OPT_STR_STORE ||
1173 o->type == FIO_OPT_STR_MULTI)
9f988e2e 1174 return;
7b504edd 1175 if (o->cb && (o->off1 || o->off2 || o->off3 || o->off4))
06b0be6e 1176 log_err("Option %s: both cb and offset given\n", o->name);
9f988e2e
JA
1177}
1178
13335ddb
JA
1179/*
1180 * Sanitize the options structure. For now it just sets min/max for bool
5b0a8880 1181 * values and whether both callback and offsets are given.
13335ddb
JA
1182 */
1183void options_init(struct fio_option *options)
1184{
4945ba12 1185 struct fio_option *o;
13335ddb 1186
a3d741fa
JA
1187 dprint(FD_PARSE, "init options\n");
1188
90265353 1189 for (o = &options[0]; o->name; o++) {
9f988e2e 1190 option_init(o);
90265353
JA
1191 if (o->inverse)
1192 o->inv_opt = find_option(options, o->inverse);
1193 }
13335ddb 1194}
7e356b2d
JA
1195
1196void options_free(struct fio_option *options, void *data)
1197{
1198 struct fio_option *o;
1199 char **ptr;
1200
1201 dprint(FD_PARSE, "free options\n");
1202
1203 for (o = &options[0]; o->name; o++) {
de890a1e 1204 if (o->type != FIO_OPT_STR_STORE || !o->off1)
7e356b2d
JA
1205 continue;
1206
f0fdbcaf 1207 ptr = td_var(data, o, o->off1);
7e356b2d
JA
1208 if (*ptr) {
1209 free(*ptr);
1210 *ptr = NULL;
1211 }
1212 }
1213}