From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from smtp56.i.mail.ru (smtp56.i.mail.ru [217.69.128.36]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by dev.tarantool.org (Postfix) with ESMTPS id 335724765E0 for ; Wed, 23 Dec 2020 14:59:37 +0300 (MSK) From: Serge Petrenko Date: Wed, 23 Dec 2020 14:59:18 +0300 Message-Id: MIME-Version: 1.0 Content-Transfer-Encoding: 8bit Subject: [Tarantool-patches] [PATCH v2 0/6] make clear_synchro_queue commit everything List-Id: Tarantool development patches List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , To: v.shpilevoy@tarantool.org, gorcunov@gmail.com Cc: tarantool-patches@dev.tarantool.org Changes in v2: - implement something similar to relay_lsn_watcher with the help of triggers. - fix election_qsync_stress test hang. One issue with the test itself and one issue with the txn_limbo. - various minor fixes. - change clear_synchro_queue behaviour: wait for quorum for replication_synchro_timeout. If the quorum isn't reached, rollback nothing, and warn the user. @ChangeLog - Change `box.ctl.clear_synchro_queue` behaviour. Now it tries to commit everything that is present on the node. In order to do so it waits for other instances to replicate the data for `replication_synchro_quorum` seconds. In case timeout passes and quorum wasn't reached, nothing is rolled back (gh-5435) Serge Petrenko (6): box: add a single execution guard to clear_synchro_queue relay: introduce on_status_update trigger txn_limbo: introduce txn_limbo_last_synchro_entry method box: rework clear_synchro_queue to commit everything test: fix replication/election_qsync_stress test txn_limbo: ignore CONFIRM/ROLLBACK for a foreign master src/box/applier.cc | 3 +- src/box/box.cc | 170 +++++++++++++++--- src/box/box.h | 2 +- src/box/lua/ctl.c | 4 +- src/box/raft.c | 9 +- src/box/relay.cc | 12 ++ src/box/relay.h | 4 + src/box/txn_limbo.c | 26 ++- src/box/txn_limbo.h | 9 +- test/replication/election_qsync_stress.result | 7 +- .../election_qsync_stress.test.lua | 7 +- test/replication/election_replica.lua | 5 +- ...5435-clear-synchro-queue-commit-all.result | 144 +++++++++++++++ ...35-clear-synchro-queue-commit-all.test.lua | 65 +++++++ test/replication/suite.cfg | 1 + 15 files changed, 423 insertions(+), 45 deletions(-) create mode 100644 test/replication/gh-5435-clear-synchro-queue-commit-all.result create mode 100644 test/replication/gh-5435-clear-synchro-queue-commit-all.test.lua -- 2.24.3 (Apple Git-128)