X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;ds=sidebyside;f=init.c;h=142a1637b43bd108a1d34e16a3ac6349a2dfbc54;hb=d5e3a0c6f5376e0d76143edb2c1622efd77f995f;hp=d9c78ec5e69b2953701c799ac292f3295df25c73;hpb=cdf54d85054858d9e3fc4d7ee8ea5c6a418f1b43;p=fio.git diff --git a/init.c b/init.c index d9c78ec5..142a1637 100644 --- a/init.c +++ b/init.c @@ -23,13 +23,21 @@ #include "lib/getopt.h" -static char fio_version_string[] = "fio 1.58"; +#if FIO_PATCH > 0 +static char fio_version_string[] = __fio_stringify(FIO_MAJOR) "." \ + __fio_stringify(FIO_MINOR) "." \ + __fio_stringify(FIO_PATCH); +#else +static char fio_version_string[] = __fio_stringify(FIO_MAJOR) "." \ + __fio_stringify(FIO_MINOR); +#endif #define FIO_RANDSEED (0xb1899bedUL) static char **ini_file; static int max_jobs = FIO_MAX_JOBS; static int dump_cmdline; +static int def_timeout; static struct thread_data def_thread; struct thread_data *threads = NULL; @@ -62,6 +70,24 @@ unsigned int *fio_debug_jobp = NULL; static char cmd_optstr[256]; +const fio_fp64_t def_percentile_list[FIO_IO_U_LIST_MAX_LEN] = { + { .u.f = 1.0 }, + { .u.f = 5.0 }, + { .u.f = 10.0 }, + { .u.f = 20.0 }, + { .u.f = 30.0 }, + { .u.f = 40.0 }, + { .u.f = 50.0 }, + { .u.f = 60.0 }, + { .u.f = 70.0 }, + { .u.f = 80.0 }, + { .u.f = 90.0 }, + { .u.f = 95.0 }, + { .u.f = 99.0 }, + { .u.f = 99.5 }, + { .u.f = 99.9 }, +}; + /* * Command line options. These will contain the above, plus a few * extra that only pertain to fio itself and not jobs. @@ -711,9 +737,9 @@ static int add_job(struct thread_data *td, const char *jobname, int job_add_num) td->ts.clat_percentiles = td->o.clat_percentiles; if (td->o.overwrite_plist) - td->ts.percentile_list = td->o.percentile_list; + memcpy(td->ts.percentile_list, td->o.percentile_list, sizeof(td->o.percentile_list)); else - td->ts.percentile_list = NULL; + memcpy(td->ts.percentile_list, def_percentile_list, sizeof(def_percentile_list)); td->ts.clat_stat[0].min_val = td->ts.clat_stat[1].min_val = ULONG_MAX; td->ts.slat_stat[0].min_val = td->ts.slat_stat[1].min_val = ULONG_MAX; @@ -1058,6 +1084,7 @@ static int fill_def_thread(void) memset(&def_thread, 0, sizeof(def_thread)); fio_getaffinity(getpid(), &def_thread.o.cpumask); + def_thread.o.timeout = def_timeout; /* * fill default options @@ -1198,28 +1225,35 @@ static void fio_options_fill_optstring(void) ostr[c] = '\0'; } -static int parse_cmd_line(int argc, char *argv[]) +int parse_cmd_line(int argc, char *argv[]) { struct thread_data *td = NULL; int c, ini_idx = 0, lidx, ret = 0, do_exit = 0, exit_val = 0; char *ostr = cmd_optstr; int daemonize_server = 0; + char *cur_client = NULL; + int backend = 0; while ((c = getopt_long_only(argc, argv, ostr, l_opts, &lidx)) != -1) { switch (c) { case 'a': + fio_client_add_cmd_option(cur_client, argv[optind-1]); smalloc_pool_size = atoi(optarg); break; case 't': - def_thread.o.timeout = atoi(optarg); + fio_client_add_cmd_option(cur_client, argv[optind-1]); + def_timeout = atoi(optarg); break; case 'l': + fio_client_add_cmd_option(cur_client, argv[optind-1]); write_lat_log = 1; break; case 'b': + fio_client_add_cmd_option(cur_client, argv[optind-1]); write_bw_log = 1; break; case 'o': + fio_client_add_cmd_option(cur_client, argv[optind-1]); f_out = fopen(optarg, "w+"); if (!f_out) { perror("fopen output"); @@ -1228,6 +1262,7 @@ static int parse_cmd_line(int argc, char *argv[]) f_err = f_out; break; case 'm': + fio_client_add_cmd_option(cur_client, argv[optind-1]); terse_output = 1; break; case 'h': @@ -1236,15 +1271,18 @@ static int parse_cmd_line(int argc, char *argv[]) case 'c': exit(fio_show_option_help(optarg)); case 's': + fio_client_add_cmd_option(cur_client, argv[optind-1]); dump_cmdline = 1; break; case 'r': + fio_client_add_cmd_option(cur_client, argv[optind-1]); read_only = 1; break; case 'v': log_info("%s\n", fio_version_string); exit(0); case 'V': + fio_client_add_cmd_option(cur_client, argv[optind-1]); terse_version = atoi(optarg); if (terse_version != 2) { log_err("fio: bad terse version format\n"); @@ -1253,18 +1291,22 @@ static int parse_cmd_line(int argc, char *argv[]) } break; case 'e': + fio_client_add_cmd_option(cur_client, argv[optind-1]); if (!strcmp("always", optarg)) eta_print = FIO_ETA_ALWAYS; else if (!strcmp("never", optarg)) eta_print = FIO_ETA_NEVER; break; case 'd': + fio_client_add_cmd_option(cur_client, argv[optind-1]); if (set_debug(optarg)) do_exit++; break; case 'x': { size_t new_size; + fio_client_add_cmd_option(cur_client, argv[optind-1]); + if (!strcmp(optarg, "global")) { log_err("fio: can't use global as only " "section\n"); @@ -1279,12 +1321,15 @@ static int parse_cmd_line(int argc, char *argv[]) break; } case 'p': + fio_client_add_cmd_option(cur_client, argv[optind-1]); exec_profile = strdup(optarg); break; case FIO_GETOPT_JOB: { const char *opt = l_opts[lidx].name; char *val = optarg; + fio_client_add_cmd_option(cur_client, argv[optind-1]); + if (!strncmp(opt, "name", 4) && td) { ret = add_job(td, td->o.name ?: "fio", 0); if (ret) @@ -1310,9 +1355,11 @@ static int parse_cmd_line(int argc, char *argv[]) break; } case 'w': + fio_client_add_cmd_option(cur_client, argv[optind-1]); warnings_fatal = 1; break; case 'j': + fio_client_add_cmd_option(cur_client, argv[optind-1]); max_jobs = atoi(optarg); if (!max_jobs || max_jobs > REAL_MAX_JOBS) { log_err("fio: invalid max jobs: %d\n", max_jobs); @@ -1328,6 +1375,7 @@ static int parse_cmd_line(int argc, char *argv[]) break; } is_backend = 1; + backend = 1; break; case 'D': daemonize_server = 1; @@ -1343,6 +1391,7 @@ static int parse_cmd_line(int argc, char *argv[]) break; } fio_client_add(optarg); + cur_client = optarg; break; default: do_exit++; @@ -1362,7 +1411,7 @@ static int parse_cmd_line(int argc, char *argv[]) return -1; } - if (is_backend) + if (is_backend && backend) return fio_start_server(daemonize_server); if (td) {