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

Catch connection exceptions

This commit is contained in:
terry-xiaoyu 2019-08-05 13:41:40 +08:00
parent f7529f4fad
commit faa1d5bf07
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

@ -187,7 +187,7 @@ handle_disconnect(Client, Disconnect) ->
Disconnect(Client). Disconnect(Client).
connect_internal(State) -> connect_internal(State) ->
case connect(State) of try connect(State) of
{ok, Client} when is_pid(Client) -> {ok, Client} when is_pid(Client) ->
erlang:link(Client), erlang:link(Client),
{ok, State#state{client = Client, supervisees = [Client]}}; {ok, State#state{client = Client, supervisees = [Client]}};
@ -196,4 +196,6 @@ connect_internal(State) ->
{ok, State#state{client = Client, supervisees = SupPids}}; {ok, State#state{client = Client, supervisees = SupPids}};
{error, Error} -> {error, Error} ->
{error, Error} {error, Error}
catch
_C:Reason -> {error, Reason}
end. end.