summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorVlad Alexandru Ionescu <vlad@rabbitmq.com>2011-02-14 13:19:56 -0600
committerVlad Alexandru Ionescu <vlad@rabbitmq.com>2011-02-14 13:19:56 -0600
commit2212cec012790f2c1a982e9f2178a01a7af830b0 (patch)
treeb79aa2c095977a7d36ae847a2b1f87d30ac2834e
parent8e078622827fa18389866220d88facda5c3390bf (diff)
downloadrabbitmq-server-git-2212cec012790f2c1a982e9f2178a01a7af830b0.tar.gz
removing duplication and use of sets in rabbit_mnesia
-rw-r--r--src/rabbit_mnesia.erl13
1 files changed, 4 insertions, 9 deletions
diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl
index c6441b689b..51b6c6a920 100644
--- a/src/rabbit_mnesia.erl
+++ b/src/rabbit_mnesia.erl
@@ -553,19 +553,14 @@ create_local_table_copy(Tab, Type) ->
ok.
wait_for_replicated_tables() ->
- AllTablesSet = ordsets:from_list(mnesia:system_info(tables)),
- ReplicatedTablesSet = ordsets:from_list(replicated_table_names()),
- wait_for_tables(ordsets:to_list(ordsets:intersection(AllTablesSet,
- ReplicatedTablesSet))).
+ wait_for_tables(replicated_table_names()).
wait_for_tables() ->
- AllTablesSet = ordsets:from_list(mnesia:system_info(tables)),
- RabbitTablesSet = ordsets:from_list(table_names()),
- wait_for_tables(ordsets:to_list(ordsets:intersection(AllTablesSet,
- RabbitTablesSet))).
+ wait_for_tables(table_names()).
wait_for_tables(TableNames) ->
- case mnesia:wait_for_tables(TableNames, 30000) of
+ Inexistent = TableNames -- mnesia:system_info(tables),
+ case mnesia:wait_for_tables(TableNames -- Inexistent, 30000) of
ok -> ok;
{timeout, BadTabs} ->
throw({error, {timeout_waiting_for_tables, BadTabs}});