From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from smtp51.i.mail.ru (smtp51.i.mail.ru [94.100.177.111]) (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 403CA42EF5F for ; Fri, 3 Jul 2020 00:15:12 +0300 (MSK) From: sergeyb@tarantool.org Date: Fri, 3 Jul 2020 00:13:37 +0300 Message-Id: In-Reply-To: References: MIME-Version: 1.0 Content-Transfer-Encoding: 8bit Subject: [Tarantool-patches] [PATCH 3/4] replication: add tests for sync replication with anon replica List-Id: Tarantool development patches List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , To: tarantool-patches@dev.tarantool.org, v.shpilevoy@tarantool.org, sergepetrenko@tarantool.org, gorcunov@gmail.com, lvasiliev@tarantool.org From: Sergey Bronnikov Part of #5055 --- test/replication/qsync_with_anon.result | 177 ++++++++++++++++++++++ test/replication/qsync_with_anon.test.lua | 65 ++++++++ 2 files changed, 242 insertions(+) create mode 100644 test/replication/qsync_with_anon.result create mode 100644 test/replication/qsync_with_anon.test.lua diff --git a/test/replication/qsync_with_anon.result b/test/replication/qsync_with_anon.result new file mode 100644 index 000000000..59506a608 --- /dev/null +++ b/test/replication/qsync_with_anon.result @@ -0,0 +1,177 @@ +-- test-run result file version 2 +env = require('test_run') + | --- + | ... +test_run = env.new() + | --- + | ... +engine = test_run:get_cfg('engine') + | --- + | ... + +orig_synchro_quorum = box.cfg.replication_synchro_quorum + | --- + | ... +orig_synchro_timeout = box.cfg.replication_synchro_timeout + | --- + | ... + +NUM_INSTANCES = 2 + | --- + | ... +BROKEN_QUORUM = NUM_INSTANCES + 1 + | --- + | ... + +box.schema.user.grant('guest', 'replication') + | --- + | ... + +-- Setup a cluster with anonymous replica. +test_run:cmd('create server replica_anon with rpl_master=default, script="replication/anon1.lua"') + | --- + | - true + | ... +test_run:cmd('start server replica_anon') + | --- + | - true + | ... +test_run:cmd('switch replica_anon') + | --- + | - true + | ... + +-- [RFC, Asynchronous replication] successful transaction applied on async +-- replica. +-- Testcase setup. +test_run:switch('default') + | --- + | - true + | ... +box.cfg{replication_synchro_quorum=NUM_INSTANCES, replication_synchro_timeout=0.1} + | --- + | ... +_ = box.schema.space.create('sync', {is_sync=true, engine=engine}) + | --- + | ... +_ = box.space.sync:create_index('pk') + | --- + | ... +-- Testcase body. +test_run:switch('default') + | --- + | - true + | ... +box.space.sync:insert{1} -- success + | --- + | - [1] + | ... +box.space.sync:insert{2} -- success + | --- + | - [2] + | ... +box.space.sync:insert{3} -- success + | --- + | - [3] + | ... +test_run:cmd('switch replica_anon') + | --- + | - true + | ... +box.space.sync:select{} -- 1, 2, 3 + | --- + | - - [1] + | - [2] + | - [3] + | ... +-- Testcase cleanup. +test_run:switch('default') + | --- + | - true + | ... +box.space.sync:drop() + | --- + | ... + +-- [RFC, Asynchronous replication] failed transaction rolled back on async +-- replica. +-- Testcase setup. +box.cfg{replication_synchro_quorum=BROKEN_QUORUM, replication_synchro_timeout=0.1} + | --- + | ... +_ = box.schema.space.create('sync', {is_sync=true, engine=engine}) + | --- + | ... +_ = box.space.sync:create_index('pk') + | --- + | ... +-- Testcase body. +test_run:switch('default') + | --- + | - true + | ... +box.space.sync:insert{1} -- failure + | --- + | - error: Quorum collection for a synchronous transaction is timed out + | ... +test_run:cmd('switch replica_anon') + | --- + | - true + | ... +box.space.sync:select{} -- none + | --- + | - [] + | ... +test_run:switch('default') + | --- + | - true + | ... +box.cfg{replication_synchro_quorum=NUM_INSTANCES} + | --- + | ... +box.space.sync:insert{1} -- success + | --- + | - [1] + | ... +test_run:cmd('switch replica_anon') + | --- + | - true + | ... +box.space.sync:select{} -- 1 + | --- + | - - [1] + | ... +-- Testcase cleanup. +test_run:switch('default') + | --- + | - true + | ... +box.space.sync:drop() + | --- + | ... + +-- Teardown. +test_run:switch('default') + | --- + | - true + | ... +test_run:cmd('stop server replica_anon') + | --- + | - true + | ... +test_run:cmd('delete server replica_anon') + | --- + | - true + | ... +box.schema.user.revoke('guest', 'replication') + | --- + | ... +box.cfg{ \ + replication_synchro_quorum = orig_synchro_quorum, \ + replication_synchro_timeout = orig_synchro_timeout, \ +} + | --- + | ... +test_run:cleanup_cluster() + | --- + | ... diff --git a/test/replication/qsync_with_anon.test.lua b/test/replication/qsync_with_anon.test.lua new file mode 100644 index 000000000..aed62775e --- /dev/null +++ b/test/replication/qsync_with_anon.test.lua @@ -0,0 +1,65 @@ +env = require('test_run') +test_run = env.new() +engine = test_run:get_cfg('engine') + +orig_synchro_quorum = box.cfg.replication_synchro_quorum +orig_synchro_timeout = box.cfg.replication_synchro_timeout + +NUM_INSTANCES = 2 +BROKEN_QUORUM = NUM_INSTANCES + 1 + +box.schema.user.grant('guest', 'replication') + +-- Setup a cluster with anonymous replica. +test_run:cmd('create server replica_anon with rpl_master=default, script="replication/anon1.lua"') +test_run:cmd('start server replica_anon') +test_run:cmd('switch replica_anon') + +-- [RFC, Asynchronous replication] successful transaction applied on async +-- replica. +-- Testcase setup. +test_run:switch('default') +box.cfg{replication_synchro_quorum=NUM_INSTANCES, replication_synchro_timeout=0.1} +_ = box.schema.space.create('sync', {is_sync=true, engine=engine}) +_ = box.space.sync:create_index('pk') +-- Testcase body. +test_run:switch('default') +box.space.sync:insert{1} -- success +box.space.sync:insert{2} -- success +box.space.sync:insert{3} -- success +test_run:cmd('switch replica_anon') +box.space.sync:select{} -- 1, 2, 3 +-- Testcase cleanup. +test_run:switch('default') +box.space.sync:drop() + +-- [RFC, Asynchronous replication] failed transaction rolled back on async +-- replica. +-- Testcase setup. +box.cfg{replication_synchro_quorum=BROKEN_QUORUM, replication_synchro_timeout=0.1} +_ = box.schema.space.create('sync', {is_sync=true, engine=engine}) +_ = box.space.sync:create_index('pk') +-- Testcase body. +test_run:switch('default') +box.space.sync:insert{1} -- failure +test_run:cmd('switch replica_anon') +box.space.sync:select{} -- none +test_run:switch('default') +box.cfg{replication_synchro_quorum=NUM_INSTANCES} +box.space.sync:insert{1} -- success +test_run:cmd('switch replica_anon') +box.space.sync:select{} -- 1 +-- Testcase cleanup. +test_run:switch('default') +box.space.sync:drop() + +-- Teardown. +test_run:switch('default') +test_run:cmd('stop server replica_anon') +test_run:cmd('delete server replica_anon') +box.schema.user.revoke('guest', 'replication') +box.cfg{ \ + replication_synchro_quorum = orig_synchro_quorum, \ + replication_synchro_timeout = orig_synchro_timeout, \ +} +test_run:cleanup_cluster() -- 2.26.2