blk-iolatency: fix STS_AGAIN handling

The iolatency controller is based on rq_qos. It increments on
rq_qos_throttle() and decrements on either rq_qos_cleanup() or
rq_qos_done_bio(). a3fb01ba5af0 fixes the double accounting issue where
blk_mq_make_request() may call both rq_qos_cleanup() and
rq_qos_done_bio() on REQ_NO_WAIT. So checking STS_AGAIN prevents the
double decrement.

The above works upstream as the only way we can get STS_AGAIN is from
blk_mq_get_request() failing. The STS_AGAIN handling isn't a real
problem as bio_endio() skipping only happens on reserved tag allocation
failures which can only be caused by driver bugs and already triggers
WARN.

However, the fix creates a not so great dependency on how STS_AGAIN can
be propagated. Internally, we (Facebook) carry a patch that kills read
ahead if a cgroup is io congested or a fatal signal is pending. This
combined with chained bios progagate their bi_status to the parent is
not already set can can cause the parent bio to not clean up properly
even though it was successful. This consequently leaks the inflight
counter and can hang all IOs under that blkg.

To nip the adverse interaction early, this removes the rq_qos_cleanup()
callback in iolatency in favor of cleaning up always on the
rq_qos_done_bio() path.

Fixes: a3fb01ba5af0 ("blk-iolatency: only account submitted bios")
Debugged-by: Tejun Heo <tj@kernel.org>
Debugged-by: Josef Bacik <josef@toxicpanda.com>
Signed-off-by: Dennis Zhou <dennis@kernel.org>
Signed-off-by: Jens Axboe <axboe@kernel.dk>

diff --git a/block/blk-iolatency.c b/block/blk-iolatency.c
index e8859350ab6ea0b25def8a76b5f99ea3db404405..d973c38ee4fd65b502af755e491e1a4bb830c0c3 100644 (file)
--- a/block/blk-iolatency.c
+++ b/block/blk-iolatency.c
@@ -600,10 +600,6 @@ static void blkcg_iolatency_done_bio(struct rq_qos *rqos, struct bio *bio)
        if (!blkg || !bio_flagged(bio, BIO_TRACKED))
                return;
 
-       /* We didn't actually submit this bio, don't account it. */
-       if (bio->bi_status == BLK_STS_AGAIN)
-               return;
-
        iolat = blkg_to_lat(bio->bi_blkg);
        if (!iolat)
                return;
@@ -622,40 +618,22 @@ static void blkcg_iolatency_done_bio(struct rq_qos *rqos, struct bio *bio)
 
                inflight = atomic_dec_return(&rqw->inflight);
                WARN_ON_ONCE(inflight < 0);
-               if (iolat->min_lat_nsec == 0)
-                       goto next;
-               iolatency_record_time(iolat, &bio->bi_issue, now,
-                                     issue_as_root);
-               window_start = atomic64_read(&iolat->window_start);
-               if (now > window_start &&
-                   (now - window_start) >= iolat->cur_win_nsec) {
-                       if (atomic64_cmpxchg(&iolat->window_start,
-                                       window_start, now) == window_start)
-                               iolatency_check_latencies(iolat, now);
+               /*
+                * If bi_status is BLK_STS_AGAIN, the bio wasn't actually
+                * submitted, so do not account for it.
+                */
+               if (iolat->min_lat_nsec && bio->bi_status != BLK_STS_AGAIN) {
+                       iolatency_record_time(iolat, &bio->bi_issue, now,
+                                             issue_as_root);
+                       window_start = atomic64_read(&iolat->window_start);
+                       if (now > window_start &&
+                           (now - window_start) >= iolat->cur_win_nsec) {
+                               if (atomic64_cmpxchg(&iolat->window_start,
+                                            window_start, now) == window_start)
+                                       iolatency_check_latencies(iolat, now);
+                       }
                }
-next:
-               wake_up(&rqw->wait);
-               blkg = blkg->parent;
-       }
-}
-
-static void blkcg_iolatency_cleanup(struct rq_qos *rqos, struct bio *bio)
-{
-       struct blkcg_gq *blkg;
-
-       blkg = bio->bi_blkg;
-       while (blkg && blkg->parent) {
-               struct rq_wait *rqw;
-               struct iolatency_grp *iolat;
-
-               iolat = blkg_to_lat(blkg);
-               if (!iolat)
-                       goto next;
-
-               rqw = &iolat->rq_wait;
-               atomic_dec(&rqw->inflight);
                wake_up(&rqw->wait);
-next:
                blkg = blkg->parent;
        }
 }
@@ -671,7 +649,6 @@ static void blkcg_iolatency_exit(struct rq_qos *rqos)
 
 static struct rq_qos_ops blkcg_iolatency_ops = {
        .throttle = blkcg_iolatency_throttle,
-       .cleanup = blkcg_iolatency_cleanup,
        .done_bio = blkcg_iolatency_done_bio,
        .exit = blkcg_iolatency_exit,
 };