From 8db7cb5b11f90af32b79c67dc0b3c1f1df1fd750 Mon Sep 17 00:00:00 2001 From: anlicheng <244108715@qq.com> Date: Tue, 21 Apr 2026 17:21:06 +0800 Subject: [PATCH] =?UTF-8?q?=E9=80=BB=E8=BE=91=E5=AF=B9=E9=BD=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/transport/efka_client.erl | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/transport/efka_client.erl b/src/transport/efka_client.erl index 8471a36..a707b42 100644 --- a/src/transport/efka_client.erl +++ b/src/transport/efka_client.erl @@ -126,7 +126,8 @@ handle_event(info, {timeout, _, create_transport}, ?STATE_DISCONNECTED, State = case connect_socket() of {ok, Socket} -> AuthPacket = auth_packet(PacketId), - send_packet(Socket, AuthPacket), + AuthRequestFrame = <>, + send_packet(Socket, AuthRequestFrame), {next_state, ?STATE_AUTH, State#state{socket = Socket, auth_packet_id = PacketId, next_packet_id = PacketId + 1}, [{state_timeout, 5000, auth_timeout}]}; {error, Reason} -> @@ -225,7 +226,8 @@ handle_event(internal, {decoded_cast, #'CastFrame'{body = {command, #'Command'{c {keep_state, State}; {1, _} -> AuthPacket = auth_packet(PacketId), - send_packet(Socket, AuthPacket), + AuthRequestFrame = <>, + send_packet(Socket, AuthRequestFrame), {next_state, ?STATE_AUTH, State#state{auth_packet_id = PacketId, next_packet_id = PacketId + 1}, [{state_timeout, 5000, auth_timeout}]}; {0, _} ->