Skip to content

Commit 13aa6e0

Browse files
committed
Increase mongoose_wpool_mgr:start and stop timeout to 30 seconds
Use mongoose_task:run_tracked to print the wpool start progress
1 parent 0dcad73 commit 13aa6e0

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

src/wpool/mongoose_wpool_mgr.erl

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -71,10 +71,10 @@ start_link(Type) ->
7171

7272
start(Type, Host, Tag, PoolOpts, ConnOpts) ->
7373
ok = ensure_started(Type),
74-
gen_server:call(name(Type), {start_pool, Host, Tag, PoolOpts, ConnOpts}).
74+
gen_server:call(name(Type), {start_pool, Host, Tag, PoolOpts, ConnOpts}, timer:seconds(30)).
7575

7676
stop(Type, Host, Tag) ->
77-
gen_server:call(name(Type), {stop_pool, Host, Tag}).
77+
gen_server:call(name(Type), {stop_pool, Host, Tag}, timer:seconds(30)).
7878

7979
-spec name(mongoose_wpool:pool_type()) -> mongoose_wpool:proc_name().
8080
name(Type) ->
@@ -93,7 +93,11 @@ handle_call({start_pool, Host, Tag, WpoolOpts, ConnOpts}, _From,
9393
#state{type = Type, pools = Pools, monitors = Monitors} = State) ->
9494
?LOG_INFO(#{what => pool_starting, pool_type => Type, tag => Tag, server => Host,
9595
pool_opts => WpoolOpts}),
96-
case mongoose_wpool:call_start_callback(Type, [Host, Tag, WpoolOpts, ConnOpts]) of
96+
F = fun() ->
97+
mongoose_wpool:call_start_callback(Type, [Host, Tag, WpoolOpts, ConnOpts])
98+
end,
99+
Info = #{task => start_pool, tag => Tag},
100+
case mongoose_task:run_tracked(Info, F) of
97101
{_, Pid} = OkReply when is_pid(Pid) ->
98102
Ref = erlang:monitor(process, Pid),
99103
Key = {Type, Host, Tag},

0 commit comments

Comments
 (0)