anchor.diff:  %% @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})
  +             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}),
  +    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}.
  +    {State, State, BenchPid, false}.
   
   %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
   % Miscellaneous
  
positive.code:                           A#state{perf_tx = rrd:add_with(T, PerfTX, DB, fun rrd:timing_with_hist_merge_fun/3)}
                    end
            end, Leader, DataL),
      {AllNodes, Leader1};
  on({bulkowner, reply, _Id, {gather_stats_response, _Data}} = _Msg, State) ->
      ?TRACE1(_Msg, State),
      State;
  
  on({bulkowner, deliver, _Id, _Range, {report_value, OtherState}, _Parents} = _Msg, {AllNodes, Leader} = _State) ->
      ?TRACE1(_Msg, _State),
      AllNodes1 = integrate_values(AllNodes, OtherState),
      {AllNodes1, Leader};
  
  on({get_rrds, KeyList, SourcePid}, {AllNodes, _Leader} = State) ->
      MyData = [begin
                    Value = case FullKey of
                                {?MODULE, 'read_read'} ->
  
negative.code:     comm:send_local(DHT_Node, {get_node_details, comm:this(), [my_range]}),
      State;
  
  on({get_node_details_response, NodeDetails} = _Msg,
     {AllNodes, Leader, BenchPid, IgnBenchT} = State) ->
      ?TRACE1(_Msg, State),
      case is_leader(node_details:get(NodeDetails, my_range)) of
          false -> State;
  