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

逻辑对齐

Browse Source
This commit is contained in:
anlicheng 2026-04-21 17:21:06 +08:00
parent 2c66394593
commit 8db7cb5b11
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/transport/efka_client.erl
View File

@ -126,7 +126,8 @@ handle_event(info, {timeout, _, create_transport}, ?STATE_DISCONNECTED, State =
case connect_socket() of case connect_socket() of
{ok, Socket} -> {ok, Socket} ->
AuthPacket = auth_packet(PacketId), AuthPacket = auth_packet(PacketId),
send_packet(Socket, AuthPacket), AuthRequestFrame = <<?FRAME_REQUEST, AuthPacket/binary>>,
send_packet(Socket, AuthRequestFrame),
{next_state, ?STATE_AUTH, State#state{socket = Socket, auth_packet_id = PacketId, next_packet_id = PacketId + 1}, {next_state, ?STATE_AUTH, State#state{socket = Socket, auth_packet_id = PacketId, next_packet_id = PacketId + 1},
[{state_timeout, 5000, auth_timeout}]}; [{state_timeout, 5000, auth_timeout}]};
{error, Reason} -> {error, Reason} ->
@ -225,7 +226,8 @@ handle_event(internal, {decoded_cast, #'CastFrame'{body = {command, #'Command'{c
{keep_state, State}; {keep_state, State};
{1, _} -> {1, _} ->
AuthPacket = auth_packet(PacketId), AuthPacket = auth_packet(PacketId),
send_packet(Socket, AuthPacket), AuthRequestFrame = <<?FRAME_REQUEST, AuthPacket/binary>>,
send_packet(Socket, AuthRequestFrame),
{next_state, ?STATE_AUTH, State#state{auth_packet_id = PacketId, next_packet_id = PacketId + 1}, {next_state, ?STATE_AUTH, State#state{auth_packet_id = PacketId, next_packet_id = PacketId + 1},
[{state_timeout, 5000, auth_timeout}]}; [{state_timeout, 5000, auth_timeout}]};
{0, _} -> {0, _} ->