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 18:12:16 +08:00
parent d544c04709
commit a0724db88c
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -93,7 +93,7 @@ handle_event(info, {connect_reply, Reply}, ?STATE_CONNECTING, State = #state{tra
{next_state, ?STATE_AUTH, State}; {next_state, ?STATE_AUTH, State};
{error, Reason} -> {error, Reason} ->
lager:debug("[efka_agent] connect failed, error: ~p, pid: ~p", [Reason, TransportPid]), 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} {next_state, ?STATE_DENIED, State}
end; end;

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

@ -38,6 +38,7 @@
auth_request(Pid, Timeout) when is_pid(Pid), is_integer(Timeout) -> auth_request(Pid, Timeout) when is_pid(Pid), is_integer(Timeout) ->
gen_server:cast(Pid, {auth_request, Timeout}). gen_server:cast(Pid, {auth_request, Timeout}).
-spec connect(Pid :: pid()) -> no_return().
connect(Pid) when is_pid(Pid) -> connect(Pid) when is_pid(Pid) ->
gen_server:cast(Pid, connect). 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}} {noreply, State#state{packet_id = PacketId + 1}}
after Timeout -> after Timeout ->
ParentPid ! {auth_reply, {error, timeout}}, ParentPid ! {auth_reply, {error, timeout}},
{stop, normal, State} {noreply, State#state{packet_id = PacketId + 1}}
end; end;
handle_cast({send, Method, Packet}, State = #state{socket = Socket}) -> handle_cast({send, Method, Packet}, State = #state{socket = Socket}) ->