Same code as before, just prepared for it.
Signed-off-by: Jens Axboe <jens.axboe@oracle.com>
extern void io_u_log_error(struct thread_data *, struct io_u *);
extern void io_u_init_timeout(void);
extern void io_u_set_timeout(struct thread_data *);
extern void io_u_log_error(struct thread_data *, struct io_u *);
extern void io_u_init_timeout(void);
extern void io_u_set_timeout(struct thread_data *);
-extern void io_u_mark_depth(struct thread_data *, struct io_u *);
+extern void io_u_mark_depth(struct thread_data *, struct io_u *, unsigned int);
/*
* io engine entry points
/*
* io engine entry points
-void io_u_mark_depth(struct thread_data *td, struct io_u *io_u)
+void io_u_mark_depth(struct thread_data *td, struct io_u *io_u,
+ unsigned int nr)
- td->ts.io_u_map[index]++;
- td->ts.total_io_u[io_u->ddir]++;
+ td->ts.io_u_map[index] += nr;
+ td->ts.total_io_u[io_u->ddir] += nr;
}
static void io_u_mark_lat_usec(struct thread_data *td, unsigned long usec)
}
static void io_u_mark_lat_usec(struct thread_data *td, unsigned long usec)
unlock_file(td, io_u->file);
if (ret != FIO_Q_BUSY)
unlock_file(td, io_u->file);
if (ret != FIO_Q_BUSY)
- io_u_mark_depth(td, io_u);
+ io_u_mark_depth(td, io_u, 1);
if (ret == FIO_Q_QUEUED) {
int r;
if (ret == FIO_Q_QUEUED) {
int r;