summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@lshift.net>2009-08-21 12:50:50 +0100
committerMatthew Sackman <matthew@lshift.net>2009-08-21 12:50:50 +0100
commite850b8ec85dbc911477f91a64bc646ae8b6c9165 (patch)
tree3b48eb6fdccb5f3e2769ebefe9a0c82fad6c5566
parent05270ad59cfbabdbd7b9a1b8587b9d69bbc2cc78 (diff)
downloadrabbitmq-server-e850b8ec85dbc911477f91a64bc646ae8b6c9165.tar.gz
tiny refactoring
-rw-r--r--src/rabbit_mnesia.erl18
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 ->