anchor.diff:              bulkowner:issue_bulk_owner(NewId, intervals:all(), Msg),
               Leader1 = check_timeslots(Leader),
               broadcast_values(Leader, Leader1),
  -            {AllNodes, Leader1#state{id = NewId}}
  +            {AllNodes, Leader1#state{id = NewId}, BenchPid, IgnBenchT}
       end;
   
   on({bulkowner, deliver, Id, Range, {gather_stats, SourcePid}, Parents} = _Msg, State) ->
  
positive.code: 
  %% @doc Message handler when the rm_loop module is fully initialized.
  -spec on(message(), state()) -> state().
  on({bench} = _Msg, State) ->
      ?TRACE1(_Msg, State),
      case get_bench_interval() of
          0 -> ok;
          I -> msg_delay:send_local(I, self(), {bench})
      end,
      run_bench(),
      State;
  
  on({collect_system_stats} = _Msg, State) ->
  
negative.code: %% @doc Initialises the module with an empty state.
  -spec init(null) -> state().
  init(null) ->
      Self = self(),
      case get_bench_interval() of
          0 -> ok;
          I -> FirstDelay = randoms:rand_uniform(1, I + 1),
               msg_delay:send_local(FirstDelay, Self, {bench}),
               msg_delay:send_local(get_gather_interval(), Self, {propagate})
      end,
      init_bench(),
      init_system_stats(),
      msg_delay:send_local(10, Self, {collect_system_stats}),
      Now = os:timestamp(),
      BenchPid = erlang:spawn(fun() -> bench_service(Self) end),
      State = #state{id = uid:get_global_uid(),
                     perf_rr = rrd:create(get_gather_interval() * 1000000, 60, {timing_with_hist, ms}, Now),
                     perf_lh = rrd:create(get_gather_interval() * 1000000, 60, {timing, count}, Now),
                     perf_tx = rrd:create(get_gather_interval() * 1000000, 60, {timing_with_hist, ms}, Now)},
      {State, State, BenchPid, false}.
  
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  % Miscellaneous
  