[Tarantool-patches] [PATCH 3/3 v2] replication: add test with change space sync mode in a loop

[Serge Petrenko]

12.11.2020 12:11, sergeyb at tarantool.org пишет:
> From: Sergey Bronnikov <sergeyb at tarantool.org>
>
> Closes #5055
> Part of #5144
> ---


Thanks for the patch!

LGTM.

>   test/replication/qsync_sync_mode.result   | 114 ++++++++++++++++++++++
>   test/replication/qsync_sync_mode.test.lua |  56 +++++++++++
>   2 files changed, 170 insertions(+)
>   create mode 100644 test/replication/qsync_sync_mode.result
>   create mode 100644 test/replication/qsync_sync_mode.test.lua
>
> diff --git a/test/replication/qsync_sync_mode.result b/test/replication/qsync_sync_mode.result
> new file mode 100644
> index 000000000..66f6a70b2
> --- /dev/null
> +++ b/test/replication/qsync_sync_mode.result
> @@ -0,0 +1,114 @@
> +-- test-run result file version 2
> +env = require('test_run')
> + | ---
> + | ...
> +test_run = env.new()
> + | ---
> + | ...
> +engine = test_run:get_cfg('engine')
> + | ---
> + | ...
> +fiber = require('fiber')
> + | ---
> + | ...
> +math = require('math')
> + | ---
> + | ...
> +
> +orig_synchro_quorum = box.cfg.replication_synchro_quorum
> + | ---
> + | ...
> +orig_synchro_timeout = box.cfg.replication_synchro_timeout
> + | ---
> + | ...
> +
> +math.randomseed(os.time())
> + | ---
> + | ...
> +random_boolean = function()                                                    \
> +    if (math.random(1, 10) > 5) then                                           \
> +        return true                                                            \
> +    else                                                                       \
> +        return false                                                           \
> +    end                                                                        \
> +end
> + | ---
> + | ...
> +
> +box.schema.user.grant('guest', 'replication')
> + | ---
> + | ...
> +
> +-- Setup an cluster with two instances.
> +test_run:cmd('create server replica with rpl_master=default,\
> +                                         script="replication/replica.lua"')
> + | ---
> + | - true
> + | ...
> +test_run:cmd('start server replica with wait=True, wait_load=True')
> + | ---
> + | - true
> + | ...
> +
> +-- Write data to a leader and enable/disable sync mode in a loop.
> +-- Testcase setup.
> +_ = box.schema.space.create('sync', {is_sync=true, engine=engine})
> + | ---
> + | ...
> +_ = box.space.sync:create_index('pk')
> + | ---
> + | ...
> +box.cfg{replication_synchro_quorum=2, replication_synchro_timeout=1000}
> + | ---
> + | ...
> +
> +-- Testcase body.
> +for i = 1,100 do                                                               \
> +    box.space.sync:alter{is_sync=random_boolean()}                             \
> +    box.space.sync:insert{i}                                                   \
> +    test_run:switch('replica')                                                 \
> +    test_run:wait_cond(function() return box.space.sync:get{i} ~= nil end)     \
> +    test_run:switch('default')                                                 \
> +    test_run:wait_cond(function() return box.space.sync:get{i} ~= nil end)     \
> +end
> + | ---
> + | ...
> +box.space.sync:count() -- 100
> + | ---
> + | - 100
> + | ...
> +
> +-- Testcase cleanup.
> +test_run:switch('default')
> + | ---
> + | - true
> + | ...
> +box.space.sync:drop()
> + | ---
> + | ...
> +
> +-- Teardown.
> +test_run:cmd('switch default')
> + | ---
> + | - true
> + | ...
> +test_run:cmd('stop server replica')
> + | ---
> + | - true
> + | ...
> +test_run:cmd('delete server replica')
> + | ---
> + | - true
> + | ...
> +test_run:cleanup_cluster()
> + | ---
> + | ...
> +box.schema.user.revoke('guest', 'replication')
> + | ---
> + | ...
> +box.cfg{                                                                       \
> +    replication_synchro_quorum = orig_synchro_quorum,                          \
> +    replication_synchro_timeout = orig_synchro_timeout,                        \
> +}
> + | ---
> + | ...
> diff --git a/test/replication/qsync_sync_mode.test.lua b/test/replication/qsync_sync_mode.test.lua
> new file mode 100644
> index 000000000..ea5725169
> --- /dev/null
> +++ b/test/replication/qsync_sync_mode.test.lua
> @@ -0,0 +1,56 @@
> +env = require('test_run')
> +test_run = env.new()
> +engine = test_run:get_cfg('engine')
> +fiber = require('fiber')
> +math = require('math')
> +
> +orig_synchro_quorum = box.cfg.replication_synchro_quorum
> +orig_synchro_timeout = box.cfg.replication_synchro_timeout
> +
> +math.randomseed(os.time())
> +random_boolean = function()                                                    \
> +    if (math.random(1, 10) > 5) then                                           \
> +        return true                                                            \
> +    else                                                                       \
> +        return false                                                           \
> +    end                                                                        \
> +end
> +
> +box.schema.user.grant('guest', 'replication')
> +
> +-- Setup an cluster with two instances.
> +test_run:cmd('create server replica with rpl_master=default,\
> +                                         script="replication/replica.lua"')
> +test_run:cmd('start server replica with wait=True, wait_load=True')
> +
> +-- Write data to a leader and enable/disable sync mode in a loop.
> +-- Testcase setup.
> +_ = box.schema.space.create('sync', {is_sync=true, engine=engine})
> +_ = box.space.sync:create_index('pk')
> +box.cfg{replication_synchro_quorum=2, replication_synchro_timeout=1000}
> +
> +-- Testcase body.
> +for i = 1,100 do                                                               \
> +    box.space.sync:alter{is_sync=random_boolean()}                             \
> +    box.space.sync:insert{i}                                                   \
> +    test_run:switch('replica')                                                 \
> +    test_run:wait_cond(function() return box.space.sync:get{i} ~= nil end)     \
> +    test_run:switch('default')                                                 \
> +    test_run:wait_cond(function() return box.space.sync:get{i} ~= nil end)     \
> +end
> +box.space.sync:count() -- 100
> +
> +-- Testcase cleanup.
> +test_run:switch('default')
> +box.space.sync:drop()
> +
> +-- Teardown.
> +test_run:cmd('switch default')
> +test_run:cmd('stop server replica')
> +test_run:cmd('delete server replica')
> +test_run:cleanup_cluster()
> +box.schema.user.revoke('guest', 'replication')
> +box.cfg{                                                                       \
> +    replication_synchro_quorum = orig_synchro_quorum,                          \
> +    replication_synchro_timeout = orig_synchro_timeout,                        \
> +}

-- 
Serge Petrenko