summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDavid Ansari <david.ansari@gmx.de>2022-11-10 14:49:09 +0100
committerDavid Ansari <david.ansari@gmx.de>2022-11-10 15:49:51 +0100
commit9e452ace8a7a9a96a8b2a5d372bbd7f81bd44aa5 (patch)
treebc9c404d3f303545c429815225845b863faadb43
parent20385790a192c8f4ef9fc5ceacf1a465d13ed5a9 (diff)
downloadrabbitmq-server-git-9e452ace8a7a9a96a8b2a5d372bbd7f81bd44aa5.tar.gz
Support coverage when node being killed by index
(cherry picked from commit 1b1a7751609499980536a41a87dec89b46abbc8e)
-rw-r--r--deps/rabbitmq_ct_helpers/src/rabbit_ct_broker_helpers.erl13
1 files changed, 10 insertions, 3 deletions
diff --git a/deps/rabbitmq_ct_helpers/src/rabbit_ct_broker_helpers.erl b/deps/rabbitmq_ct_helpers/src/rabbit_ct_broker_helpers.erl
index faecf4a30e..0518ca8c23 100644
--- a/deps/rabbitmq_ct_helpers/src/rabbit_ct_broker_helpers.erl
+++ b/deps/rabbitmq_ct_helpers/src/rabbit_ct_broker_helpers.erl
@@ -1628,7 +1628,7 @@ stop_node_after(Config, Node, Sleep) ->
kill_node(Config, Node) ->
Pid = rpc(Config, Node, os, getpid, []),
- cover_remove_node(Node),
+ cover_remove_node(Config, Node),
Cmd = case os:type() of
{win32, _} ->
case os:find_executable("taskkill.exe") of
@@ -1920,18 +1920,25 @@ user(Username) ->
tags = [administrator],
authz_backends = [{rabbit_auth_backend_internal, none}]}.
-cover_add_node(Node) ->
+cover_add_node(Node)
+ when is_atom(Node) andalso Node =/= undefined ->
if_cover(
fun() ->
{ok, [Node]} = ct_cover:add_nodes([Node])
end).
-cover_remove_node(Node) ->
+cover_remove_node(Node)
+ when is_atom(Node) andalso Node =/= undefined ->
if_cover(
fun() ->
ok = ct_cover:remove_nodes([Node])
end).
+cover_remove_node(Config, Node) ->
+ NodeConfig = get_node_config(Config, Node),
+ Nodename = ?config(nodename, NodeConfig),
+ cover_remove_node(Nodename).
+
if_cover(F) ->
case os:getenv("COVER") of
false ->