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-29 17:47:18 +08:00
parent f9690fc81f
commit f088ae8795
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/efka/src/efka_agent.erl
View File

@ -100,8 +100,8 @@ handle_info({connect_reply, Reply}, State = #state{transport_pid = TransportPid}
efka_transport:auth_request(TransportPid, 5000), efka_transport:auth_request(TransportPid, 5000),
{noreply, State#state{status = ?STATE_AUTH}}; {noreply, State#state{status = ?STATE_AUTH}};
{error, Reason} -> {error, Reason} ->
lager:debug("[efka_agent] connect failed, error: ~p", [Reason]), lager:debug("[efka_agent] connect failed, error: ~p, pid: ~p", [Reason, TransportPid]),
efka_transport:stop(TransportPid), % efka_transport:stop(TransportPid),
{noreply, State#state{status = ?STATE_DENIED}} {noreply, State#state{status = ?STATE_DENIED}}
end; end;

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

@ -174,7 +174,8 @@ handle_info(Info, State = #state{}) ->
%% with Reason. The return value is ignored. %% with Reason. The return value is ignored.
-spec(terminate(Reason :: (normal | shutdown | {shutdown, term()} | term()), -spec(terminate(Reason :: (normal | shutdown | {shutdown, term()} | term()),
State :: #state{}) -> term()). State :: #state{}) -> term()).
terminate(_Reason, _State = #state{}) -> terminate(Reason, _State = #state{}) ->
lager:debug("[efka_transport] terminate with reason: ~p", [Reason]),
ok. ok.
%% @private %% @private