summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@lshift.net>2009-08-19 12:12:06 +0100
committerMatthew Sackman <matthew@lshift.net>2009-08-19 12:12:06 +0100
commitafe4be9eea994d2bb376af42f8b118d330854526 (patch)
tree1be28fab65758d082c72d6c2dfc67581f7d6092f /src
parent857ab133c6905a762c7fcbfb89b3115e4580f449 (diff)
parent1a05739c4e7df3db4140e77497098384b0720109 (diff)
downloadrabbitmq-server-git-afe4be9eea994d2bb376af42f8b118d330854526.tar.gz
merging in bug21429
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_mnesia.erl22
1 files changed, 10 insertions, 12 deletions
diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl
index b40294f686..d650edb09d 100644
--- a/src/rabbit_mnesia.erl
+++ b/src/rabbit_mnesia.erl
@@ -364,18 +364,16 @@ create_local_non_replicated_table_copies(Type) ->
create_local_table_copies(Type, TableDefinitions) ->
lists:foreach(
fun({Tab, TabDef}) ->
- HasDiscCopies =
- case lists:keysearch(disc_copies, 1, TabDef) of
- false -> false;
- {value, {disc_copies, List1}} ->
- lists:member(node(), List1)
- end,
- HasDiscOnlyCopies =
- case lists:keysearch(disc_only_copies, 1, TabDef) of
- false -> false;
- {value, {disc_only_copies, List2}} ->
- lists:member(node(), List2)
- end,
+ 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),
StorageType =
case Type of
disc ->