summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@lshift.net>2008-07-12 10:36:48 +0100
committerMatthias Radestock <matthias@lshift.net>2008-07-12 10:36:48 +0100
commit2538ff288eb028235049b47c524fff53747a1a6e (patch)
tree5b92e6c07687a879bc412a38b44b0c3fda80e224
parent30e6d7a967673e7ca4ca5cf6b07f099521bf3c49 (diff)
downloadrabbitmq-server-2538ff288eb028235049b47c524fff53747a1a6e.tar.gz
minor refactoring of preen_realm
-rw-r--r--src/rabbit_realm.erl12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/rabbit_realm.erl b/src/rabbit_realm.erl
index 4668be26..b2c721fc 100644
--- a/src/rabbit_realm.erl
+++ b/src/rabbit_realm.erl
@@ -228,10 +228,11 @@ on_node_down(Node) ->
%% This iterates through the realm_exchange and realm_queue link tables
%% and deletes rows that have no underlying exchange or queue record.
preen_realms() ->
- Resources = [#resource{kind = exchange},#resource{kind = queue}],
- [preen_realm(Resource) || Resource <- Resources ],
+ lists:foreach(fun preen_realm/1, [exchange, queue]),
ok.
-preen_realm(R = #resource{}) ->
+
+preen_realm(Kind) ->
+ R = #resource{kind = Kind},
LinkType = realm_table_for_resource(R),
Cursor = qlc:cursor(
qlc:q([L#realm_resource.resource ||
@@ -244,9 +245,8 @@ preen_next(Cursor, LinkType, ParentTable) ->
[] -> ok;
[Name] ->
case mnesia:read({ParentTable, Name}) of
- [] ->
- mnesia:delete_object({LinkType, '_', Name});
- _ -> ok
+ [] -> mnesia:delete_object({LinkType, '_', Name});
+ _ -> ok
end,
preen_next(Cursor, LinkType, ParentTable)
end.