anlicheng/ekfa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
anlicheng 2025-04-22 15:58:58 +08:00
parent eb3c9eb19d
commit f947453e59
1 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
apps/efka/src/efka_transport.erl
View File

@ -69,12 +69,9 @@ init([ParentPid]) ->
{active, true},
{verify, verify_none}
],
case ssl:connect(Host, Port, SslOptions, 5000) of
{ok, Socket} ->
{ok, #state{parent_pid = ParentPid, host = Host, port = Port, socket = Socket}};
{error, Reason} ->
{stop, Reason}
end.
{ok, Socket} = ssl:connect(Host, Port, SslOptions, 5000),
{ok, #state{parent_pid = ParentPid, host = Host, port = Port, socket = Socket}}.
%% @private
%% @doc Handling call messages
@ -145,12 +142,10 @@ handle_info({ssl, Socket, <<?PACKET_PUBLISH, PacketId:32, Msg/binary>>}, State =
{noreply, State#state{}};
handle_info({ssl_error, Socket, Reason}, State = #state{socket = Socket}) ->
lager:warning("[efka_agent] socket close with reason: ~p", [Reason]),
{stop, transport_error, State};
{stop, Reason, State};
handle_info({ssl_closed, Socket}, State = #state{socket = Socket}) ->
lager:warning("[efka_agent] socket closed"),
{stop, transport_closed, State};
{stop, ssl_closed, State};
handle_info(_Info, State = #state{}) ->
{noreply, State}.