anchor.diff:              end
       end.
   
  -grab_op_stats_body(Bucket, Nodes, ClientTStamp, Ref, PeriodParams) ->
  +gather_op_stats_body(Bucket, Nodes, ClientTStamp,
  +                   Ref, PeriodParams) ->
       FirstNode = case Nodes of
                       all -> node();
                       [X] -> X
                   end,
       RV = invoke_archiver(Bucket, FirstNode, PeriodParams),
       case RV of
  -        [] -> [];
  -        [_] -> [];
  +        [] -> {[], [], ClientTStamp, PeriodParams};
  +        [_] -> {[], [], ClientTStamp, PeriodParams};
           _ ->
               %% we throw out last sample 'cause it might be missing on other nodes yet
               %% previous samples should be ok on all live nodes
  
positive.code:                                      all -> ns_bucket:live_bucket_nodes(Bucket);
                                       [_] -> []
                                   end,
                      Replies = invoke_archiver(
                                  Bucket,
                                  OtherNodes,
                                  PeriodParams),
                      %% merge samples from other nodes
                      MergedSamples = lists:foldl(fun ({Node, _}, AccSamples) when Node =:= node() -> AccSamples;
                                                      ({_Node, RemoteSamples}, AccSamples) ->
                                                          merge_samples_normally(AccSamples, RemoteSamples)
                                                  end, MainSamples, Replies),
                      lists:reverse(MergedSamples)
              end
      end.
  
  
negative.code:                     minute -> Ref;
                      _ -> []
                  end,
      try gather_op_stats_body(Bucket, Nodes, ClientTStamp, RefToPass,
                               {Step, Period, Window}) of
          Something -> Something
      after
          ns_pubsub:unsubscribe(ns_stats_event, Subscription),
          misc:flush(Ref)
  