anchor.diff:  
   init(Bucket) ->
       process_flag(trap_exit, true),
  +
  +    TableName = server_name(Bucket),
  +    ets:new(TableName, [protected, set, named_table]),
  +    ets:insert(TableName, {repl_type, tap}),
  +
       {ok, #state{
               bucket_name = Bucket,
               repl_type = tap,
  
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:     {reply, ok, State};
  handle_call({set_replication_type, ReplType}, _From,
              #state{repl_type = OldReplType,
                     desired_replications = DesiredReplications,
                     bucket_name = Bucket} = State) ->
  
      ?log_debug("Change replication type from ~p to ~p", [OldReplType, ReplType]),
  
  