Commit Diff


commit - 434a11be947065b3865d3e46c6d9285a513abfbb
commit + 536be22215a9c6fa0a2c426ffe7d46685c67d432
blob - 42c704265fea99494356c63c38a5bc9e9fda113d
blob + 4912d5c19f037e34561d51c1cd23adc71068fdfb
--- molly/client.lua
+++ molly/client.lua
@@ -45,7 +45,7 @@ local function process_operation(client, history, op, 
     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
@@ -166,5 +166,5 @@ end
 return {
     new = new,
 
-    invoke = invoke,        -- A wrapper for user-defined invoke.
+    run = run_client,
 }
blob - 8cd2efbeeca276ce73b3886aa3d8045d159930da
blob + 9fdbc71cda26c3629828a7dbf8796b6a05c50f7e
--- molly/runner.lua
+++ molly/runner.lua
@@ -57,7 +57,7 @@ local clock = require('molly.clock')
 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')
@@ -192,7 +192,7 @@ local function run_test(workload, opts)
     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,