anchor.diff:      end.
   
   build_per_node_stats(BucketName, StatName, Params, LocalAddr) ->
  -    {MainSamples, Replies, ClientTStamp, {Step, _, Window}}
  +    {MainNode, MainSamples, RestSamplesRaw, ClientTStamp, {Step, _, Window}}
           = gather_op_stats(BucketName, all, Params),
   
       StatExtractor = build_stat_extractor(BucketName, StatName),
   
  -    RestSamplesRaw = lists:keydelete(node(), 1, Replies),
  -    Nodes = [node() | [N || {N, _} <- RestSamplesRaw]],
  -    AllNodesSamples = [{node(), lists:reverse(MainSamples)} | RestSamplesRaw],
  +    Nodes = [MainNode | [N || {N, _} <- RestSamplesRaw]],
  +    AllNodesSamples = [{MainNode, lists:reverse(MainSamples)} | RestSamplesRaw],
   
       NodesSamples = [lists:map(StatExtractor, NodeSamples) || {_, NodeSamples} <- AllNodesSamples],
   
  
positive.code:                         Ref ->
                              gather_op_stats_body(Bucket, Nodes, ClientTStamp, [], PeriodParams)
                      after 2000 ->
                              {[], [], ClientTStamp, PeriodParams}
                      end;
                  _ ->
                      %% cut samples up-to and including ClientTStamp
  
negative.code:     [hd(ets:lookup(ETS, T)) || #stat_entry{timestamp = T} <- MainSamples].
  
  grab_aggregate_op_stats(Bucket, Nodes, Params) ->
      {_MainNode, MainSamples, Replies, ClientTStamp, {Step, _, Window}} = gather_op_stats(Bucket, Nodes, Params),
      RV = merge_all_samples_normally(MainSamples, [S || {_,S} <- Replies]),
      V = lists:reverse(RV),
      case V =/= [] andalso (hd(V))#stat_entry.timestamp of
          ClientTStamp -> {V, ClientTStamp, Step, Window};
  