anchor.diff:          end),
       ?assertEqual(ok, Res).
   
  -wait_until_leader_converge([Node|_] = Nodes) ->
  -    rt:wait_until(Node,
  -        fun(_) ->
  -                length(lists:usort([begin
  -                        Status = rpc:call(N, riak_repl_console, status, [quiet]),
  -                        case Status of
  -                            {badrpc, _} ->
  -                                false;
  -                            _ ->
  -                                case proplists:get_value(leader, Status) of
  -                                    undefined ->
  -                                        false;
  -                                    L ->
  -                                        %lager:info("Leader for ~p is ~p",
  -                                            %[N,L]),
  -                                        L
  -                                end
  -                        end
  -                end || N <- Nodes])) == 1
  -        end).
  -
   wait_until_connection(Node) ->
       rt:wait_until(Node,
           fun(_) ->
  
positive.code:     Res = rpc:call(Node, riak_repl_console, del_site, [[Name]]),
      ?assertEqual(ok, Res),
      timer:sleep(timer:seconds(5)).
  
  fake_site(Port) ->
      lists:flatten(io_lib:format("fake_site_~p", [Port])).
  
  verify_listeners(Listeners) ->
      Strs = [IP ++ ":" ++ integer_to_list(Port) || {IP, Port, _} <- Listeners],
  
negative.code:     Res = rpc:call(N, riak_repl_console, add_listener, Args),
      ?assertEqual(ok, Res).
  
  gen_ports(Start, Len) ->
      lists:seq(Start, Start + Len - 1).
  
  verify_site_ips(Leader, Site, Listeners) ->
      Status = rpc:call(Leader, riak_repl_console, status, [quiet]),
  