|
|
@@ -30,22 +30,22 @@
|
|
|
|
|
|
-include("emqttd.hrl").
|
|
|
|
|
|
--behaviour(gen_server2).
|
|
|
-
|
|
|
--define(SERVER, ?MODULE).
|
|
|
-
|
|
|
%% API Exports
|
|
|
-export([start_link/2, pool/0]).
|
|
|
|
|
|
-export([lookup/1, register/1, unregister/1]).
|
|
|
|
|
|
+-behaviour(gen_server2).
|
|
|
+
|
|
|
+-define(SERVER, ?MODULE).
|
|
|
+
|
|
|
%% gen_server Function Exports
|
|
|
-export([init/1, handle_call/3, handle_cast/2, handle_info/2,
|
|
|
terminate/2, code_change/3]).
|
|
|
|
|
|
-record(state, {id, statsfun}).
|
|
|
|
|
|
--define(CM_POOL, cm_pool).
|
|
|
+-define(CM_POOL, ?MODULE).
|
|
|
|
|
|
%%%=============================================================================
|
|
|
%%% API
|