summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <mklishin@pivotal.io>2016-07-03 03:54:52 +0300
committerMichael Klishin <michael@clojurewerkz.org>2016-07-03 03:55:57 +0300
commitca99a3edaffea883f5190aa6fc444e21afe0019f (patch)
treed1cd6309e4f4ab9e151650f42521483c19c92a6a
parenta9f5d3884121ce041965517df25b07c7cd8ce87d (diff)
downloadrabbitmq-server-git-ca99a3edaffea883f5190aa6fc444e21afe0019f.tar.gz
{allow,block}_traffic_between/2 are moved to rabbit_ct_broker_helpers
-rw-r--r--test/partitions_SUITE.erl6
1 files changed, 2 insertions, 4 deletions
diff --git a/test/partitions_SUITE.erl b/test/partitions_SUITE.erl
index ff8d5f5f13..7425bec307 100644
--- a/test/partitions_SUITE.erl
+++ b/test/partitions_SUITE.erl
@@ -389,12 +389,10 @@ partitions(Node) ->
end.
block(X, Y) ->
- rpc:call(X, inet_tcp_proxy, block, [Y]),
- rpc:call(Y, inet_tcp_proxy, block, [X]).
+ rabbit_ct_broker_helpers:block_traffic_between(X, Y).
allow(X, Y) ->
- rpc:call(X, inet_tcp_proxy, allow, [Y]),
- rpc:call(Y, inet_tcp_proxy, allow, [X]).
+ rabbit_ct_broker_helpers:allow_traffic_between(X, Y).
await_running (Node, Bool) -> await(Node, Bool, fun is_running/1).
await_listening (Node, Bool) -> await(Node, Bool, fun is_listening/1).