int output_format = FIO_OUTPUT_NORMAL;
int eta_print = FIO_ETA_AUTO;
int eta_new_line = 0;
-unsigned long long mlock_size = 0;
FILE *f_out = NULL;
FILE *f_err = NULL;
char **job_sections = NULL;
/*
* This function leaks the buffer
*/
-static char *to_kmg(unsigned int val)
+char *fio_uint_to_kmg(unsigned int val)
{
char *buf = malloc(32);
char post[] = { 0, 'K', 'M', 'G', 'P', 'E', 0 };
if (ioengine_load(td))
goto err;
- if (o->use_thread)
- nr_thread++;
- else
- nr_process++;
-
if (o->odirect)
td->io_ops->flags |= FIO_RAWIO;
goto err;
if (o->write_lat_log) {
- setup_log(&td->lat_log, o->log_avg_msec);
- setup_log(&td->slat_log, o->log_avg_msec);
- setup_log(&td->clat_log, o->log_avg_msec);
+ setup_log(&td->lat_log, o->log_avg_msec, IO_LOG_TYPE_LAT);
+ setup_log(&td->slat_log, o->log_avg_msec, IO_LOG_TYPE_LAT);
+ setup_log(&td->clat_log, o->log_avg_msec, IO_LOG_TYPE_LAT);
}
if (o->write_bw_log)
- setup_log(&td->bw_log, o->log_avg_msec);
+ setup_log(&td->bw_log, o->log_avg_msec, IO_LOG_TYPE_BW);
if (o->write_iops_log)
- setup_log(&td->iops_log, o->log_avg_msec);
+ setup_log(&td->iops_log, o->log_avg_msec, IO_LOG_TYPE_IOPS);
if (!o->name)
o->name = strdup(jobname);
} else {
char *c1, *c2, *c3, *c4, *c5, *c6;
- c1 = to_kmg(o->min_bs[DDIR_READ]);
- c2 = to_kmg(o->max_bs[DDIR_READ]);
- c3 = to_kmg(o->min_bs[DDIR_WRITE]);
- c4 = to_kmg(o->max_bs[DDIR_WRITE]);
- c5 = to_kmg(o->min_bs[DDIR_TRIM]);
- c6 = to_kmg(o->max_bs[DDIR_TRIM]);
+ c1 = fio_uint_to_kmg(o->min_bs[DDIR_READ]);
+ c2 = fio_uint_to_kmg(o->max_bs[DDIR_READ]);
+ c3 = fio_uint_to_kmg(o->min_bs[DDIR_WRITE]);
+ c4 = fio_uint_to_kmg(o->max_bs[DDIR_WRITE]);
+ c5 = fio_uint_to_kmg(o->min_bs[DDIR_TRIM]);
+ c6 = fio_uint_to_kmg(o->max_bs[DDIR_TRIM]);
log_info("%s: (g=%d): rw=%s, bs=%s-%s/%s-%s/%s-%s,"
" ioengine=%s, iodepth=%u\n",