From 143829d73016c4a53349d6eb5ec32469f96c1dba Mon Sep 17 00:00:00 2001
From: anlicheng <244108715@qq.com>
Date: Wed, 7 May 2025 11:38:49 +0800
Subject: [PATCH] fix

---
 apps/efka/src/efka_agent.erl | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/apps/efka/src/efka_agent.erl b/apps/efka/src/efka_agent.erl
index 3086500..a925b21 100644
--- a/apps/efka/src/efka_agent.erl
+++ b/apps/efka/src/efka_agent.erl
@@ -318,7 +318,7 @@ handle_info({server_push_message, PacketId, <<?METHOD_PRAMAS:8, ParamsBin/binary
     {noreply, State};
 
 %% 采集项目
-handle_info({server_push_message, PacketId, <<?METHOD_METRICS:8, MetricsBin/binary>>}, State = #state{transport_pid = TransportPid, inflight = Inflight}) ->
+handle_info({server_push_message, PacketId, <<?METHOD_METRICS:8, MetricsBin/binary>>}, State = #state{inflight = Inflight}) ->
     #service_metrics{service_id = ServiceId, metrics = Metrics, timeout = Timeout} = message_pb:decode_msg(MetricsBin, service_metrics),
 
     case efka_micro_service:get_pid(ServiceId) of
@@ -327,11 +327,16 @@ handle_info({server_push_message, PacketId, <<?METHOD_METRICS:8, MetricsBin/bina
                 code = 0,
                 message = <<"service not run">>
             },
-            efka_transport:response(TransportPid, PacketId, message_pb:encode_msg(Reply)),
+            safe_response(PacketId, message_pb:encode_msg(Reply), State),
+
             {noreply, State};
         ServicePid when is_pid(ServicePid) ->
             Ref = make_ref(),
             efka_micro_service:push_metrics(ServicePid, Ref, Metrics),
+
+            %% 处理超时逻辑
+            erlang:start_timer(Timeout * 1000, self(), {request_timeout, Ref}),
+
             {noreply, State#state{inflight = maps:put(Ref, PacketId, Inflight)}}
     end;