anchor.diff:      {ok, #state{
               bucket_name = Bucket,
               repl_type = tap,
  -            remaining_tap_partitions = undefined,
               desired_replications = [],
               tap_replication_manager = undefined
              }}.
  
positive.code:     {TapP, UprP} = split_partitions(Partitions, State),
      split_replications(Rest, State, [{SrcNode, TapP} | Tap], [{SrcNode, UprP} | Upr]).
  
  replication_type(Partition, ReplType, TapPartitions) ->
      case {ReplType, TapPartitions} of
          {tap, undefined} ->
              tap;
          {upr, undefined} ->
              upr;
          {both, _} ->
              case ordsets:is_element(Partition, TapPartitions) of
                  true ->
                      tap;
  
negative.code:             misc:ukeymergewith(MergeFn, 1, TapReps, UprReps)
      end.
  
  merge_partitions(TapP, UprP, TapPartitions) ->
      [] = ordsets:intersection(UprP, TapPartitions) ++
          ordsets:subtract(TapP, TapPartitions),
      lists:sort(TapP ++ UprP).
  
  call_replicators(TapFun, TapArgs, UprFun, UprArgs, ReplType) ->
      call_replicators(TapFun, TapArgs, UprFun, UprArgs,
                       fun(_, _, _) -> ok end,
                       ReplType).
  
  call_replicators(TapFun, TapArgs, UprFun, UprArgs, MergeCB, ReplType) ->
      case ReplType of
          tap ->
              erlang:apply(tap_replication_manager, TapFun, TapArgs);
          upr ->
              erlang:apply(upr_sup, UprFun, UprArgs);
          {upr, TapPartitions} ->
              MergeCB(
                erlang:apply(tap_replication_manager, TapFun, TapArgs),
                erlang:apply(upr_sup, UprFun, UprArgs), TapPartitions)
      end.
  
  get_actual_replications(Bucket, ReplTypeTuple) ->
      call_replicators(get_actual_replications, [Bucket], get_actual_replications, [Bucket],
                       fun merge_replications/3, ReplTypeTuple).
  
  get_actual_replications_as_list(#state{repl_type = ReplType,
                                         bucket_name = Bucket}) ->
      case get_actual_replications(Bucket, ReplType) of
          not_running ->
              [];
          Reps ->
  