anchor.diff:      erlcloud_s3:put_object(?TEST_BUCKET, "object_three", Object3, U1C1Config),
   
       lager:info("disable proxy_get"),
  -    %LeaderB = rpc:call(hd(BNodes), riak_repl_leader, leader_node, []),
  -    %LeaderA = rpc:call(AFirst, riak_core_cluster_mgr, get_leader, []),
  -
  -    disable_pg(LeaderA, "B", ANodes, BNodes),
  +
  +    disable_pg(LeaderA, "B", ANodes, BNodes, BPort),
   
       %% not sure what this is for, but I'm not going to touch it right now
       timer:sleep(5000),
  
positive.code:     lager:info("Replication Modes = ~p", [ModeResA]),
      lager:info("Replication Modes = ~p", [ModeResB]),
  
      {ok, {_IP, BPort}} = rpc:call(BFirst, application, get_env,
                                    [riak_core, cluster_mgr]),
      repl_helpers:connect_clusters13(LeaderA, ANodes, BPort, "B"),
  
negative.code:     ?assertEqual(Object4A, proplists:get_value(content,Obj15)),
      pass.
  
  enable_pg(SourceLeader, SinkName, ANodes, BNodes, BPort) ->
      repl_helpers:connect_clusters13(SourceLeader, ANodes, BPort, SinkName),
      set_proxy_get(SourceLeader, "enable", SinkName, ANodes, BNodes).
  
  disable_pg(SourceLeader, SinkName, ANodes, BNodes, _BPort) ->
      set_proxy_get(SourceLeader, "disable", SinkName, ANodes, BNodes),
      repl_helpers:disconnect_clusters13(SourceLeader, ANodes, SinkName).
  
  set_proxy_get(SourceLeader, EnableOrDisable, SinkName, ANodes, BNodes) ->
      PGEnableResult = rpc:call(SourceLeader, riak_repl_console, proxy_get,
  