queue_for_each_hw_ctx(q, hctx, i) {
hctx_for_each_ctx(hctx, ctx, j) {
+ blk_stat_flush_batch(&ctx->stat[0]);
+ blk_stat_flush_batch(&ctx->stat[1]);
+
if (!ctx->stat[0].nr_samples &&
!ctx->stat[1].nr_samples)
continue;
if (q->mq_ops)
blk_mq_stat_get(q, dst);
else {
+ blk_stat_flush_batch(&q->rq_stats[0]);
+ blk_stat_flush_batch(&q->rq_stats[1]);
memcpy(&dst[0], &q->rq_stats[0], sizeof(struct blk_rq_stat));
memcpy(&dst[1], &q->rq_stats[1], sizeof(struct blk_rq_stat));
}
uint64_t newest = 0;
hctx_for_each_ctx(hctx, ctx, i) {
+ blk_stat_flush_batch(&ctx->stat[0]);
+ blk_stat_flush_batch(&ctx->stat[1]);
+
if (!ctx->stat[0].nr_samples &&
!ctx->stat[1].nr_samples)
continue;