diff options
| -rw-r--r-- | app/relay/remote.js | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/app/relay/remote.js b/app/relay/remote.js index 8f72f03..512745f 100644 --- a/app/relay/remote.js +++ b/app/relay/remote.js @@ -29,9 +29,7 @@ remote.on('cmd', (data) => { }) break default: - rpc.invoke('send_command', data.cmd, data.payload || null, (err, res, more) => { - console.log('command:', data.cmd, res) - remote.emit('res', { + rpc.invoke('send_command', data.cmd, data.payload || null, (err, res, more) => { console.log('command:', data.cmd, res) remote.emit('res', { cmd: data.cmd, res: res, }) @@ -65,12 +63,13 @@ remote.on('task', (data) => { queue.remove_task(data.task) break case 'start_queue': - queue = runner.get_queue(data.task) - console.log(queue) - if (! queue.is_active()) { - queue.activate() - runner.start_queue() + if (q.cpu && ! q.cpu.is_active()) { + q.activate() + } + if (q.gpu && ! q.gpu.is_active()) { + q.activate() } + runner.start_queue() break case 'stop_queue': queue = q.get_processor(data.task) |