anchor.diff:      {async, {fold, AsyncWork, FinishFun}, Sender, State};
   
   handle_coverage({update_ttl, Bucket}, _KeySpaces, _Sender,
  -                State = #state{partition=P, node=N,
  -                               bucket_info = BktInfo}) ->
  -    BktInfo1 = btrie:erase(Bucket, BktInfo),
  +                State = #state{partition=P, node=N
  +                               %%,bucket_info = BktInfo
  +                              }) ->
  +    %BktInfo1 = btrie:erase(Bucket, BktInfo),
  +    erase(Bucket),
       R = btrie:new(),
       R1 = btrie:store(Bucket, t, R),
       Reply = {ok, undefined, {P, N}, R1},
  -    {reply, Reply, State#state{bucket_info = BktInfo1}};
  +    {reply, Reply, State};%#state{bucket_info = BktInfo1}};
   
   handle_coverage(update_env, _KeySpaces, _Sender,
                   State = #state{partition=P, node=N, io = IO}) ->
  
positive.code:     {reply, Reply, update_env(State#state{io = IO1})};
  
  handle_coverage({delete, Bucket}, _KeySpaces, _Sender,
                  State = #state{partition=P, node=N, cache = C, io = IO,
                                 bucket_info = BktInfo}) ->
      mcache:remove_bucket(C, Bucket),
      _Repply = metric_io:delete(IO, Bucket),
      R = btrie:new(),
      R1 = btrie:store(Bucket, t, R),
      Reply = {ok, undefined, {P, N}, R1},
      BktInfo1 = btrie:erase(Bucket, BktInfo),
      {reply, Reply, State#state{bucket_info = BktInfo1}}.
  
  handle_info(vacuum, State = #state{io = IO, partition = P}) ->
      lager:info("[vaccum] Starting vaccum for partition ~p.", [P]),
  
negative.code:     Exp = (Now - LT) div Res,
      {Exp, State}.
  
  get_bucket_info(Bucket, State) ->
      case get(Bucket) of
          undefined ->
              metric_io:inform(State#state.io, Bucket),
              {ok, Info} = dalmatiner_bucket:info(Bucket),
              Info1 = case Info of
  