From 0a3c6743543dd3dfcb876f5ce735b72d050e981d Mon Sep 17 00:00:00 2001
From: "jules@lens" <julescarbon@gmail.com>
Date: Wed, 5 Sep 2018 12:00:18 +0200
Subject: remote listener

---
 app/relay/remote.js | 16 +++++++---------
 1 file changed, 7 insertions(+), 9 deletions(-)

(limited to 'app')

diff --git a/app/relay/remote.js b/app/relay/remote.js
index 512745f..6911572 100644
--- a/app/relay/remote.js
+++ b/app/relay/remote.js
@@ -29,7 +29,9 @@ 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,
         })
@@ -63,17 +65,13 @@ remote.on('task', (data) => {
       queue.remove_task(data.task)
       break
     case 'start_queue':
-      if (q.cpu && ! q.cpu.is_active()) {
-        q.activate()
-      }
-      if (q.gpu && ! q.gpu.is_active()) {
-        q.activate()
-      }
+      q.cpu.activate()
+      q.gpu.activate()
       runner.start_queue()
       break
     case 'stop_queue':
-      queue = q.get_processor(data.task)
-      queue && queue.deactivate()
+      q.cpu.deactivate()
+      q.gpu.deactivate()
       break
     case 'list':
       queue = q.get_processor(data.task)
-- 
cgit v1.2.3-70-g09d2