fixed cluster fail

This commit is contained in:
turtled 2016-12-13 16:57:18 +08:00
parent 696647f2cf
commit 15a2b265be
1 changed files with 4 additions and 4 deletions

View File

@ -30,12 +30,12 @@ join(Node) when Node =:= node() ->
{error, {cannot_join_with_self, Node}};
join(Node) when is_atom(Node) ->
case {is_clustered(Node), emqttd:is_running(Node)} of
{false, true} ->
case {net_adm:ping(Node), is_clustered(Node), emqttd:is_running(Node)} of
{pong, false, true} ->
prepare(), ok = emqttd_mnesia:join_cluster(Node), reboot();
{false, false} ->
{_, false, false} ->
{error, {node_not_running, Node}};
{true, _} ->
{_, true, _} ->
{error, {already_clustered, Node}}
end.