From mboxrd@z Thu Jan 1 00:00:00 1970 Received: from eggs.gnu.org ([2001:4830:134:3::10]:54851) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1c4t0d-00018k-Bt for qemu-devel@nongnu.org; Thu, 10 Nov 2016 12:19:32 -0500 Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71) (envelope-from ) id 1c4t0c-000846-AN for qemu-devel@nongnu.org; Thu, 10 Nov 2016 12:19:31 -0500 From: Kevin Wolf Date: Thu, 10 Nov 2016 18:19:09 +0100 Message-Id: <1478798349-28983-9-git-send-email-kwolf@redhat.com> In-Reply-To: <1478798349-28983-1-git-send-email-kwolf@redhat.com> References: <1478798349-28983-1-git-send-email-kwolf@redhat.com> Subject: [Qemu-devel] [RFC PATCH 8/8] quorum: Inline quorum_fifo_aio_cb() List-Id: List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , To: qemu-block@nongnu.org Cc: kwolf@redhat.com, mreitz@redhat.com, berto@igalia.com, qemu-devel@nongnu.org Inlining the function removes some boilerplace code and replaces recursion by a simple loop, so the code becomes somewhat easier to understand. Signed-off-by: Kevin Wolf --- block/quorum.c | 42 +++++++++++++----------------------------- 1 file changed, 13 insertions(+), 29 deletions(-) diff --git a/block/quorum.c b/block/quorum.c index 45939c5..0e91d59 100644 --- a/block/quorum.c +++ b/block/quorum.c @@ -248,30 +248,6 @@ static void quorum_report_bad_acb(QuorumChildRequest *sacb, int ret) quorum_report_bad(type, acb->offset, acb->bytes, sacb->bs->node_name, ret); } -static int quorum_fifo_aio_cb(void *opaque, int ret) -{ - QuorumChildRequest *sacb = opaque; - QuorumAIOCB *acb = sacb->parent; - BDRVQuorumState *s = acb->bs->opaque; - - assert(acb->is_read && s->read_pattern == QUORUM_READ_PATTERN_FIFO); - - if (ret < 0) { - quorum_report_bad_acb(sacb, ret); - - /* We try to read next child in FIFO order if we fail to read */ - if (acb->children_read < s->num_children) { - return read_fifo_child(acb); - } - } - - acb->vote_ret = ret; - - /* FIXME: rewrite failed children if acb->children_read > 1? */ - - return ret; -} - static void quorum_report_bad_versions(BDRVQuorumState *s, QuorumAIOCB *acb, QuorumVoteValue *value) @@ -677,12 +653,20 @@ static int read_quorum_children(QuorumAIOCB *acb) static int read_fifo_child(QuorumAIOCB *acb) { BDRVQuorumState *s = acb->bs->opaque; - int n = acb->children_read++; - int ret; + int n, ret; + + /* We try to read the next child in FIFO order if we failed to read */ + do { + n = acb->children_read++; + acb->qcrs[n].bs = s->children[n]->bs; + ret = bdrv_co_preadv(s->children[n], acb->offset, acb->bytes, + acb->qiov, 0); + if (ret < 0) { + quorum_report_bad_acb(&acb->qcrs[n], ret); + } + } while(ret < 0 && acb->children_read < s->num_children); - acb->qcrs[n].bs = s->children[n]->bs; - ret = bdrv_co_preadv(s->children[n], acb->offset, acb->bytes, acb->qiov, 0); - ret = quorum_fifo_aio_cb(&acb->qcrs[n], ret); + /* FIXME: rewrite failed children if acb->children_read > 1? */ return ret; } -- 1.8.3.1