[Tarantool-patches] [PATCH 4/6] txn: stop using txn_clear_flag
Cyrill Gorcunov
gorcunov at gmail.com
Fri Jan 22 16:26:58 MSK 2021
Part-of #5128
Signed-off-by: Cyrill Gorcunov <gorcunov at gmail.com>
---
src/box/txn.c | 2 +-
src/box/txn_limbo.c | 9 +++------
2 files changed, 4 insertions(+), 7 deletions(-)
diff --git a/src/box/txn.c b/src/box/txn.c
index 32eca02c5..6197cf012 100644
--- a/src/box/txn.c
+++ b/src/box/txn.c
@@ -996,7 +996,7 @@ txn_can_yield(struct txn *txn, bool set)
txn->flags |= TXN_CAN_YIELD;
trigger_clear(&txn->fiber_on_yield);
} else if (!set && could) {
- txn_clear_flag(txn, TXN_CAN_YIELD);
+ txn->flags &= ~TXN_CAN_YIELD;
trigger_create(&txn->fiber_on_yield, txn_on_yield, NULL, NULL);
trigger_add(&fiber()->on_yield, &txn->fiber_on_yield);
}
diff --git a/src/box/txn_limbo.c b/src/box/txn_limbo.c
index 9c4c3cdf1..d418530ad 100644
--- a/src/box/txn_limbo.c
+++ b/src/box/txn_limbo.c
@@ -266,8 +266,7 @@ txn_limbo_wait_complete(struct txn_limbo *limbo, struct txn_limbo_entry *entry)
in_queue, tmp) {
e->txn->signature = TXN_SIGNATURE_QUORUM_TIMEOUT;
txn_limbo_abort(limbo, e);
- txn_clear_flag(e->txn, TXN_WAIT_SYNC);
- txn_clear_flag(e->txn, TXN_WAIT_ACK);
+ e->txn->flags &= ~(TXN_WAIT_SYNC | TXN_WAIT_ACK);
txn_complete_fail(e->txn);
if (e == entry)
break;
@@ -399,8 +398,7 @@ txn_limbo_read_confirm(struct txn_limbo *limbo, int64_t lsn)
}
e->is_commit = true;
txn_limbo_remove(limbo, e);
- txn_clear_flag(e->txn, TXN_WAIT_SYNC);
- txn_clear_flag(e->txn, TXN_WAIT_ACK);
+ e->txn->flags &= ~(TXN_WAIT_SYNC | TXN_WAIT_ACK);
/*
* If already written to WAL by now, finish tx processing.
* Otherwise just clear the sync flags. Tx procesing will finish
@@ -456,8 +454,7 @@ txn_limbo_read_rollback(struct txn_limbo *limbo, int64_t lsn)
return;
rlist_foreach_entry_safe_reverse(e, &limbo->queue, in_queue, tmp) {
txn_limbo_abort(limbo, e);
- txn_clear_flag(e->txn, TXN_WAIT_SYNC);
- txn_clear_flag(e->txn, TXN_WAIT_ACK);
+ e->txn->flags &= ~(TXN_WAIT_SYNC | TXN_WAIT_ACK);
if (e->txn->signature >= 0) {
/* Rollback the transaction. */
e->txn->signature = TXN_SIGNATURE_SYNC_ROLLBACK;
--
2.29.2
More information about the Tarantool-patches
mailing list