anchor.diff:  code_change(_OldVsn, State, _Extra) ->
       {ok, State}.
   
  +full_vbucket_update(#state{vbuckets=VBuckets,
  +                           bucket=Bucket, master=Master} = State) ->
  +    [stop_vbucket_replication(Master, Bucket, Srv) || Srv <- VBuckets],
  +    [start_vbucket_replication(Master, Bucket, Srv) || Srv <- VBuckets],
  +
  +    State.
  +
   
   update(#state{vbuckets=VBuckets, servers=Servers,
                 bucket=Bucket, master=Master} = State) ->
  
positive.code: -define(i2l(V), integer_to_list(V)).
  
  
  -export([start_link/1, force_update/1]).
  -export([init/1, handle_call/3, handle_cast/2,
           handle_info/2, terminate/2, code_change/3]).
  
  
negative.code:       fun (_, _) -> Self ! update end,
        empty),
  
      ns_pubsub:subscribe(
        mc_couch_events,
        fun ({flush_all, FlushedBucket}, _) when Bucket =:= FlushedBucket ->
                Self ! full_vbucket_update;
            (_, _) -> ok
        end,
        empty),
  
      Self ! update,
  
      erlang:process_flag(trap_exit, true),
  