Update ramp_time

[fio.git] / io_u.c

diff --git a/io_u.c b/io_u.c
index 17db16b1cb3ad13a29a7d4c8e905b564f3e88573..e7d1efa6dac80f86da7dd41309557d2416d7d1e2 100644 (file)
--- a/io_u.c
+++ b/io_u.c
@@ -903,15 +903,13 @@ static void io_completed(struct thread_data *td, struct io_u *io_u,
        if (!io_u->error) {
                unsigned int bytes = io_u->buflen - io_u->resid;
                const enum fio_ddir idx = io_u->ddir;
-               int ret, ramp_done;
+               int ret;
 
-               ramp_done = ramp_time_over(td);
-
-               if (ramp_done) {
-                       td->io_blocks[idx]++;
-                       td->io_bytes[idx] += bytes;
-                       td->this_io_bytes[idx] += bytes;
+               td->io_blocks[idx]++;
+               td->io_bytes[idx] += bytes;
+               td->this_io_bytes[idx] += bytes;
 
+               if (ramp_time_over(td)) {
                        usec = utime_since(&io_u->issue_time, &icd->time);
 
                        add_clat_sample(td, idx, usec);
@@ -924,8 +922,7 @@ static void io_completed(struct thread_data *td, struct io_u *io_u,
                    td->o.verify != VERIFY_NONE)
                        log_io_piece(td, io_u);
 
-               if (ramp_done)
-                       icd->bytes_done[idx] += bytes;
+               icd->bytes_done[idx] += bytes;
 
                if (io_u->end_io) {
                        ret = io_u->end_io(td, io_u);