try {

if (

managed.process?.exitCode === null &&

managed.process &&

!hasLocalServiceProcessExited(managed.process) &&

(await probeHealth(healthUrl, healthHeaders, signal))

) {

return { release };

});

}

await waitForAbort(managed.starting, signal);

if (!managed.process || managed.process.exitCode !== null) {

if (!managed.process || hasLocalServiceProcessExited(managed.process)) {

release();

return undefined;

}

if (await probeHealth(healthUrl, healthHeaders, signal)) {

return;

}

if (managed.process?.exitCode === null) {

if (managed.process && !hasLocalServiceProcessExited(managed.process)) {

log.info(`restarting unhealthy ${provider} local service`);

await stopManagedProcessForRestart(managed, signal);

}

managed.process = undefined;

managed.lastExit = undefined;

services.delete(key);

if (child && child.exitCode === null) {

if (child && !hasLocalServiceProcessExited(child)) {

log.info(`stopping local model service: reason=${reason}`);

child.kill("SIGTERM");

}

const child = managed.process;

managed.process = undefined;

managed.lastExit = undefined;

if (!child || child.exitCode !== null) {

if (!child || hasLocalServiceProcessExited(child)) {

return;

}

child.kill("SIGTERM");

await waitForChildExit(child, signal, DEFAULT_PROBE_TIMEOUT_MS);

if (child.exitCode === null) {

if (!hasLocalServiceProcessExited(child)) {

child.kill("SIGKILL");

await waitForChildExit(child, signal, DEFAULT_PROBE_TIMEOUT_MS);

}

signal: AbortSignal,

timeoutMs: number,

): Promise<void> {

if (child.exitCode !== null) {

if (hasLocalServiceProcessExited(child)) {

return Promise.resolve();

}

throwIfAborted(signal);

signal.addEventListener("abort", onAbort, { once: true });

});

}

export function hasLocalServiceProcessExited(

child: Pick<ChildProcess, "exitCode" | "signalCode">,

): boolean {

return child.exitCode !== null || child.signalCode !== null;

}