queue_io_piece(td, ipo);
}
-static void handle_trace_notify( struct blk_io_trace *t)
+static void handle_trace_notify(struct blk_io_trace *t)
{
switch (t->action) {
case BLK_TN_PROCESS:
}
}
if (td->o.rate[0] || td->o.rate[1]) {
- r_eta = (bytes_total / 1024) / (td->o.rate[0] + td->o.rate[1]);
+ r_eta = (bytes_total / 1024) /
+ (td->o.rate[0] + td->o.rate[1]);
r_eta += td->o.start_delay;
}
t_rate += td->o.rate[0] + td->o.rate[1];
m_rate += td->o.ratemin[0] + td->o.ratemin[1];
t_iops += td->o.rate_iops[0] + td->o.rate_iops[1];
- m_iops += td->o.rate_iops_min[0] + td->o.rate_iops_min[1];
+ m_iops += td->o.rate_iops_min[0] +
+ td->o.rate_iops_min[1];
files_open += td->nr_open_files;
} else if (td->runstate == TD_RAMP) {
nr_running++;
iops_str[1] = num2str(iops[1], 4, 1, 0);
l = printf(": [%s] [%s] [%s/%s /s] [%s/%s iops] [eta %s]",
- run_str, perc_str, rate_str[0], rate_str[1],
+ run_str, perc_str, rate_str[0], rate_str[1],
iops_str[0], iops_str[1], eta_str);
if (l >= 0 && l < linelen_last)
printf("%*s", linelen_last - l, "");
fio_file_clear_extend(f);
if (!td->o.fill_device) {
old_len = f->real_file_size;
- extend_len = f->io_size + f->file_offset - old_len;
+ extend_len = f->io_size + f->file_offset -
+ old_len;
}
f->real_file_size = (f->io_size + f->file_offset);
err = extend_file(td, f);
log_err("fio: smalloc OOM\n");
assert(0);
}
-
+
f->fd = -1;
if (td->files_size <= td->files_index) {
log_err("fio: smalloc OOM\n");
assert(0);
}
-
+
get_file_type(f);
switch (td->o.file_lock_mode) {
assert(0);
}
__f->fd = -1;
-
+
if (f->file_name) {
__f->file_name = smalloc_strdup(f->file_name);
if (!__f->file_name) {
log_err("fio: smalloc OOM\n");
assert(0);
}
-
+
__f->filetype = f->filetype;
}
odir = ddir ^ 1;
if (td_rw(td) && __should_check_rate(td, odir))
td->rate_pending_usleep[odir] -= usec;
-
+
return ddir;
}
opened = 1;
}
- dprint(FD_FILE, "goodf=%x, badf=%x, ff=%x\n", goodf, badf, f->flags);
+ dprint(FD_FILE, "goodf=%x, badf=%x, ff=%x\n", goodf, badf,
+ f->flags);
if ((!goodf || (f->flags & goodf)) && !(f->flags & badf))
break;
io_u->file = NULL;
fio_file_set_done(f);
td->nr_done_files++;
- dprint(FD_FILE, "%s: is done (%d of %d)\n", f->file_name, td->nr_done_files, td->o.nr_files);
+ dprint(FD_FILE, "%s: is done (%d of %d)\n", f->file_name,
+ td->nr_done_files, td->o.nr_files);
} while (1);
return 0;
ret = 1;
break;
}
-
+
dprint(FD_PARSE, "set cpu allowed %d\n", icpu);
fio_cpu_set(mask, icpu);
icpu++;
.help = "Create files when they are opened for IO",
.def = "0",
},
- {
+ {
.name = "pre_read",
.type = FIO_OPT_BOOL,
.off1 = td_var_offset(pre_read),
o1 = get_option(s1, fio_options, &foo);
o2 = get_option(s2, fio_options, &foo);
-
+
prio1 = prio2 = 0;
if (o1)
prio1 = o1->prio;
bitmap_blocks = alloc_size / SMALLOC_BPL;
alloc_size += bitmap_blocks * sizeof(unsigned int);
pool->mmap_size = alloc_size;
-
+
pool->nr_blocks = bitmap_blocks;
pool->free_blocks = bitmap_blocks * SMALLOC_BPB;
if (spent < td->o.bw_avg_time)
return;
- rate = (td->this_io_bytes[ddir] - ts->stat_io_bytes[ddir]) * 1000 / spent / 1024;
+ rate = (td->this_io_bytes[ddir] - ts->stat_io_bytes[ddir]) *
+ 1000 / spent / 1024;
add_stat_sample(&ts->bw_stat[ddir], rate);
if (ts->bw_log)