summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/rabbit_connection_tracking.erl20
1 files changed, 10 insertions, 10 deletions
diff --git a/src/rabbit_connection_tracking.erl b/src/rabbit_connection_tracking.erl
index bd82b7c27e..ab945abc2f 100644
--- a/src/rabbit_connection_tracking.erl
+++ b/src/rabbit_connection_tracking.erl
@@ -188,21 +188,21 @@ unregister_connection(ConnId = {Node, _Name}) when Node =:= node() ->
-spec list() -> [rabbit_types:tracked_connection()].
list() ->
- Chunks = lists:foldl(
- fun (Node, Acc) ->
- Tab = tracked_connection_table_name_for(Node),
- Acc ++ mnesia:dirty_match_object(Tab, #tracked_connection{_ = '_'})
- end, [], rabbit_mnesia:cluster_nodes(running)).
+ lists:foldl(
+ fun (Node, Acc) ->
+ Tab = tracked_connection_table_name_for(Node),
+ Acc ++ mnesia:dirty_match_object(Tab, #tracked_connection{_ = '_'})
+ end, [], rabbit_mnesia:cluster_nodes(running)).
-spec list(rabbit_types:vhost()) -> [rabbit_types:tracked_connection()].
list(VHost) ->
- Chunks = lists:foldl(
- fun (Node, Acc) ->
- Tab = tracked_connection_table_name_for(Node),
- Acc ++ mnesia:dirty_match_object(Tab, #tracked_connection{vhost = VHost, _ = '_'})
- end, [], rabbit_mnesia:cluster_nodes(running)).
+ lists:foldl(
+ fun (Node, Acc) ->
+ Tab = tracked_connection_table_name_for(Node),
+ Acc ++ mnesia:dirty_match_object(Tab, #tracked_connection{vhost = VHost, _ = '_'})
+ end, [], rabbit_mnesia:cluster_nodes(running)).
-spec list_on_node(node()) -> [rabbit_types:tracked_connection()].