From 03cb68127c7d52642b164a845989f82ab037de7c Mon Sep 17 00:00:00 2001 From: Jules Laplace Date: Thu, 28 Jun 2018 19:25:00 +0200 Subject: runner --- app/relay/runner.js | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/app/relay/runner.js b/app/relay/runner.js index e0e1a29..c7c3166 100644 --- a/app/relay/runner.js +++ b/app/relay/runner.js @@ -51,10 +51,12 @@ function serialize_task(t){ function clear_task(is_gpu, task){ if (is_gpu) { if (state.current_gpu_task.task && state.current_gpu_task.task.uuid === task.uuid) { + state.current_gpu_task.processor = null state.current_gpu_task = idle_state } } else { if (state.current_cpu_task.task && state.current_cpu_task.task.uuid === task.uuid) { + state.current_gpu_task.processor = null state.current_cpu_task = idle_state } } @@ -459,14 +461,23 @@ export function terminate(processor, sigkill=false){ console.log('kill pid', processor.subprocess.pid) processor.task.cancelled = true if (sigkill) { - kill(processor.subprocess.pid, 'SIGKILL') + kill(processor.subprocess.pid, 'SIGKILL', err => { + if (err) { + console.error(err) + } + else { + console.log('process killed via SIGKILL -', processor.subprocess) + processor.subprocess = null + } + }) } else { kill(processor.subprocess.pid, 'SIGTERM', err => { if (err) { console.log(err) } else { - console.log('process killed?', processor.subprocess) + console.log('process killed via SIGTERM -', processor.subprocess) + processor.subprocess = null } }) } -- cgit v1.2.3-70-g09d2