yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Check if the node is in cluster before remove

This commit is contained in:
Feng Lee 2017-03-23 18:37:04 +08:00
parent f194f92418
commit 440307081b
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/emqttd_cluster.erl
View File

@ -73,12 +73,14 @@ remove(Node) when Node =:= node() ->
{error, {cannot_remove_self, Node}}; {error, {cannot_remove_self, Node}};
remove(Node) -> remove(Node) ->
case rpc:call(Node, ?MODULE, prepare, []) of case is_clustered(Node) andalso rpc:call(Node, ?MODULE, prepare, []) of
ok -> ok ->
case emqttd_mnesia:remove_from_cluster(Node) of case emqttd_mnesia:remove_from_cluster(Node) of
ok -> rpc:call(Node, ?MODULE, reboot, []); ok -> rpc:call(Node, ?MODULE, reboot, []);
Error -> Error Error -> Error
end; end;
false ->
{error, node_not_in_cluster};
{badrpc, nodedown} -> {badrpc, nodedown} ->
emqttd_mnesia:remove_from_cluster(Node); emqttd_mnesia:remove_from_cluster(Node);
{badrpc, Reason} -> {badrpc, Reason} ->