From 737a89d5e851c1a05ce26cbe407ffc6d956bea2d Mon Sep 17 00:00:00 2001 From: turtled Date: Wed, 14 Dec 2016 18:09:41 +0800 Subject: [PATCH] rm net_adm:ping --- src/emqttd_cluster.erl | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/emqttd_cluster.erl b/src/emqttd_cluster.erl index 33eda2499..d5494a6b9 100644 --- a/src/emqttd_cluster.erl +++ b/src/emqttd_cluster.erl @@ -30,12 +30,12 @@ join(Node) when Node =:= node() -> {error, {cannot_join_with_self, Node}}; join(Node) when is_atom(Node) -> - case {net_adm:ping(Node), is_clustered(Node), emqttd:is_running(Node)} of - {pong, false, true} -> + case {is_clustered(Node), emqttd:is_running(Node)} of + {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.