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-08 11:23:39 +08:00
parent e5cf3222df
commit c9a04da151
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -261,7 +261,7 @@ handle_info({server_push_message, PacketId, <<?METHOD_DEPLOY:8, DeployBin/binary
%% config.json配置信息
handle_info({server_push_message, PacketId, <<?METHOD_CONFIG:8, ParamsBin/binary>>}, State = #state{transport_pid = TransportPid, inflight = Inflight}) ->
#service_config{service_id = ServiceId, config_json = ConfigJson, timeout = Timeout} = message_pb:decode_msg(ParamsBin, service_params),
#service_config{service_id = ServiceId, config_json = ConfigJson, timeout = Timeout} = message_pb:decode_msg(ParamsBin, service_config),
case efka_micro_service:get_pid(ServiceId) of
undefined ->

1
apps/efka/src/efka_service_sup.erl
View File

@ -49,6 +49,7 @@ init([]) ->
service_model:insert(#micro_service{
service_id = <<"test1234">>,
tar_url = <<"http://118.178.229.213:3000/anlicheng/ekfa/archive1/main.tar.gz">>,
%% 工作目录
root_dir = <<"/usr/local/code/tmp/test/">>,
params = <<"">>,