diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-09-24 15:37:36 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-09-24 15:37:36 +0100 |
| commit | 4a4bd43ab4cbf1aff1605d9a306bbbf494e71fb6 (patch) | |
| tree | 7180718819c501ee1de38b1654d4a8d11b251cc1 /src | |
| parent | abe09fafd79c8addee98e62e401f4d5a0ac93e94 (diff) | |
| download | rabbitmq-server-git-4a4bd43ab4cbf1aff1605d9a306bbbf494e71fb6.tar.gz | |
some more inlining
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mnesia.erl | 13 |
1 files changed, 4 insertions, 9 deletions
diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl index 30bfa61fc2..c4920dc481 100644 --- a/src/rabbit_mnesia.erl +++ b/src/rabbit_mnesia.erl @@ -539,7 +539,7 @@ check_schema_integrity() -> true -> check_table_attributes(Tab, TabDef) end end) of - ok -> ok = wait_for_tables(), + ok -> ok = wait_for_tables(table_names()), check_tables(fun check_table_content/2); Other -> Other end. @@ -574,9 +574,9 @@ copy_db(Destination) -> ok = ensure_mnesia_not_running(), rabbit_file:recursive_copy(dir(), Destination). -wait_for_replicated_tables() -> wait_for_tables(replicated_table_names()). - -wait_for_tables() -> wait_for_tables(table_names()). +wait_for_replicated_tables() -> + wait_for_tables([Tab || {Tab, TabDef} <- table_definitions(), + not lists:member({local_content, true}, TabDef)]). wait_for_tables(TableNames) -> case mnesia:wait_for_tables(TableNames, 30000) of @@ -801,11 +801,6 @@ queue_name_match() -> resource_match(Kind) -> #resource{kind = Kind, _='_'}. -replicated_table_names() -> - [Tab || {Tab, TabDef} <- table_definitions(), - not lists:member({local_content, true}, TabDef) - ]. - check_table_attributes(Tab, TabDef) -> {_, ExpAttrs} = proplists:lookup(attributes, TabDef), case mnesia:table_info(Tab, attributes) of |