diff options
Diffstat (limited to 'btt/trace_queue.c')
| -rw-r--r-- | btt/trace_queue.c | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/btt/trace_queue.c b/btt/trace_queue.c index fe85a09..60294b6 100644 --- a/btt/trace_queue.c +++ b/btt/trace_queue.c @@ -23,15 +23,18 @@ static void handle_queue(struct io *q_iop) { seeki_add(q_iop->dip->q2q_handle, q_iop); - update_lq(&last_q, &all_avgs.q2q, q_iop->t.time); update_qregion(&all_regions, q_iop->t.time); dip_update_q(q_iop->dip, q_iop); pip_update_q(q_iop); - if (!remapper_dev(q_iop->t.device)) + if (remapper_dev(q_iop->t.device)) + update_lq(&last_q, &all_avgs.q2q_dm, q_iop->t.time); + else { update_q_histo(q_iop->t.bytes); + update_lq(&last_q, &all_avgs.q2q, q_iop->t.time); + } - q_iop->i_time = q_iop->gm_time = q_iop->d_time = (__u64)-1; - q_iop->is_getrq = -1; + q_iop->i_time = q_iop->g_time = q_iop->i_time = q_iop->m_time = + q_iop->d_time = (__u64)-1; q_iop->dip->n_qs++; q_iop->dip->t_act_q += q_iop->dip->n_act_q; |