anchor.diff:                      minute -> Ref;
                       _ -> []
                   end,
  -    try grab_op_stats_body(Bucket, Nodes, ClientTStamp, RefToPass, {Step, Period, Window}) of
  -        V -> case V =/= [] andalso (hd(V))#stat_entry.timestamp of
  -                 ClientTStamp -> {V, ClientTStamp, Step, Window};
  -                 _ -> {V, undefined, Step, Window}
  -             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)
  
positive.code:             end
      end.
  
  grab_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
          [] -> [];
          [_] -> [];
          _ ->
              %% we throw out last sample 'cause it might be missing on other nodes yet
              %% previous samples should be ok on all live nodes
  
negative.code:         ++ orddict:to_list(Dict).
  
  build_buckets_stats_ops_response(_PoolId, Nodes, [BucketName], Params) ->
      {Samples, ClientTStamp, Step, TotalNumber} = grab_aggregate_op_stats(BucketName, Nodes, Params),
      PropList2 = samples_to_proplists(Samples),
      OpPropList0 = [{samples, {struct, PropList2}},
                     {samplesCount, TotalNumber},
  