void write_iolog_put(struct thread_data *td, struct io_u *io_u)
{
- fprintf(td->iolog_f, "%d,%llu,%u\n", io_u->ddir, io_u->offset, io_u->buflen);
+ fprintf(td->iolog_f, "%u,%llu,%u\n", io_u->ddir, io_u->offset, io_u->buflen);
}
int read_iolog_get(struct thread_data *td, struct io_u *io_u)
FILE *f;
int rw, reads, writes;
- f = fopen(td->iolog_file, "r");
+ f = fopen(td->read_iolog_file, "r");
if (!f) {
perror("fopen read iolog");
return 1;
INIT_LIST_HEAD(&ipo->list);
ipo->offset = offset;
ipo->len = bytes;
- if (bytes > td->max_bs)
- td->max_bs = bytes;
- ipo->ddir = rw;
+ ipo->ddir = (enum fio_ddir) rw;
+ if (bytes > td->max_bs[rw])
+ td->max_bs[rw] = bytes;
list_add_tail(&ipo->list, &td->io_log_list);
}
*/
static int init_iolog_write(struct thread_data *td)
{
- FILE *f = fopen(td->iolog_file, "w");
+ FILE *f;
- f = fopen(td->iolog_file, "w");
+ f = fopen(td->write_iolog_file, "w+");
if (!f) {
perror("fopen write iolog");
return 1;
int init_iolog(struct thread_data *td)
{
- if (td->read_iolog)
- return init_iolog_read(td);
- else if (td->write_iolog)
- return init_iolog_write(td);
+ int ret = 0;
- return 0;
+ if (td->io_ops->flags & FIO_CPUIO)
+ return 0;
+
+ if (td->read_iolog_file)
+ ret = init_iolog_read(td);
+ else if (td->write_iolog_file)
+ ret = init_iolog_write(td);
+
+ return ret;
}
int setup_rate(struct thread_data *td)
return -1;
}
- nr_reads_per_sec = (td->rate * 1024) / td->min_bs;
+ nr_reads_per_sec = (td->rate * 1024) / td->min_bs[DDIR_READ];
td->rate_usec_cycle = 1000000 / nr_reads_per_sec;
td->rate_pending_usleep = 0;
return 0;