fix inetd

This commit is contained in:
anlicheng 2025-05-19 23:59:09 +08:00
parent 040198e8d5
commit 136b8bc627

View File

@ -120,9 +120,9 @@ handle_info({'EXIT', TaskPid, Reason}, State = #state{task_map = TaskMap}) ->
Error -> Error ->
lager:notice("[efka_inetd] service_id: ~p, task_pid: ~p, exit with error: ~p", [ServiceId, TaskPid, Error]), lager:notice("[efka_inetd] service_id: ~p, task_pid: ~p, exit with error: ~p", [ServiceId, TaskPid, Error]),
efka_inetd_task_log:stash(TaskId, <<"task aborted">>), efka_inetd_task_log:stash(TaskId, <<"task aborted">>),
efka_inetd_task_log:flush(TaskId), efka_inetd_task_log:flush(TaskId)
{noreply, State#state{task_map = NTaskMap}} end,
end {noreply, State#state{task_map = NTaskMap}}
end; end;
handle_info(_Info, State = #state{}) -> handle_info(_Info, State = #state{}) ->