anchor.diff:                      k6_bytea:set(Array, 0, Value),
                       k6_bytea:set(Array, Len * ?DATA_SIZE,
                                    <<0:(?DATA_SIZE * 8 * (CacheSize - Len))>>),
  +                    End = cache_end(Time, CacheSize),
                       ets:update_element(T, BM, [{2, Time}, {3, Len},
  -                                               {4, Time + CacheSize}]),
  +                                               {4, End}]),
                       metric_io:write(IO, Bucket, Metric, Start, Bin);
                   %% In the case the data is already longer then the cache we
                   %% flush the cache
  
positive.code: 
  handle_overload_info(_, _Idx) ->
      ok.
  
negative.code:             end,
              State1
      end.
  
  
  reply(Reply, {_, ReqID, _} = Sender, #state{node=N, partition=P}) ->
      riak_core_vnode:reply(Sender, {ok, ReqID, {P, N}, Reply}).
  