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

PubSub:init_tabs

This commit is contained in:
Feng 2016-08-08 14:14:54 +08:00
parent b3a48b937f
commit bc72e33056
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/emqttd_pubsub_sup.erl
View File

@ -32,11 +32,10 @@ pubsub_pool() ->
hd([Pid || {pubsub_pool, Pid, _, _} <- supervisor:which_children(?MODULE)]).
init([Env]) ->
{ok, PubSub} = emqttd:conf(pubsub_adapter),
PubSubMFA = {PubSub, start_link, [Env]},
PoolArgs = [pubsub, hash, pool_size(Env), PubSubMFA],
PubSubPoolSup = emqttd_pool_sup:spec(pubsub_pool, PoolArgs),
{ok, { {one_for_all, 10, 3600}, [PubSubPoolSup]} }.
{ok, PubSub} = emqttd:conf(pubsub_adapter), PubSub:init_tabs(),
PoolArgs = [pubsub, hash, pool_size(Env), {PubSub, start_link, [Env]}],
PoolSup = emqttd_pool_sup:spec(pubsub_pool, PoolArgs),
{ok, { {one_for_all, 10, 3600}, [PoolSup]} }.
pool_size(Env) ->
Schedulers = erlang:system_info(schedulers),