From 4fb90d1e19e526e0ea6dd70084d22fdb20d5d68e Mon Sep 17 00:00:00 2001 From: Ery Lee Date: Sun, 12 Apr 2015 21:04:17 +0800 Subject: [PATCH] cluster --- apps/emqttd/src/emqttd_ctl.erl | 2 +- apps/emqttd/src/emqttd_mnesia.erl | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/apps/emqttd/src/emqttd_ctl.erl b/apps/emqttd/src/emqttd_ctl.erl index f99048114..dfa8936c7 100644 --- a/apps/emqttd/src/emqttd_ctl.erl +++ b/apps/emqttd/src/emqttd_ctl.erl @@ -68,7 +68,7 @@ cluster([SNode]) -> pong -> application:stop(emqttd), application:stop(esockd), - emqtt_mnesia:cluster(Node), + emqttd_mnesia:cluster(Node), application:start(esockd), application:start(emqttd), ?PRINT("cluster with ~p successfully.~n", [Node]); diff --git a/apps/emqttd/src/emqttd_mnesia.erl b/apps/emqttd/src/emqttd_mnesia.erl index 8cb688936..f7e5d5bab 100644 --- a/apps/emqttd/src/emqttd_mnesia.erl +++ b/apps/emqttd/src/emqttd_mnesia.erl @@ -153,13 +153,13 @@ wait_for_tables() -> %% Simple cluster with another nodes. %% %% @end -%%------------------------------------------------------------------------------ +%%-------------- cluster(Node) -> %% stop mnesia mnesia:stop(), ok = wait_for_mnesia(stop), %% delete mnesia - ok = mnesia:delete_schema(node()), + ok = mnesia:delete_schema([node()]), %% start mnesia ok = mnesia:start(), %% connect with extra_db_nodes