anchor.diff:      monitor:proc_set_value(
         ?MODULE, 'read_read', rrd:create(60 * 1000000, 1, {timing_with_hist, ms})).
   
  --spec run_bench() -> ok.
  -run_bench() ->
  -    Key1 = randoms:getRandomString(),
  -    Key2 = randoms:getRandomString(),
  -    ReqList = [{read, Key1}, {read, Key2}, {commit}],
  -    {TimeInUs, _Result} = util:tc(fun api_tx:req_list/1, [ReqList]),
  -    monitor:proc_set_value(?MODULE, 'read_read',
  -                           fun(Old) -> rrd:add_now(TimeInUs / 1000, Old) end).
  +-spec bench_service(Owner::comm:erl_local_pid()) -> ok.
  +bench_service(Owner) ->
  +    receive
  +        ?SCALARIS_RECV({bench}, %% ->
  +            begin
  +                Key1 = randoms:getRandomString(),
  +                Key2 = randoms:getRandomString(),
  +                ReqList = [{read, Key1}, {read, Key2}, {commit}],
  +                Time = os:timestamp(),
  +                {TimeInUs, _Result} = util:tc(fun api_tx:req_list/1, [ReqList]),
  +                comm:send_local(Owner, {bench_result, Time, TimeInUs / 1000})
  +            end)
  +    end,
  +    bench_service(Owner).
   
   -spec init_system_stats() -> ok.
   init_system_stats() ->
  
positive.code:     bulkowner:send_reply(Id, Target, Msg, Parents, pid_groups:get_my(dht_node)),
      State;
  
  on({bulkowner, reply, Id, {gather_stats_response, DataL}} = _Msg, {AllNodes, Leader} = _State)
    when Id =:= Leader#state.id ->
      ?TRACE1(_Msg, _State),
      Leader1 =
  
negative.code:             bulkowner:issue_bulk_owner(NewId, intervals:all(), Msg),
              Leader1 = check_timeslots(Leader),
              broadcast_values(Leader, Leader1),
              {AllNodes, Leader1#state{id = NewId}, BenchPid, IgnBenchT}
      end;
  
  on({bulkowner, deliver, Id, Range, {gather_stats, SourcePid}, Parents} = _Msg, State) ->
  