anchor.diff:  handle_info(_Msg, State) ->
       {noreply, State}.
   
  -handle_call(get_incoming_replication_map, _From, #state{repl_type = ReplType,
  -                                                        bucket_name = Bucket} = State) ->
  -    {reply, get_actual_replications(Bucket, ReplType), State};
   handle_call({remove_undesired_replications, FutureReps}, From,
               #state{desired_replications = CurrentReps} = State) ->
       Diff = replications_difference(FutureReps, CurrentReps),
  
positive.code:                     handle_call({set_desired_replications, CleanedReplications}, [], State),
                  S
          end,
      {reply, ok, State1#state{repl_type = ReplType}};
  handle_call({upr_takeover, OldMasterNode, VBucket}, _From,
              #state{bucket_name = Bucket,
  
negative.code:            }}.
  
  get_incoming_replication_map(Bucket) ->
      try ets:lookup(server_name(Bucket), repl_type) of
          [{repl_type, ReplType}] ->
              get_actual_replications(Bucket, ReplType);
          [] ->
              not_running
      catch
          error:badarg -> not_running
      end.
  
  -spec set_incoming_replication_map(bucket_name(),
  