anchor.diff:                                      metric_io:delete(IO, Bucket, Exp),
                                       SAcc1
                               end
  -                    end, State, btrie:fetch_keys(Bs)),
  +                    end, State1, btrie:fetch_keys(Bs)),
       lager:info("[vaccum] Finalized vaccum for partution ~p.", [P]),
  -    {ok, State1};
  +    {ok, State2};
   
   handle_info({'EXIT', IO, normal}, State = #state{io = IO}) ->
       {ok, State};
  
positive.code: reply(Reply, {_, ReqID, _} = Sender, #state{node=N, partition=P}) ->
      riak_core_vnode:reply(Sender, {ok, ReqID, {P, N}, Reply}).
  
  valid_ts(TS, Bucket, State) ->
      case expiry(Bucket, State) of
          %% TODO:
  
negative.code:           tbl,
            ct,
            io,
            now,
            resolutions = btrie:new(),
            lifetimes  = btrie:new()
           }).
  