summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2013-01-17 18:47:34 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2013-01-17 18:47:34 +0000
commitd8ebb900ad0477e737e5d20c4337e1837508348a (patch)
tree54b6c891765db6c256653aacfbf0e5de644b36ff /src
parent6924ebe38a97333bbed404e4d6ff87bb5d1dfbbe (diff)
downloadrabbitmq-server-git-d8ebb900ad0477e737e5d20c4337e1837508348a.tar.gz
simplifying refactor on rabbit_mnesia:discover_cluster
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_mnesia.erl15
1 files changed, 6 insertions, 9 deletions
diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl
index 6a442fecf2..d5efffa54e 100644
--- a/src/rabbit_mnesia.erl
+++ b/src/rabbit_mnesia.erl
@@ -601,19 +601,16 @@ discover_cluster(Nodes) when is_list(Nodes) ->
lists:foldl(fun (_, {ok, Res}) -> {ok, Res};
(Node, {error, _}) -> discover_cluster(Node)
end, {error, no_nodes_provided}, Nodes);
+discover_cluster(Node) when Node == node() ->
+ {error, {cannot_discover_cluster, "Cannot cluster node with itself"}};
discover_cluster(Node) ->
OfflineError =
{error, {cannot_discover_cluster,
"The nodes provided are either offline or not running"}},
- case node() of
- Node -> {error, {cannot_discover_cluster,
- "Cannot cluster node with itself"}};
- _ -> case rpc:call(Node,
- rabbit_mnesia, cluster_status_from_mnesia, []) of
- {badrpc, _Reason} -> OfflineError;
- {error, mnesia_not_running} -> OfflineError;
- {ok, Res} -> {ok, Res}
- end
+ case rpc:call(Node, rabbit_mnesia, cluster_status_from_mnesia, []) of
+ {badrpc, _Reason} -> OfflineError;
+ {error, mnesia_not_running} -> OfflineError;
+ {ok, Res} -> {ok, Res}
end.
schema_ok_or_move() ->