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

fix cluster

This commit is contained in:
erylee 2012-12-27 16:51:32 +08:00
parent 60b42661b1
commit dbad1cf920
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
rel/files/vm.args
View File

@ -1,5 +1,5 @@
## Name of the node ## Name of the node
-name emqtt@127.0.0.1 -sname emqtt
## Cookie for distributed erlang ## Cookie for distributed erlang
-setcookie emqtt -setcookie emqtt

5
src/emqtt_ctl.erl
View File

@ -22,8 +22,9 @@ cluster_info([]) ->
Nodes = [node()|nodes()], Nodes = [node()|nodes()],
?PRINT("cluster nodes: ~p~n", [Nodes]). ?PRINT("cluster nodes: ~p~n", [Nodes]).
cluster([Node]) -> cluster([SNode]) ->
case net_adm:ping(list_to_atom(Node)) of Node = list_to_atom(SNode),
case net_adm:ping(Node) of
pong -> pong ->
application:stop(emqtt), application:stop(emqtt),
mnesia:stop(), mnesia:stop(),