commit - a62e645a49fb291f590208f7d2e67842f84faaca
commit + 6b831cb253cbe6b4e7ab5d56d487905618f14fcd
blob - 6daa5c3df1d61bd998fe94e646c4c412c88a16a7
blob + 0147b4f845ed21c34b1a69ed0f476fd8a8f7ff4b
--- test/tarantool/qsync_test.lua
+++ test/tarantool/qsync_test.lua
t.assert_equals(cg.master_quorum1:eval('return box.space.test:insert{1}'), {1})
cg.master_quorum1:eval(('box.cfg{replication = %s}'):format(repl.replication))
cg.master_quorum2:wait_vclock_of(cg.master_quorum1)
- t.assert_equals(cg.master_quorum2:eval('return box.space.test:select()'), {{1}})
+ t.assert_equals(cg.master_quorum2:eval('return box.space.test:select({}, {limit = 100})'), {{1}})
end
pg.test_qsync_bank = function(cg)
t.assert_equals(cg.master_quorum1:eval('return box.space.test:insert{1}'), {1})
cg.master_quorum1:eval(('box.cfg{replication = %s}'):format(repl.replication))
cg.master_quorum2:wait_vclock_of(cg.master_quorum1)
- t.assert_equals(cg.master_quorum2:eval('return box.space.test:select()'), {{1}})
+ t.assert_equals(cg.master_quorum2:eval('return box.space.test:select({}, {limit = 100})'), {{1}})
local bank = require('test.tarantool.bank_client')
local read = bank.ops.read
t.assert_equals(ok, true)
end
-pg.test_qsync_cas_register = function(cg)
+pg.test_qsync_cas_register = function(_)
local cas_register = require('test.tarantool.cas_register_client')
local r = cas_register.ops.r
local w = cas_register.ops.w