-l Generate per-job latency logs
-w Generate per-job bandwidth logs
-f <file> Read <file> for job descriptions
+ -O <file> Log output to file
-h Print help info
-v Print version information and exit
rate = (td->this_io_bytes[ddir] - td->rate_bytes) / spent;
if (rate < td->ratemin) {
- printf("%s: min rate %d not met, got %ldKiB/sec\n", td->name, td->ratemin, rate);
+ fprintf(f_out, "%s: min rate %d not met, got %ldKiB/sec\n", td->name, td->ratemin, rate);
if (rate_quit)
terminate_threads(td->groupid);
return 1;
int i;
for (i = 0; i < len; i++)
- printf("%02x", p[i]);
- printf("\n");
+ fprintf(f_out, "%02x", p[i]);
+ fprintf(f_out, "\n");
}
static int verify_io_u_crc32(struct verify_header *hdr, struct io_u *io_u)
c = crc32(p, hdr->len - sizeof(*hdr));
if (c != hdr->crc32) {
- fprintf(stderr, "crc32: verify failed at %llu/%u\n", io_u->offset, io_u->buflen);
- fprintf(stderr, "crc32: wanted %lx, got %lx\n", hdr->crc32, c);
+ fprintf(f_err, "crc32: verify failed at %llu/%u\n", io_u->offset, io_u->buflen);
+ fprintf(f_err, "crc32: wanted %lx, got %lx\n", hdr->crc32, c);
return 1;
}
md5_update(&md5_ctx, p, hdr->len - sizeof(*hdr));
if (memcmp(hdr->md5_digest, md5_ctx.hash, sizeof(md5_ctx.hash))) {
- fprintf(stderr, "md5: verify failed at %llu/%u\n", io_u->offset, io_u->buflen);
+ fprintf(f_err, "md5: verify failed at %llu/%u\n", io_u->offset, io_u->buflen);
hexdump(hdr->md5_digest, sizeof(hdr->md5_digest));
hexdump(md5_ctx.hash, sizeof(md5_ctx.hash));
return 1;
else if (hdr->verify_type == VERIFY_CRC32)
ret = verify_io_u_crc32(hdr, io_u);
else {
- fprintf(stderr, "Bad verify type %d\n", hdr->verify_type);
+ fprintf(f_err, "Bad verify type %d\n", hdr->verify_type);
ret = 1;
}
else if (td->io_engine == FIO_SPLICEIO)
return fio_spliceio_init(td);
else {
- fprintf(stderr, "bad io_engine %d\n", td->io_engine);
+ fprintf(f_err, "bad io_engine %d\n", td->io_engine);
return 1;
}
}
} else if (td->mem_type == MEM_MMAP)
munmap(td->orig_buffer, td->orig_buffer_size);
else
- fprintf(stderr, "Bad memory type %d\n", td->mem_type);
+ fprintf(f_err, "Bad memory type %d\n", td->mem_type);
td->orig_buffer = NULL;
}
return 0;
if (!size) {
- fprintf(stderr, "Need size for create\n");
+ fprintf(f_err, "Need size for create\n");
td_verror(td, EINVAL);
return 1;
}
if (!extend) {
oflags = O_CREAT | O_TRUNC;
- printf("%s: Laying out IO file (%LuMiB)\n", td->name, size >> 20);
+ fprintf(f_out, "%s: Laying out IO file (%LuMiB)\n", td->name, size >> 20);
} else {
oflags = O_APPEND;
- printf("%s: Extending IO file (%Lu -> %LuMiB)\n", td->name, (td->file_size - size) >> 20, td->file_size >> 20);
+ fprintf(f_out, "%s: Extending IO file (%Lu -> %LuMiB)\n", td->name, (td->file_size - size) >> 20, td->file_size >> 20);
}
td->fd = open(td->file_name, O_WRONLY | oflags, 0644);
return ret;
if (td->file_offset > td->real_file_size) {
- fprintf(stderr, "%s: offset extends end (%Lu > %Lu)\n", td->name, td->file_offset, td->real_file_size);
+ fprintf(f_err, "%s: offset extends end (%Lu > %Lu)\n", td->name, td->file_offset, td->real_file_size);
return 1;
}
td->io_size = td->file_size;
if (td->io_size == 0) {
- fprintf(stderr, "%s: no io blocks\n", td->name);
+ fprintf(f_err, "%s: no io blocks\n", td->name);
td_verror(td, EINVAL);
return 1;
}
sprintf(tmp2, "[%s]", td->ioscheduler);
if (!strstr(tmp, tmp2)) {
- fprintf(stderr, "fio: io scheduler %s not found\n", td->ioscheduler);
+ fprintf(f_err, "fio: io scheduler %s not found\n", td->ioscheduler);
td_verror(td, EINVAL);
fclose(f);
return 1;
c = 'P';
break;
default:
- printf("state %d\n", td->runstate);
+ fprintf(f_err, "state %d\n", td->runstate);
}
run_str[td->thread_number - 1] = c;
if (!nr_running && !nr_pending)
return;
- printf("Threads now running (%d)", nr_running);
+ printf("Threads running: %d", nr_running);
if (m_rate || t_rate)
printf(", commitrate %d/%dKiB/sec", t_rate, m_rate);
if (eta_sec != INT_MAX) {
if (phys_mem) {
if ((mlock_size + 128 * 1024 * 1024) > phys_mem) {
mlock_size = phys_mem - 128 * 1024 * 1024;
- printf("fio: limiting mlocked memory to %lluMiB\n",
- mlock_size >> 20);
+ fprintf(f_out, "fio: limiting mlocked memory to %lluMiB\n", mlock_size >> 20);
}
}
}
if (left) {
- fprintf(stderr, "fio: %d jobs failed to start\n", left);
+ fprintf(f_err, "fio: %d jobs failed to start\n", left);
for (i = 0; i < this_jobs; i++) {
td = map[i];
if (!td)
return 1;
if (!thread_number) {
- printf("Nothing to do\n");
+ fprintf(f_err, "Nothing to do\n");
return 1;
}
extern int thread_number;
extern int shm_id;
extern int groupid;
+extern FILE *f_out;
+extern FILE *f_err;
extern struct thread_data *threads;
int write_bw_log = 0;
int exitall_on_terminate = 0;
unsigned long long mlock_size = 0;
+FILE *f_out = NULL;
+FILE *f_err = NULL;
static struct thread_data *get_new_job(int global, struct thread_data *parent)
{
#ifndef FIO_HAVE_LIBAIO
if (td->io_engine == FIO_LIBAIO) {
- fprintf(stderr, "Linux libaio not available\n");
+ fprintf(f_err, "Linux libaio not available\n");
return 1;
}
#endif
#ifndef FIO_HAVE_POSIXAIO
if (td->io_engine == FIO_POSIXAIO) {
- fprintf(stderr, "posix aio not available\n");
+ fprintf(f_err, "posix aio not available\n");
return 1;
}
#endif
ddir = td->ddir + (!td->sequential << 1) + (td->iomix << 2);
if (!job_add_num)
- printf("%s: (g=%d): rw=%s, odir=%d, bs=%d-%d, rate=%d, ioengine=%s, iodepth=%d\n", td->name, td->groupid, ddir_str[ddir], td->odirect, td->min_bs, td->max_bs, td->rate, td->io_engine_name, td->iodepth);
+ fprintf(f_out, "%s: (g=%d): rw=%s, odir=%d, bs=%d-%d, rate=%d, ioengine=%s, iodepth=%d\n", td->name, td->groupid, ddir_str[ddir], td->odirect, td->min_bs, td->max_bs, td->rate, td->io_engine_name, td->iodepth);
else if (job_add_num == 1)
- printf("...\n");
+ fprintf(f_out, "...\n");
/*
* recurse add identical jobs, clear numjobs and stonewall options
return 0;
}
- fprintf(stderr, "fio: data direction: read, write, randread, randwrite, rw, randrw\n");
+ fprintf(f_err, "fio: data direction: read, write, randread, randwrite, rw, randrw\n");
return 1;
}
return 0;
}
- fprintf(stderr, "fio: verify types: md5, crc32\n");
+ fprintf(f_err, "fio: verify types: md5, crc32\n");
return 1;
}
return 0;
}
- fprintf(stderr, "fio: mem type: malloc, shm, mmap\n");
+ fprintf(f_err, "fio: mem type: malloc, shm, mmap\n");
return 1;
}
return 0;
}
- fprintf(stderr, "fio: ioengine: { linuxaio, aio, libaio }, posixaio, sync, mmap, sgio, splice\n");
+ fprintf(f_err, "fio: ioengine: { linuxaio, aio, libaio }, posixaio, sync, mmap, sgio, splice\n");
return 1;
}
if (!check_int(p, "prio", &prio)) {
#ifndef FIO_HAVE_IOPRIO
- fprintf(stderr, "io priorities not available\n");
+ fprintf(f_err, "io priorities not available\n");
ret = 1;
break;
#endif
}
if (!check_int(p, "prioclass", &prioclass)) {
#ifndef FIO_HAVE_IOPRIO
- fprintf(stderr, "io priorities not available\n");
+ fprintf(f_err, "io priorities not available\n");
ret = 1;
break;
#else
}
if (!check_int(p, "cpumask", &cpu)) {
#ifndef FIO_HAVE_CPU_AFFINITY
- fprintf(stderr, "cpu affinity not available\n");
+ fprintf(f_err, "cpu affinity not available\n");
ret = 1;
break;
#endif
}
if (!check_strstore(p, "iolog", tmpbuf)) {
if (td->write_iolog) {
- fprintf(stderr, "fio: read iolog overrides given write_iolog\n");
+ fprintf(f_err, "fio: read iolog overrides given write_iolog\n");
free(td->iolog_file);
td->write_iolog = 0;
}
td->iolog_file = strdup(tmpbuf);
td->write_iolog = 1;
} else
- fprintf(stderr, "fio: read iolog overrides given write_iolog\n");
+ fprintf(f_err, "fio: read iolog overrides given write_iolog\n");
fgetpos(f, &off);
continue;
}
}
if (!check_strstore(p, "ioscheduler", tmpbuf)) {
#ifndef FIO_HAVE_IOSCHED_SWITCH
- fprintf(stderr, "io scheduler switching not available\n");
+ fprintf(f_err, "io scheduler switching not available\n");
ret = 1;
break;
#else
{
int c;
- while ((c = getopt(argc, argv, "s:b:t:r:R:o:f:lwvh")) != EOF) {
+ while ((c = getopt(argc, argv, "s:b:t:r:R:o:f:lwvhO:")) != EOF) {
switch (c) {
case 's':
def_thread.sequential = !!atoi(optarg);
case 'w':
write_bw_log = 1;
break;
+ case 'O':
+ f_out = fopen(optarg, "w+");
+ if (!f_out) {
+ perror("fopen output");
+ exit(1);
+ }
+ f_err = f_out;
+ break;
case 'h':
usage(argv[0]);
exit(0);
if (!ini_file && argc > 1 && argv[argc - 1][0] != '-')
ini_file = strdup(argv[argc - 1]);
+ if (!f_out) {
+ f_out = stdout;
+ f_err = stderr;
+ }
}
static void free_shm(void)
parse_cmd_line(argc, argv);
if (!ini_file) {
- printf("Need job file\n");
+ fprintf(f_err, "Need job file\n");
usage(argv[0]);
return 1;
}
int nr_blocks, lba;
if (io_u->buflen & (sd->bs - 1)) {
- fprintf(stderr, "read/write not sector aligned\n");
+ fprintf(f_err, "read/write not sector aligned\n");
return EINVAL;
}
if (ret)
return ret;
} else {
- fprintf(stderr, "ioengine sgio only works on block devices\n");
+ fprintf(f_err, "ioengine sgio only works on block devices\n");
return 1;
}
struct io_piece *ipo;
if (sscanf(p, "%d,%llu,%u", &rw, &offset, &bytes) != 3) {
- fprintf(stderr, "bad iolog: %s\n", p);
+ fprintf(f_err, "bad iolog: %s\n", p);
continue;
}
if (rw == DDIR_READ)
else if (rw == DDIR_WRITE)
writes++;
else {
- fprintf(stderr, "bad ddir: %d\n", rw);
+ fprintf(f_err, "bad ddir: %d\n", rw);
continue;
}
return 0;
if (td->rate < td->ratemin) {
- fprintf(stderr, "min rate larger than nominal rate\n");
+ fprintf(f_err, "min rate larger than nominal rate\n");
return -1;
}
p = dirname(foo);
sprintf(tmp, "%s/queue", p);
if (stat(tmp, &st)) {
- fprintf(stderr, "unknown sysfs layout\n");
+ fprintf(f_err, "unknown sysfs layout\n");
return;
}
sprintf(foo, "%s", p);
static void show_group_stats(struct group_run_stats *rs, int id)
{
- printf("\nRun status group %d (all jobs):\n", id);
+ fprintf(f_out, "\nRun status group %d (all jobs):\n", id);
if (rs->max_run[DDIR_READ])
- printf(" READ: io=%lluMiB, aggrb=%llu, minb=%llu, maxb=%llu, mint=%llumsec, maxt=%llumsec\n", rs->io_kb[0] >> 10, rs->agg[0], rs->min_bw[0], rs->max_bw[0], rs->min_run[0], rs->max_run[0]);
+ fprintf(f_out, " READ: io=%lluMiB, aggrb=%llu, minb=%llu, maxb=%llu, mint=%llumsec, maxt=%llumsec\n", rs->io_kb[0] >> 10, rs->agg[0], rs->min_bw[0], rs->max_bw[0], rs->min_run[0], rs->max_run[0]);
if (rs->max_run[DDIR_WRITE])
- printf(" WRITE: io=%lluMiB, aggrb=%llu, minb=%llu, maxb=%llu, mint=%llumsec, maxt=%llumsec\n", rs->io_kb[1] >> 10, rs->agg[1], rs->min_bw[1], rs->max_bw[1], rs->min_run[1], rs->max_run[1]);
+ fprintf(f_out, " WRITE: io=%lluMiB, aggrb=%llu, minb=%llu, maxb=%llu, mint=%llumsec, maxt=%llumsec\n", rs->io_kb[1] >> 10, rs->agg[1], rs->min_bw[1], rs->max_bw[1], rs->min_run[1], rs->max_run[1]);
}
static void show_disk_util(void)
struct disk_util *du;
double util;
- printf("\nDisk stats (read/write):\n");
+ fprintf(f_out, "\nDisk stats (read/write):\n");
list_for_each(entry, &disk_list) {
du = list_entry(entry, struct disk_util, list);
if (util > 100.0)
util = 100.0;
- printf(" %s: ios=%u/%u, merge=%u/%u, ticks=%u/%u, in_queue=%u, util=%3.2f%%\n", du->name, dus->ios[0], dus->ios[1], dus->merges[0], dus->merges[1], dus->ticks[0], dus->ticks[1], dus->time_in_queue, util);
+ fprintf(f_out, " %s: ios=%u/%u, merge=%u/%u, ticks=%u/%u, in_queue=%u, util=%3.2f%%\n", du->name, dus->ios[0], dus->ios[1], dus->merges[0], dus->merges[1], dus->ticks[0], dus->ticks[1], dus->time_in_queue, util);
}
}
return;
bw = td->io_bytes[ddir] / td->runtime[ddir];
- printf(" %s: io=%6lluMiB, bw=%6lluKiB/s, runt=%6lumsec\n", ddir_str[ddir], td->io_bytes[ddir] >> 20, bw, td->runtime[ddir]);
+ fprintf(f_out, " %s: io=%6lluMiB, bw=%6lluKiB/s, runt=%6lumsec\n", ddir_str[ddir], td->io_bytes[ddir] >> 20, bw, td->runtime[ddir]);
if (calc_lat(&td->slat_stat[ddir], &min, &max, &mean, &dev))
- printf(" slat (msec): min=%5lu, max=%5lu, avg=%5.02f, dev=%5.02f\n", min, max, mean, dev);
+ fprintf(f_out, " slat (msec): min=%5lu, max=%5lu, avg=%5.02f, dev=%5.02f\n", min, max, mean, dev);
if (calc_lat(&td->clat_stat[ddir], &min, &max, &mean, &dev))
- printf(" clat (msec): min=%5lu, max=%5lu, avg=%5.02f, dev=%5.02f\n", min, max, mean, dev);
+ fprintf(f_out, " clat (msec): min=%5lu, max=%5lu, avg=%5.02f, dev=%5.02f\n", min, max, mean, dev);
if (calc_lat(&td->bw_stat[ddir], &min, &max, &mean, &dev)) {
double p_of_agg;
p_of_agg = mean * 100 / (double) rs->agg[ddir];
- printf(" bw (KiB/s) : min=%5lu, max=%5lu, per=%3.2f%%, avg=%5.02f, dev=%5.02f\n", min, max, p_of_agg, mean, dev);
+ fprintf(f_out, " bw (KiB/s) : min=%5lu, max=%5lu, per=%3.2f%%, avg=%5.02f, dev=%5.02f\n", min, max, p_of_agg, mean, dev);
}
}
if (!(td->io_bytes[0] + td->io_bytes[1]) && !td->error)
return;
- printf("%s: (groupid=%d): err=%2d:\n",td->name, td->groupid, td->error);
+ fprintf(f_out, "%s: (groupid=%d): err=%2d:\n",td->name, td->groupid, td->error);
show_ddir_status(td, rs, td->ddir);
if (td->io_bytes[td->ddir ^ 1])
sys_cpu = 0;
}
- printf(" cpu : usr=%3.2f%%, sys=%3.2f%%, ctx=%lu\n", usr_cpu, sys_cpu, td->ctx);
+ fprintf(f_out, " cpu : usr=%3.2f%%, sys=%3.2f%%, ctx=%lu\n", usr_cpu, sys_cpu, td->ctx);
}
void show_run_stats(void)
td = &threads[i];
if (td->error) {
- printf("%s: %s\n", td->name, td->verror);
+ fprintf(f_out, "%s: %s\n", td->name, td->verror);
continue;
}