From 64f62fa0ce5095a75f77792daee2dc646bfea524 Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Tue, 4 Dec 2018 23:22:39 +0800 Subject: [PATCH] Make some processes hibernate after 1s. --- src/emqx_broker.erl | 2 +- src/emqx_hooks.erl | 2 +- src/emqx_pool.erl | 3 ++- src/emqx_router.erl | 2 +- 4 files changed, 5 insertions(+), 4 deletions(-) diff --git a/src/emqx_broker.erl b/src/emqx_broker.erl index ca4a86c87..b816a0a69 100644 --- a/src/emqx_broker.erl +++ b/src/emqx_broker.erl @@ -56,7 +56,7 @@ -spec(start_link(atom(), pos_integer()) -> {ok, pid()} | ignore | {error, term()}). start_link(Pool, Id) -> gen_server:start_link({local, emqx_misc:proc_name(?MODULE, Id)}, ?MODULE, - [Pool, Id], [{hibernate_after, 2000}]). + [Pool, Id], [{hibernate_after, 1000}]). %%------------------------------------------------------------------------------ %% Subscribe diff --git a/src/emqx_hooks.erl b/src/emqx_hooks.erl index 073c12870..b10445742 100644 --- a/src/emqx_hooks.erl +++ b/src/emqx_hooks.erl @@ -42,7 +42,7 @@ -spec(start_link() -> emqx_types:startlink_ret()). start_link() -> - gen_server:start_link({local, ?SERVER}, ?MODULE, [], [{hibernate_after, 60000}]). + gen_server:start_link({local, ?SERVER}, ?MODULE, [], [{hibernate_after, 1000}]). -spec(stop() -> ok). stop() -> diff --git a/src/emqx_pool.erl b/src/emqx_pool.erl index 762f5dc6d..7b12bea69 100644 --- a/src/emqx_pool.erl +++ b/src/emqx_pool.erl @@ -35,7 +35,8 @@ start_link() -> %% @doc Start pool. -spec(start_link(atom(), pos_integer()) -> emqx_types:startlink_ret()). start_link(Pool, Id) -> - gen_server:start_link({local, emqx_misc:proc_name(?MODULE, Id)}, ?MODULE, [Pool, Id], []). + gen_server:start_link({local, emqx_misc:proc_name(?MODULE, Id)}, + ?MODULE, [Pool, Id], [{hibernate_after, 1000}]). %% @doc Submit work to the pool. -spec(submit(task()) -> any()). diff --git a/src/emqx_router.erl b/src/emqx_router.erl index 941c004f7..e513d041d 100644 --- a/src/emqx_router.erl +++ b/src/emqx_router.erl @@ -68,7 +68,7 @@ mnesia(copy) -> -spec(start_link(atom(), pos_integer()) -> {ok, pid()} | ignore | {error, term()}). start_link(Pool, Id) -> gen_server:start_link({local, emqx_misc:proc_name(?MODULE, Id)}, - ?MODULE, [Pool, Id], [{hibernate_after, 2000}]). + ?MODULE, [Pool, Id], [{hibernate_after, 1000}]). %%------------------------------------------------------------------------------ %% Route APIs