diff options
author | Matthias Radestock <matthias@lshift.net> | 2008-07-12 10:36:48 +0100 |
---|---|---|
committer | Matthias Radestock <matthias@lshift.net> | 2008-07-12 10:36:48 +0100 |
commit | 2538ff288eb028235049b47c524fff53747a1a6e (patch) | |
tree | 5b92e6c07687a879bc412a38b44b0c3fda80e224 | |
parent | 30e6d7a967673e7ca4ca5cf6b07f099521bf3c49 (diff) | |
download | rabbitmq-server-2538ff288eb028235049b47c524fff53747a1a6e.tar.gz |
minor refactoring of preen_realm
-rw-r--r-- | src/rabbit_realm.erl | 12 |
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. |