From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mail-lf1-f67.google.com (mail-lf1-f67.google.com [209.85.167.67]) (using TLSv1.2 with cipher ECDHE-RSA-AES128-GCM-SHA256 (128/128 bits)) (No client certificate requested) by dev.tarantool.org (Postfix) with ESMTPS id E42D943040E for ; Sat, 15 Aug 2020 00:15:58 +0300 (MSK) Received: by mail-lf1-f67.google.com with SMTP id v15so5494254lfg.6 for ; Fri, 14 Aug 2020 14:15:58 -0700 (PDT) From: Cyrill Gorcunov Date: Sat, 15 Aug 2020 00:14:40 +0300 Message-Id: <20200814211442.667099-7-gorcunov@gmail.com> In-Reply-To: <20200814211442.667099-1-gorcunov@gmail.com> References: <20200814211442.667099-1-gorcunov@gmail.com> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit Subject: [Tarantool-patches] [PATCH v7 6/8] applier: add shorthands to queue access List-Id: Tarantool development patches List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , To: tml Cc: Vladislav Shpilevoy We need to access first and last xrow in a queue frenquently and opencoded variants are too ugly. Lets provide shorthands (we will reuse them in qsync packets handling as well). Part-of #5129 Signed-off-by: Cyrill Gorcunov --- src/box/applier.cc | 37 ++++++++++++++++++++++++++----------- 1 file changed, 26 insertions(+), 11 deletions(-) diff --git a/src/box/applier.cc b/src/box/applier.cc index 60689f6d3..a71516282 100644 --- a/src/box/applier.cc +++ b/src/box/applier.cc @@ -648,6 +648,26 @@ struct applier_tx_row { struct xrow_header row; }; +/** + * Get first xrow from a list. + */ +static inline struct xrow_header * +applier_first_row(struct stailq *rows) +{ + return &stailq_first_entry(rows, + struct applier_tx_row, next)->row; +} + +/** + * Get last xrow from a list. + */ +static inline struct xrow_header * +applier_last_row(struct stailq *rows) +{ + return &stailq_last_entry(rows, + struct applier_tx_row, next)->row; +} + static struct applier_tx_row * applier_read_tx_row(struct applier *applier) { @@ -749,8 +769,7 @@ applier_read_tx(struct applier *applier, struct stailq *rows) } stailq_add_tail(rows, &tx_row->next); - } while (!stailq_last_entry(rows, struct applier_tx_row, - next)->row.is_commit); + } while (!applier_last_row(rows)->is_commit); } static int @@ -830,10 +849,8 @@ applier_unlock(struct latch *latch) static int applier_apply_tx(struct stailq *rows) { - struct xrow_header *first_row = &stailq_first_entry(rows, - struct applier_tx_row, next)->row; - struct xrow_header *last_row; - last_row = &stailq_last_entry(rows, struct applier_tx_row, next)->row; + struct xrow_header *first_row = applier_first_row(rows); + struct xrow_header *last_row = applier_last_row(rows); struct latch *latch = applier_lock(first_row->replica_id); if (vclock_get(&replicaset.applier.vclock, @@ -849,9 +866,7 @@ applier_apply_tx(struct stailq *rows) */ struct xrow_header *tmp; while (true) { - tmp = &stailq_first_entry(rows, - struct applier_tx_row, - next)->row; + tmp = applier_first_row(rows); if (tmp->lsn <= vclock_get(&replicaset.applier.vclock, tmp->replica_id)) { stailq_shift(rows); @@ -1133,12 +1148,12 @@ applier_subscribe(struct applier *applier) applier_read_tx(applier, &rows); applier->last_row_time = ev_monotonic_now(loop()); + /* * In case of an heartbeat message wake a writer up * and check applier state. */ - if (stailq_first_entry(&rows, struct applier_tx_row, - next)->row.lsn == 0) + if (applier_first_row(&rows)->lsn == 0) applier_signal_ack(applier); else if (applier_apply_tx(&rows) != 0) diag_raise(); -- 2.26.2