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

Format code

This commit is contained in:
Feng Lee 2019-08-26 14:21:33 +08:00
parent 31e26ec5df
commit e457b28fdd
3 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/ecpool_pool.erl
View File

@ -36,9 +36,9 @@
-record(state, {name, size, type}). -record(state, {name, size, type}).
%%------------------------------------------------------------------------------ %%--------------------------------------------------------------------
%% API %% API
%%------------------------------------------------------------------------------ %%--------------------------------------------------------------------
-spec(start_link(ecpool:pool_name(), list(ecpool:option())) -spec(start_link(ecpool:pool_name(), list(ecpool:option()))
-> {ok, pid()} | {error, term()}). -> {ok, pid()} | {error, term()}).
@ -49,9 +49,9 @@ start_link(Pool, Opts) ->
info(Pid) -> info(Pid) ->
gen_server:call(Pid, info). gen_server:call(Pid, info).
%%------------------------------------------------------------------------------ %%--------------------------------------------------------------------
%% gen_server callbacks %% gen_server callbacks
%%------------------------------------------------------------------------------ %%--------------------------------------------------------------------
init([Pool, Opts]) -> init([Pool, Opts]) ->
Schedulers = erlang:system_info(schedulers), Schedulers = erlang:system_info(schedulers),

8
src/ecpool_sup.erl
View File

@ -36,9 +36,9 @@
start_link() -> start_link() ->
supervisor:start_link({local, ?MODULE}, ?MODULE, []). supervisor:start_link({local, ?MODULE}, ?MODULE, []).
%%------------------------------------------------------------------------------ %%--------------------------------------------------------------------
%% Start/Stop a pool %% Start/Stop a pool
%%------------------------------------------------------------------------------ %%--------------------------------------------------------------------
%% @doc Start a pool. %% @doc Start a pool.
-spec(start_pool(atom(), atom(), list(tuple())) -> {ok, pid()} | {error, term()}). -spec(start_pool(atom(), atom(), list(tuple())) -> {ok, pid()} | {error, term()}).
@ -71,9 +71,9 @@ pools() ->
[{Pool, Pid} || {{pool_sup, Pool}, Pid, supervisor, _} [{Pool, Pid} || {{pool_sup, Pool}, Pid, supervisor, _}
<- supervisor:which_children(?MODULE)]. <- supervisor:which_children(?MODULE)].
%%------------------------------------------------------------------------------ %%--------------------------------------------------------------------
%% Supervisor callbacks %% Supervisor callbacks
%%------------------------------------------------------------------------------ %%--------------------------------------------------------------------
init([]) -> init([]) ->
{ok, { {one_for_one, 10, 100}, []} }. {ok, { {one_for_one, 10, 100}, []} }.

18
src/ecpool_worker.erl
View File

@ -34,9 +34,9 @@
-record(state, {pool, id, client, mod, on_reconnect, opts}). -record(state, {pool, id, client, mod, on_reconnect, opts}).
%%------------------------------------------------------------------------------ %%--------------------------------------------------------------------
%% Callback %% Callback
%%------------------------------------------------------------------------------ %%--------------------------------------------------------------------
-ifdef(use_specs). -ifdef(use_specs).
@ -54,9 +54,9 @@ behaviour_info(_Other) ->
-endif. -endif.
%%------------------------------------------------------------------------------ %%--------------------------------------------------------------------
%% API %% API
%%------------------------------------------------------------------------------ %%--------------------------------------------------------------------
%% @doc Start a pool worker. %% @doc Start a pool worker.
-spec(start_link(atom(), pos_integer(), module(), list()) -> -spec(start_link(atom(), pos_integer(), module(), list()) ->
@ -78,9 +78,9 @@ is_connected(Pid) ->
set_reconnect_callback(Pid, OnReconnect) -> set_reconnect_callback(Pid, OnReconnect) ->
gen_server:cast(Pid, {set_reconn_callbk, OnReconnect}). gen_server:cast(Pid, {set_reconn_callbk, OnReconnect}).
%%%============================================================================= %%--------------------------------------------------------------------
%%% gen_server callbacks %% gen_server callbacks
%%%============================================================================= %%--------------------------------------------------------------------
init([Pool, Id, Mod, Opts]) -> init([Pool, Id, Mod, Opts]) ->
process_flag(trap_exit, true), process_flag(trap_exit, true),
@ -148,9 +148,9 @@ terminate(_Reason, #state{pool = Pool, id = Id, opts = Opts}) ->
code_change(_OldVsn, State, _Extra) -> code_change(_OldVsn, State, _Extra) ->
{ok, State}. {ok, State}.
%%------------------------------------------------------------------------------ %%--------------------------------------------------------------------
%% Internal Functions %% Internal Functions
%%------------------------------------------------------------------------------ %%--------------------------------------------------------------------
connect(#state{mod = Mod, opts = Opts}) -> connect(#state{mod = Mod, opts = Opts}) ->
Mod:connect(connopts(Opts, [])). Mod:connect(connopts(Opts, [])).