anchor.diff:      {bench} |
       {propagate} |
       {get_node_details_response, node_details:node_details()} |
  -    {gather_stats, SourcePid::comm:mypid(), Round::pos_integer()} |
  -    {{get_rrds_response, [{Process::atom(), Key::string(), DB::rrd:rrd() | undefined}]}, {SourcePid::comm:mypid(), Round::pos_integer()}} |
  -    {gather_stats_response, Round::pos_integer(), [{Process::atom(), Key::string(), Data::rrd:timing_type(number())}]} |
  +    {gather_stats, SourcePid::comm:mypid(), Id::util:global_uid()} |
  +    {{get_rrds_response, [{Process::atom(), Key::string(), DB::rrd:rrd() | undefined}]}, {SourcePid::comm:mypid(), Id::util:global_uid()}} |
  +    {gather_stats_response, Id::util:global_uid(), [{Process::atom(), Key::string(), Data::rrd:timing_type(number())}]} |
       {report_value, StatsOneRound::#state{}} |
       {get_rrds, [{Process::atom(), Key::string()},...], SourcePid::comm:mypid()}.
   
  
positive.code:                end || {Process, Key, DB} <- DBs, DB =/= undefined]),
      case DataL of
          [] -> ok;
          _  -> comm:send(SourcePid, {gather_stats_response, Round, DataL})
      end,
      State;
  
  on({gather_stats_response, Round, DataL} = _Msg, {AllNodes, Leader} = _State)
    when Round =:= Leader#state.round->
      ?TRACE1(_Msg, _State),
      Leader1 =
          lists:foldl(
  
negative.code: integrate_values(OtherState, MyState) ->
      MyPerfRR1 = integrate_value(OtherState#state.perf_rr, MyState#state.perf_rr),
      MyPerfLH1 = integrate_value(OtherState#state.perf_lh, MyState#state.perf_lh),
      MyState#state{id = OtherState#state.id,
                    perf_rr = MyPerfRR1, perf_lh = MyPerfLH1}.
  
  -spec integrate_value(OtherDB::rrd:rrd(), MyDB::rrd:rrd()) -> rrd:rrd().
  