From 0a29c8760ea40fbe863d12db33f035b927d66a0a Mon Sep 17 00:00:00 2001 From: Feng Date: Sun, 17 Jan 2016 19:59:05 +0800 Subject: [PATCH] add reg_name/2 function --- src/emqttd.erl | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/src/emqttd.erl b/src/emqttd.erl index cf5e75e78..63470420d 100644 --- a/src/emqttd.erl +++ b/src/emqttd.erl @@ -30,6 +30,9 @@ load_all_mods/0, is_mod_enabled/1, is_running/1]). +%% Utility functions. +-export([reg_name/2]). + -define(MQTT_SOCKOPTS, [ binary, {packet, raw}, @@ -122,10 +125,8 @@ load_mod({Name, Opts}) -> is_mod_enabled(Name) -> env(modules, Name) =/= undefined. -%%------------------------------------------------------------------------------ %% @doc Is running? -%% @end -%%------------------------------------------------------------------------------ +-spec is_running(node()) -> boolean(). is_running(Node) -> case rpc:call(Node, erlang, whereis, [?APP]) of {badrpc, _} -> false; @@ -133,3 +134,7 @@ is_running(Node) -> Pid when is_pid(Pid) -> true end. +-spec reg_name(module(), pos_integer()) -> atom(). +reg_name(M, Id) when is_atom(M), is_integer(Id) -> + list_to_atom(lists:concat([M, "_", Id])). +