--
-- Instance 1
--
-- Step 1
--
fiber = require('fiber')
log = require('log')
data = string.rep('a', 1000)
box.cfg{
    listen = 3313,
    replication = {3313, 3314},
    replication_synchro_timeout = 1000,
    election_mode = 'candidate',
    replication_synchro_quorum = 3,
    replication_timeout = 1000,
    replication_reconnect_timeout = 1,
}
box.ctl.promote()
box.ctl.wait_rw()
box.schema.user.grant('guest', 'super')
s = box.schema.create_space('test', {is_sync= true})
_ = s:create_index('pk')
a = box.schema.create_space('test2')
_ = a:create_index('pk')
--
-- Step 3
--
f1 = make_txn_fiber(s, 1)
f2 = make_txn_fiber(a, 2)
f3 = make_txn_fiber(a, 3)
--
-- Step 5
--
box.cfg{replication_synchro_quorum = 2}
-- Observe the logs that the f1, f2, f3 are committed.
-- Also see that box.info.synchro queue length is zero.


--
-- Instance 2
--
-- Step 2
--
fiber = require('fiber')
log = require('log')
json = require('json')
box.cfg{
    listen = 3314,
    replication = {3313, 3314},
    election_mode = 'voter',
    replication_synchro_queue_max_size = 1000,
    read_only = true,
    replication_timeout = 1000,
    replication_reconnect_timeout = 1,
}
function make_on_replace(space_name)
    return function(old, new)
        log.info(('%s: %s -> %s'):format(space_name, json.encode(old), json.encode(new)))
    end
end
s = box.space.test
_ = s:on_replace(make_on_replace(s.name))
a = box.space.test2
_ = a:on_replace(make_on_replace(a.name))
--
-- Step 4
--
-- Observe the logs. Only txns from f1 and f2 fibers are logged. Like f3 never arrived.
--
-- Step 6
--
-- Observe that nothing happened in the logs and the box.info.synchro queue length
-- is still 1. It means f1 is in the queue, f2 is volatile in the limbo, and f3 wasn't received.