commit - 0b168a024e40f3f1e15364f3fd51c6a21d083168
commit + 46c81b6f77111c15cba319906d296392fc03fd86
blob - a6088cb7099fe48226da2358c23a99c6fd0f3904
blob + 3062a101e7e9148de99791f9b5622539cfd08c77
--- test/tarantool/cas_register_client.lua
+++ test/tarantool/cas_register_client.lua
-- Molly client with read, write and CAS operations.
-local math = require('math')
local net_box = require('net.box')
local molly = require('molly')
local client = molly.client
-local function r()
- return {
- f = 'read',
- v = nil,
- }
-end
-
-local function w()
- return {
- f = 'write',
- v = math.random(1, 10),
- }
-end
-
-local function cas()
- return {
- f = 'cas',
- v = {
- math.random(1, 10), -- Old value.
- math.random(1, 10), -- New value.
- },
- }
-end
-
local space_name = 'register_space'
local cl = client.new()
return {
client = cl,
- ops = {
- r = r,
- w = w,
- cas = cas,
- }
}
blob - 61e714b5cdb6c251452e2ae8a09be804be7beabd
blob + d0bbf62966a664c083acaab8e7401fba1b233609
--- test/tarantool/rw_register_client.lua
+++ test/tarantool/rw_register_client.lua
-- Molly client with read and write operations.
-local math = require('math')
local net_box = require('net.box')
local molly = require('molly')
-local function r()
- return {
- f = 'read',
- v = nil,
- }
-end
-
-local function w()
- return {
- f = 'write',
- v = math.random(1, 100),
- }
-end
-
local space_name = 'rw_register_mc'
local client = molly.client.new()
return {
client = client,
- ops = {
- r = r,
- w = w,
- }
}
blob - 2c47fd7c72aa37296280b3aeb9b65176082334c8
blob + 7cf3de478e829b94f7d571c841fa9cb1fe36b480
--- test/tarantool/tarantool_test.lua
+++ test/tarantool/tarantool_test.lua
local molly = require('molly')
local gen = molly.gen
+local tests = molly.tests
local runner = molly.runner
local cur_dir = fio.pathjoin(fio.dirname(debug.sourcedir()), '?.lua')
end
g.test_cas_register = function()
- local r = cas_register.ops.r
- local w = cas_register.ops.w
- local cas = cas_register.ops.cas
local test_options = {
create_reports = true,
threads = 5,
}
local ok, err = runner.run_test({
client = cas_register.client,
- generator = gen.cycle(gen.iter({ r, w, cas, })):take(1000),
+ generator = tests.cas_register_gen():take(1000),
}, test_options)
t.assert_equals(err, nil)
t.assert_equals(ok, true)