소스 검색

Merge branch 'emqx32' into subscription-sharding

Feng Lee 7 년 전
부모
커밋
fb7b63c59b
3개의 변경된 파일8개의 추가작업 그리고 2개의 파일을 삭제
  1. 5 0
      src/emqx_broker.erl
  2. 1 1
      src/emqx_hooks.erl
  3. 2 1
      src/emqx_pool.erl

+ 5 - 0
src/emqx_broker.erl

@@ -34,6 +34,11 @@
 -export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2,
          code_change/3]).
 
+-ifdef(TEST).
+-compile(export_all).
+-compile(nowarn_export_all).
+-endif.
+
 -define(BROKER, ?MODULE).
 
 %% ETS tables

+ 1 - 1
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() ->

+ 2 - 1
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()).