From cc03613a72db9fe10f43de7f80ba17e218299986 Mon Sep 17 00:00:00 2001 From: anlicheng <244108715@qq.com> Date: Fri, 9 May 2025 17:43:29 +0800 Subject: [PATCH] fix --- apps/efka/src/efka_agent.erl | 16 +--------------- 1 file changed, 1 insertion(+), 15 deletions(-) diff --git a/apps/efka/src/efka_agent.erl b/apps/efka/src/efka_agent.erl index ce36daf..8d03407 100644 --- a/apps/efka/src/efka_agent.erl +++ b/apps/efka/src/efka_agent.erl @@ -16,7 +16,7 @@ %% API -export([start_link/0]). --export([metric_data/3, event/3, ping/13, feedback_phase/3]). +-export([metric_data/3, event/3, ping/13]). %% gen_server callbacks -export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2, code_change/3]). @@ -56,10 +56,6 @@ event(ServiceId, EventType, Params) when is_binary(ServiceId), is_integer(EventT ping(AdCode, BootTime, Province, City, EfkaVersion, KernelArch, Ips, CpuCore, CpuLoad, CpuTemperature, Disk, Memory, Interfaces) -> gen_server:cast(?SERVER, {ping, AdCode, BootTime, Province, City, EfkaVersion, KernelArch, Ips, CpuCore, CpuLoad, CpuTemperature, Disk, Memory, Interfaces}). --spec feedback_phase(TaskId :: integer(), Timestamp :: integer(), Phase :: binary()) -> no_return(). -feedback_phase(TaskId, Timestamp, Phase) when is_integer(TaskId), is_integer(Timestamp), is_binary(Phase) -> - gen_server:cast(?SERVER, {feedback_phase, TaskId, Timestamp, Phase}). - %% @doc Spawns the server and registers the local name (unique) -spec(start_link() -> {ok, Pid :: pid()} | ignore | {error, Reason :: term()}). @@ -122,16 +118,6 @@ handle_cast({event, ServiceId, EventType, Params}, State) -> {noreply, State}; -handle_cast({feedback_phase, TaskId, Timestamp, Phase}, State) -> - PhasePacket = message_pb:encode_msg(#feedback_phase{ - task_id = TaskId, - timestamp = Timestamp, - phase = Phase - }), - safe_send(?METHOD_PHASE, PhasePacket, State), - - {noreply, State}; - %% 处理ping消息 handle_cast({ping, AdCode, BootTime, Province, City, EfkaVersion, KernelArch, Ips, CpuCore, CpuLoad, CpuTemperature, Disk, Memory, Interfaces}, State = #state{status = Status, transport_pid = TransportPid}) ->