diff options
| author | Jules Laplace <julescarbon@gmail.com> | 2018-08-30 12:11:46 +0200 |
|---|---|---|
| committer | Jules Laplace <julescarbon@gmail.com> | 2018-08-30 12:11:46 +0200 |
| commit | 948040033bbc089ad9d1e52174415c4c7e1de4be (patch) | |
| tree | e85b427a7c924a2aac65a356b5a0f27e6e821464 /app/relay/remote.js | |
| parent | 9b896ff0e91393e2aab9126b64efcc9c9e00c519 (diff) | |
| parent | 1b2b7f799baff030f9e7da7da8c1e41b8386c72a (diff) | |
Merge branch 'master' of asdf.us:live-cortex
Diffstat (limited to 'app/relay/remote.js')
| -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) |