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:33:09 +08:00
parent ff6af0faa3
commit 22b4e9e9de
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/efka/src/efka_inetd.erl
View File

@ -102,11 +102,11 @@ handle_info({'EXIT', TaskPid, Reason}, State = #state{task_map = TaskMap}) ->
case Reason of
normal ->
lager:debug("[efka_inetd] service_id: ~p, task_pid: ~p, exit normal", [ServiceId, TaskPid]),
efka_agent:feedback_phase(TaskId, efka_util:timestamp(), <<"task completed">>, 1);
efka_agent:feedback_phase(TaskId, efka_util:timestamp(), <<"task completed">>);
Error ->
lager:debug("[efka_inetd] service_id: ~p, task_pid: ~p, exit with error: ~p", [ServiceId, TaskPid, Error]),
%% 下载完整
efka_agent:feedback_phase(TaskId, efka_util:timestamp(), <<"task aborted">>, 0),
efka_agent:feedback_phase(TaskId, efka_util:timestamp(), <<"task aborted">>),
{noreply, State#state{task_map = NTaskMap}}
end
end;

4
apps/efka/src/efka_micro_service_sup.erl
View File

@ -50,7 +50,7 @@ init([]) ->
MicroServices = micro_service_model:get_all_services(),
Specs = lists:map(fun(Service) -> child_spec(Service) end, MicroServices),
Spec1 = child_spec(#micro_service{
micro_service_model:insert(#micro_service{
service_id = <<"test1234">>,
%% 工作目录
root_dir = <<"/usr/local/code/tmp/test/">>,
@ -60,6 +60,8 @@ init([]) ->
status = 1
}),
Spec1 = child_spec(<<"test1234">>),
{ok, {SupFlags, [Spec1|Specs]}}.
%%%===================================================================