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 /src | |
| parent | 30e6d7a967673e7ca4ca5cf6b07f099521bf3c49 (diff) | |
| download | rabbitmq-server-git-2538ff288eb028235049b47c524fff53747a1a6e.tar.gz | |
minor refactoring of preen_realm
Diffstat (limited to 'src')
| -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 4668be26d4..b2c721fca1 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. |
