From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mail-lf1-f48.google.com (mail-lf1-f48.google.com [209.85.167.48]) (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 318FB469711 for ; Tue, 24 Nov 2020 18:24:47 +0300 (MSK) Received: by mail-lf1-f48.google.com with SMTP id l11so29477680lfg.0 for ; Tue, 24 Nov 2020 07:24:47 -0800 (PST) From: Cyrill Gorcunov Date: Tue, 24 Nov 2020 18:24:05 +0300 Message-Id: <20201124152405.1174898-4-gorcunov@gmail.com> In-Reply-To: <20201124152405.1174898-1-gorcunov@gmail.com> References: <20201124152405.1174898-1-gorcunov@gmail.com> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit Subject: [Tarantool-patches] [PATCH v2 3/3] test: add replication/gh-5446-sqync-eval-quorum.test.lua List-Id: Tarantool development patches List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , To: tml Cc: Vladislav Shpilevoy Part-of #5446 Signed-off-by: Cyrill Gorcunov --- .../gh-5446-sqync-eval-quorum.result | 156 ++++++++++++++++++ .../gh-5446-sqync-eval-quorum.test.lua | 62 +++++++ test/replication/replica-quorum-1.lua | 1 + test/replication/replica-quorum-2.lua | 1 + test/replication/replica-quorum-3.lua | 1 + test/replication/replica-quorum-4.lua | 1 + test/replication/replica-quorum.lua | 13 ++ 7 files changed, 235 insertions(+) create mode 100644 test/replication/gh-5446-sqync-eval-quorum.result create mode 100644 test/replication/gh-5446-sqync-eval-quorum.test.lua create mode 120000 test/replication/replica-quorum-1.lua create mode 120000 test/replication/replica-quorum-2.lua create mode 120000 test/replication/replica-quorum-3.lua create mode 120000 test/replication/replica-quorum-4.lua create mode 100644 test/replication/replica-quorum.lua diff --git a/test/replication/gh-5446-sqync-eval-quorum.result b/test/replication/gh-5446-sqync-eval-quorum.result new file mode 100644 index 000000000..3aff913a3 --- /dev/null +++ b/test/replication/gh-5446-sqync-eval-quorum.result @@ -0,0 +1,156 @@ +-- test-run result file version 2 +test_run = require('test_run').new() + | --- + | ... +engine = test_run:get_cfg('engine') + | --- + | ... + +box.schema.user.grant('guest', 'replication') + | --- + | ... + +box.cfg { replication_synchro_quorum = "n/2+1", replication_synchro_timeout = 1000 } + | --- + | ... + +test_run:cmd('create server replica1 with rpl_master=default,\ + script="replication/replica-quorum-1.lua"') + | --- + | - true + | ... +test_run:cmd('start server replica1 with wait=True, wait_load=True') + | --- + | - true + | ... + +test_run:cmd('create server replica2 with rpl_master=default,\ + script="replication/replica-quorum-2.lua"') + | --- + | - true + | ... +test_run:cmd('start server replica2 with wait=True, wait_load=True') + | --- + | - true + | ... + +test_run:cmd('create server replica3 with rpl_master=default,\ + script="replication/replica-quorum-3.lua"') + | --- + | - true + | ... +test_run:cmd('start server replica3 with wait=True, wait_load=True') + | --- + | - true + | ... + +test_run:cmd('create server replica4 with rpl_master=default,\ + script="replication/replica-quorum-4.lua"') + | --- + | - true + | ... +test_run:cmd('start server replica4 with wait=True, wait_load=True') + | --- + | - true + | ... + +_ = box.schema.space.create('sync', {is_sync = true, engine = engine}) + | --- + | ... +s = box.space.sync + | --- + | ... + +s:format({{name = 'id', type = 'unsigned'}, {name = 'band_name', type = 'string'}}) + | --- + | ... + +_ = s:create_index('primary', {parts = {'id'}}) + | --- + | ... +s:insert({1, '1'}) + | --- + | - [1, '1'] + | ... +s:insert({2, '2'}) + | --- + | - [2, '2'] + | ... +s:insert({3, '3'}) + | --- + | - [3, '3'] + | ... + +-- Wait the data to be propagated, there is no much +-- need for this since we're testing the quorum number +-- update only but just in case. +test_run:wait_lsn('replica1', 'default') + | --- + | ... +test_run:wait_lsn('replica2', 'default') + | --- + | ... +test_run:wait_lsn('replica3', 'default') + | --- + | ... +test_run:wait_lsn('replica4', 'default') + | --- + | ... + +-- Make sure we were configured in a proper way +match = 'set \'replication_synchro_quorum\' configuration option to \"n\\/2%+1' + | --- + | ... +test_run:grep_log("default", match) ~= nil + | --- + | - true + | ... + +-- There are 4 replicas -> replication_synchro_quorum = 4/2 + 1 = 3 +match = 'renew replication_synchro_quorum = 3' + | --- + | ... +test_run:grep_log("default", match) ~= nil + | --- + | - true + | ... + +test_run:cmd('stop server replica1') + | --- + | - true + | ... +test_run:cmd('delete server replica1') + | --- + | - true + | ... + +test_run:cmd('stop server replica2') + | --- + | - true + | ... +test_run:cmd('delete server replica2') + | --- + | - true + | ... + +test_run:cmd('stop server replica3') + | --- + | - true + | ... +test_run:cmd('delete server replica3') + | --- + | - true + | ... + +test_run:cmd('stop server replica4') + | --- + | - true + | ... +test_run:cmd('delete server replica4') + | --- + | - true + | ... + +box.schema.user.revoke('guest', 'replication') + | --- + | ... diff --git a/test/replication/gh-5446-sqync-eval-quorum.test.lua b/test/replication/gh-5446-sqync-eval-quorum.test.lua new file mode 100644 index 000000000..cf8058c85 --- /dev/null +++ b/test/replication/gh-5446-sqync-eval-quorum.test.lua @@ -0,0 +1,62 @@ +test_run = require('test_run').new() +engine = test_run:get_cfg('engine') + +box.schema.user.grant('guest', 'replication') + +box.cfg { replication_synchro_quorum = "n/2+1", replication_synchro_timeout = 1000 } + +test_run:cmd('create server replica1 with rpl_master=default,\ + script="replication/replica-quorum-1.lua"') +test_run:cmd('start server replica1 with wait=True, wait_load=True') + +test_run:cmd('create server replica2 with rpl_master=default,\ + script="replication/replica-quorum-2.lua"') +test_run:cmd('start server replica2 with wait=True, wait_load=True') + +test_run:cmd('create server replica3 with rpl_master=default,\ + script="replication/replica-quorum-3.lua"') +test_run:cmd('start server replica3 with wait=True, wait_load=True') + +test_run:cmd('create server replica4 with rpl_master=default,\ + script="replication/replica-quorum-4.lua"') +test_run:cmd('start server replica4 with wait=True, wait_load=True') + +_ = box.schema.space.create('sync', {is_sync = true, engine = engine}) +s = box.space.sync + +s:format({{name = 'id', type = 'unsigned'}, {name = 'band_name', type = 'string'}}) + +_ = s:create_index('primary', {parts = {'id'}}) +s:insert({1, '1'}) +s:insert({2, '2'}) +s:insert({3, '3'}) + +-- Wait the data to be propagated, there is no much +-- need for this since we're testing the quorum number +-- update only but just in case. +test_run:wait_lsn('replica1', 'default') +test_run:wait_lsn('replica2', 'default') +test_run:wait_lsn('replica3', 'default') +test_run:wait_lsn('replica4', 'default') + +-- Make sure we were configured in a proper way +match = 'set \'replication_synchro_quorum\' configuration option to \"n\\/2%+1' +test_run:grep_log("default", match) ~= nil + +-- There are 4 replicas -> replication_synchro_quorum = 4/2 + 1 = 3 +match = 'renew replication_synchro_quorum = 3' +test_run:grep_log("default", match) ~= nil + +test_run:cmd('stop server replica1') +test_run:cmd('delete server replica1') + +test_run:cmd('stop server replica2') +test_run:cmd('delete server replica2') + +test_run:cmd('stop server replica3') +test_run:cmd('delete server replica3') + +test_run:cmd('stop server replica4') +test_run:cmd('delete server replica4') + +box.schema.user.revoke('guest', 'replication') diff --git a/test/replication/replica-quorum-1.lua b/test/replication/replica-quorum-1.lua new file mode 120000 index 000000000..f0c3e7089 --- /dev/null +++ b/test/replication/replica-quorum-1.lua @@ -0,0 +1 @@ +/home/cyrill/projects/tarantool/tarantool.git/test/replication/replica-quorum.lua \ No newline at end of file diff --git a/test/replication/replica-quorum-2.lua b/test/replication/replica-quorum-2.lua new file mode 120000 index 000000000..f0c3e7089 --- /dev/null +++ b/test/replication/replica-quorum-2.lua @@ -0,0 +1 @@ +/home/cyrill/projects/tarantool/tarantool.git/test/replication/replica-quorum.lua \ No newline at end of file diff --git a/test/replication/replica-quorum-3.lua b/test/replication/replica-quorum-3.lua new file mode 120000 index 000000000..f0c3e7089 --- /dev/null +++ b/test/replication/replica-quorum-3.lua @@ -0,0 +1 @@ +/home/cyrill/projects/tarantool/tarantool.git/test/replication/replica-quorum.lua \ No newline at end of file diff --git a/test/replication/replica-quorum-4.lua b/test/replication/replica-quorum-4.lua new file mode 120000 index 000000000..f0c3e7089 --- /dev/null +++ b/test/replication/replica-quorum-4.lua @@ -0,0 +1 @@ +/home/cyrill/projects/tarantool/tarantool.git/test/replication/replica-quorum.lua \ No newline at end of file diff --git a/test/replication/replica-quorum.lua b/test/replication/replica-quorum.lua new file mode 100644 index 000000000..8d91a078f --- /dev/null +++ b/test/replication/replica-quorum.lua @@ -0,0 +1,13 @@ +#!/usr/bin/env tarantool +repl_list = os.getenv("MASTER") + +-- Start the console first to allow test-run to attach even before +-- box.cfg is finished. +require('console').listen(os.getenv('ADMIN')) + +box.cfg({ + listen = os.getenv("LISTEN"), + replication = repl_list, + memtx_memory = 107374182, + replication_timeout = 1000, +}) -- 2.26.2