summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJules Laplace <julescarbon@gmail.com>2018-05-20 19:21:07 +0200
committerJules Laplace <julescarbon@gmail.com>2018-05-20 19:21:07 +0200
commitd6e7b1e32b9395ae8699461ba7c58059e5712d49 (patch)
tree9659ff6cc5082d89a6c5808e42b659a7bfd48db6
parent0691bca6d1f59a61ac30938363e437da034e9c47 (diff)
sick its working
-rw-r--r--app/relay/index.js3
-rw-r--r--app/server/index.js1
-rw-r--r--rpc/rpc.py2
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)
})
diff --git a/rpc/rpc.py b/rpc/rpc.py
index a375302..957a049 100644
--- a/rpc/rpc.py
+++ b/rpc/rpc.py
@@ -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')