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

fix #11

This commit is contained in:
付强 2019-08-04 19:03:05 +08:00 committed by Shawn
parent 253ffcdb5e
commit 111380bf25
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/ecpool_worker.erl
View File

@ -137,9 +137,11 @@ handle_info(reconnect, State = #state{opts = Opts, on_reconnect = OnReconnect})
case catch connect(State) of case catch connect(State) of
{ok, Client} -> {ok, Client} ->
handle_reconnect(Client, OnReconnect), handle_reconnect(Client, OnReconnect),
{noreply, State#state{client = Client}}; erlang:link(Client),
{noreply, State#state{client = Client, supervisees = [Client]}};
{{ok, Client}, #{supervisees := SupPids} = _SupOpts} -> {{ok, Client}, #{supervisees := SupPids} = _SupOpts} ->
handle_reconnect(Client, OnReconnect), handle_reconnect(Client, OnReconnect),
[erlang:link(P) || P <- SupPids],
{noreply, State#state{client = Client, supervisees = SupPids}}; {noreply, State#state{client = Client, supervisees = SupPids}};
{Err, _Reason} when Err =:= error orelse Err =:= 'EXIT' -> {Err, _Reason} when Err =:= error orelse Err =:= 'EXIT' ->
reconnect(proplists:get_value(auto_reconnect, Opts), State) reconnect(proplists:get_value(auto_reconnect, Opts), State)