From cb4aa88deaf91be4b9951c446bec37cca3a31e53 Mon Sep 17 00:00:00 2001 From: anlicheng <244108715@qq.com> Date: Fri, 9 May 2025 18:06:54 +0800 Subject: [PATCH] fix --- apps/efka/src/efka_agent.erl | 15 --------------- 1 file changed, 15 deletions(-) diff --git a/apps/efka/src/efka_agent.erl b/apps/efka/src/efka_agent.erl index 3ce6ef0..a4f3cab 100644 --- a/apps/efka/src/efka_agent.erl +++ b/apps/efka/src/efka_agent.erl @@ -233,21 +233,6 @@ handle_info({server_push, PacketId, <>}, State {noreply, State}; -%% 获取task的部署日志 -handle_info({server_push, PacketId, <>}, State = #state{transport_pid = TransportPid}) -> - #deploy{task_id = TaskId, service_id = ServiceId, tar_url = TarUrl} = message_pb:decode_msg(DeployBin, deploy), - - %% 短暂的等待,efka_inetd收到消息后就立即返回了 - Reply = case efka_inetd:deploy(TaskId, ServiceId, TarUrl) of - ok -> - #push_reply{code = 1, message = <<"">>}; - {error, Reason} when is_binary(Reason) -> - #push_reply{code = 0, message = Reason} - end, - is_pid(TransportPid) andalso efka_transport:push_response(TransportPid, PacketId, message_pb:encode_msg(Reply)), - - {noreply, State}; - %% config.json配置信息 handle_info({server_push, PacketId, <>}, State = #state{transport_pid = TransportPid, inflight = Inflight}) -> #service_config{service_id = ServiceId, config_json = ConfigJson, timeout = Timeout} = message_pb:decode_msg(ConfigBin, service_config),