mb/bdmgrdts
1
Fork 0
Code Pull requests Releases Activity

fix looping errors

Browse source
This commit is contained in:
JOLIMAITRE Matthieu 2024-02-03 23:29:39 +01:00
parent 466239d0e6
commit 8aac0b8bde
1 changed files with 11 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

19
instance/src/lib/utils.ts
View file

@ -53,17 +53,20 @@ export function loop_process(
on_start: opts?.on_start ?? async_noop, on_start: opts?.on_start ?? async_noop,
on_stop: opts?.on_stop ?? async_noop, on_stop: opts?.on_stop ?? async_noop,
}; };
const control = {
do_continue: true,
child_process: null as null | Deno.ChildProcess,
};
const kill_sig = channel<"kill">(); const kill_sig = channel<"kill">();
kill_sig.receive().then(() => {
control.do_continue = false;
control.child_process?.kill();
});
async function launch() { async function launch() {
while (true) { while (control.do_continue) {
await events.on_start(); await events.on_start();
const child_process = command.spawn(); control.child_process = command.spawn();
const result = await Promise.any([kill_sig.receive(), child_process.output()]); await control.child_process.output();
if (result === "kill") {
await events.on_stop();
child_process.kill();
break;
}
await events.on_stop(); await events.on_stop();
await sleep(opts?.delay ?? 500); await sleep(opts?.delay ?? 500);
} }