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

fix

Browse Source
This commit is contained in:
anlicheng 2025-05-06 22:23:33 +08:00
parent 54cae14ad4
commit 3797fda241
3 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/efka/src/efka_agent.erl
View File

@ -296,7 +296,7 @@ handle_info({server_push_message, PacketId, <<?METHOD_DEPLOY:8, DeployBin/binary
{noreply, State}; {noreply, State};
%% 参数项目 %% 参数项目
handle_info({server_push_message, PacketId, <<?METHOD_PARAMS:8, ParamsBin/binary>>}, State = #state{transport_pid = TransportPid}) -> handle_info({server_push_message, PacketId, <<?METHOD_PRAMAS:8, ParamsBin/binary>>}, State = #state{transport_pid = TransportPid}) ->
#service_params{service_id = ServiceId, params = Params} = message_pb:decode_msg(ParamsBin, service_params), #service_params{service_id = ServiceId, params = Params} = message_pb:decode_msg(ParamsBin, service_params),
case efka_micro_service:get_pid(ServiceId) of case efka_micro_service:get_pid(ServiceId) of

10
apps/efka/src/efka_micro_service.erl
View File

@ -20,7 +20,7 @@
%% API %% API
-export([start_link/2]). -export([start_link/2]).
-export([get_name/1, get_pid/1, start_service/1, stop_service/1, attach_channel/2]). -export([get_name/1, get_pid/1, start_service/1, stop_service/1, attach_channel/2]).
-export([push_params/2, push_metrics/2, request_arguments/1, request_metrics/1]). -export([push_params/2, push_metrics/2, request_params/1, request_metrics/1]).
-export([metric_data/4, send_event/3, send_ai_event/3]). -export([metric_data/4, send_event/3, send_ai_event/3]).
%% gen_server callbacks %% gen_server callbacks
@ -66,13 +66,13 @@ get_pid(ServiceId) when is_binary(ServiceId) ->
whereis(get_name(ServiceId)). whereis(get_name(ServiceId)).
push_params(Pid, Args) when is_pid(Pid), is_binary(Args) -> push_params(Pid, Args) when is_pid(Pid), is_binary(Args) ->
gen_server:call(Pid, {push_arguments, Args}). gen_server:call(Pid, {push_params, Args}).
push_metrics(Pid, Metrics) when is_pid(Pid), is_binary(Metrics) -> push_metrics(Pid, Metrics) when is_pid(Pid), is_binary(Metrics) ->
gen_server:call(Pid, {push_metrics, Metrics}). gen_server:call(Pid, {push_metrics, Metrics}).
request_arguments(Pid) when is_pid(Pid) -> request_params(Pid) when is_pid(Pid) ->
gen_server:call(Pid, request_arguments). gen_server:call(Pid, request_params).
request_metrics(Pid) when is_pid(Pid) -> request_metrics(Pid) when is_pid(Pid) ->
gen_server:call(Pid, request_metrics). gen_server:call(Pid, request_metrics).
@ -160,7 +160,7 @@ handle_call({attach_channel, ChannelPid}, _From, State = #state{channel_pid = Ol
end; end;
%% 推送配置项目 %% 推送配置项目
handle_call({push_arguments, Args}, _From, State = #state{running_status = ?STATUS_RUNNING, channel_pid = ChannelPid}) -> handle_call({push_params, Args}, _From, State = #state{running_status = ?STATUS_RUNNING, channel_pid = ChannelPid}) ->
case is_pid(ChannelPid) of case is_pid(ChannelPid) of
true -> true ->
ok; ok;

2
apps/efka/src/efka_tcp_channel.erl
View File

@ -147,7 +147,7 @@ handle_info({tcp, Socket, <<PacketId:32, ?PACKET_REGISTER:8, ServiceId/binary>>}
%% 请求参数 %% 请求参数
handle_info({tcp, Socket, <<PacketId:32, ?PACKET_REQUEST_PARAM:8>>}, State = #state{socket = Socket, service_pid = ServicePid, is_registered = true}) -> handle_info({tcp, Socket, <<PacketId:32, ?PACKET_REQUEST_PARAM:8>>}, State = #state{socket = Socket, service_pid = ServicePid, is_registered = true}) ->
{ok, Args} = efka_micro_service:request_arguments(ServicePid), {ok, Args} = efka_micro_service:request_params(ServicePid),
ok = gen_tcp:send(Socket, <<PacketId:32, ?PACKET_RESPONSE:8, Args/binary>>), ok = gen_tcp:send(Socket, <<PacketId:32, ?PACKET_RESPONSE:8, Args/binary>>),
{noreply, State}; {noreply, State};