P Thread setup, but not started.
C Thread created.
I Thread initialized, waiting.
+ p Thread running pre-reading file(s).
R Running, doing sequential reads.
r Running, doing random reads.
W Running, doing sequential writes.
c = 'W';
}
break;
+ case TD_PRE_READING:
+ c = 'p';
+ break;
case TD_VERIFYING:
c = 'V';
break;
eta_sec = td->o.timeout + done_secs - elapsed;
} else if (td->runstate == TD_NOT_CREATED || td->runstate == TD_CREATED
|| td->runstate == TD_INITIALIZED
- || td->runstate == TD_RAMP) {
+ || td->runstate == TD_RAMP
+ || td->runstate == TD_PRE_READING) {
int t_eta = 0, r_eta = 0;
/*
if (td->o.bw_avg_time < bw_avg_time)
bw_avg_time = td->o.bw_avg_time;
if (td->runstate == TD_RUNNING || td->runstate == TD_VERIFYING
- || td->runstate == TD_FSYNCING) {
+ || td->runstate == TD_FSYNCING
+ || td->runstate == TD_PRE_READING) {
nr_running++;
t_rate += td->o.rate;
m_rate += td->o.ratemin;
static int pre_read_file(struct thread_data *td, struct fio_file *f)
{
- int r;
+ int r, did_open = 0, old_runstate;
unsigned long long left;
unsigned int bs;
char *b;
+ if (!(f->flags & FIO_FILE_OPEN)) {
+ if (td->io_ops->open_file(td, f)) {
+ log_err("fio: cannot pre-read, failed to open file\n");
+ return 1;
+ }
+ did_open = 1;
+ }
+
+ old_runstate = td->runstate;
+ td_set_runstate(td, TD_PRE_READING);
+
bs = td->o.max_bs[DDIR_READ];
b = malloc(bs);
memset(b, 0, bs);
left -= bs;
continue;
} else {
+ printf("r=%d\n", r);
td_verror(td, EIO, "pre_read");
break;
}
}
+ td_set_runstate(td, old_runstate);
+
+ if (did_open)
+ td->io_ops->close_file(td, f);
free(b);
return 0;
}
TD_INITIALIZED,
TD_RAMP,
TD_RUNNING,
+ TD_PRE_READING,
TD_VERIFYING,
TD_FSYNCING,
TD_EXITED,