From nobody Tue Nov 11 03:19:19 2025 Delivered-To: importer@patchew.org Received-SPF: pass (zoho.com: domain of gnu.org designates 209.51.188.17 as permitted sender) client-ip=209.51.188.17; envelope-from=qemu-devel-bounces+importer=patchew.org@nongnu.org; helo=lists.gnu.org; Authentication-Results: mx.zohomail.com; spf=pass (zoho.com: domain of gnu.org designates 209.51.188.17 as permitted sender) smtp.mailfrom=qemu-devel-bounces+importer=patchew.org@nongnu.org; dmarc=fail(p=none dis=none) header.from=virtuozzo.com ARC-Seal: i=1; a=rsa-sha256; t=1560956314; cv=none; d=zoho.com; s=zohoarc; b=g+t++dStFmmnfC+gx28V0CAlVT2U04jgvPRXvW5RtVFUkiYdUWl0NhWm4kGnphOQ2067bolDw2syWgZgEaWh5xv8RGnLD0qTVtKVyU9z1g4U3RHvjO+9PtOPkpiXz5LlWfPKHS75JZ3HB1ynz23+peUZhYUosnuQIB7esK6NeBg= ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=zoho.com; s=zohoarc; t=1560956314; h=Cc:Date:From:List-Subscribe:List-Post:List-Id:List-Archive:List-Help:List-Unsubscribe:Message-ID:Sender:Subject:To:ARC-Authentication-Results; bh=gB9Py24FDDZRgJAe8IQcZL4qDBf4TH/E1gcJFp5swCw=; b=VjSZW0caEIHOnfAoQd9jiMc4lwIR93+6aalZqbH5Gz8ObcAFaNoD7SznzsIWxizZk/8y++xjLbJenabCM34gzI9kNL9RfYKPDMNqyMvA2ajlH27bHw9A2Tetjb1ddbt7dKniAuWUZretM96DrYghTXlzfoQdQquu6Y8uFzeClno= ARC-Authentication-Results: i=1; mx.zoho.com; spf=pass (zoho.com: domain of gnu.org designates 209.51.188.17 as permitted sender) smtp.mailfrom=qemu-devel-bounces+importer=patchew.org@nongnu.org; dmarc=fail header.from= (p=none dis=none) header.from= Return-Path: Received: from lists.gnu.org (lists.gnu.org [209.51.188.17]) by mx.zohomail.com with SMTPS id 1560956313965743.9201485457676; Wed, 19 Jun 2019 07:58:33 -0700 (PDT) Received: from localhost ([::1]:39026 helo=lists.gnu.org) by lists.gnu.org with esmtp (Exim 4.86_2) (envelope-from ) id 1hdc2i-0007Vw-UI for importer@patchew.org; Wed, 19 Jun 2019 10:58:32 -0400 Received: from eggs.gnu.org ([2001:470:142:3::10]:34446) by lists.gnu.org with esmtp (Exim 4.86_2) (envelope-from ) id 1hdc0g-0005fl-Al for qemu-devel@nongnu.org; Wed, 19 Jun 2019 10:56:27 -0400 Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71) (envelope-from ) id 1hdbpX-0006U8-CY for qemu-devel@nongnu.org; Wed, 19 Jun 2019 10:44:57 -0400 Received: from relay.sw.ru ([185.231.240.75]:55956) by eggs.gnu.org with esmtps (TLS1.0:DHE_RSA_AES_256_CBC_SHA1:32) (Exim 4.71) (envelope-from ) id 1hdbpV-0006RS-TB; Wed, 19 Jun 2019 10:44:54 -0400 Received: from [10.94.3.0] (helo=kvm.qa.sw.ru) by relay.sw.ru with esmtp (Exim 4.92) (envelope-from ) id 1hdbpQ-0000Eu-1T; Wed, 19 Jun 2019 17:44:48 +0300 From: Vladimir Sementsov-Ogievskiy To: qemu-devel@nongnu.org, qemu-block@nongnu.org Date: Wed, 19 Jun 2019 17:44:46 +0300 Message-Id: <20190619144447.215894-1-vsementsov@virtuozzo.com> X-Mailer: git-send-email 2.18.0 X-detected-operating-system: by eggs.gnu.org: GNU/Linux 3.x X-Received-From: 185.231.240.75 Subject: [Qemu-devel] [PATCH] blockjob: drain all job nodes in block_job_drain X-BeenThere: qemu-devel@nongnu.org X-Mailman-Version: 2.1.23 Precedence: list List-Id: List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Cc: kwolf@redhat.com, vsementsov@virtuozzo.com, jsnow@redhat.com, mreitz@redhat.com Errors-To: qemu-devel-bounces+importer=patchew.org@nongnu.org Sender: "Qemu-devel" Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" Instead of draining additional nodes in each job code, let's do it in common block_job_drain, draining just all job's children. It's also a first step to finally get rid of blockjob->blk. Signed-off-by: Vladimir Sementsov-Ogievskiy --- Hi all! As a follow-up for "block: drop bs->job" recently merged, I'm now trying to drop BlockJob.blk pointer, jobs really works with several nodes and now reason to keep special blk for one of the children, and no reason to handle nodes differently in, for example, backup code.. And as a first step I need to sort out block_job_drain, and here is my suggestion on it. block/backup.c | 18 +----------------- block/mirror.c | 26 +++----------------------- blockjob.c | 7 ++++++- 3 files changed, 10 insertions(+), 41 deletions(-) diff --git a/block/backup.c b/block/backup.c index 715e1d3be8..7930004bbd 100644 --- a/block/backup.c +++ b/block/backup.c @@ -320,21 +320,6 @@ void backup_do_checkpoint(BlockJob *job, Error **errp) hbitmap_set(backup_job->copy_bitmap, 0, backup_job->len); } =20 -static void backup_drain(BlockJob *job) -{ - BackupBlockJob *s =3D container_of(job, BackupBlockJob, common); - - /* Need to keep a reference in case blk_drain triggers execution - * of backup_complete... - */ - if (s->target) { - BlockBackend *target =3D s->target; - blk_ref(target); - blk_drain(target); - blk_unref(target); - } -} - static BlockErrorAction backup_error_action(BackupBlockJob *job, bool read, int error) { @@ -493,8 +478,7 @@ static const BlockJobDriver backup_job_driver =3D { .commit =3D backup_commit, .abort =3D backup_abort, .clean =3D backup_clean, - }, - .drain =3D backup_drain, + } }; =20 static int64_t backup_calculate_cluster_size(BlockDriverState *target, diff --git a/block/mirror.c b/block/mirror.c index d17be4cdbc..6bea99558f 100644 --- a/block/mirror.c +++ b/block/mirror.c @@ -644,14 +644,11 @@ static int mirror_exit_common(Job *job) bdrv_ref(mirror_top_bs); bdrv_ref(target_bs); =20 - /* Remove target parent that still uses BLK_PERM_WRITE/RESIZE before + /* + * Remove target parent that still uses BLK_PERM_WRITE/RESIZE before * inserting target_bs at s->to_replace, where we might not be able to= get * these permissions. - * - * Note that blk_unref() alone doesn't necessarily drop permissions be= cause - * we might be running nested inside mirror_drain(), which takes an ex= tra - * reference, so use an explicit blk_set_perm() first. */ - blk_set_perm(s->target, 0, BLK_PERM_ALL, &error_abort); + */ blk_unref(s->target); s->target =3D NULL; =20 @@ -1143,21 +1140,6 @@ static bool mirror_drained_poll(BlockJob *job) return !!s->in_flight; } =20 -static void mirror_drain(BlockJob *job) -{ - MirrorBlockJob *s =3D container_of(job, MirrorBlockJob, common); - - /* Need to keep a reference in case blk_drain triggers execution - * of mirror_complete... - */ - if (s->target) { - BlockBackend *target =3D s->target; - blk_ref(target); - blk_drain(target); - blk_unref(target); - } -} - static const BlockJobDriver mirror_job_driver =3D { .job_driver =3D { .instance_size =3D sizeof(MirrorBlockJob), @@ -1172,7 +1154,6 @@ static const BlockJobDriver mirror_job_driver =3D { .complete =3D mirror_complete, }, .drained_poll =3D mirror_drained_poll, - .drain =3D mirror_drain, }; =20 static const BlockJobDriver commit_active_job_driver =3D { @@ -1189,7 +1170,6 @@ static const BlockJobDriver commit_active_job_driver = =3D { .complete =3D mirror_complete, }, .drained_poll =3D mirror_drained_poll, - .drain =3D mirror_drain, }; =20 static void coroutine_fn diff --git a/blockjob.c b/blockjob.c index 458ae76f51..0cabdc867d 100644 --- a/blockjob.c +++ b/blockjob.c @@ -94,8 +94,13 @@ void block_job_drain(Job *job) BlockJob *bjob =3D container_of(job, BlockJob, job); const JobDriver *drv =3D job->driver; BlockJobDriver *bjdrv =3D container_of(drv, BlockJobDriver, job_driver= ); + GSList *l; + + for (l =3D bjob->nodes; l; l =3D l->next) { + BdrvChild *c =3D l->data; + bdrv_drain(c->bs); + } =20 - blk_drain(bjob->blk); if (bjdrv->drain) { bjdrv->drain(bjob); } --=20 2.18.0