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