diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2010-11-12 15:46:42 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-11-12 15:46:42 +0000 |
| commit | 5b7457c08325814cea0c69434d52e040ca2409bc (patch) | |
| tree | 9bc7def5ec8f9d5197fff2ba8e73a2d26c91ef3a | |
| parent | 0cef8cb483d0108cd21a252952376e4455559e71 (diff) | |
| download | rabbitmq-server-5b7457c08325814cea0c69434d52e040ca2409bc.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_mnesia.erl | 22 | ||||
| -rw-r--r-- | src/rabbit_upgrade.erl | 4 |
2 files changed, 12 insertions, 14 deletions
diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl index 9d172269..da81f884 100644 --- a/src/rabbit_mnesia.erl +++ b/src/rabbit_mnesia.erl @@ -361,16 +361,15 @@ init_db(ClusterNodes, Force) -> case mnesia:change_config(extra_db_nodes, ProperClusterNodes) of {ok, Nodes} -> case Force of - false -> - FailedClusterNodes = ProperClusterNodes -- Nodes, - case FailedClusterNodes of - [] -> ok; - _ -> - throw({error, {failed_to_cluster_with, - FailedClusterNodes, - "Mnesia could not connect to some nodes."}}) - end; - _ -> ok + false -> FailedClusterNodes = ProperClusterNodes -- Nodes, + case FailedClusterNodes of + [] -> ok; + _ -> throw({error, {failed_to_cluster_with, + FailedClusterNodes, + "Mnesia could not connect " + "to some nodes."}}) + end; + true -> ok end, case {Nodes, mnesia:system_info(use_dir), mnesia:system_info(db_nodes)} of @@ -411,8 +410,7 @@ init_db(ClusterNodes, Force) -> %% one reason we may end up here is if we try to join %% nodes together that are currently running standalone or %% are members of a different cluster - throw({error, {unable_to_join_cluster, - ClusterNodes, Reason}}) + throw({error, {unable_to_join_cluster, ClusterNodes, Reason}}) end. schema_ok_or_move() -> diff --git a/src/rabbit_upgrade.erl b/src/rabbit_upgrade.erl index 0071a08a..4ecef7ee 100644 --- a/src/rabbit_upgrade.erl +++ b/src/rabbit_upgrade.erl @@ -66,8 +66,8 @@ maybe_upgrade() -> read_version() -> case rabbit_misc:read_term_file(schema_filename()) of - {ok, [Heads]} -> {ok, Heads}; - {error, E} -> {error, E} + {ok, [Heads]} -> {ok, Heads}; + {error, _E} = Err -> Err end. write_version() -> |