projects
/
fio.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fix latency logging for io_submit_mode=offload
[fio.git]
/
io_u.c
diff --git
a/io_u.c
b/io_u.c
index 63a176f5eb02b315f3646bfca3fd299279e4f5e4..d80ef983c15972e4dbafc00fb68319826f16b3f2 100644
(file)
--- a/
io_u.c
+++ b/
io_u.c
@@
-1604,6
+1604,9
@@
static void account_io_completion(struct thread_data *td, struct io_u *io_u,
const int no_reduce = !gtod_reduce(td);
unsigned long lusec = 0;
const int no_reduce = !gtod_reduce(td);
unsigned long lusec = 0;
+ if (td->parent)
+ td = td->parent;
+
if (no_reduce)
lusec = utime_since(&io_u->issue_time, &icd->time);
if (no_reduce)
lusec = utime_since(&io_u->issue_time, &icd->time);
@@
-1633,9
+1636,6
@@
static void account_io_completion(struct thread_data *td, struct io_u *io_u,
io_u_mark_latency(td, lusec);
}
io_u_mark_latency(td, lusec);
}
- if (td->parent)
- td = td->parent;
-
if (!td->o.disable_bw)
add_bw_sample(td, idx, bytes, &icd->time);
if (!td->o.disable_bw)
add_bw_sample(td, idx, bytes, &icd->time);
@@
-1891,6
+1891,10
@@
void io_u_queued(struct thread_data *td, struct io_u *io_u)
unsigned long slat_time;
slat_time = utime_since(&io_u->start_time, &io_u->issue_time);
unsigned long slat_time;
slat_time = utime_since(&io_u->start_time, &io_u->issue_time);
+
+ if (td->parent)
+ td = td->parent;
+
add_slat_sample(td, io_u->ddir, slat_time, io_u->xfer_buflen,
io_u->offset);
}
add_slat_sample(td, io_u->ddir, slat_time, io_u->xfer_buflen,
io_u->offset);
}