anchor.diff:             evict_bucket(BucketName, Partition, MaxBucketSize, MaxTimeMsNoEviction)
       end,
   
  -    {ok, State#state{next_bucket_index=NewNextIndex}}.
  +    {ok, State#state{next_bucket_index=NewNextIndex}};
  +
  +handle_info({'DOWN', _MonitorRef, process, Pid, _Info}, State=#state{buckets=Buckets}) ->
  +    NewBuckets = sblob_preg:remove_reverse(Buckets, Pid),
  +    {noreply, State#state{buckets=NewBuckets}}.
   
   terminate(_Reason, State=#state{partition=Partition}) ->
       lager:info("terminate ~p", [Partition]),
  
positive.code:     Path = filename:join([BasePath, PartitionStr]),
      Buckets = sblob_preg:new(),
      Channels = sblob_preg:new(),
  
      % TODO: configure and calculate based on number of buckets
      BucketEvictTimeInterval = 60000,
  
negative.code:           end),
  
      {ok, #state{partition=Partition, path=Path, buckets=Buckets,
                  channels=Channels, buckets_sup=BucketsSup}}.
  
  %% Sample command: respond to a ping
  handle_command(ping, _Sender, State) ->
  