commit - 434a11be947065b3865d3e46c6d9285a513abfbb
commit + 536be22215a9c6fa0a2c426ffe7d46685c67d432
blob - 42c704265fea99494356c63c38a5bc9e9fda113d
blob + 4912d5c19f037e34561d51c1cd23adc71068fdfb
--- molly/client.lua
+++ molly/client.lua
history:add(res)
end
-local function invoke(thread_id, opts)
+local function run_client(thread_id, opts)
dev_checks('number', 'table')
local client = opts.client
return {
new = new,
- invoke = invoke, -- A wrapper for user-defined invoke.
+ run = run_client,
}
blob - 8cd2efbeeca276ce73b3886aa3d8045d159930da
blob + 9fdbc71cda26c3629828a7dbf8796b6a05c50f7e
--- molly/runner.lua
+++ molly/runner.lua
local history_lib = require('molly.history')
local log = require('molly.log')
local threadpool = require('molly.threadpool')
-local wrapper = require('molly.client')
+local client = require('molly.client')
local is_tarantool = require('molly.utils').is_tarantool
local has_fun, _ = pcall(require, 'fun')
local history = history_lib.new()
local total_time_begin = clock.proc()
local pool = threadpool.new(opts.thread_type, opts.threads)
- local ok, err = pool:start(wrapper.invoke, {
+ local ok, err = pool:start(client.run, {
client = workload.client,
gen = workload.generator,
history = history,