diff options
author | Matthew Sackman <matthew@lshift.net> | 2009-08-21 12:50:50 +0100 |
---|---|---|
committer | Matthew Sackman <matthew@lshift.net> | 2009-08-21 12:50:50 +0100 |
commit | e850b8ec85dbc911477f91a64bc646ae8b6c9165 (patch) | |
tree | 3b48eb6fdccb5f3e2769ebefe9a0c82fad6c5566 | |
parent | 05270ad59cfbabdbd7b9a1b8587b9d69bbc2cc78 (diff) | |
download | rabbitmq-server-e850b8ec85dbc911477f91a64bc646ae8b6c9165.tar.gz |
tiny refactoring
-rw-r--r-- | src/rabbit_mnesia.erl | 18 |
1 files changed, 8 insertions, 10 deletions
diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl index 82a8fde1..6d652624 100644 --- a/src/rabbit_mnesia.erl +++ b/src/rabbit_mnesia.erl @@ -344,6 +344,12 @@ create_tables() -> table_definitions()), ok. +table_has_copy_type(TabDef, DiscType) -> + case lists:keysearch(DiscType, 1, TabDef) of + false -> false; + {value, {DiscType, List}} -> lists:member(node(), List) + end. + create_local_replicated_table_copies(Type) -> create_local_table_copies(Type, replicated_table_definitions()). @@ -353,16 +359,8 @@ create_local_non_replicated_table_copies(Type) -> create_local_table_copies(Type, TableDefinitions) -> lists:foreach( fun({Tab, TabDef}) -> - Fun = fun(DiscType) -> - case lists:keysearch(DiscType, 1, TabDef) of - false -> - false; - {value, {DiscType, List}} -> - lists:member(node(), List) - end - end, - HasDiscCopies = Fun(disc_copies), - HasDiscOnlyCopies = Fun(disc_only_copies), + HasDiscCopies = table_has_copy_type(TabDef, disc_copies), + HasDiscOnlyCopies = table_has_copy_type(TabDef, disc_only_copies), StorageType = case Type of disc -> |