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

Add cluster_nodes/1 function

This commit is contained in:
Feng Lee 2017-06-13 10:33:56 +08:00
parent 53f5188cbb
commit a5cac277c1
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/emqttd_mnesia.erl
View File

@ -27,7 +27,7 @@
%% Cluster mnesia %% Cluster mnesia
-export([join_cluster/1, cluster_status/0, leave_cluster/0, -export([join_cluster/1, cluster_status/0, leave_cluster/0,
remove_from_cluster/1, running_nodes/0]). remove_from_cluster/1, cluster_nodes/1, running_nodes/0]).
%% Schema and tables %% Schema and tables
-export([copy_schema/1, delete_schema/0, del_schema_copy/1, -export([copy_schema/1, delete_schema/0, del_schema_copy/1,
@ -213,10 +213,18 @@ connect(Node) ->
Error -> Error Error -> Error
end. end.
%% @doc Running nodes %% @doc Running nodes.
-spec(running_nodes() -> list(node())). -spec(running_nodes() -> list(node())).
running_nodes() -> running_nodes() -> cluster_nodes(running).
mnesia:system_info(running_db_nodes).
%% @doc Cluster nodes.
-spec(cluster_nodes(all | running | stopped) -> [node()]).
cluster_nodes(all) ->
mnesia:system_info(db_nodes);
cluster_nodes(running) ->
mnesia:system_info(running_db_nodes);
cluster_nodes(stopped) ->
cluster_nodes(all) -- cluster_nodes(running).
%% @private %% @private
ensure_ok(ok) -> ok; ensure_ok(ok) -> ok;