diff --git a/apps/efka/src/efka_inetd.erl b/apps/efka/src/efka_inetd.erl index 6816b50..ea570a0 100644 --- a/apps/efka/src/efka_inetd.erl +++ b/apps/efka/src/efka_inetd.erl @@ -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; diff --git a/apps/efka/src/efka_micro_service_sup.erl b/apps/efka/src/efka_micro_service_sup.erl index 159130f..c4642a8 100644 --- a/apps/efka/src/efka_micro_service_sup.erl +++ b/apps/efka/src/efka_micro_service_sup.erl @@ -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]}}. %%%===================================================================