From nobody Tue Sep 16 20:00:51 2025 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from vger.kernel.org (vger.kernel.org [23.128.96.18]) by smtp.lore.kernel.org (Postfix) with ESMTP id 70906C4708E for ; Thu, 29 Dec 2022 20:38:11 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S234078AbiL2Uhy (ORCPT ); Thu, 29 Dec 2022 15:37:54 -0500 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:51258 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S233830AbiL2Uho (ORCPT ); Thu, 29 Dec 2022 15:37:44 -0500 Received: from mail-ej1-x636.google.com (mail-ej1-x636.google.com [IPv6:2a00:1450:4864:20::636]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 7E4721572B for ; Thu, 29 Dec 2022 12:37:41 -0800 (PST) Received: by mail-ej1-x636.google.com with SMTP id tz12so47410495ejc.9 for ; Thu, 29 Dec 2022 12:37:41 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=linaro.org; s=google; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:from:to:cc:subject:date :message-id:reply-to; bh=YR4JnXnYS5FMMYOySXhDL+PD7Qu4VdENoQn+RMs+O/U=; b=FK20p6oCZ8joyijlZjny/iXYyIAJ96k3A6V0nr966LziFCUDKrEVOjTz++HMush7Df vzuwgHMR5a2IAnZXclA+bfYITjXrqXY+X6ILyfltQg0dThnMS75AEaovMExLnMIwUa2X ybVdu1JMUq+0FdSkxQVqN+1rEDn5fVEyzuzfftS5eqqc+mK8mkHT5O4sSfJaH153Ixg2 9DoGZ5cv/2J5HSRLeF4VHFL+faJtlNkoHi0ypSUv+Tr+ESKfrZ+Je9G6835oFzxNXsNf dOaXVklp2W/NiatrvGKupUvm85MgTL0EjhoaGLbKdcxIoFDMRu+eHdZvekwa4inNZvzw rLTg== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20210112; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:x-gm-message-state:from:to:cc :subject:date:message-id:reply-to; bh=YR4JnXnYS5FMMYOySXhDL+PD7Qu4VdENoQn+RMs+O/U=; b=SEdCsROoDzDwEXWmtJXRgzY2tSgWJYCs3KNxLq5XpjAhfNqx52dpojt13Axl1V5okA vOZtsF8avLSu8PyR/CLOVPj63WWlfv0+HhF+5OB7vUvLy8GmY9cgG99Mgu1JeN3CKh9+ dhVy0f8/1tRQtbi+rBaJH/1yYE7/nyYBIVpz3Pbpx5HTVQXC1rdt2o6wZ0y8pz2HmnR1 zF+2kInSMKeCNXYd1IOzdvM9cWmKxNmb1VE3jWeYVKY2ygA75KHkmkRKKAUmK9STY5K5 R494LVOUvMKGu/YOgsxG7n125vVNa/eOxzKyU0bq6YLr64MS8yqzu8SXmIpm8icW9gzM uTYQ== X-Gm-Message-State: AFqh2kpWyv6int85/h08QaXbTtNPD0qFhuKfW0x15L8hMWpElakvjds7 g1qT6BUQB1jQEKjCxFqM9kovbA== X-Google-Smtp-Source: AMrXdXsveBVb5dZW0kVXFDxruI/gseJ1k1JM1CAU77vUYdBgwQ7+uhhjQua7o0fIcA8w62wj1JkOYw== X-Received: by 2002:a17:906:1419:b0:84c:9016:79ae with SMTP id p25-20020a170906141900b0084c901679aemr2845125ejc.53.1672346259898; Thu, 29 Dec 2022 12:37:39 -0800 (PST) Received: from localhost.localdomain (mob-109-118-160-216.net.vodafone.it. [109.118.160.216]) by smtp.gmail.com with ESMTPSA id d16-20020a170906371000b0073d7b876621sm8872814ejc.205.2022.12.29.12.37.38 (version=TLS1_2 cipher=ECDHE-ECDSA-AES128-GCM-SHA256 bits=128/128); Thu, 29 Dec 2022 12:37:39 -0800 (PST) From: Paolo Valente To: Jens Axboe Cc: linux-block@vger.kernel.org, linux-kernel@vger.kernel.org, arie.vanderhoeven@seagate.com, rory.c.chen@seagate.com, glen.valante@linaro.org, damien.lemoal@opensource.wdc.com, Paolo Valente , Gabriele Felici , Carmine Zaccagnino Subject: [PATCH V13 1/8] block, bfq: split sync bfq_queues on a per-actuator basis Date: Thu, 29 Dec 2022 21:37:00 +0100 Message-Id: <20221229203707.68458-2-paolo.valente@linaro.org> X-Mailer: git-send-email 2.20.1 In-Reply-To: <20221229203707.68458-1-paolo.valente@linaro.org> References: <20221229203707.68458-1-paolo.valente@linaro.org> MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: quoted-printable Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Single-LUN multi-actuator SCSI drives, as well as all multi-actuator SATA drives appear as a single device to the I/O subsystem [1]. Yet they address commands to different actuators internally, as a function of Logical Block Addressing (LBAs). A given sector is reachable by only one of the actuators. For example, Seagate=E2=80=99s Serial Advanced Technology Attachment (SATA) version contains two actuators and maps the lower half of the SATA LBA space to the lower actuator and the upper half to the upper actuator. Evidently, to fully utilize actuators, no actuator must be left idle or underutilized while there is pending I/O for it. The block layer must somehow control the load of each actuator individually. This commit lays the ground for allowing BFQ to provide such a per-actuator control. BFQ associates an I/O-request sync bfq_queue with each process doing synchronous I/O, or with a group of processes, in case of queue merging. Then BFQ serves one bfq_queue at a time. While in service, a bfq_queue is emptied in request-position order. Yet the same process, or group of processes, may generate I/O for different actuators. In this case, different streams of I/O (each for a different actuator) get all inserted into the same sync bfq_queue. So there is basically no individual control on when each stream is served, i.e., on when the I/O requests of the stream are picked from the bfq_queue and dispatched to the drive. This commit enables BFQ to control the service of each actuator individually for synchronous I/O, by simply splitting each sync bfq_queue into N queues, one for each actuator. In other words, a sync bfq_queue is now associated to a pair (process, actuator). As a consequence of this split, the per-queue proportional-share policy implemented by BFQ will guarantee that the sync I/O generated for each actuator, by each process, receives its fair share of service. This is just a preparatory patch. If the I/O of the same process happens to be sent to different queues, then each of these queues may undergo queue merging. To handle this event, the bfq_io_cq data structure must be properly extended. In addition, stable merging must be disabled to avoid loss of control on individual actuators. Finally, also async queues must be split. These issues are described in detail and addressed in next commits. As for this commit, although multiple per-process bfq_queues are provided, the I/O of each process or group of processes is still sent to only one queue, regardless of the actuator the I/O is for. The forwarding to distinct bfq_queues will be enabled after addressing the above issues. [1] https://www.linaro.org/blog/budget-fair-queueing-bfq-linux-io-scheduler= -optimizations-for-multi-actuator-sata-hard-drives/ Reviewed-by: Damien Le Moal Signed-off-by: Gabriele Felici Signed-off-by: Carmine Zaccagnino Signed-off-by: Paolo Valente --- block/bfq-cgroup.c | 91 +++++++++++++------------ block/bfq-iosched.c | 160 +++++++++++++++++++++++++++++--------------- block/bfq-iosched.h | 51 +++++++++++--- 3 files changed, 195 insertions(+), 107 deletions(-) diff --git a/block/bfq-cgroup.c b/block/bfq-cgroup.c index 1b2829e99dad..bd7bf0f8121d 100644 --- a/block/bfq-cgroup.c +++ b/block/bfq-cgroup.c @@ -714,6 +714,46 @@ void bfq_bfqq_move(struct bfq_data *bfqd, struct bfq_q= ueue *bfqq, bfq_put_queue(bfqq); } =20 +static void bfq_sync_bfqq_move(struct bfq_data *bfqd, + struct bfq_queue *sync_bfqq, + struct bfq_io_cq *bic, + struct bfq_group *bfqg, + unsigned int act_idx) +{ + struct bfq_queue *bfqq; + + if (!sync_bfqq->new_bfqq && !bfq_bfqq_coop(sync_bfqq)) { + /* We are the only user of this bfqq, just move it */ + if (sync_bfqq->entity.sched_data !=3D &bfqg->sched_data) + bfq_bfqq_move(bfqd, sync_bfqq, bfqg); + return; + } + + /* + * The queue was merged to a different queue. Check + * that the merge chain still belongs to the same + * cgroup. + */ + for (bfqq =3D sync_bfqq; bfqq; bfqq =3D bfqq->new_bfqq) + if (bfqq->entity.sched_data !=3D &bfqg->sched_data) + break; + if (bfqq) { + /* + * Some queue changed cgroup so the merge is not valid + * anymore. We cannot easily just cancel the merge (by + * clearing new_bfqq) as there may be other processes + * using this queue and holding refs to all queues + * below sync_bfqq->new_bfqq. Similarly if the merge + * already happened, we need to detach from bfqq now + * so that we cannot merge bio to a request from the + * old cgroup. + */ + bfq_put_cooperator(sync_bfqq); + bfq_release_process_ref(bfqd, sync_bfqq); + bic_set_bfqq(bic, NULL, true, act_idx); + } +} + /** * __bfq_bic_change_cgroup - move @bic to @bfqg. * @bfqd: the queue descriptor. @@ -728,53 +768,20 @@ static void __bfq_bic_change_cgroup(struct bfq_data *= bfqd, struct bfq_io_cq *bic, struct bfq_group *bfqg) { - struct bfq_queue *async_bfqq =3D bic_to_bfqq(bic, false); - struct bfq_queue *sync_bfqq =3D bic_to_bfqq(bic, true); - struct bfq_entity *entity; + unsigned int act_idx; =20 - if (async_bfqq) { - entity =3D &async_bfqq->entity; + for (act_idx =3D 0; act_idx < bfqd->num_actuators; act_idx++) { + struct bfq_queue *async_bfqq =3D bic_to_bfqq(bic, false, act_idx); + struct bfq_queue *sync_bfqq =3D bic_to_bfqq(bic, true, act_idx); =20 - if (entity->sched_data !=3D &bfqg->sched_data) { - bic_set_bfqq(bic, NULL, false); + if (async_bfqq && + async_bfqq->entity.sched_data !=3D &bfqg->sched_data) { + bic_set_bfqq(bic, NULL, false, act_idx); bfq_release_process_ref(bfqd, async_bfqq); } - } =20 - if (sync_bfqq) { - if (!sync_bfqq->new_bfqq && !bfq_bfqq_coop(sync_bfqq)) { - /* We are the only user of this bfqq, just move it */ - if (sync_bfqq->entity.sched_data !=3D &bfqg->sched_data) - bfq_bfqq_move(bfqd, sync_bfqq, bfqg); - } else { - struct bfq_queue *bfqq; - - /* - * The queue was merged to a different queue. Check - * that the merge chain still belongs to the same - * cgroup. - */ - for (bfqq =3D sync_bfqq; bfqq; bfqq =3D bfqq->new_bfqq) - if (bfqq->entity.sched_data !=3D - &bfqg->sched_data) - break; - if (bfqq) { - /* - * Some queue changed cgroup so the merge is - * not valid anymore. We cannot easily just - * cancel the merge (by clearing new_bfqq) as - * there may be other processes using this - * queue and holding refs to all queues below - * sync_bfqq->new_bfqq. Similarly if the merge - * already happened, we need to detach from - * bfqq now so that we cannot merge bio to a - * request from the old cgroup. - */ - bfq_put_cooperator(sync_bfqq); - bfq_release_process_ref(bfqd, sync_bfqq); - bic_set_bfqq(bic, NULL, true); - } - } + if (sync_bfqq) + bfq_sync_bfqq_move(bfqd, sync_bfqq, bic, bfqg, act_idx); } } =20 diff --git a/block/bfq-iosched.c b/block/bfq-iosched.c index 16f43bbc575a..801fd66df651 100644 --- a/block/bfq-iosched.c +++ b/block/bfq-iosched.c @@ -377,16 +377,23 @@ static const unsigned long bfq_late_stable_merging = =3D 600; #define RQ_BIC(rq) ((struct bfq_io_cq *)((rq)->elv.priv[0])) #define RQ_BFQQ(rq) ((rq)->elv.priv[1]) =20 -struct bfq_queue *bic_to_bfqq(struct bfq_io_cq *bic, bool is_sync) +struct bfq_queue *bic_to_bfqq(struct bfq_io_cq *bic, bool is_sync, + unsigned int actuator_idx) { - return bic->bfqq[is_sync]; + if (is_sync) + return bic->bfqq[1][actuator_idx]; + + return bic->bfqq[0][actuator_idx]; } =20 static void bfq_put_stable_ref(struct bfq_queue *bfqq); =20 -void bic_set_bfqq(struct bfq_io_cq *bic, struct bfq_queue *bfqq, bool is_s= ync) +void bic_set_bfqq(struct bfq_io_cq *bic, + struct bfq_queue *bfqq, + bool is_sync, + unsigned int actuator_idx) { - struct bfq_queue *old_bfqq =3D bic->bfqq[is_sync]; + struct bfq_queue *old_bfqq =3D bic->bfqq[is_sync][actuator_idx]; =20 /* Clear bic pointer if bfqq is detached from this bic */ if (old_bfqq && old_bfqq->bic =3D=3D bic) @@ -405,7 +412,10 @@ void bic_set_bfqq(struct bfq_io_cq *bic, struct bfq_qu= eue *bfqq, bool is_sync) * we cancel the stable merge if * bic->stable_merge_bfqq =3D=3D bfqq. */ - bic->bfqq[is_sync] =3D bfqq; + if (is_sync) + bic->bfqq[1][actuator_idx] =3D bfqq; + else + bic->bfqq[0][actuator_idx] =3D bfqq; =20 if (bfqq && bic->stable_merge_bfqq =3D=3D bfqq) { /* @@ -678,9 +688,9 @@ static void bfq_limit_depth(blk_opf_t opf, struct blk_m= q_alloc_data *data) { struct bfq_data *bfqd =3D data->q->elevator->elevator_data; struct bfq_io_cq *bic =3D bfq_bic_lookup(data->q); - struct bfq_queue *bfqq =3D bic ? bic_to_bfqq(bic, op_is_sync(opf)) : NULL; int depth; unsigned limit =3D data->q->nr_requests; + unsigned int act_idx; =20 /* Sync reads have full depth available */ if (op_is_sync(opf) && !op_is_write(opf)) { @@ -690,14 +700,21 @@ static void bfq_limit_depth(blk_opf_t opf, struct blk= _mq_alloc_data *data) limit =3D (limit * depth) >> bfqd->full_depth_shift; } =20 - /* - * Does queue (or any parent entity) exceed number of requests that - * should be available to it? Heavily limit depth so that it cannot - * consume more available requests and thus starve other entities. - */ - if (bfqq && bfqq_request_over_limit(bfqq, limit)) - depth =3D 1; + for (act_idx =3D 0; bic && act_idx < bfqd->num_actuators; act_idx++) { + struct bfq_queue *bfqq =3D + bic_to_bfqq(bic, op_is_sync(opf), act_idx); =20 + /* + * Does queue (or any parent entity) exceed number of + * requests that should be available to it? Heavily + * limit depth so that it cannot consume more + * available requests and thus starve other entities. + */ + if (bfqq && bfqq_request_over_limit(bfqq, limit)) { + depth =3D 1; + break; + } + } bfq_log(bfqd, "[%s] wr_busy %d sync %d depth %u", __func__, bfqd->wr_busy_queues, op_is_sync(opf), depth); if (depth) @@ -1766,6 +1783,18 @@ static bool bfq_bfqq_higher_class_or_weight(struct b= fq_queue *bfqq, return bfqq_weight > in_serv_weight; } =20 +/* + * Get the index of the actuator that will serve bio. + */ +static unsigned int bfq_actuator_index(struct bfq_data *bfqd, struct bio *= bio) +{ + /* + * Multi-actuator support not complete yet, so always return 0 + * for the moment (to keep incomplete mechanisms off). + */ + return 0; +} + static bool bfq_better_to_idle(struct bfq_queue *bfqq); =20 static void bfq_bfqq_handle_idle_busy_switch(struct bfq_data *bfqd, @@ -2098,7 +2127,7 @@ static void bfq_check_waker(struct bfq_data *bfqd, st= ruct bfq_queue *bfqq, * We reset waker detection logic also if too much time has passed * since the first detection. If wakeups are rare, pointless idling * doesn't hurt throughput that much. The condition below makes sure - * we do not uselessly idle blocking waker in more than 1/64 cases.=20 + * we do not uselessly idle blocking waker in more than 1/64 cases. */ if (bfqd->last_completed_rq_bfqq !=3D bfqq->tentative_waker_bfqq || @@ -2418,7 +2447,8 @@ static bool bfq_bio_merge(struct request_queue *q, st= ruct bio *bio, */ bfq_bic_update_cgroup(bic, bio); =20 - bfqd->bio_bfqq =3D bic_to_bfqq(bic, op_is_sync(bio->bi_opf)); + bfqd->bio_bfqq =3D bic_to_bfqq(bic, op_is_sync(bio->bi_opf), + bfq_actuator_index(bfqd, bio)); } else { bfqd->bio_bfqq =3D NULL; } @@ -3114,7 +3144,7 @@ bfq_merge_bfqqs(struct bfq_data *bfqd, struct bfq_io_= cq *bic, /* * Merge queues (that is, let bic redirect its requests to new_bfqq) */ - bic_set_bfqq(bic, new_bfqq, true); + bic_set_bfqq(bic, new_bfqq, true, bfqq->actuator_idx); bfq_mark_bfqq_coop(new_bfqq); /* * new_bfqq now belongs to at least two bics (it is a shared queue): @@ -4748,11 +4778,8 @@ static struct bfq_queue *bfq_select_queue(struct bfq= _data *bfqd) */ if (bfq_bfqq_wait_request(bfqq) || (bfqq->dispatched !=3D 0 && bfq_better_to_idle(bfqq))) { - struct bfq_queue *async_bfqq =3D - bfqq->bic && bfqq->bic->bfqq[0] && - bfq_bfqq_busy(bfqq->bic->bfqq[0]) && - bfqq->bic->bfqq[0]->next_rq ? - bfqq->bic->bfqq[0] : NULL; + unsigned int act_idx =3D bfqq->actuator_idx; + struct bfq_queue *async_bfqq =3D NULL; struct bfq_queue *blocked_bfqq =3D !hlist_empty(&bfqq->woken_list) ? container_of(bfqq->woken_list.first, @@ -4760,6 +4787,10 @@ static struct bfq_queue *bfq_select_queue(struct bfq= _data *bfqd) woken_list_node) : NULL; =20 + if (bfqq->bic && bfqq->bic->bfqq[0][act_idx] && + bfq_bfqq_busy(bfqq->bic->bfqq[0][act_idx]) && + bfqq->bic->bfqq[0][act_idx]->next_rq) + async_bfqq =3D bfqq->bic->bfqq[0][act_idx]; /* * The next four mutually-exclusive ifs decide * whether to try injection, and choose the queue to @@ -4844,7 +4875,7 @@ static struct bfq_queue *bfq_select_queue(struct bfq_= data *bfqd) icq_to_bic(async_bfqq->next_rq->elv.icq) =3D=3D bfqq->bic && bfq_serv_to_charge(async_bfqq->next_rq, async_bfqq) <=3D bfq_bfqq_budget_left(async_bfqq)) - bfqq =3D bfqq->bic->bfqq[0]; + bfqq =3D bfqq->bic->bfqq[0][act_idx]; else if (bfqq->waker_bfqq && bfq_bfqq_busy(bfqq->waker_bfqq) && bfqq->waker_bfqq->next_rq && @@ -5305,48 +5336,54 @@ static void bfq_exit_bfqq(struct bfq_data *bfqd, st= ruct bfq_queue *bfqq) bfq_release_process_ref(bfqd, bfqq); } =20 -static void bfq_exit_icq_bfqq(struct bfq_io_cq *bic, bool is_sync) +static void bfq_exit_icq_bfqq(struct bfq_io_cq *bic, bool is_sync, + unsigned int actuator_idx) { - struct bfq_queue *bfqq =3D bic_to_bfqq(bic, is_sync); + struct bfq_queue *bfqq =3D bic_to_bfqq(bic, is_sync, actuator_idx); struct bfq_data *bfqd; =20 if (bfqq) bfqd =3D bfqq->bfqd; /* NULL if scheduler already exited */ =20 if (bfqq && bfqd) { - unsigned long flags; - - spin_lock_irqsave(&bfqd->lock, flags); bfq_exit_bfqq(bfqd, bfqq); - bic_set_bfqq(bic, NULL, is_sync); - spin_unlock_irqrestore(&bfqd->lock, flags); + bic_set_bfqq(bic, NULL, is_sync, actuator_idx); } } =20 static void bfq_exit_icq(struct io_cq *icq) { struct bfq_io_cq *bic =3D icq_to_bic(icq); + struct bfq_data *bfqd =3D bic_to_bfqd(bic); + unsigned long flags; + unsigned int act_idx; + /* + * If bfqd and thus bfqd->num_actuators is not available any + * longer, then cycle over all possible per-actuator bfqqs in + * next loop. We rely on bic being zeroed on creation, and + * therefore on its unused per-actuator fields being NULL. + */ + unsigned int num_actuators =3D BFQ_MAX_ACTUATORS; =20 - if (bic->stable_merge_bfqq) { - struct bfq_data *bfqd =3D bic->stable_merge_bfqq->bfqd; + /* + * bfqd is NULL if scheduler already exited, and in that case + * this is the last time these queues are accessed. + */ + if (bfqd) { + spin_lock_irqsave(&bfqd->lock, flags); + num_actuators =3D bfqd->num_actuators; + } =20 - /* - * bfqd is NULL if scheduler already exited, and in - * that case this is the last time bfqq is accessed. - */ - if (bfqd) { - unsigned long flags; + if (bic->stable_merge_bfqq) + bfq_put_stable_ref(bic->stable_merge_bfqq); =20 - spin_lock_irqsave(&bfqd->lock, flags); - bfq_put_stable_ref(bic->stable_merge_bfqq); - spin_unlock_irqrestore(&bfqd->lock, flags); - } else { - bfq_put_stable_ref(bic->stable_merge_bfqq); - } + for (act_idx =3D 0; act_idx < num_actuators; act_idx++) { + bfq_exit_icq_bfqq(bic, true, act_idx); + bfq_exit_icq_bfqq(bic, false, act_idx); } =20 - bfq_exit_icq_bfqq(bic, true); - bfq_exit_icq_bfqq(bic, false); + if (bfqd) + spin_unlock_irqrestore(&bfqd->lock, flags); } =20 /* @@ -5423,23 +5460,25 @@ static void bfq_check_ioprio_change(struct bfq_io_c= q *bic, struct bio *bio) =20 bic->ioprio =3D ioprio; =20 - bfqq =3D bic_to_bfqq(bic, false); + bfqq =3D bic_to_bfqq(bic, false, bfq_actuator_index(bfqd, bio)); if (bfqq) { bfq_release_process_ref(bfqd, bfqq); bfqq =3D bfq_get_queue(bfqd, bio, false, bic, true); - bic_set_bfqq(bic, bfqq, false); + bic_set_bfqq(bic, bfqq, false, bfq_actuator_index(bfqd, bio)); } =20 - bfqq =3D bic_to_bfqq(bic, true); + bfqq =3D bic_to_bfqq(bic, true, bfq_actuator_index(bfqd, bio)); if (bfqq) bfq_set_next_ioprio_data(bfqq, bic); } =20 static void bfq_init_bfqq(struct bfq_data *bfqd, struct bfq_queue *bfqq, - struct bfq_io_cq *bic, pid_t pid, int is_sync) + struct bfq_io_cq *bic, pid_t pid, int is_sync, + unsigned int act_idx) { u64 now_ns =3D ktime_get_ns(); =20 + bfqq->actuator_idx =3D act_idx; RB_CLEAR_NODE(&bfqq->entity.rb_node); INIT_LIST_HEAD(&bfqq->fifo); INIT_HLIST_NODE(&bfqq->burst_list_node); @@ -5692,7 +5731,7 @@ static struct bfq_queue *bfq_get_queue(struct bfq_dat= a *bfqd, =20 if (bfqq) { bfq_init_bfqq(bfqd, bfqq, bic, current->pid, - is_sync); + is_sync, bfq_actuator_index(bfqd, bio)); bfq_init_entity(&bfqq->entity, bfqg); bfq_log_bfqq(bfqd, bfqq, "allocated"); } else { @@ -6007,7 +6046,8 @@ static bool __bfq_insert_request(struct bfq_data *bfq= d, struct request *rq) * then complete the merge and redirect it to * new_bfqq. */ - if (bic_to_bfqq(RQ_BIC(rq), 1) =3D=3D bfqq) + if (bic_to_bfqq(RQ_BIC(rq), true, + bfq_actuator_index(bfqd, rq->bio)) =3D=3D bfqq) bfq_merge_bfqqs(bfqd, RQ_BIC(rq), bfqq, new_bfqq); =20 @@ -6562,7 +6602,7 @@ bfq_split_bfqq(struct bfq_io_cq *bic, struct bfq_queu= e *bfqq) return bfqq; } =20 - bic_set_bfqq(bic, NULL, true); + bic_set_bfqq(bic, NULL, true, bfqq->actuator_idx); =20 bfq_put_cooperator(bfqq); =20 @@ -6576,7 +6616,8 @@ static struct bfq_queue *bfq_get_bfqq_handle_split(st= ruct bfq_data *bfqd, bool split, bool is_sync, bool *new_queue) { - struct bfq_queue *bfqq =3D bic_to_bfqq(bic, is_sync); + unsigned int act_idx =3D bfq_actuator_index(bfqd, bio); + struct bfq_queue *bfqq =3D bic_to_bfqq(bic, is_sync, act_idx); =20 if (likely(bfqq && bfqq !=3D &bfqd->oom_bfqq)) return bfqq; @@ -6588,7 +6629,7 @@ static struct bfq_queue *bfq_get_bfqq_handle_split(st= ruct bfq_data *bfqd, bfq_put_queue(bfqq); bfqq =3D bfq_get_queue(bfqd, bio, is_sync, bic, split); =20 - bic_set_bfqq(bic, bfqq, is_sync); + bic_set_bfqq(bic, bfqq, is_sync, act_idx); if (split && is_sync) { if ((bic->was_in_burst_list && bfqd->large_burst) || bic->saved_in_large_burst) @@ -7036,8 +7077,10 @@ static int bfq_init_queue(struct request_queue *q, s= truct elevator_type *e) * Our fallback bfqq if bfq_find_alloc_queue() runs into OOM issues. * Grab a permanent reference to it, so that the normal code flow * will not attempt to free it. + * Set zero as actuator index: we will pretend that + * all I/O requests are for the same actuator. */ - bfq_init_bfqq(bfqd, &bfqd->oom_bfqq, NULL, 1, 0); + bfq_init_bfqq(bfqd, &bfqd->oom_bfqq, NULL, 1, 0, 0); bfqd->oom_bfqq.ref++; bfqd->oom_bfqq.new_ioprio =3D BFQ_DEFAULT_QUEUE_IOPRIO; bfqd->oom_bfqq.new_ioprio_class =3D IOPRIO_CLASS_BE; @@ -7056,6 +7099,13 @@ static int bfq_init_queue(struct request_queue *q, s= truct elevator_type *e) =20 bfqd->queue =3D q; =20 + /* + * Multi-actuator support not complete yet, unconditionally + * set to only one actuator for the moment (to keep incomplete + * mechanisms off). + */ + bfqd->num_actuators =3D 1; + INIT_LIST_HEAD(&bfqd->dispatch); =20 hrtimer_init(&bfqd->idle_slice_timer, CLOCK_MONOTONIC, diff --git a/block/bfq-iosched.h b/block/bfq-iosched.h index 41aa151ccc22..3c6b21b2cd95 100644 --- a/block/bfq-iosched.h +++ b/block/bfq-iosched.h @@ -33,6 +33,14 @@ */ #define BFQ_SOFTRT_WEIGHT_FACTOR 100 =20 +/* + * Maximum number of actuators supported. This constant is used simply + * to define the size of the static array that will contain + * per-actuator data. The current value is hopefully a good upper + * bound to the possible number of actuators of any actual drive. + */ +#define BFQ_MAX_ACTUATORS 8 + struct bfq_entity; =20 /** @@ -227,12 +235,14 @@ struct bfq_ttime { * struct bfq_queue - leaf schedulable entity. * * A bfq_queue is a leaf request queue; it can be associated with an - * io_context or more, if it is async or shared between cooperating - * processes. @cgroup holds a reference to the cgroup, to be sure that it - * does not disappear while a bfqq still references it (mostly to avoid - * races between request issuing and task migration followed by cgroup - * destruction). - * All the fields are protected by the queue lock of the containing bfqd. + * io_context or more, if it is async or shared between cooperating + * processes. Besides, it contains I/O requests for only one actuator + * (an io_context is associated with a different bfq_queue for each + * actuator it generates I/O for). @cgroup holds a reference to the + * cgroup, to be sure that it does not disappear while a bfqq still + * references it (mostly to avoid races between request issuing and + * task migration followed by cgroup destruction). All the fields are + * protected by the queue lock of the containing bfqd. */ struct bfq_queue { /* reference counter */ @@ -397,6 +407,9 @@ struct bfq_queue { * the woken queues when this queue exits. */ struct hlist_head woken_list; + + /* index of the actuator this queue is associated with */ + unsigned int actuator_idx; }; =20 /** @@ -405,8 +418,17 @@ struct bfq_queue { struct bfq_io_cq { /* associated io_cq structure */ struct io_cq icq; /* must be the first member */ - /* array of two process queues, the sync and the async */ - struct bfq_queue *bfqq[2]; + /* + * Matrix of associated process queues: first row for async + * queues, second row sync queues. Each row contains one + * column for each actuator. An I/O request generated by the + * process is inserted into the queue pointed by bfqq[i][j] if + * the request is to be served by the j-th actuator of the + * drive, where i=3D=3D0 or i=3D=3D1, depending on whether the request + * is async or sync. So there is a distinct queue for each + * actuator. + */ + struct bfq_queue *bfqq[2][BFQ_MAX_ACTUATORS]; /* per (request_queue, blkcg) ioprio */ int ioprio; #ifdef CONFIG_BFQ_GROUP_IOSCHED @@ -772,6 +794,13 @@ struct bfq_data { */ unsigned int word_depths[2][2]; unsigned int full_depth_shift; + + /* + * Number of independent actuators. This is equal to 1 in + * case of single-actuator drives. + */ + unsigned int num_actuators; + }; =20 enum bfqq_state_flags { @@ -969,8 +998,10 @@ struct bfq_group { =20 extern const int bfq_timeout; =20 -struct bfq_queue *bic_to_bfqq(struct bfq_io_cq *bic, bool is_sync); -void bic_set_bfqq(struct bfq_io_cq *bic, struct bfq_queue *bfqq, bool is_s= ync); +struct bfq_queue *bic_to_bfqq(struct bfq_io_cq *bic, bool is_sync, + unsigned int actuator_idx); +void bic_set_bfqq(struct bfq_io_cq *bic, struct bfq_queue *bfqq, bool is_s= ync, + unsigned int actuator_idx); struct bfq_data *bic_to_bfqd(struct bfq_io_cq *bic); void bfq_pos_tree_add_move(struct bfq_data *bfqd, struct bfq_queue *bfqq); void bfq_weights_tree_add(struct bfq_queue *bfqq); --=20 2.20.1 From nobody Tue Sep 16 20:00:51 2025 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from vger.kernel.org (vger.kernel.org [23.128.96.18]) by smtp.lore.kernel.org (Postfix) with ESMTP id 80995C5479D for ; Thu, 29 Dec 2022 20:38:11 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S234094AbiL2Uh4 (ORCPT ); Thu, 29 Dec 2022 15:37:56 -0500 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:51266 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S233913AbiL2Uho (ORCPT ); Thu, 29 Dec 2022 15:37:44 -0500 Received: from mail-ej1-x62b.google.com (mail-ej1-x62b.google.com [IPv6:2a00:1450:4864:20::62b]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 83F08165B2 for ; Thu, 29 Dec 2022 12:37:42 -0800 (PST) Received: by mail-ej1-x62b.google.com with SMTP id tz12so47410601ejc.9 for ; Thu, 29 Dec 2022 12:37:42 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=linaro.org; s=google; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:from:to:cc:subject:date :message-id:reply-to; bh=Qu2Bp3avWp+ua5WBjxSJKabJBT3O2LRwTKJPgSSWaGY=; b=J61TpuOQz0dlHt7rlxRtCP3uv1Z8FPHT2neu1sGs3/sq/Sv6Puad8p18yVZRtiCySC P+5ra7/JjBLOUFnhfawToplWhlYfJ8QGciLeikBwvOMu7KTD8WMERoM8XmlAUwVDpivF shOYpP/LBhdwZjd00IGK5Yhe8oPvwVSyCyozWS3jY+Td5ICDl1SqzZO+Qz5b0yAcmP8c MxpfpKCBKGR9sFCvSKeGMs81mcxikzqsLgDLoo518XRWjB0GxCUr9k6sI+DDvi2s5V8V jI9XpaAY82xoGOckYYs1a7EVlz95wz9QV0obpUiVIl4/iTTv7WyMUwyLMzqYatof1M7v JXHw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20210112; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:x-gm-message-state:from:to:cc :subject:date:message-id:reply-to; bh=Qu2Bp3avWp+ua5WBjxSJKabJBT3O2LRwTKJPgSSWaGY=; b=DKsE2agPq2Vpseu2P95VhKjjQWIPTSWskWypyBMln45pIqj0BzhZHh1GOBB+nsTnCh UK5v7Hi4pqiX0nX+iRcJQDAOFn0IFHe5oNwG1b7HvaYjyqnKboFS7JCJDbjp4IFoYgF1 A4HxPRHjMnUW+TLvUq6JxtQuQiLciAtUjoxekH6jtxNoNhzt/iFZufy4zB8Is0gxHPML N0nRckgG60UyTQV+u6678QuSF5lIu8UOBis6QUcuwP/ByheDm/8VrShj1Dtrb+MVge7n p6Qp3mIvh0abSkPO38R5kbgoE0K5c6qxFiilugi1a0lYC+5Rt6JjDkC0qSFSE2z0+FtZ /X6w== X-Gm-Message-State: AFqh2krE3PKwgViyNGPMomj2eOn5JQjRMtdqvcmhDOOQ5fyRZXFiXcoM n3cUy4JToBxohhs8pSDLahPQAg== X-Google-Smtp-Source: AMrXdXszrXhse4Qz9szBouzaMHX25dA7rFzloIJ6HotOtL7+h55wT0KSklGyBnryLrvdlaPDavKAZw== X-Received: by 2002:a17:906:1519:b0:803:4426:d31d with SMTP id b25-20020a170906151900b008034426d31dmr23462289ejd.11.1672346261060; Thu, 29 Dec 2022 12:37:41 -0800 (PST) Received: from localhost.localdomain (mob-109-118-160-216.net.vodafone.it. [109.118.160.216]) by smtp.gmail.com with ESMTPSA id d16-20020a170906371000b0073d7b876621sm8872814ejc.205.2022.12.29.12.37.40 (version=TLS1_2 cipher=ECDHE-ECDSA-AES128-GCM-SHA256 bits=128/128); Thu, 29 Dec 2022 12:37:40 -0800 (PST) From: Paolo Valente To: Jens Axboe Cc: linux-block@vger.kernel.org, linux-kernel@vger.kernel.org, arie.vanderhoeven@seagate.com, rory.c.chen@seagate.com, glen.valante@linaro.org, damien.lemoal@opensource.wdc.com, Paolo Valente Subject: [PATCH V13 2/8] block, bfq: forbid stable merging of queues associated with different actuators Date: Thu, 29 Dec 2022 21:37:01 +0100 Message-Id: <20221229203707.68458-3-paolo.valente@linaro.org> X-Mailer: git-send-email 2.20.1 In-Reply-To: <20221229203707.68458-1-paolo.valente@linaro.org> References: <20221229203707.68458-1-paolo.valente@linaro.org> MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Content-Type: text/plain; charset="utf-8" If queues associated with different actuators are merged, then control is lost on each actuator. Therefore some actuator may be underutilized, and throughput may decrease. This problem cannot occur with basic queue merging, because the latter is triggered by spatial locality, and sectors for different actuators are not close to each other. Yet it may happen with stable merging. To address this issue, this commit prevents stable merging from occurring among queues associated with different actuators. Reviewed-by: Damien Le Moal Signed-off-by: Paolo Valente --- block/bfq-iosched.c | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/block/bfq-iosched.c b/block/bfq-iosched.c index 801fd66df651..54d629639c1b 100644 --- a/block/bfq-iosched.c +++ b/block/bfq-iosched.c @@ -5647,9 +5647,13 @@ static struct bfq_queue *bfq_do_or_sched_stable_merg= e(struct bfq_data *bfqd, * it has been set already, but too long ago, then move it * forward to bfqq. Finally, move also if bfqq belongs to a * different group than last_bfqq_created, or if bfqq has a - * different ioprio or ioprio_class. If none of these - * conditions holds true, then try an early stable merge or - * schedule a delayed stable merge. + * different ioprio, ioprio_class or actuator_idx. If none of + * these conditions holds true, then try an early stable merge + * or schedule a delayed stable merge. As for the condition on + * actuator_idx, the reason is that, if queues associated with + * different actuators are merged, then control is lost on + * each actuator. Therefore some actuator may be + * underutilized, and throughput may decrease. * * A delayed merge is scheduled (instead of performing an * early merge), in case bfqq might soon prove to be more @@ -5667,7 +5671,8 @@ static struct bfq_queue *bfq_do_or_sched_stable_merge= (struct bfq_data *bfqd, bfqq->creation_time) || bfqq->entity.parent !=3D last_bfqq_created->entity.parent || bfqq->ioprio !=3D last_bfqq_created->ioprio || - bfqq->ioprio_class !=3D last_bfqq_created->ioprio_class) + bfqq->ioprio_class !=3D last_bfqq_created->ioprio_class || + bfqq->actuator_idx !=3D last_bfqq_created->actuator_idx) *source_bfqq =3D bfqq; else if (time_after_eq(last_bfqq_created->creation_time + bfqd->bfq_burst_interval, --=20 2.20.1 From nobody Tue Sep 16 20:00:51 2025 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from vger.kernel.org (vger.kernel.org [23.128.96.18]) by smtp.lore.kernel.org (Postfix) with ESMTP id 336D0C3DA79 for ; Thu, 29 Dec 2022 20:38:11 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S234039AbiL2Uhv (ORCPT ); Thu, 29 Dec 2022 15:37:51 -0500 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:51328 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S233943AbiL2Uhq (ORCPT ); Thu, 29 Dec 2022 15:37:46 -0500 Received: from mail-ej1-x62f.google.com (mail-ej1-x62f.google.com [IPv6:2a00:1450:4864:20::62f]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 349F917050 for ; Thu, 29 Dec 2022 12:37:44 -0800 (PST) Received: by mail-ej1-x62f.google.com with SMTP id vm8so40509647ejc.2 for ; Thu, 29 Dec 2022 12:37:44 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=linaro.org; s=google; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:from:to:cc:subject:date :message-id:reply-to; bh=zKXcXZqbFWb4l9z8ONxcTOH3ED2krDDsUZINWHwO810=; b=B01S/lgX9MohEo480Ws8JrFfsfHrIx3XnU1CzEIqnM2LeXcXO9z5qZnnxz2W876sZB ZEwixbGfg7au+ufBAmeYOH6eOjpg/u9NgdgWDKa+uEaOArWpt6rmSC5DtoXjwAw8zlCO 1TBN7kU19yv+gJ8/0K6ydUHCsZtW97wrsDw45vYq2PoEf1wir7y+2ToAEHuahdtdJMDk Farx5F+ilLDzZfPEUkmO94JR/fdRtuT1s6h2htttQJi28uJuXBcPp2+kfa3MGJVvxnpV +YSNlto7nNMNUwKFBQIblhKPFLwkdJ/mrNxiZv9rQKNHowG5U+Ql9Em9Xa+exr9J+5zy ZChw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20210112; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:x-gm-message-state:from:to:cc :subject:date:message-id:reply-to; bh=zKXcXZqbFWb4l9z8ONxcTOH3ED2krDDsUZINWHwO810=; b=6IjUrlhF2Kads2XNyN/djgk8NUty4iNXf3c60Jd95xOn/LjlHi4wz0E2dUZrl/AHPe 4nA3IOxhgnzCZ5k1uAFaHNFC8X3fQIu1na0NnaCXRRlqlTL/Qx9ysNfJIU4wCelXuVP7 X1TL7tozBmP9x5dfb3hvIsNxqEC2A23UyyzdeSdSRwp+A1j+MfJoIBbwZ+1P5ahuee5L 19nD6eWvBJrjc5Uc9zRxBgOd6INri5g4R3R6Xji2R3rOTFOCctFHLJVkhCXCr4Kq2m/g b3PVyLlvVgtsYAfHEWNPvp3x/D3wCK/ZgorMz1hn8rVGG0BUeTg1kuvvOugUXCcMJu/q PJog== X-Gm-Message-State: AFqh2ko/A3LF8ZuEmKFWLOvBpEI1oraGV9Ps3NH36LjyROf3RqQKrG4i tqjG/x7CrNjN/bDU09+85gtWFA== X-Google-Smtp-Source: AMrXdXt3Obu0ylxnjcid5jspqpsh6fRBn3ioui93KnDyp8VsQ2K8Qphsd2DZ3UvNQZbv22Y7ksBkPg== X-Received: by 2002:a17:906:6d8:b0:844:79b1:ab36 with SMTP id v24-20020a17090606d800b0084479b1ab36mr23982468ejb.25.1672346262542; Thu, 29 Dec 2022 12:37:42 -0800 (PST) Received: from localhost.localdomain (mob-109-118-160-216.net.vodafone.it. [109.118.160.216]) by smtp.gmail.com with ESMTPSA id d16-20020a170906371000b0073d7b876621sm8872814ejc.205.2022.12.29.12.37.41 (version=TLS1_2 cipher=ECDHE-ECDSA-AES128-GCM-SHA256 bits=128/128); Thu, 29 Dec 2022 12:37:42 -0800 (PST) From: Paolo Valente To: Jens Axboe Cc: linux-block@vger.kernel.org, linux-kernel@vger.kernel.org, arie.vanderhoeven@seagate.com, rory.c.chen@seagate.com, glen.valante@linaro.org, damien.lemoal@opensource.wdc.com, Paolo Valente , Gianmarco Lusvardi , Giulio Barabino , Emiliano Maccaferri Subject: [PATCH V13 3/8] block, bfq: move io_cq-persistent bfqq data into a dedicated struct Date: Thu, 29 Dec 2022 21:37:02 +0100 Message-Id: <20221229203707.68458-4-paolo.valente@linaro.org> X-Mailer: git-send-email 2.20.1 In-Reply-To: <20221229203707.68458-1-paolo.valente@linaro.org> References: <20221229203707.68458-1-paolo.valente@linaro.org> MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Content-Type: text/plain; charset="utf-8" With a multi-actuator drive, a process may get associated with multiple bfq_queues: one queue for each of the N actuators. So, the bfq_io_cq data structure must be able to accommodate its per-queue persistent information for N queues. Currently it stores this information for just one queue, in several scalar fields. This is a preparatory commit for moving to accommodating persistent information for N queues. In particular, this commit packs all the above scalar fields into a single data structure. Then there is now only one field, in bfq_io_cq, that stores all the above information. This scalar field will then be turned into an array by a following commit. Suggested-by: Damien Le Moal Reviewed-by: Damien Le Moal Signed-off-by: Gianmarco Lusvardi Signed-off-by: Giulio Barabino Signed-off-by: Emiliano Maccaferri Signed-off-by: Paolo Valente --- block/bfq-iosched.c | 138 +++++++++++++++++++++++++------------------- block/bfq-iosched.h | 52 ++++++++++------- 2 files changed, 110 insertions(+), 80 deletions(-) diff --git a/block/bfq-iosched.c b/block/bfq-iosched.c index 54d629639c1b..af364a7336e5 100644 --- a/block/bfq-iosched.c +++ b/block/bfq-iosched.c @@ -395,10 +395,6 @@ void bic_set_bfqq(struct bfq_io_cq *bic, { struct bfq_queue *old_bfqq =3D bic->bfqq[is_sync][actuator_idx]; =20 - /* Clear bic pointer if bfqq is detached from this bic */ - if (old_bfqq && old_bfqq->bic =3D=3D bic) - old_bfqq->bic =3D NULL; - /* * If bfqq !=3D NULL, then a non-stable queue merge between * bic->bfqq and bfqq is happening here. This causes troubles @@ -412,12 +408,18 @@ void bic_set_bfqq(struct bfq_io_cq *bic, * we cancel the stable merge if * bic->stable_merge_bfqq =3D=3D bfqq. */ + struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data; + + /* Clear bic pointer if bfqq is detached from this bic */ + if (old_bfqq && old_bfqq->bic =3D=3D bic) + old_bfqq->bic =3D NULL; + if (is_sync) bic->bfqq[1][actuator_idx] =3D bfqq; else bic->bfqq[0][actuator_idx] =3D bfqq; =20 - if (bfqq && bic->stable_merge_bfqq =3D=3D bfqq) { + if (bfqq && bfqq_data->stable_merge_bfqq =3D=3D bfqq) { /* * Actually, these same instructions are executed also * in bfq_setup_cooperator, in case of abort or actual @@ -426,9 +428,9 @@ void bic_set_bfqq(struct bfq_io_cq *bic, * did so, we would nest even more complexity in this * function. */ - bfq_put_stable_ref(bic->stable_merge_bfqq); + bfq_put_stable_ref(bfqq_data->stable_merge_bfqq); =20 - bic->stable_merge_bfqq =3D NULL; + bfqq_data->stable_merge_bfqq =3D NULL; } } =20 @@ -1133,38 +1135,40 @@ static void bfq_bfqq_resume_state(struct bfq_queue *bfqq, struct bfq_data *bfqd, struct bfq_io_cq *bic, bool bfq_already_existing) { + struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data; unsigned int old_wr_coeff =3D 1; bool busy =3D bfq_already_existing && bfq_bfqq_busy(bfqq); =20 - if (bic->saved_has_short_ttime) + if (bfqq_data->saved_has_short_ttime) bfq_mark_bfqq_has_short_ttime(bfqq); else bfq_clear_bfqq_has_short_ttime(bfqq); =20 - if (bic->saved_IO_bound) + if (bfqq_data->saved_IO_bound) bfq_mark_bfqq_IO_bound(bfqq); else bfq_clear_bfqq_IO_bound(bfqq); =20 - bfqq->last_serv_time_ns =3D bic->saved_last_serv_time_ns; - bfqq->inject_limit =3D bic->saved_inject_limit; - bfqq->decrease_time_jif =3D bic->saved_decrease_time_jif; + bfqq->last_serv_time_ns =3D bfqq_data->saved_last_serv_time_ns; + bfqq->inject_limit =3D bfqq_data->saved_inject_limit; + bfqq->decrease_time_jif =3D bfqq_data->saved_decrease_time_jif; =20 - bfqq->entity.new_weight =3D bic->saved_weight; - bfqq->ttime =3D bic->saved_ttime; - bfqq->io_start_time =3D bic->saved_io_start_time; - bfqq->tot_idle_time =3D bic->saved_tot_idle_time; + bfqq->entity.new_weight =3D bfqq_data->saved_weight; + bfqq->ttime =3D bfqq_data->saved_ttime; + bfqq->io_start_time =3D bfqq_data->saved_io_start_time; + bfqq->tot_idle_time =3D bfqq_data->saved_tot_idle_time; /* * Restore weight coefficient only if low_latency is on */ if (bfqd->low_latency) { old_wr_coeff =3D bfqq->wr_coeff; - bfqq->wr_coeff =3D bic->saved_wr_coeff; + bfqq->wr_coeff =3D bfqq_data->saved_wr_coeff; } - bfqq->service_from_wr =3D bic->saved_service_from_wr; - bfqq->wr_start_at_switch_to_srt =3D bic->saved_wr_start_at_switch_to_srt; - bfqq->last_wr_start_finish =3D bic->saved_last_wr_start_finish; - bfqq->wr_cur_max_time =3D bic->saved_wr_cur_max_time; + bfqq->service_from_wr =3D bfqq_data->saved_service_from_wr; + bfqq->wr_start_at_switch_to_srt =3D + bfqq_data->saved_wr_start_at_switch_to_srt; + bfqq->last_wr_start_finish =3D bfqq_data->saved_last_wr_start_finish; + bfqq->wr_cur_max_time =3D bfqq_data->saved_wr_cur_max_time; =20 if (bfqq->wr_coeff > 1 && (bfq_bfqq_in_large_burst(bfqq) || time_is_before_jiffies(bfqq->last_wr_start_finish + @@ -1849,7 +1853,7 @@ static void bfq_bfqq_handle_idle_busy_switch(struct b= fq_data *bfqd, wr_or_deserves_wr =3D bfqd->low_latency && (bfqq->wr_coeff > 1 || (bfq_bfqq_sync(bfqq) && - (bfqq->bic || RQ_BIC(rq)->stably_merged) && + (bfqq->bic || RQ_BIC(rq)->bfqq_data.stably_merged) && (*interactive || soft_rt))); =20 /* @@ -2849,6 +2853,7 @@ bfq_setup_cooperator(struct bfq_data *bfqd, struct bf= q_queue *bfqq, void *io_struct, bool request, struct bfq_io_cq *bic) { struct bfq_queue *in_service_bfqq, *new_bfqq; + struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data; =20 /* if a merge has already been setup, then proceed with that first */ if (bfqq->new_bfqq) @@ -2870,21 +2875,21 @@ bfq_setup_cooperator(struct bfq_data *bfqd, struct = bfq_queue *bfqq, * stable merging) also if bic is associated with a * sync queue, but this bfqq is async */ - if (bfq_bfqq_sync(bfqq) && bic->stable_merge_bfqq && + if (bfq_bfqq_sync(bfqq) && bfqq_data->stable_merge_bfqq && !bfq_bfqq_just_created(bfqq) && time_is_before_jiffies(bfqq->split_time + msecs_to_jiffies(bfq_late_stable_merging)) && time_is_before_jiffies(bfqq->creation_time + msecs_to_jiffies(bfq_late_stable_merging))) { struct bfq_queue *stable_merge_bfqq =3D - bic->stable_merge_bfqq; + bfqq_data->stable_merge_bfqq; int proc_ref =3D min(bfqq_process_refs(bfqq), bfqq_process_refs(stable_merge_bfqq)); =20 /* deschedule stable merge, because done or aborted here */ bfq_put_stable_ref(stable_merge_bfqq); =20 - bic->stable_merge_bfqq =3D NULL; + bfqq_data->stable_merge_bfqq =3D NULL; =20 if (!idling_boosts_thr_without_issues(bfqd, bfqq) && proc_ref > 0) { @@ -2893,10 +2898,10 @@ bfq_setup_cooperator(struct bfq_data *bfqd, struct = bfq_queue *bfqq, bfq_setup_merge(bfqq, stable_merge_bfqq); =20 if (new_bfqq) { - bic->stably_merged =3D true; + bfqq_data->stably_merged =3D true; if (new_bfqq->bic) - new_bfqq->bic->stably_merged =3D - true; + new_bfqq->bic->bfqq_data.stably_merged =3D + true; } return new_bfqq; } else @@ -2995,6 +3000,7 @@ bfq_setup_cooperator(struct bfq_data *bfqd, struct bf= q_queue *bfqq, static void bfq_bfqq_save_state(struct bfq_queue *bfqq) { struct bfq_io_cq *bic =3D bfqq->bic; + struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data; =20 /* * If !bfqq->bic, the queue is already shared or its requests @@ -3004,18 +3010,21 @@ static void bfq_bfqq_save_state(struct bfq_queue *b= fqq) if (!bic) return; =20 - bic->saved_last_serv_time_ns =3D bfqq->last_serv_time_ns; - bic->saved_inject_limit =3D bfqq->inject_limit; - bic->saved_decrease_time_jif =3D bfqq->decrease_time_jif; - - bic->saved_weight =3D bfqq->entity.orig_weight; - bic->saved_ttime =3D bfqq->ttime; - bic->saved_has_short_ttime =3D bfq_bfqq_has_short_ttime(bfqq); - bic->saved_IO_bound =3D bfq_bfqq_IO_bound(bfqq); - bic->saved_io_start_time =3D bfqq->io_start_time; - bic->saved_tot_idle_time =3D bfqq->tot_idle_time; - bic->saved_in_large_burst =3D bfq_bfqq_in_large_burst(bfqq); - bic->was_in_burst_list =3D !hlist_unhashed(&bfqq->burst_list_node); + bfqq_data->saved_last_serv_time_ns =3D bfqq->last_serv_time_ns; + bfqq_data->saved_inject_limit =3D bfqq->inject_limit; + bfqq_data->saved_decrease_time_jif =3D bfqq->decrease_time_jif; + + bfqq_data->saved_weight =3D bfqq->entity.orig_weight; + bfqq_data->saved_ttime =3D bfqq->ttime; + bfqq_data->saved_has_short_ttime =3D + bfq_bfqq_has_short_ttime(bfqq); + bfqq_data->saved_IO_bound =3D bfq_bfqq_IO_bound(bfqq); + bfqq_data->saved_io_start_time =3D bfqq->io_start_time; + bfqq_data->saved_tot_idle_time =3D bfqq->tot_idle_time; + bfqq_data->saved_in_large_burst =3D bfq_bfqq_in_large_burst(bfqq); + bfqq_data->was_in_burst_list =3D + !hlist_unhashed(&bfqq->burst_list_node); + if (unlikely(bfq_bfqq_just_created(bfqq) && !bfq_bfqq_in_large_burst(bfqq) && bfqq->bfqd->low_latency)) { @@ -3028,17 +3037,21 @@ static void bfq_bfqq_save_state(struct bfq_queue *b= fqq) * to bfqq, so that to avoid that bfqq unjustly fails * to enjoy weight raising if split soon. */ - bic->saved_wr_coeff =3D bfqq->bfqd->bfq_wr_coeff; - bic->saved_wr_start_at_switch_to_srt =3D bfq_smallest_from_now(); - bic->saved_wr_cur_max_time =3D bfq_wr_duration(bfqq->bfqd); - bic->saved_last_wr_start_finish =3D jiffies; + bfqq_data->saved_wr_coeff =3D bfqq->bfqd->bfq_wr_coeff; + bfqq_data->saved_wr_start_at_switch_to_srt =3D + bfq_smallest_from_now(); + bfqq_data->saved_wr_cur_max_time =3D + bfq_wr_duration(bfqq->bfqd); + bfqq_data->saved_last_wr_start_finish =3D jiffies; } else { - bic->saved_wr_coeff =3D bfqq->wr_coeff; - bic->saved_wr_start_at_switch_to_srt =3D + bfqq_data->saved_wr_coeff =3D bfqq->wr_coeff; + bfqq_data->saved_wr_start_at_switch_to_srt =3D bfqq->wr_start_at_switch_to_srt; - bic->saved_service_from_wr =3D bfqq->service_from_wr; - bic->saved_last_wr_start_finish =3D bfqq->last_wr_start_finish; - bic->saved_wr_cur_max_time =3D bfqq->wr_cur_max_time; + bfqq_data->saved_service_from_wr =3D + bfqq->service_from_wr; + bfqq_data->saved_last_wr_start_finish =3D + bfqq->last_wr_start_finish; + bfqq_data->saved_wr_cur_max_time =3D bfqq->wr_cur_max_time; } } =20 @@ -5364,6 +5377,7 @@ static void bfq_exit_icq(struct io_cq *icq) * therefore on its unused per-actuator fields being NULL. */ unsigned int num_actuators =3D BFQ_MAX_ACTUATORS; + struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data; =20 /* * bfqd is NULL if scheduler already exited, and in that case @@ -5374,8 +5388,8 @@ static void bfq_exit_icq(struct io_cq *icq) num_actuators =3D bfqd->num_actuators; } =20 - if (bic->stable_merge_bfqq) - bfq_put_stable_ref(bic->stable_merge_bfqq); + if (bfqq_data->stable_merge_bfqq) + bfq_put_stable_ref(bfqq_data->stable_merge_bfqq); =20 for (act_idx =3D 0; act_idx < num_actuators; act_idx++) { bfq_exit_icq_bfqq(bic, true, act_idx); @@ -5566,13 +5580,14 @@ bfq_do_early_stable_merge(struct bfq_data *bfqd, st= ruct bfq_queue *bfqq, { struct bfq_queue *new_bfqq =3D bfq_setup_merge(bfqq, last_bfqq_created); + struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data; =20 if (!new_bfqq) return bfqq; =20 if (new_bfqq->bic) - new_bfqq->bic->stably_merged =3D true; - bic->stably_merged =3D true; + new_bfqq->bic->bfqq_data.stably_merged =3D true; + bfqq_data->stably_merged =3D true; =20 /* * Reusing merge functions. This implies that @@ -5641,6 +5656,7 @@ static struct bfq_queue *bfq_do_or_sched_stable_merge= (struct bfq_data *bfqd, &bfqd->last_bfqq_created; =20 struct bfq_queue *last_bfqq_created =3D *source_bfqq; + struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data; =20 /* * If last_bfqq_created has not been set yet, then init it. If @@ -5702,7 +5718,7 @@ static struct bfq_queue *bfq_do_or_sched_stable_merge= (struct bfq_data *bfqd, /* * Record the bfqq to merge to. */ - bic->stable_merge_bfqq =3D last_bfqq_created; + bfqq_data->stable_merge_bfqq =3D last_bfqq_created; } } =20 @@ -6623,6 +6639,7 @@ static struct bfq_queue *bfq_get_bfqq_handle_split(st= ruct bfq_data *bfqd, { unsigned int act_idx =3D bfq_actuator_index(bfqd, bio); struct bfq_queue *bfqq =3D bic_to_bfqq(bic, is_sync, act_idx); + struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data; =20 if (likely(bfqq && bfqq !=3D &bfqd->oom_bfqq)) return bfqq; @@ -6636,12 +6653,12 @@ static struct bfq_queue *bfq_get_bfqq_handle_split(= struct bfq_data *bfqd, =20 bic_set_bfqq(bic, bfqq, is_sync, act_idx); if (split && is_sync) { - if ((bic->was_in_burst_list && bfqd->large_burst) || - bic->saved_in_large_burst) + if ((bfqq_data->was_in_burst_list && bfqd->large_burst) || + bfqq_data->saved_in_large_burst) bfq_mark_bfqq_in_large_burst(bfqq); else { bfq_clear_bfqq_in_large_burst(bfqq); - if (bic->was_in_burst_list) + if (bfqq_data->was_in_burst_list) /* * If bfqq was in the current * burst list before being @@ -6730,6 +6747,7 @@ static struct bfq_queue *bfq_init_rq(struct request *= rq) struct bfq_queue *bfqq; bool new_queue =3D false; bool bfqq_already_existing =3D false, split =3D false; + struct bfq_iocq_bfqq_data *bfqq_data; =20 if (unlikely(!rq->elv.icq)) return NULL; @@ -6753,15 +6771,17 @@ static struct bfq_queue *bfq_init_rq(struct request= *rq) bfqq =3D bfq_get_bfqq_handle_split(bfqd, bic, bio, false, is_sync, &new_queue); =20 + bfqq_data =3D &bic->bfqq_data; + if (likely(!new_queue)) { /* If the queue was seeky for too long, break it apart. */ if (bfq_bfqq_coop(bfqq) && bfq_bfqq_split_coop(bfqq) && - !bic->stably_merged) { + !bfqq_data->stably_merged) { struct bfq_queue *old_bfqq =3D bfqq; =20 /* Update bic before losing reference to bfqq */ if (bfq_bfqq_in_large_burst(bfqq)) - bic->saved_in_large_burst =3D true; + bfqq_data->saved_in_large_burst =3D true; =20 bfqq =3D bfq_split_bfqq(bic, bfqq); split =3D true; diff --git a/block/bfq-iosched.h b/block/bfq-iosched.h index 3c6b21b2cd95..8e0215b8cc30 100644 --- a/block/bfq-iosched.h +++ b/block/bfq-iosched.h @@ -413,27 +413,9 @@ struct bfq_queue { }; =20 /** - * struct bfq_io_cq - per (request_queue, io_context) structure. - */ -struct bfq_io_cq { - /* associated io_cq structure */ - struct io_cq icq; /* must be the first member */ - /* - * Matrix of associated process queues: first row for async - * queues, second row sync queues. Each row contains one - * column for each actuator. An I/O request generated by the - * process is inserted into the queue pointed by bfqq[i][j] if - * the request is to be served by the j-th actuator of the - * drive, where i=3D=3D0 or i=3D=3D1, depending on whether the request - * is async or sync. So there is a distinct queue for each - * actuator. - */ - struct bfq_queue *bfqq[2][BFQ_MAX_ACTUATORS]; - /* per (request_queue, blkcg) ioprio */ - int ioprio; -#ifdef CONFIG_BFQ_GROUP_IOSCHED - uint64_t blkcg_serial_nr; /* the current blkcg serial */ -#endif +* struct bfq_data - bfqq data unique and persistent for associated bfq_io_= cq +*/ +struct bfq_iocq_bfqq_data { /* * Snapshot of the has_short_time flag before merging; taken * to remember its value while the queue is merged, so as to @@ -488,6 +470,34 @@ struct bfq_io_cq { struct bfq_queue *stable_merge_bfqq; =20 bool stably_merged; /* non splittable if true */ +}; + +/** + * struct bfq_io_cq - per (request_queue, io_context) structure. + */ +struct bfq_io_cq { + /* associated io_cq structure */ + struct io_cq icq; /* must be the first member */ + /* + * Matrix of associated process queues: first row for async + * queues, second row sync queues. Each row contains one + * column for each actuator. An I/O request generated by the + * process is inserted into the queue pointed by bfqq[i][j] if + * the request is to be served by the j-th actuator of the + * drive, where i=3D=3D0 or i=3D=3D1, depending on whether the request + * is async or sync. So there is a distinct queue for each + * actuator. + */ + struct bfq_queue *bfqq[2][BFQ_MAX_ACTUATORS]; + /* per (request_queue, blkcg) ioprio */ + int ioprio; +#ifdef CONFIG_BFQ_GROUP_IOSCHED + uint64_t blkcg_serial_nr; /* the current blkcg serial */ +#endif + + /* persistent data for associated synchronous process queue */ + struct bfq_iocq_bfqq_data bfqq_data; + unsigned int requests; /* Number of requests this process has in flight */ }; =20 --=20 2.20.1 From nobody Tue Sep 16 20:00:51 2025 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from vger.kernel.org (vger.kernel.org [23.128.96.18]) by smtp.lore.kernel.org (Postfix) with ESMTP id A2A07C53210 for ; Thu, 29 Dec 2022 20:38:11 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S234115AbiL2UiB (ORCPT ); Thu, 29 Dec 2022 15:38:01 -0500 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:51426 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S229598AbiL2Uhs (ORCPT ); Thu, 29 Dec 2022 15:37:48 -0500 Received: from mail-ed1-x52c.google.com (mail-ed1-x52c.google.com [IPv6:2a00:1450:4864:20::52c]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id EBDCC1706C for ; Thu, 29 Dec 2022 12:37:45 -0800 (PST) Received: by mail-ed1-x52c.google.com with SMTP id i9so28060707edj.4 for ; Thu, 29 Dec 2022 12:37:45 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=linaro.org; s=google; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:from:to:cc:subject:date :message-id:reply-to; bh=+M0XPk4u99AI/joJU0SzB8dhAfGp1Q+4dpSVduLSVDc=; b=e/c7V0dgYRU0VF31nfdI3FUr4XYvIo+2hG9DqER92KoY50BlTA0owwDJNNAsc6ndzl ssz5fZP5qF6Dg9t2usddSprcpF7KLefWjHFNY7d2yMdDcOZXh5nTPE5TVI/o10da6KRR iX5yyQEMH/JEma0bi8SJtgHmE6Hhm6P2tY/vKPLXQ1G6TUZDa9ilD2P3ayGa1zaiAEOw dDPBTBDZVQGmPKXmlCJQ0gANCGukECRaetXd1oeMn5/czKmRcvcM8UlPTINS7SfaPgqV 6tiEMTO3CYcduZFHkUqC+e0KCi2M6gqPi0bzGGzPN0nPb5Av9P8n+wvGZjykp4CWD6x8 xjMw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20210112; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:x-gm-message-state:from:to:cc :subject:date:message-id:reply-to; bh=+M0XPk4u99AI/joJU0SzB8dhAfGp1Q+4dpSVduLSVDc=; b=wpb+p/Yy4PL3259YK8eh8sIoeoY6fkEOMQf5H7C8fj2OOfhr0o4nXQ/e6ZFdUD0eWO dqMHx8Ab3GMU7nAcauiLrYjvhAHIJT7SSl6POmPZhn2zIgmLKEoQlP25HrfHEA5TKds0 yV4cPIKXOxaiCv6OlkfbN1P/hrScIWYsMua6zdi9s+Zv8YJwsIc9TULBUKmkaaRILPG6 w26xuyfPLnlTRWKVJAQCqxk05OsA3h0yXDnrya6hykqOKznwzWjASTGFkZF/tnwLxQ4o 0y5whqxE+9eLBMWYbwAFT5+Od1nOkkIQceLRCDdzxe8svXz/tO2dQd6NJHyI2u9BU6Ml O2rQ== X-Gm-Message-State: AFqh2kpz3Eb3ou9x/zncvptPBktOTGG5Z8NfWgI59LTT96kMkHfbfQA5 Ug8AZjvy7L7SyNcmzoz9c5Mdtg== X-Google-Smtp-Source: AMrXdXu2IHhA1kJ+nnPT7lsIdIcEZ2U8DsOWiF+5AAPHI6lOflWRRTpimUuxZ9tyyiHdFe/jsdvBhQ== X-Received: by 2002:a05:6402:12d4:b0:46c:fe2d:a588 with SMTP id k20-20020a05640212d400b0046cfe2da588mr25393749edx.18.1672346264271; Thu, 29 Dec 2022 12:37:44 -0800 (PST) Received: from localhost.localdomain (mob-109-118-160-216.net.vodafone.it. [109.118.160.216]) by smtp.gmail.com with ESMTPSA id d16-20020a170906371000b0073d7b876621sm8872814ejc.205.2022.12.29.12.37.42 (version=TLS1_2 cipher=ECDHE-ECDSA-AES128-GCM-SHA256 bits=128/128); Thu, 29 Dec 2022 12:37:43 -0800 (PST) From: Paolo Valente To: Jens Axboe Cc: linux-block@vger.kernel.org, linux-kernel@vger.kernel.org, arie.vanderhoeven@seagate.com, rory.c.chen@seagate.com, glen.valante@linaro.org, damien.lemoal@opensource.wdc.com, Paolo Valente , Gabriele Felici , Gianmarco Lusvardi , Giulio Barabino , Emiliano Maccaferri Subject: [PATCH V13 4/8] block, bfq: turn bfqq_data into an array in bfq_io_cq Date: Thu, 29 Dec 2022 21:37:03 +0100 Message-Id: <20221229203707.68458-5-paolo.valente@linaro.org> X-Mailer: git-send-email 2.20.1 In-Reply-To: <20221229203707.68458-1-paolo.valente@linaro.org> References: <20221229203707.68458-1-paolo.valente@linaro.org> MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Content-Type: text/plain; charset="utf-8" When a bfq_queue Q is merged with another queue, several pieces of information are saved about Q. These pieces are stored in the bfqq_data field in the bfq_io_cq data structure of the process associated with Q. Yet, with a multi-actuator drive, a process may get associated with multiple bfq_queues: one queue for each of the N actuators. Each of these queues may undergo a merge. So, the bfq_io_cq data structure must be able to accommodate the above information for N queues. This commit solves this problem by turning the bfqq_data scalar field into an array of N elements (and by changing code so as to handle this array). This solution is written under the assumption that bfq_queues associated with different actuators cannot be cross-merged. This assumption holds naturally with basic queue merging: the latter is triggered by spatial locality, and sectors for different actuators are not close to each other (apart from the corner case of the last sectors served by a given actuator and the first sectors served by the next actuator). As for stable cross-merging, the assumption here is that it is disabled. Reviewed-by: Damien Le Moal Signed-off-by: Gabriele Felici Signed-off-by: Gianmarco Lusvardi Signed-off-by: Giulio Barabino Signed-off-by: Emiliano Maccaferri Signed-off-by: Paolo Valente --- block/bfq-iosched.c | 100 ++++++++++++++++++++++++++------------------ block/bfq-iosched.h | 12 ++++-- 2 files changed, 67 insertions(+), 45 deletions(-) diff --git a/block/bfq-iosched.c b/block/bfq-iosched.c index af364a7336e5..b522438a61cd 100644 --- a/block/bfq-iosched.c +++ b/block/bfq-iosched.c @@ -408,7 +408,7 @@ void bic_set_bfqq(struct bfq_io_cq *bic, * we cancel the stable merge if * bic->stable_merge_bfqq =3D=3D bfqq. */ - struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data; + struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data[actuator_idx]; =20 /* Clear bic pointer if bfqq is detached from this bic */ if (old_bfqq && old_bfqq->bic =3D=3D bic) @@ -1135,9 +1135,10 @@ static void bfq_bfqq_resume_state(struct bfq_queue *bfqq, struct bfq_data *bfqd, struct bfq_io_cq *bic, bool bfq_already_existing) { - struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data; unsigned int old_wr_coeff =3D 1; bool busy =3D bfq_already_existing && bfq_bfqq_busy(bfqq); + unsigned int a_idx =3D bfqq->actuator_idx; + struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data[a_idx]; =20 if (bfqq_data->saved_has_short_ttime) bfq_mark_bfqq_has_short_ttime(bfqq); @@ -1818,7 +1819,9 @@ static void bfq_bfqq_handle_idle_busy_switch(struct b= fq_data *bfqd, arrived_in_time =3D ktime_get_ns() <=3D bfqq->ttime.last_end_request + bfqd->bfq_slice_idle * 3; - + unsigned int act_idx =3D bfq_actuator_index(bfqd, rq->bio); + bool bfqq_non_merged_or_stably_merged =3D + bfqq->bic || RQ_BIC(rq)->bfqq_data[act_idx].stably_merged; =20 /* * bfqq deserves to be weight-raised if: @@ -1852,9 +1855,8 @@ static void bfq_bfqq_handle_idle_busy_switch(struct b= fq_data *bfqd, */ wr_or_deserves_wr =3D bfqd->low_latency && (bfqq->wr_coeff > 1 || - (bfq_bfqq_sync(bfqq) && - (bfqq->bic || RQ_BIC(rq)->bfqq_data.stably_merged) && - (*interactive || soft_rt))); + (bfq_bfqq_sync(bfqq) && bfqq_non_merged_or_stably_merged && + (*interactive || soft_rt))); =20 /* * Using the last flag, update budget and check whether bfqq @@ -2828,6 +2830,35 @@ static bool bfq_may_be_close_cooperator(struct bfq_q= ueue *bfqq, static bool idling_boosts_thr_without_issues(struct bfq_data *bfqd, struct bfq_queue *bfqq); =20 +static struct bfq_queue * +bfq_setup_stable_merge(struct bfq_data *bfqd, struct bfq_queue *bfqq, + struct bfq_queue *stable_merge_bfqq, + struct bfq_iocq_bfqq_data *bfqq_data) +{ + int proc_ref =3D min(bfqq_process_refs(bfqq), + bfqq_process_refs(stable_merge_bfqq)); + struct bfq_queue *new_bfqq; + + if (idling_boosts_thr_without_issues(bfqd, bfqq) || + proc_ref =3D=3D 0) + return NULL; + + /* next function will take at least one ref */ + new_bfqq =3D bfq_setup_merge(bfqq, stable_merge_bfqq); + + if (new_bfqq) { + bfqq_data->stably_merged =3D true; + if (new_bfqq->bic) { + unsigned int new_a_idx =3D new_bfqq->actuator_idx; + struct bfq_iocq_bfqq_data *new_bfqq_data =3D + &new_bfqq->bic->bfqq_data[new_a_idx]; + + new_bfqq_data->stably_merged =3D true; + } + } + return new_bfqq; +} + /* * Attempt to schedule a merge of bfqq with the currently in-service * queue or with a close queue among the scheduled queues. Return @@ -2853,7 +2884,8 @@ bfq_setup_cooperator(struct bfq_data *bfqd, struct bf= q_queue *bfqq, void *io_struct, bool request, struct bfq_io_cq *bic) { struct bfq_queue *in_service_bfqq, *new_bfqq; - struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data; + unsigned int a_idx =3D bfqq->actuator_idx; + struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data[a_idx]; =20 /* if a merge has already been setup, then proceed with that first */ if (bfqq->new_bfqq) @@ -2883,29 +2915,15 @@ bfq_setup_cooperator(struct bfq_data *bfqd, struct = bfq_queue *bfqq, msecs_to_jiffies(bfq_late_stable_merging))) { struct bfq_queue *stable_merge_bfqq =3D bfqq_data->stable_merge_bfqq; - int proc_ref =3D min(bfqq_process_refs(bfqq), - bfqq_process_refs(stable_merge_bfqq)); =20 /* deschedule stable merge, because done or aborted here */ bfq_put_stable_ref(stable_merge_bfqq); =20 bfqq_data->stable_merge_bfqq =3D NULL; =20 - if (!idling_boosts_thr_without_issues(bfqd, bfqq) && - proc_ref > 0) { - /* next function will take at least one ref */ - struct bfq_queue *new_bfqq =3D - bfq_setup_merge(bfqq, stable_merge_bfqq); - - if (new_bfqq) { - bfqq_data->stably_merged =3D true; - if (new_bfqq->bic) - new_bfqq->bic->bfqq_data.stably_merged =3D - true; - } - return new_bfqq; - } else - return NULL; + return bfq_setup_stable_merge(bfqd, bfqq, + stable_merge_bfqq, + bfqq_data); } } =20 @@ -3000,7 +3018,8 @@ bfq_setup_cooperator(struct bfq_data *bfqd, struct bf= q_queue *bfqq, static void bfq_bfqq_save_state(struct bfq_queue *bfqq) { struct bfq_io_cq *bic =3D bfqq->bic; - struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data; + unsigned int a_idx =3D bfqq->actuator_idx; + struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data[a_idx]; =20 /* * If !bfqq->bic, the queue is already shared or its requests @@ -3011,7 +3030,7 @@ static void bfq_bfqq_save_state(struct bfq_queue *bfq= q) return; =20 bfqq_data->saved_last_serv_time_ns =3D bfqq->last_serv_time_ns; - bfqq_data->saved_inject_limit =3D bfqq->inject_limit; + bfqq_data->saved_inject_limit =3D bfqq->inject_limit; bfqq_data->saved_decrease_time_jif =3D bfqq->decrease_time_jif; =20 bfqq_data->saved_weight =3D bfqq->entity.orig_weight; @@ -5377,7 +5396,7 @@ static void bfq_exit_icq(struct io_cq *icq) * therefore on its unused per-actuator fields being NULL. */ unsigned int num_actuators =3D BFQ_MAX_ACTUATORS; - struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data; + struct bfq_iocq_bfqq_data *bfqq_data =3D bic->bfqq_data; =20 /* * bfqd is NULL if scheduler already exited, and in that case @@ -5388,10 +5407,10 @@ static void bfq_exit_icq(struct io_cq *icq) num_actuators =3D bfqd->num_actuators; } =20 - if (bfqq_data->stable_merge_bfqq) - bfq_put_stable_ref(bfqq_data->stable_merge_bfqq); - for (act_idx =3D 0; act_idx < num_actuators; act_idx++) { + if (bfqq_data[act_idx].stable_merge_bfqq) + bfq_put_stable_ref(bfqq_data[act_idx].stable_merge_bfqq); + bfq_exit_icq_bfqq(bic, true, act_idx); bfq_exit_icq_bfqq(bic, false, act_idx); } @@ -5578,16 +5597,16 @@ bfq_do_early_stable_merge(struct bfq_data *bfqd, st= ruct bfq_queue *bfqq, struct bfq_io_cq *bic, struct bfq_queue *last_bfqq_created) { + unsigned int a_idx =3D last_bfqq_created->actuator_idx; struct bfq_queue *new_bfqq =3D bfq_setup_merge(bfqq, last_bfqq_created); - struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data; =20 if (!new_bfqq) return bfqq; =20 if (new_bfqq->bic) - new_bfqq->bic->bfqq_data.stably_merged =3D true; - bfqq_data->stably_merged =3D true; + new_bfqq->bic->bfqq_data[a_idx].stably_merged =3D true; + bic->bfqq_data[a_idx].stably_merged =3D true; =20 /* * Reusing merge functions. This implies that @@ -5656,7 +5675,6 @@ static struct bfq_queue *bfq_do_or_sched_stable_merge= (struct bfq_data *bfqd, &bfqd->last_bfqq_created; =20 struct bfq_queue *last_bfqq_created =3D *source_bfqq; - struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data; =20 /* * If last_bfqq_created has not been set yet, then init it. If @@ -5718,7 +5736,8 @@ static struct bfq_queue *bfq_do_or_sched_stable_merge= (struct bfq_data *bfqd, /* * Record the bfqq to merge to. */ - bfqq_data->stable_merge_bfqq =3D last_bfqq_created; + bic->bfqq_data[last_bfqq_created->actuator_idx].stable_merge_bfqq =3D + last_bfqq_created; } } =20 @@ -6639,7 +6658,7 @@ static struct bfq_queue *bfq_get_bfqq_handle_split(st= ruct bfq_data *bfqd, { unsigned int act_idx =3D bfq_actuator_index(bfqd, bio); struct bfq_queue *bfqq =3D bic_to_bfqq(bic, is_sync, act_idx); - struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data; + struct bfq_iocq_bfqq_data *bfqq_data =3D &bic->bfqq_data[act_idx]; =20 if (likely(bfqq && bfqq !=3D &bfqd->oom_bfqq)) return bfqq; @@ -6747,7 +6766,7 @@ static struct bfq_queue *bfq_init_rq(struct request *= rq) struct bfq_queue *bfqq; bool new_queue =3D false; bool bfqq_already_existing =3D false, split =3D false; - struct bfq_iocq_bfqq_data *bfqq_data; + unsigned int a_idx =3D bfq_actuator_index(bfqd, bio); =20 if (unlikely(!rq->elv.icq)) return NULL; @@ -6771,17 +6790,16 @@ static struct bfq_queue *bfq_init_rq(struct request= *rq) bfqq =3D bfq_get_bfqq_handle_split(bfqd, bic, bio, false, is_sync, &new_queue); =20 - bfqq_data =3D &bic->bfqq_data; - if (likely(!new_queue)) { /* If the queue was seeky for too long, break it apart. */ if (bfq_bfqq_coop(bfqq) && bfq_bfqq_split_coop(bfqq) && - !bfqq_data->stably_merged) { + !bic->bfqq_data[a_idx].stably_merged) { struct bfq_queue *old_bfqq =3D bfqq; =20 /* Update bic before losing reference to bfqq */ if (bfq_bfqq_in_large_burst(bfqq)) - bfqq_data->saved_in_large_burst =3D true; + bic->bfqq_data[a_idx].saved_in_large_burst =3D + true; =20 bfqq =3D bfq_split_bfqq(bic, bfqq); split =3D true; diff --git a/block/bfq-iosched.h b/block/bfq-iosched.h index 8e0215b8cc30..5a6f888930ad 100644 --- a/block/bfq-iosched.h +++ b/block/bfq-iosched.h @@ -418,7 +418,7 @@ struct bfq_queue { struct bfq_iocq_bfqq_data { /* * Snapshot of the has_short_time flag before merging; taken - * to remember its value while the queue is merged, so as to + * to remember its values while the queue is merged, so as to * be able to restore it in case of split. */ bool saved_has_short_ttime; @@ -432,7 +432,7 @@ struct bfq_iocq_bfqq_data { u64 saved_tot_idle_time; =20 /* - * Same purpose as the previous fields for the value of the + * Same purpose as the previous fields for the values of the * field keeping the queue's belonging to a large burst */ bool saved_in_large_burst; @@ -495,8 +495,12 @@ struct bfq_io_cq { uint64_t blkcg_serial_nr; /* the current blkcg serial */ #endif =20 - /* persistent data for associated synchronous process queue */ - struct bfq_iocq_bfqq_data bfqq_data; + /* + * Persistent data for associated synchronous process queues + * (one queue per actuator, see field bfqq above). In + * particular, each of these queues may undergo a merge. + */ + struct bfq_iocq_bfqq_data bfqq_data[BFQ_MAX_ACTUATORS]; =20 unsigned int requests; /* Number of requests this process has in flight */ }; --=20 2.20.1 From nobody Tue Sep 16 20:00:51 2025 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from vger.kernel.org (vger.kernel.org [23.128.96.18]) by smtp.lore.kernel.org (Postfix) with ESMTP id 7A67BC54EBD for ; Thu, 29 Dec 2022 20:38:15 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S233982AbiL2UiO (ORCPT ); Thu, 29 Dec 2022 15:38:14 -0500 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:51476 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S234000AbiL2Uhs (ORCPT ); Thu, 29 Dec 2022 15:37:48 -0500 Received: from mail-ej1-x62a.google.com (mail-ej1-x62a.google.com [IPv6:2a00:1450:4864:20::62a]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 2502717046 for ; Thu, 29 Dec 2022 12:37:47 -0800 (PST) Received: by mail-ej1-x62a.google.com with SMTP id vm8so40509873ejc.2 for ; Thu, 29 Dec 2022 12:37:47 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=linaro.org; s=google; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:from:to:cc:subject:date :message-id:reply-to; bh=PR1sxuRU/36TJDiACytBY64OGuYBjmbBR8pWbCnAcBY=; b=GWZy175mB1j6fdLDvTSm6Lmk2BC9k4erUX21w+Mmc/mvwPbOo59uJFZedUv1rICbsC idCKGc1Ut6k8q5neOSJMutWJvmfhEwn60I3KKX2k91P5BKI7EvJBMky6q7omvXeasaEl 81/xB88Dgar6X7jJUn5Tgks454bTK+OhHwuSby9q5nK2ND7GQNrHVTxiTcpJdXh0RmjM RZiZ/PluNlJZ8Drt/ja086JyTH5vf1YNMHeR3cv71lji4DtdWxiLI+PruycMzh/4LRAw qSc5GFio38KZkD/MSMS2gpwobZSa9snrEBLTDhwg7FDKxrEBwjkitCjoovtZe4ewgnQy wlZQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20210112; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:x-gm-message-state:from:to:cc :subject:date:message-id:reply-to; bh=PR1sxuRU/36TJDiACytBY64OGuYBjmbBR8pWbCnAcBY=; b=ChzQHBZebZhlsjlzbkD2f2QTHhBCHlCGza5FLHYknrywRNYXct5Uf5CqsCkRZkf8y0 XKRRxNUGk+7A73EWPXganqIBslfBc/QR8euzBsfsR3n2EO8uLHgIK8lnSvaWCR5ZXbAr eWR4p+708cWDpPVyu4t7mGuHCFm3nYqmDDVGyGjBB3cuLShLRopWKbRMujU5tMfEpaCe 8+DwCHjp3t84kk9seAdbdq/36bn4rQ4rlTrpMO/vSyMUJP9LCtgk+Nkh9VWoQ6+bCXZq r9Z5hew8ZZpuwDvi+PtpCWMgJ8lfUrQ2bdV7f+raeXq4XIYqhF1NH5O71U4GH4CcQLzz LofQ== X-Gm-Message-State: AFqh2kqY3zBCuKqWXarAzMy6KtXpzwFq+oW7BETHage2LIPm5gDu3rZ2 L1N4mPFEYVcjZrmKWGbCbRXMWA== X-Google-Smtp-Source: AMrXdXufFOOaHr2CU7hsFNKq4Pqijjdinl6gtA+zgaHltSxcHTAmWt73sRQKXepop457/r9988hy4w== X-Received: by 2002:a17:907:a407:b0:84c:7974:8a73 with SMTP id sg7-20020a170907a40700b0084c79748a73mr8259023ejc.57.1672346265657; Thu, 29 Dec 2022 12:37:45 -0800 (PST) Received: from localhost.localdomain (mob-109-118-160-216.net.vodafone.it. [109.118.160.216]) by smtp.gmail.com with ESMTPSA id d16-20020a170906371000b0073d7b876621sm8872814ejc.205.2022.12.29.12.37.44 (version=TLS1_2 cipher=ECDHE-ECDSA-AES128-GCM-SHA256 bits=128/128); Thu, 29 Dec 2022 12:37:45 -0800 (PST) From: Paolo Valente To: Jens Axboe Cc: linux-block@vger.kernel.org, linux-kernel@vger.kernel.org, arie.vanderhoeven@seagate.com, rory.c.chen@seagate.com, glen.valante@linaro.org, damien.lemoal@opensource.wdc.com, Davide Zini , Paolo Valente Subject: [PATCH V13 5/8] block, bfq: split also async bfq_queues on a per-actuator basis Date: Thu, 29 Dec 2022 21:37:04 +0100 Message-Id: <20221229203707.68458-6-paolo.valente@linaro.org> X-Mailer: git-send-email 2.20.1 In-Reply-To: <20221229203707.68458-1-paolo.valente@linaro.org> References: <20221229203707.68458-1-paolo.valente@linaro.org> MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Content-Type: text/plain; charset="utf-8" From: Davide Zini Similarly to sync bfq_queues, also async bfq_queues need to be split on a per-actuator basis. Reviewed-by: Damien Le Moal Signed-off-by: Paolo Valente Signed-off-by: Davide Zini --- block/bfq-iosched.c | 41 +++++++++++++++++++++++------------------ block/bfq-iosched.h | 8 ++++---- 2 files changed, 27 insertions(+), 22 deletions(-) diff --git a/block/bfq-iosched.c b/block/bfq-iosched.c index b522438a61cd..9abd920467cf 100644 --- a/block/bfq-iosched.c +++ b/block/bfq-iosched.c @@ -2620,14 +2620,16 @@ static void bfq_bfqq_end_wr(struct bfq_queue *bfqq) void bfq_end_wr_async_queues(struct bfq_data *bfqd, struct bfq_group *bfqg) { - int i, j; - - for (i =3D 0; i < 2; i++) - for (j =3D 0; j < IOPRIO_NR_LEVELS; j++) - if (bfqg->async_bfqq[i][j]) - bfq_bfqq_end_wr(bfqg->async_bfqq[i][j]); - if (bfqg->async_idle_bfqq) - bfq_bfqq_end_wr(bfqg->async_idle_bfqq); + int i, j, k; + + for (k =3D 0; k < bfqd->num_actuators; k++) { + for (i =3D 0; i < 2; i++) + for (j =3D 0; j < IOPRIO_NR_LEVELS; j++) + if (bfqg->async_bfqq[i][j][k]) + bfq_bfqq_end_wr(bfqg->async_bfqq[i][j][k]); + if (bfqg->async_idle_bfqq[k]) + bfq_bfqq_end_wr(bfqg->async_idle_bfqq[k]); + } } =20 static void bfq_end_wr(struct bfq_data *bfqd) @@ -5575,18 +5577,18 @@ static void bfq_init_bfqq(struct bfq_data *bfqd, st= ruct bfq_queue *bfqq, =20 static struct bfq_queue **bfq_async_queue_prio(struct bfq_data *bfqd, struct bfq_group *bfqg, - int ioprio_class, int ioprio) + int ioprio_class, int ioprio, int act_idx) { switch (ioprio_class) { case IOPRIO_CLASS_RT: - return &bfqg->async_bfqq[0][ioprio]; + return &bfqg->async_bfqq[0][ioprio][act_idx]; case IOPRIO_CLASS_NONE: ioprio =3D IOPRIO_BE_NORM; fallthrough; case IOPRIO_CLASS_BE: - return &bfqg->async_bfqq[1][ioprio]; + return &bfqg->async_bfqq[1][ioprio][act_idx]; case IOPRIO_CLASS_IDLE: - return &bfqg->async_idle_bfqq; + return &bfqg->async_idle_bfqq[act_idx]; default: return NULL; } @@ -5759,7 +5761,8 @@ static struct bfq_queue *bfq_get_queue(struct bfq_dat= a *bfqd, bfqg =3D bfq_bio_bfqg(bfqd, bio); if (!is_sync) { async_bfqq =3D bfq_async_queue_prio(bfqd, bfqg, ioprio_class, - ioprio); + ioprio, + bfq_actuator_index(bfqd, bio)); bfqq =3D *async_bfqq; if (bfqq) goto out; @@ -6982,13 +6985,15 @@ static void __bfq_put_async_bfqq(struct bfq_data *b= fqd, */ void bfq_put_async_queues(struct bfq_data *bfqd, struct bfq_group *bfqg) { - int i, j; + int i, j, k; =20 - for (i =3D 0; i < 2; i++) - for (j =3D 0; j < IOPRIO_NR_LEVELS; j++) - __bfq_put_async_bfqq(bfqd, &bfqg->async_bfqq[i][j]); + for (k =3D 0; k < bfqd->num_actuators; k++) { + for (i =3D 0; i < 2; i++) + for (j =3D 0; j < IOPRIO_NR_LEVELS; j++) + __bfq_put_async_bfqq(bfqd, &bfqg->async_bfqq[i][j][k]); =20 - __bfq_put_async_bfqq(bfqd, &bfqg->async_idle_bfqq); + __bfq_put_async_bfqq(bfqd, &bfqg->async_idle_bfqq[k]); + } } =20 /* diff --git a/block/bfq-iosched.h b/block/bfq-iosched.h index 5a6f888930ad..de2b2af643e5 100644 --- a/block/bfq-iosched.h +++ b/block/bfq-iosched.h @@ -980,8 +980,8 @@ struct bfq_group { =20 struct bfq_data *bfqd; =20 - struct bfq_queue *async_bfqq[2][IOPRIO_NR_LEVELS]; - struct bfq_queue *async_idle_bfqq; + struct bfq_queue *async_bfqq[2][IOPRIO_NR_LEVELS][BFQ_MAX_ACTUATORS]; + struct bfq_queue *async_idle_bfqq[BFQ_MAX_ACTUATORS]; =20 struct bfq_entity *my_entity; =20 @@ -998,8 +998,8 @@ struct bfq_group { struct bfq_entity entity; struct bfq_sched_data sched_data; =20 - struct bfq_queue *async_bfqq[2][IOPRIO_NR_LEVELS]; - struct bfq_queue *async_idle_bfqq; + struct bfq_queue *async_bfqq[2][IOPRIO_NR_LEVELS][BFQ_MAX_ACTUATORS]; + struct bfq_queue *async_idle_bfqq[BFQ_MAX_ACTUATORS]; =20 struct rb_root rq_pos_tree; }; --=20 2.20.1 From nobody Tue Sep 16 20:00:51 2025 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from vger.kernel.org (vger.kernel.org [23.128.96.18]) by smtp.lore.kernel.org (Postfix) with ESMTP id EFF69C3DA79 for ; Thu, 29 Dec 2022 20:38:21 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S233928AbiL2UiR (ORCPT ); Thu, 29 Dec 2022 15:38:17 -0500 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:51366 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S233987AbiL2Uht (ORCPT ); Thu, 29 Dec 2022 15:37:49 -0500 Received: from mail-ej1-x635.google.com (mail-ej1-x635.google.com [IPv6:2a00:1450:4864:20::635]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 6CFC817071 for ; Thu, 29 Dec 2022 12:37:47 -0800 (PST) Received: by mail-ej1-x635.google.com with SMTP id m18so47346360eji.5 for ; Thu, 29 Dec 2022 12:37:47 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=linaro.org; s=google; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:from:to:cc:subject:date :message-id:reply-to; bh=rG80s5GgWMdUv/CK4RkTzoQTp3+Pav/YrlTEzf358PQ=; b=uUcUwBRYbgiQL3lPnPqmt6JxVVgfN3Lxhu0NoRxVUwtEvZt2ycR/qSJEygXeEES/bA fu3mEmKq1Q9EeTi0WaC4LSKtfBygyz/049+wm5dE86w39YJ/jHqpyGFwSEFkx1eOgwbt qENFw56E6rgspHmZtC8lPh/89BbLQS6IsNp278UqFKERDfjbhPtwwMEoKuH5TBHw6AAk pHK4eTgb2FSVFZDjuYMKLrpS2n4+2c/LIM6AJq8fKd1nrY1l50jnJ1+Y6IPLVEUrNp9T KakqRKHNBhoXAQa50dcMausl5nhNf8EEmVMAL4KYk1UTPwWWENMbDaCZpgvwTsmHdV4k OmUA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20210112; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:x-gm-message-state:from:to:cc :subject:date:message-id:reply-to; bh=rG80s5GgWMdUv/CK4RkTzoQTp3+Pav/YrlTEzf358PQ=; b=CdOM8xrllA7f+7omt/JytiToORcjZBKSgRjCZF5iUumRYR3hlDxBxQdeogMBNRKMOn QjVYxrzEaTqS7v2bl0mWrs4FcZ/051rJyVz4LnzdzcaFEY3B6KnRD8AjxwOW1ZKIdNiU HV0xCfUSsdHTanlGsBabtzyXfaflLXmTKjLm1KRadoR0IgzN8Jphmu6eX/JQbCektoc8 ucQ66jhHEYwS+h8vWd7br67vpt1P0jv0upmbB5EHfNECAo1T35iVTMxOtasHBBjzccek hKqkGrZQCG9h0rKmLiSak3z6dITP7rrANTsA9osRieNzc8WADMLULLRACgMitIAgPwTc gNBw== X-Gm-Message-State: AFqh2kqWvmOtnXEDkNFafHQogQ/Z9fV+App7l5zvQYF+n5KKbNavFXgD LWwFyI+gEZIOZOUcF5caoeY5+g== X-Google-Smtp-Source: AMrXdXuU8VGNWj2uhtCIzvj/qvHrrRA087ANrQYyQ2yTmv/xxtgxqJNMfGwuI08NHGhNT/kzQSyOmw== X-Received: by 2002:a17:907:a407:b0:84c:7974:8a73 with SMTP id sg7-20020a170907a40700b0084c79748a73mr8259069ejc.57.1672346266979; Thu, 29 Dec 2022 12:37:46 -0800 (PST) Received: from localhost.localdomain (mob-109-118-160-216.net.vodafone.it. [109.118.160.216]) by smtp.gmail.com with ESMTPSA id d16-20020a170906371000b0073d7b876621sm8872814ejc.205.2022.12.29.12.37.45 (version=TLS1_2 cipher=ECDHE-ECDSA-AES128-GCM-SHA256 bits=128/128); Thu, 29 Dec 2022 12:37:46 -0800 (PST) From: Paolo Valente To: Jens Axboe Cc: linux-block@vger.kernel.org, linux-kernel@vger.kernel.org, arie.vanderhoeven@seagate.com, rory.c.chen@seagate.com, glen.valante@linaro.org, damien.lemoal@opensource.wdc.com, Federico Gavioli , Paolo Valente Subject: [PATCH V13 6/8] block, bfq: retrieve independent access ranges from request queue Date: Thu, 29 Dec 2022 21:37:05 +0100 Message-Id: <20221229203707.68458-7-paolo.valente@linaro.org> X-Mailer: git-send-email 2.20.1 In-Reply-To: <20221229203707.68458-1-paolo.valente@linaro.org> References: <20221229203707.68458-1-paolo.valente@linaro.org> MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Content-Type: text/plain; charset="utf-8" From: Federico Gavioli This patch implements the code to gather the content of the independent_access_ranges structure from the request_queue and copy it into the queue's bfq_data. This copy is done at queue initialization. We copy the access ranges into the bfq_data to avoid taking the queue lock each time we access the ranges. This implementation, however, puts a limit to the maximum independent ranges supported by the scheduler. Such a limit is equal to the constant BFQ_MAX_ACTUATORS. This limit was placed to avoid the allocation of dynamic memory. Reviewed-by: Damien Le Moal Co-developed-by: Rory Chen Signed-off-by: Rory Chen Signed-off-by: Federico Gavioli Signed-off-by: Paolo Valente --- block/bfq-iosched.c | 59 +++++++++++++++++++++++++++++++++++++++------ block/bfq-iosched.h | 8 +++++- 2 files changed, 58 insertions(+), 9 deletions(-) diff --git a/block/bfq-iosched.c b/block/bfq-iosched.c index 9abd920467cf..86ac721ac136 100644 --- a/block/bfq-iosched.c +++ b/block/bfq-iosched.c @@ -1793,10 +1793,25 @@ static bool bfq_bfqq_higher_class_or_weight(struct = bfq_queue *bfqq, */ static unsigned int bfq_actuator_index(struct bfq_data *bfqd, struct bio *= bio) { - /* - * Multi-actuator support not complete yet, so always return 0 - * for the moment (to keep incomplete mechanisms off). - */ + unsigned int i; + sector_t end; + + /* no search needed if one or zero ranges present */ + if (bfqd->num_actuators =3D=3D 1) + return 0; + + /* bio_end_sector(bio) gives the sector after the last one */ + end =3D bio_end_sector(bio) - 1; + + for (i =3D 0; i < bfqd->num_actuators; i++) { + if (end >=3D bfqd->sector[i] && + end < bfqd->sector[i] + bfqd->nr_sectors[i]) + return i; + } + + WARN_ONCE(true, + "bfq_actuator_index: bio sector out of ranges: end=3D%llu\n", + end); return 0; } =20 @@ -7105,6 +7120,8 @@ static int bfq_init_queue(struct request_queue *q, st= ruct elevator_type *e) { struct bfq_data *bfqd; struct elevator_queue *eq; + unsigned int i; + struct blk_independent_access_ranges *ia_ranges =3D q->disk->ia_ranges; =20 eq =3D elevator_alloc(q, e); if (!eq) @@ -7147,12 +7164,38 @@ static int bfq_init_queue(struct request_queue *q, = struct elevator_type *e) =20 bfqd->queue =3D q; =20 + bfqd->num_actuators =3D 1; /* - * Multi-actuator support not complete yet, unconditionally - * set to only one actuator for the moment (to keep incomplete - * mechanisms off). + * If the disk supports multiple actuators, copy independent + * access ranges from the request queue structure. */ - bfqd->num_actuators =3D 1; + spin_lock_irq(&q->queue_lock); + if (ia_ranges) { + /* + * Check if the disk ia_ranges size exceeds the current bfq + * actuator limit. + */ + if (ia_ranges->nr_ia_ranges > BFQ_MAX_ACTUATORS) { + pr_crit("nr_ia_ranges higher than act limit: iars=3D%d, max=3D%d.\n", + ia_ranges->nr_ia_ranges, BFQ_MAX_ACTUATORS); + pr_crit("Falling back to single actuator mode.\n"); + } else { + bfqd->num_actuators =3D ia_ranges->nr_ia_ranges; + + for (i =3D 0; i < bfqd->num_actuators; i++) { + bfqd->sector[i] =3D ia_ranges->ia_range[i].sector; + bfqd->nr_sectors[i] =3D + ia_ranges->ia_range[i].nr_sectors; + } + } + } + + /* Otherwise use single-actuator dev info */ + if (bfqd->num_actuators =3D=3D 1) { + bfqd->sector[0] =3D 0; + bfqd->nr_sectors[0] =3D get_capacity(q->disk); + } + spin_unlock_irq(&q->queue_lock); =20 INIT_LIST_HEAD(&bfqd->dispatch); =20 diff --git a/block/bfq-iosched.h b/block/bfq-iosched.h index de2b2af643e5..830dda1f9322 100644 --- a/block/bfq-iosched.h +++ b/block/bfq-iosched.h @@ -814,7 +814,13 @@ struct bfq_data { * case of single-actuator drives. */ unsigned int num_actuators; - + /* + * Disk independent access ranges for each actuator + * in this device. + */ + sector_t sector[BFQ_MAX_ACTUATORS]; + sector_t nr_sectors[BFQ_MAX_ACTUATORS]; + struct blk_independent_access_range ia_ranges[BFQ_MAX_ACTUATORS]; }; =20 enum bfqq_state_flags { --=20 2.20.1 From nobody Tue Sep 16 20:00:51 2025 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from vger.kernel.org (vger.kernel.org [23.128.96.18]) by smtp.lore.kernel.org (Postfix) with ESMTP id C5DF2C3DA79 for ; Thu, 29 Dec 2022 20:38:33 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S234077AbiL2Uib (ORCPT ); Thu, 29 Dec 2022 15:38:31 -0500 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:51604 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S234053AbiL2Uhw (ORCPT ); Thu, 29 Dec 2022 15:37:52 -0500 Received: from mail-ej1-x629.google.com (mail-ej1-x629.google.com [IPv6:2a00:1450:4864:20::629]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id E47CA17047 for ; Thu, 29 Dec 2022 12:37:49 -0800 (PST) Received: by mail-ej1-x629.google.com with SMTP id qk9so47413465ejc.3 for ; Thu, 29 Dec 2022 12:37:49 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=linaro.org; s=google; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:from:to:cc:subject:date :message-id:reply-to; bh=5+W2AEvihO+e+2qEzqjqAsIn/bA/Sw2inAfuzbQfsXw=; b=SflvQTy60p7eR5bHhPUiEWUO1EVdaXb6OuKOkX6dHk7YVUBLvKSzzrCRMKK3GCyGiY /slSkkCqcnKYMaKzuL/rCOEwnowe++b3x6/f5uck0cmKCiH3nW+F4LL3kjECoNrW1zJX Vql0DmuqagdPWlsyFwuTIMFpH/DuLDYTROoGEcovlOsSUemZ/qJsJ6XwTlr7yy/bAerQ Xf79vJXeq7RcRP8pIm7cr172OAkBXhS5G6SoOrC40gB7qcl3ckAMTSWtPVfRIQ26tlWq 0srtf6s6E7DyH3XhKtT9n2u+/sc1ncbXX34AJYGU8vy/FS2MLoEmw8NsZlZJfG3OcT0n pMrA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20210112; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:x-gm-message-state:from:to:cc :subject:date:message-id:reply-to; bh=5+W2AEvihO+e+2qEzqjqAsIn/bA/Sw2inAfuzbQfsXw=; b=pY4ueFJNN4oBwtWTmYPXmfzcbYMvcA6O/3ELtARL4WlhW82dloZ4XGYVsi+bGHYc7I vKNgIX/wnyqbd0GUlrEgge/q5LmyN0PRb+eg9n4ewJirDvkaTGzlCBgGvhOWT9SPTqrl wk46KVflliJVQot8fObCsH/NOKBVnVorFXp99Qy3PD8RcFL5asI7KD4LVyc/sVjB7cUj 2K0AImp/LOAEeLjSmG8Jp2wThazcXNrbla2+J1oYsmkhPWZcE76MDmy39RgcQwwmycJI MyyXNhqlM7rwXmQguZ5z1OFyj01zFrKA7Sn/SwnzA5puU5egwf4Jv1HhgYRZhUA/dw+0 6H1Q== X-Gm-Message-State: AFqh2krLCdMkfPcyv4cf+bm74Tmifh9bCt3sCp5pcmI2VXcJ5O8cB9Rr gKhcoVr2mFLfb7BZ0xZZAa5nBA== X-Google-Smtp-Source: AMrXdXt9PgCCCtMkqpkXGdizfgI8CfB4JE8XrWO/FTDVxncNwCPZM2QIa65SCXvW4KhBa7QPIyqICg== X-Received: by 2002:a17:906:280d:b0:7c1:65f5:7b95 with SMTP id r13-20020a170906280d00b007c165f57b95mr26275347ejc.26.1672346268355; Thu, 29 Dec 2022 12:37:48 -0800 (PST) Received: from localhost.localdomain (mob-109-118-160-216.net.vodafone.it. [109.118.160.216]) by smtp.gmail.com with ESMTPSA id d16-20020a170906371000b0073d7b876621sm8872814ejc.205.2022.12.29.12.37.47 (version=TLS1_2 cipher=ECDHE-ECDSA-AES128-GCM-SHA256 bits=128/128); Thu, 29 Dec 2022 12:37:48 -0800 (PST) From: Paolo Valente To: Jens Axboe Cc: linux-block@vger.kernel.org, linux-kernel@vger.kernel.org, arie.vanderhoeven@seagate.com, rory.c.chen@seagate.com, glen.valante@linaro.org, damien.lemoal@opensource.wdc.com, Davide Zini , Paolo Valente Subject: [PATCH V13 7/8] block, bfq: inject I/O to underutilized actuators Date: Thu, 29 Dec 2022 21:37:06 +0100 Message-Id: <20221229203707.68458-8-paolo.valente@linaro.org> X-Mailer: git-send-email 2.20.1 In-Reply-To: <20221229203707.68458-1-paolo.valente@linaro.org> References: <20221229203707.68458-1-paolo.valente@linaro.org> MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Content-Type: text/plain; charset="utf-8" From: Davide Zini The main service scheme of BFQ for sync I/O is serving one sync bfq_queue at a time, for a while. In particular, BFQ enforces this scheme when it deems the latter necessary to boost throughput or to preserve service guarantees. Unfortunately, when BFQ enforces this policy, only one actuator at a time gets served for a while, because each bfq_queue contains I/O only for one actuator. The other actuators may remain underutilized. Actually, BFQ may serve (inject) extra I/O, taken from other bfq_queues, in parallel with that of the in-service queue. This injection mechanism may provide the ground for dealing also with the above actuator-underutilization problem. Yet BFQ does not take the actuator load into account when choosing which queue to pick extra I/O from. In addition, BFQ may happen to inject extra I/O only when the in-service queue is temporarily empty. In view of these facts, this commit extends the injection mechanism in such a way that the latter: (1) takes into account also the actuator load; (2) checks such a load on each dispatch, and injects I/O for an underutilized actuator, if there is one and there is I/O for it. To perform the check in (2), this commit introduces a load threshold, currently set to 4. A linear scan of each actuator is performed, until an actuator is found for which the following two conditions hold: the load of the actuator is below the threshold, and there is at least one non-in-service queue that contains I/O for that actuator. If such a pair (actuator, queue) is found, then the head request of that queue is returned for dispatch, instead of the head request of the in-service queue. We have set the threshold, empirically, to the minimum possible value for which an actuator is fully utilized, or close to be fully utilized. By doing so, injected I/O 'steals' as few drive-queue slots as possibile to the in-service queue. This reduces as much as possible the probability that the service of I/O from the in-service bfq_queue gets delayed because of slot exhaustion, i.e., because all the slots of the drive queue are filled with I/O injected from other queues (NCQ provides for 32 slots). This new mechanism also counters actuator underutilization in the case of asymmetric configurations of bfq_queues. Namely if there are few bfq_queues containing I/O for some actuators and many bfq_queues containing I/O for other actuators. Or if the bfq_queues containing I/O for some actuators have lower weights than the other bfq_queues. Reviewed-by: Damien Le Moal Signed-off-by: Paolo Valente Signed-off-by: Davide Zini --- block/bfq-cgroup.c | 2 +- block/bfq-iosched.c | 136 ++++++++++++++++++++++++++++++++------------ block/bfq-iosched.h | 39 ++++++++++++- block/bfq-wf2q.c | 2 +- 4 files changed, 139 insertions(+), 40 deletions(-) diff --git a/block/bfq-cgroup.c b/block/bfq-cgroup.c index bd7bf0f8121d..a6e8da5f5cfd 100644 --- a/block/bfq-cgroup.c +++ b/block/bfq-cgroup.c @@ -708,7 +708,7 @@ void bfq_bfqq_move(struct bfq_data *bfqd, struct bfq_qu= eue *bfqq, bfq_activate_bfqq(bfqd, bfqq); } =20 - if (!bfqd->in_service_queue && !bfqd->rq_in_driver) + if (!bfqd->in_service_queue && !bfqd->tot_rq_in_driver) bfq_schedule_dispatch(bfqd); /* release extra ref taken above, bfqq may happen to be freed now */ bfq_put_queue(bfqq); diff --git a/block/bfq-iosched.c b/block/bfq-iosched.c index 86ac721ac136..6ebcd94bf3b3 100644 --- a/block/bfq-iosched.c +++ b/block/bfq-iosched.c @@ -2259,9 +2259,9 @@ static void bfq_add_request(struct request *rq) * elapsed. */ if (bfqq =3D=3D bfqd->in_service_queue && - (bfqd->rq_in_driver =3D=3D 0 || + (bfqd->tot_rq_in_driver =3D=3D 0 || (bfqq->last_serv_time_ns > 0 && - bfqd->rqs_injected && bfqd->rq_in_driver > 0)) && + bfqd->rqs_injected && bfqd->tot_rq_in_driver > 0)) && time_is_before_eq_jiffies(bfqq->decrease_time_jif + msecs_to_jiffies(10))) { bfqd->last_empty_occupied_ns =3D ktime_get_ns(); @@ -2285,7 +2285,7 @@ static void bfq_add_request(struct request *rq) * will be set in case injection is performed * on bfqq before rq is completed). */ - if (bfqd->rq_in_driver =3D=3D 0) + if (bfqd->tot_rq_in_driver =3D=3D 0) bfqd->rqs_injected =3D false; } } @@ -2650,11 +2650,14 @@ void bfq_end_wr_async_queues(struct bfq_data *bfqd, static void bfq_end_wr(struct bfq_data *bfqd) { struct bfq_queue *bfqq; + int i; =20 spin_lock_irq(&bfqd->lock); =20 - list_for_each_entry(bfqq, &bfqd->active_list, bfqq_list) - bfq_bfqq_end_wr(bfqq); + for (i =3D 0; i < bfqd->num_actuators; i++) { + list_for_each_entry(bfqq, &bfqd->active_list[i], bfqq_list) + bfq_bfqq_end_wr(bfqq); + } list_for_each_entry(bfqq, &bfqd->idle_list, bfqq_list) bfq_bfqq_end_wr(bfqq); bfq_end_wr_async(bfqd); @@ -3611,13 +3614,13 @@ static void bfq_update_peak_rate(struct bfq_data *b= fqd, struct request *rq) * - start a new observation interval with this dispatch */ if (now_ns - bfqd->last_dispatch > 100*NSEC_PER_MSEC && - bfqd->rq_in_driver =3D=3D 0) + bfqd->tot_rq_in_driver =3D=3D 0) goto update_rate_and_reset; =20 /* Update sampling information */ bfqd->peak_rate_samples++; =20 - if ((bfqd->rq_in_driver > 0 || + if ((bfqd->tot_rq_in_driver > 0 || now_ns - bfqd->last_completion < BFQ_MIN_TT) && !BFQ_RQ_SEEKY(bfqd, bfqd->last_position, rq)) bfqd->sequential_samples++; @@ -3882,10 +3885,8 @@ static bool idling_needed_for_service_guarantees(str= uct bfq_data *bfqd, return false; =20 return (bfqq->wr_coeff > 1 && - (bfqd->wr_busy_queues < - tot_busy_queues || - bfqd->rq_in_driver >=3D - bfqq->dispatched + 4)) || + (bfqd->wr_busy_queues < tot_busy_queues || + bfqd->tot_rq_in_driver >=3D bfqq->dispatched + 4)) || bfq_asymmetric_scenario(bfqd, bfqq) || tot_busy_queues =3D=3D 1; } @@ -4656,6 +4657,8 @@ bfq_choose_bfqq_for_injection(struct bfq_data *bfqd) { struct bfq_queue *bfqq, *in_serv_bfqq =3D bfqd->in_service_queue; unsigned int limit =3D in_serv_bfqq->inject_limit; + int i; + /* * If * - bfqq is not weight-raised and therefore does not carry @@ -4687,7 +4690,7 @@ bfq_choose_bfqq_for_injection(struct bfq_data *bfqd) ) limit =3D 1; =20 - if (bfqd->rq_in_driver >=3D limit) + if (bfqd->tot_rq_in_driver >=3D limit) return NULL; =20 /* @@ -4702,11 +4705,12 @@ bfq_choose_bfqq_for_injection(struct bfq_data *bfqd) * (and re-added only if it gets new requests, but then it * is assigned again enough budget for its new backlog). */ - list_for_each_entry(bfqq, &bfqd->active_list, bfqq_list) - if (!RB_EMPTY_ROOT(&bfqq->sort_list) && - (in_serv_always_inject || bfqq->wr_coeff > 1) && - bfq_serv_to_charge(bfqq->next_rq, bfqq) <=3D - bfq_bfqq_budget_left(bfqq)) { + for (i =3D 0; i < bfqd->num_actuators; i++) { + list_for_each_entry(bfqq, &bfqd->active_list[i], bfqq_list) + if (!RB_EMPTY_ROOT(&bfqq->sort_list) && + (in_serv_always_inject || bfqq->wr_coeff > 1) && + bfq_serv_to_charge(bfqq->next_rq, bfqq) <=3D + bfq_bfqq_budget_left(bfqq)) { /* * Allow for only one large in-flight request * on non-rotational devices, for the @@ -4731,22 +4735,69 @@ bfq_choose_bfqq_for_injection(struct bfq_data *bfqd) else limit =3D in_serv_bfqq->inject_limit; =20 - if (bfqd->rq_in_driver < limit) { + if (bfqd->tot_rq_in_driver < limit) { bfqd->rqs_injected =3D true; return bfqq; } } + } + + return NULL; +} + +static struct bfq_queue * +bfq_find_active_bfqq_for_actuator(struct bfq_data *bfqd, int idx) +{ + struct bfq_queue *bfqq; + + if (bfqd->in_service_queue && + bfqd->in_service_queue->actuator_idx =3D=3D idx) + return bfqd->in_service_queue; + + list_for_each_entry(bfqq, &bfqd->active_list[idx], bfqq_list) { + if (!RB_EMPTY_ROOT(&bfqq->sort_list) && + bfq_serv_to_charge(bfqq->next_rq, bfqq) <=3D + bfq_bfqq_budget_left(bfqq)) { + return bfqq; + } + } =20 return NULL; } =20 +/* + * Perform a linear scan of each actuator, until an actuator is found + * for which the following two conditions hold: the load of the + * actuator is below the threshold (see comments on actuator_load_threshold + * for details), and there is a queue that contains I/O for that + * actuator. On success, return that queue. + */ +static struct bfq_queue * +bfq_find_bfqq_for_underused_actuator(struct bfq_data *bfqd) +{ + int i; + + for (i =3D 0 ; i < bfqd->num_actuators; i++) { + if (bfqd->rq_in_driver[i] < bfqd->actuator_load_threshold) { + struct bfq_queue *bfqq =3D + bfq_find_active_bfqq_for_actuator(bfqd, i); + + if (bfqq) + return bfqq; + } + } + + return NULL; +} + + /* * Select a queue for service. If we have a current queue in service, * check whether to continue servicing it, or retrieve and set a new one. */ static struct bfq_queue *bfq_select_queue(struct bfq_data *bfqd) { - struct bfq_queue *bfqq; + struct bfq_queue *bfqq, *inject_bfqq; struct request *next_rq; enum bfqq_expiration reason =3D BFQQE_BUDGET_TIMEOUT; =20 @@ -4768,6 +4819,15 @@ static struct bfq_queue *bfq_select_queue(struct bfq= _data *bfqd) goto expire; =20 check_queue: + /* + * If some actuator is underutilized, but the in-service + * queue does not contain I/O for that actuator, then try to + * inject I/O for that actuator. + */ + inject_bfqq =3D bfq_find_bfqq_for_underused_actuator(bfqd); + if (inject_bfqq && inject_bfqq !=3D bfqq) + return inject_bfqq; + /* * This loop is rarely executed more than once. Even when it * happens, it is much more convenient to re-execute this loop @@ -5123,11 +5183,11 @@ static struct request *__bfq_dispatch_request(struc= t blk_mq_hw_ctx *hctx) =20 /* * We exploit the bfq_finish_requeue_request hook to - * decrement rq_in_driver, but + * decrement tot_rq_in_driver, but * bfq_finish_requeue_request will not be invoked on * this request. So, to avoid unbalance, just start - * this request, without incrementing rq_in_driver. As - * a negative consequence, rq_in_driver is deceptively + * this request, without incrementing tot_rq_in_driver. As + * a negative consequence, tot_rq_in_driver is deceptively * lower than it should be while this request is in * service. This may cause bfq_schedule_dispatch to be * invoked uselessly. @@ -5136,7 +5196,7 @@ static struct request *__bfq_dispatch_request(struct = blk_mq_hw_ctx *hctx) * bfq_finish_requeue_request hook, if defined, is * probably invoked also on this request. So, by * exploiting this hook, we could 1) increment - * rq_in_driver here, and 2) decrement it in + * tot_rq_in_driver here, and 2) decrement it in * bfq_finish_requeue_request. Such a solution would * let the value of the counter be always accurate, * but it would entail using an extra interface @@ -5165,7 +5225,7 @@ static struct request *__bfq_dispatch_request(struct = blk_mq_hw_ctx *hctx) * Of course, serving one request at a time may cause loss of * throughput. */ - if (bfqd->strict_guarantees && bfqd->rq_in_driver > 0) + if (bfqd->strict_guarantees && bfqd->tot_rq_in_driver > 0) goto exit; =20 bfqq =3D bfq_select_queue(bfqd); @@ -5176,7 +5236,8 @@ static struct request *__bfq_dispatch_request(struct = blk_mq_hw_ctx *hctx) =20 if (rq) { inc_in_driver_start_rq: - bfqd->rq_in_driver++; + bfqd->rq_in_driver[bfqq->actuator_idx]++; + bfqd->tot_rq_in_driver++; start_rq: rq->rq_flags |=3D RQF_STARTED; } @@ -6243,7 +6304,7 @@ static void bfq_update_hw_tag(struct bfq_data *bfqd) struct bfq_queue *bfqq =3D bfqd->in_service_queue; =20 bfqd->max_rq_in_driver =3D max_t(int, bfqd->max_rq_in_driver, - bfqd->rq_in_driver); + bfqd->tot_rq_in_driver); =20 if (bfqd->hw_tag =3D=3D 1) return; @@ -6254,7 +6315,7 @@ static void bfq_update_hw_tag(struct bfq_data *bfqd) * sum is not exact, as it's not taking into account deactivated * requests. */ - if (bfqd->rq_in_driver + bfqd->queued <=3D BFQ_HW_QUEUE_THRESHOLD) + if (bfqd->tot_rq_in_driver + bfqd->queued <=3D BFQ_HW_QUEUE_THRESHOLD) return; =20 /* @@ -6265,7 +6326,7 @@ static void bfq_update_hw_tag(struct bfq_data *bfqd) if (bfqq && bfq_bfqq_has_short_ttime(bfqq) && bfqq->dispatched + bfqq->queued[0] + bfqq->queued[1] < BFQ_HW_QUEUE_THRESHOLD && - bfqd->rq_in_driver < BFQ_HW_QUEUE_THRESHOLD) + bfqd->tot_rq_in_driver < BFQ_HW_QUEUE_THRESHOLD) return; =20 if (bfqd->hw_tag_samples++ < BFQ_HW_QUEUE_SAMPLES) @@ -6286,7 +6347,8 @@ static void bfq_completed_request(struct bfq_queue *b= fqq, struct bfq_data *bfqd) =20 bfq_update_hw_tag(bfqd); =20 - bfqd->rq_in_driver--; + bfqd->rq_in_driver[bfqq->actuator_idx]--; + bfqd->tot_rq_in_driver--; bfqq->dispatched--; =20 if (!bfqq->dispatched && !bfq_bfqq_busy(bfqq)) { @@ -6406,7 +6468,7 @@ static void bfq_completed_request(struct bfq_queue *b= fqq, struct bfq_data *bfqd) BFQQE_NO_MORE_REQUESTS); } =20 - if (!bfqd->rq_in_driver) + if (!bfqd->tot_rq_in_driver) bfq_schedule_dispatch(bfqd); } =20 @@ -6537,13 +6599,13 @@ static void bfq_update_inject_limit(struct bfq_data= *bfqd, * conditions to do it, or we can lower the last base value * computed. * - * NOTE: (bfqd->rq_in_driver =3D=3D 1) means that there is no I/O + * NOTE: (bfqd->tot_rq_in_driver =3D=3D 1) means that there is no I/O * request in flight, because this function is in the code * path that handles the completion of a request of bfqq, and, * in particular, this function is executed before - * bfqd->rq_in_driver is decremented in such a code path. + * bfqd->tot_rq_in_driver is decremented in such a code path. */ - if ((bfqq->last_serv_time_ns =3D=3D 0 && bfqd->rq_in_driver =3D=3D 1) || + if ((bfqq->last_serv_time_ns =3D=3D 0 && bfqd->tot_rq_in_driver =3D=3D 1)= || tot_time_ns < bfqq->last_serv_time_ns) { if (bfqq->last_serv_time_ns =3D=3D 0) { /* @@ -6553,7 +6615,7 @@ static void bfq_update_inject_limit(struct bfq_data *= bfqd, bfqq->inject_limit =3D max_t(unsigned int, 1, old_limit); } bfqq->last_serv_time_ns =3D tot_time_ns; - } else if (!bfqd->rqs_injected && bfqd->rq_in_driver =3D=3D 1) + } else if (!bfqd->rqs_injected && bfqd->tot_rq_in_driver =3D=3D 1) /* * No I/O injected and no request still in service in * the drive: these are the exact conditions for @@ -7208,7 +7270,8 @@ static int bfq_init_queue(struct request_queue *q, st= ruct elevator_type *e) bfqd->num_groups_with_pending_reqs =3D 0; #endif =20 - INIT_LIST_HEAD(&bfqd->active_list); + INIT_LIST_HEAD(&bfqd->active_list[0]); + INIT_LIST_HEAD(&bfqd->active_list[1]); INIT_LIST_HEAD(&bfqd->idle_list); INIT_HLIST_HEAD(&bfqd->burst_list); =20 @@ -7253,6 +7316,9 @@ static int bfq_init_queue(struct request_queue *q, st= ruct elevator_type *e) ref_wr_duration[blk_queue_nonrot(bfqd->queue)]; bfqd->peak_rate =3D ref_rate[blk_queue_nonrot(bfqd->queue)] * 2 / 3; =20 + /* see comments on the definition of next field inside bfq_data */ + bfqd->actuator_load_threshold =3D 4; + spin_lock_init(&bfqd->lock); =20 /* diff --git a/block/bfq-iosched.h b/block/bfq-iosched.h index 830dda1f9322..058af701bbbe 100644 --- a/block/bfq-iosched.h +++ b/block/bfq-iosched.h @@ -590,7 +590,12 @@ struct bfq_data { /* number of queued requests */ int queued; /* number of requests dispatched and waiting for completion */ - int rq_in_driver; + int tot_rq_in_driver; + /* + * number of requests dispatched and waiting for completion + * for each actuator + */ + int rq_in_driver[BFQ_MAX_ACTUATORS]; =20 /* true if the device is non rotational and performs queueing */ bool nonrot_with_queueing; @@ -684,8 +689,13 @@ struct bfq_data { /* maximum budget allotted to a bfq_queue before rescheduling */ int bfq_max_budget; =20 - /* list of all the bfq_queues active on the device */ - struct list_head active_list; + /* + * List of all the bfq_queues active for a specific actuator + * on the device. Keeping active queues separate on a + * per-actuator basis helps implementing per-actuator + * injection more efficiently. + */ + struct list_head active_list[BFQ_MAX_ACTUATORS]; /* list of all the bfq_queues idle on the device */ struct list_head idle_list; =20 @@ -821,6 +831,29 @@ struct bfq_data { sector_t sector[BFQ_MAX_ACTUATORS]; sector_t nr_sectors[BFQ_MAX_ACTUATORS]; struct blk_independent_access_range ia_ranges[BFQ_MAX_ACTUATORS]; + + /* + * If the number of I/O requests queued in the device for a + * given actuator is below next threshold, then the actuator + * is deemed as underutilized. If this condition is found to + * hold for some actuator upon a dispatch, but (i) the + * in-service queue does not contain I/O for that actuator, + * while (ii) some other queue does contain I/O for that + * actuator, then the head I/O request of the latter queue is + * returned (injected), instead of the head request of the + * currently in-service queue. + * + * We set the threshold, empirically, to the minimum possible + * value for which an actuator is fully utilized, or close to + * be fully utilized. By doing so, injected I/O 'steals' as + * few drive-queue slots as possibile to the in-service + * queue. This reduces as much as possible the probability + * that the service of I/O from the in-service bfq_queue gets + * delayed because of slot exhaustion, i.e., because all the + * slots of the drive queue are filled with I/O injected from + * other queues (NCQ provides for 32 slots). + */ + unsigned int actuator_load_threshold; }; =20 enum bfqq_state_flags { diff --git a/block/bfq-wf2q.c b/block/bfq-wf2q.c index ea4c3d757fdd..7941b6f07391 100644 --- a/block/bfq-wf2q.c +++ b/block/bfq-wf2q.c @@ -493,7 +493,7 @@ static void bfq_active_insert(struct bfq_service_tree *= st, bfq_update_active_tree(node); =20 if (bfqq) - list_add(&bfqq->bfqq_list, &bfqq->bfqd->active_list); + list_add(&bfqq->bfqq_list, &bfqq->bfqd->active_list[bfqq->actuator_idx]); =20 bfq_inc_active_entities(entity); } --=20 2.20.1 From nobody Tue Sep 16 20:00:51 2025 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from vger.kernel.org (vger.kernel.org [23.128.96.18]) by smtp.lore.kernel.org (Postfix) with ESMTP id CCC87C3DA79 for ; Thu, 29 Dec 2022 20:38:28 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S234064AbiL2UiZ (ORCPT ); Thu, 29 Dec 2022 15:38:25 -0500 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:51610 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S234063AbiL2Uhw (ORCPT ); Thu, 29 Dec 2022 15:37:52 -0500 Received: from mail-ej1-x630.google.com (mail-ej1-x630.google.com [IPv6:2a00:1450:4864:20::630]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 24E1B167FB for ; Thu, 29 Dec 2022 12:37:51 -0800 (PST) Received: by mail-ej1-x630.google.com with SMTP id u19so47361323ejm.8 for ; Thu, 29 Dec 2022 12:37:51 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=linaro.org; s=google; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:from:to:cc:subject:date :message-id:reply-to; bh=9zlPY0Un+v49wAp4Agod/FVz6SE5LhUB8HuWcFquXnc=; b=sdpJY2+NyUmLkfu+69Bgwa7d+tcwQGa4x1nj/LQ5dFbmRDTboBYdKioPr/sVUeIltu BnYk3KOvv6XfK9pMHkcsWdKAFwrS16GabcsrkUj++Os0adepdMfqThdiWJq+5j2G6p4p r7lEaCONi81KIIQAYX6QfVrMQp2NUQuKjpON+wA7Gco1Xj2/wSwzpE2IGm1zndSlI54U QAMofPprAxaBIE5Ei0ccCoinDXYE/w9FbQXsVrYNXUsr9mt6mfEctD5x9sb1XWAH1sbd ij1ROss27WN+HRInA3raMHsx/RqQd/QPgh6XLSFb8mqnVNjmxXK15/NVh9yFyDN1MZHX uEwg== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20210112; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:x-gm-message-state:from:to:cc :subject:date:message-id:reply-to; bh=9zlPY0Un+v49wAp4Agod/FVz6SE5LhUB8HuWcFquXnc=; b=TRaZjq6xLwDt8AVuF/301Tuqk4/mPzME7dtdPabXG8H7y7gjrjtaYmDOd+u4jhm8rF MVA22GRUO6P3juF0MEsfPV6R3oq5Y3Sug0Wm4+q/JN0+x9NKxMiP1EfAcPW7vXa1VSzs zpoYK1oYhuoQ+WSguLLVRUEKaEZWCA1V3GcEXUcLEFxVtDfsaWbHpqvzOq6xhIa6a4Fu oWnwxcSqih2e9epdw4wxs/Q88tNg+JJvL9FCzWM2ruf65KTkP2oTosBpAd5qXeXBZnRH cHiRwGCWM0UuczQ642iUS4KpEUDPaOncekqcHd9giFkXTyYYfu5RuuyPyj/a5qllvrnK J7Sw== X-Gm-Message-State: AFqh2kpJgZ/wVErxZr+uqQsjr5DlDjz/wXsxFBVj34FSv8dySZa8hFaF poi2DR+GlqC49W7UXsXPUaZ0yQ== X-Google-Smtp-Source: AMrXdXsrSlcKanVbB0wXQJjNGwoTxQZqpP3fPlRUhqCa6ENu3JN5drvPNz4/WeEsVzzsEnI35rlNiw== X-Received: by 2002:a17:906:8517:b0:7c0:a48b:2dff with SMTP id i23-20020a170906851700b007c0a48b2dffmr30315702ejx.43.1672346269647; Thu, 29 Dec 2022 12:37:49 -0800 (PST) Received: from localhost.localdomain (mob-109-118-160-216.net.vodafone.it. [109.118.160.216]) by smtp.gmail.com with ESMTPSA id d16-20020a170906371000b0073d7b876621sm8872814ejc.205.2022.12.29.12.37.48 (version=TLS1_2 cipher=ECDHE-ECDSA-AES128-GCM-SHA256 bits=128/128); Thu, 29 Dec 2022 12:37:49 -0800 (PST) From: Paolo Valente To: Jens Axboe Cc: linux-block@vger.kernel.org, linux-kernel@vger.kernel.org, arie.vanderhoeven@seagate.com, rory.c.chen@seagate.com, glen.valante@linaro.org, damien.lemoal@opensource.wdc.com, Davide Zini , Paolo Valente Subject: [PATCH V13 8/8] block, bfq: balance I/O injection among underutilized actuators Date: Thu, 29 Dec 2022 21:37:07 +0100 Message-Id: <20221229203707.68458-9-paolo.valente@linaro.org> X-Mailer: git-send-email 2.20.1 In-Reply-To: <20221229203707.68458-1-paolo.valente@linaro.org> References: <20221229203707.68458-1-paolo.valente@linaro.org> MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Content-Type: text/plain; charset="utf-8" From: Davide Zini Upon the invocation of its dispatch function, BFQ returns the next I/O request of the in-service bfq_queue, unless some exception holds. One such exception is that there is some underutilized actuator, different from the actuator for which the in-service queue contains I/O, and that some other bfq_queue happens to contain I/O for such an actuator. In this case, the next I/O request of the latter bfq_queue, and not of the in-service bfq_queue, is returned (I/O is injected from that bfq_queue). To find such an actuator, a linear scan, in increasing index order, is performed among actuators. Performing a linear scan entails a prioritization among actuators: an underutilized actuator may be considered for injection only if all actuators with a lower index are currently fully utilized, or if there is no pending I/O for any lower-index actuator that happens to be underutilized. This commits breaks this prioritization and tends to distribute injection uniformly across actuators. This is obtained by adding the following condition to the linear scan: even if an actuator A is underutilized, A is however skipped if its load is higher than that of the next actuator. Reviewed-by: Damien Le Moal Signed-off-by: Paolo Valente Signed-off-by: Davide Zini --- block/bfq-iosched.c | 18 +++++++++++++----- 1 file changed, 13 insertions(+), 5 deletions(-) diff --git a/block/bfq-iosched.c b/block/bfq-iosched.c index 6ebcd94bf3b3..f729f51fd383 100644 --- a/block/bfq-iosched.c +++ b/block/bfq-iosched.c @@ -4767,10 +4767,16 @@ bfq_find_active_bfqq_for_actuator(struct bfq_data *= bfqd, int idx) =20 /* * Perform a linear scan of each actuator, until an actuator is found - * for which the following two conditions hold: the load of the - * actuator is below the threshold (see comments on actuator_load_threshold - * for details), and there is a queue that contains I/O for that - * actuator. On success, return that queue. + * for which the following three conditions hold: the load of the + * actuator is below the threshold (see comments on + * actuator_load_threshold for details) and lower than that of the + * next actuator (comments on this extra condition below), and there + * is a queue that contains I/O for that actuator. On success, return + * that queue. + * + * Performing a plain linear scan entails a prioritization among + * actuators. The extra condition above breaks this prioritization and + * tends to distribute injection uniformly across actuators. */ static struct bfq_queue * bfq_find_bfqq_for_underused_actuator(struct bfq_data *bfqd) @@ -4778,7 +4784,9 @@ bfq_find_bfqq_for_underused_actuator(struct bfq_data = *bfqd) int i; =20 for (i =3D 0 ; i < bfqd->num_actuators; i++) { - if (bfqd->rq_in_driver[i] < bfqd->actuator_load_threshold) { + if (bfqd->rq_in_driver[i] < bfqd->actuator_load_threshold && + (i =3D=3D bfqd->num_actuators - 1 || + bfqd->rq_in_driver[i] < bfqd->rq_in_driver[i+1])) { struct bfq_queue *bfqq =3D bfq_find_active_bfqq_for_actuator(bfqd, i); =20 --=20 2.20.1