From a0724db88c7337911aa0cbe43057b49836cd72c2 Mon Sep 17 00:00:00 2001 From: anlicheng <244108715@qq.com> Date: Tue, 29 Apr 2025 18:12:16 +0800 Subject: [PATCH] fix --- apps/efka/src/efka_agent.erl | 2 +- apps/efka/src/efka_transport.erl | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/apps/efka/src/efka_agent.erl b/apps/efka/src/efka_agent.erl index 4770a5a..3831b8f 100644 --- a/apps/efka/src/efka_agent.erl +++ b/apps/efka/src/efka_agent.erl @@ -93,7 +93,7 @@ handle_event(info, {connect_reply, Reply}, ?STATE_CONNECTING, State = #state{tra {next_state, ?STATE_AUTH, State}; {error, Reason} -> lager:debug("[efka_agent] connect failed, error: ~p, pid: ~p", [Reason, TransportPid]), - % efka_transport:stop(TransportPid), + efka_transport:stop(TransportPid), {next_state, ?STATE_DENIED, State} end; diff --git a/apps/efka/src/efka_transport.erl b/apps/efka/src/efka_transport.erl index 433ab7a..5c1e1e8 100644 --- a/apps/efka/src/efka_transport.erl +++ b/apps/efka/src/efka_transport.erl @@ -38,6 +38,7 @@ auth_request(Pid, Timeout) when is_pid(Pid), is_integer(Timeout) -> gen_server:cast(Pid, {auth_request, Timeout}). +-spec connect(Pid :: pid()) -> no_return(). connect(Pid) when is_pid(Pid) -> gen_server:cast(Pid, connect). @@ -128,7 +129,7 @@ handle_cast({auth_request, Timeout}, State = #state{parent_pid = ParentPid, sock {noreply, State#state{packet_id = PacketId + 1}} after Timeout -> ParentPid ! {auth_reply, {error, timeout}}, - {stop, normal, State} + {noreply, State#state{packet_id = PacketId + 1}} end; handle_cast({send, Method, Packet}, State = #state{socket = Socket}) ->