Added in running stats for btt

[blktrace.git] / btt / trace_complete.c

diff --git a/btt/trace_complete.c b/btt/trace_complete.c
index 35a6b17a714ff821d75d827854a4eaf54ca2988b..d34fbd0caa8ad04e5984ec0c672a868698ee46f9 100644 (file)
--- a/btt/trace_complete.c
+++ b/btt/trace_complete.c
@@ -53,13 +53,17 @@ static void handle_complete(struct io *c_iop)
 {
        LIST_HEAD(head);
        struct list_head *p, *q;
+       __u64 d_time = (__u64)-1;
+       FILE *pit_fp = c_iop->dip->pit_fp;
+       double cur = BIT_TIME(c_iop->t.time);
 
        update_blks(c_iop);
        update_cregion(&all_regions, c_iop->t.time);
        update_cregion(&c_iop->dip->regions, c_iop->t.time);
        if (c_iop->pip)
                update_cregion(&c_iop->pip->regions, c_iop->t.time);
-       aqd_complete(c_iop->dip->aqd_handle, BIT_TIME(c_iop->t.time));
+       aqd_complete(c_iop->dip->aqd_handle, cur);
+       rstat_add(c_iop->dip->rstat_handle, cur, c_iop->t.bytes >> 9);
 
        dip_foreach_list(c_iop, IOP_Q, &head);
        list_for_each_safe(p, q, &head) {
@@ -77,6 +81,8 @@ static void handle_complete(struct io *c_iop)
                        update_d2c(q_iop, d2c);
                        latency_d2c(q_iop->dip, c_iop->t.time, d2c);
                        iostat_complete(q_iop, c_iop);
+
+                       d_time = q_iop->d_time;
                }
 
                if (per_io_ofp) {
@@ -86,6 +92,12 @@ static void handle_complete(struct io *c_iop)
                        display_io_track(per_io_ofp, q_iop);
                }
 
+               if (q_iop->dip->pit_fp) {
+                       fprintf(pit_fp, "%d.%09lu ",
+                               (int)SECONDS(q_iop->t.time),
+                               (unsigned long)NANO_SECONDS(q_iop->t.time));
+               }
+
                list_del(&q_iop->f_head);
                io_release(q_iop);
        }
@@ -93,6 +105,14 @@ static void handle_complete(struct io *c_iop)
        if (per_io_ofp)
                fprintf(per_io_ofp,
                        "-----------------------------------------\n");
+
+       if (c_iop->dip->pit_fp) {
+               fprintf(pit_fp, "| %d.%09lu | %d.%09lu\n",
+                       (int)SECONDS(d_time),
+                       (unsigned long)NANO_SECONDS(d_time),
+                       (int)SECONDS(c_iop->t.time),
+                       (unsigned long)NANO_SECONDS(c_iop->t.time));
+       }
 }
 
 void trace_complete(struct io *c_iop)