diff options
| author | Jules Laplace <julescarbon@gmail.com> | 2018-05-20 19:21:07 +0200 |
|---|---|---|
| committer | Jules Laplace <julescarbon@gmail.com> | 2018-05-20 19:21:07 +0200 |
| commit | d6e7b1e32b9395ae8699461ba7c58059e5712d49 (patch) | |
| tree | 9659ff6cc5082d89a6c5808e42b659a7bfd48db6 | |
| parent | 0691bca6d1f59a61ac30938363e437da034e9c47 (diff) | |
sick its working
| -rw-r--r-- | app/relay/index.js | 3 | ||||
| -rw-r--r-- | app/server/index.js | 1 | ||||
| -rw-r--r-- | rpc/rpc.py | 2 |
3 files changed, 2 insertions, 4 deletions
diff --git a/app/relay/index.js b/app/relay/index.js index 16bb988..61d3c68 100644 --- a/app/relay/index.js +++ b/app/relay/index.js @@ -5,7 +5,6 @@ const zerorpc = require('zerorpc') const Readable = require('stream').Readable; let remote = io.connect(process.env.SOCKETIO_REMOTE); - remote.on('cmd', (data) => { console.log('cmd data', data) if (! data.cmd) { @@ -50,7 +49,7 @@ let relay = new zerorpc.Server({ send_frame: function (fn, frame, reply) { reply() - console.log('got frame, ' + frame.length + ' bytes') + // console.log('got frame, ' + frame.length + ' bytes') remote.emit('frame', { fn: fn, frame: frame }) } }) diff --git a/app/server/index.js b/app/server/index.js index e561f57..69bbfc2 100644 --- a/app/server/index.js +++ b/app/server/index.js @@ -38,7 +38,6 @@ function bind_relay(socket) { }) socket.on('frame', (data) => { - console.log('got frame') client.volatile.emit('frame', data) }) @@ -47,7 +47,7 @@ class CortexRPC(object): self.fetching = True for f in onlyfiles: - gevent.sleep(1/30) + gevent.sleep(1/10) output = BytesIO() im = Image.open(os.path.join(path, f)) # im = im.convert('RGB') |
