anchor.diff:                   erlcloud_s3:get_object(?TEST_BUCKET, "object_one", U1C2Config)),
   
       lager:info("disable proxy_get again"),
  -    disable_pg(LeaderA, "B", ANodes, BNodes),
  +    disable_pg(LeaderA, "B", ANodes, BNodes, BPort),
   
       Object3A = crypto:rand_bytes(4194304),
       ?assert(Object3 /= Object3A),
  
positive.code:             "object_three", U1C2Config)),
  
      lager:info("enable proxy_get"),
      enable_pg(LeaderA, "B", ANodes, BNodes),
  
      lager:info("check we can read object_two via proxy get"),
      Obj6 = erlcloud_s3:get_object(?TEST_BUCKET, "object_two", U1C2Config),
      ?assertEqual(Object2, proplists:get_value(content, Obj6)),
  
      lager:info("disable proxy_get again"),
      disable_pg(LeaderA, "B", ANodes, BNodes),
  
      lager:info("check we still can't read object_three"),
      ?assertError({aws_error, _}, erlcloud_s3:get_object(?TEST_BUCKET,
  
negative.code:     ?assertEqual(ok, repl_helpers:wait_for_connection13(LeaderA, "B")),
      rt:wait_until_ring_converged(ANodes),
  
      repl_helpers:enable_realtime(LeaderA, "B"),
      repl_helpers:start_realtime(LeaderA, "B"),
  
      PGEnableResult = rpc:call(LeaderA, riak_repl_console, proxy_get, [["enable","B"]]),
      lager:info("Enabled pg: ~p", [PGEnableResult]),
  