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-07 17:40:41 +08:00
parent 22b4e9e9de
commit 9d4556a97e
1 changed files with 2 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
apps/efka/src/efka_inetd_task.erl
View File

@ -105,16 +105,8 @@ handle_cast(deploy, State = #state{task_id = TaskId, root_dir = RootDir, service
%% 状态： 0: 停止, 1: 运行中
status = 0
}),
%% 正常启动服务
case boot_service(ServiceId) of
{ok, Pid} when is_pid(Pid) ->
efka_agent:feedback_phase(TaskId, efka_util:timestamp(), <<"boot success">>),
{stop, normal, State};
{error, Reason} ->
efka_agent:feedback_phase(TaskId, efka_util:timestamp(), <<"boot failed">>),
{stop, {error, Reason}, State}
end;
efka_agent:feedback_phase(TaskId, efka_util:timestamp(), <<"deploy success">>),
{stop, normal, State};
{error, Reason} ->
efka_agent:feedback_phase(TaskId, efka_util:timestamp(), <<"tar decompression error">>),
{stop, {error, Reason}, State}
@ -238,16 +230,6 @@ check_download_url(Url) when is_list(Url) ->
{error, Reason}
end.
-spec boot_service(ServiceId :: binary()) -> {ok, Pid :: pid()} | {error, Reason :: any()}.
boot_service(ServiceId) ->
%% 正常启动服务
case efka_micro_service:get_pid(ServiceId) of
undefined ->
efka_micro_service_sup:start_service(ServiceId);
Pid ->
{ok, Pid}
end.
%% 解压文件到指定目录
-spec tar_extract(TarFile :: string(), TargetDir :: string()) -> ok | {error, Reason :: term()}.
tar_extract(TarFile, TargetDir) when is_list(TarFile), is_list(TargetDir) ->