summaryrefslogtreecommitdiff
path: root/rpc/rpc.py
diff options
context:
space:
mode:
authorJules Laplace <julescarbon@gmail.com>2018-05-20 16:03:57 +0200
committerJules Laplace <julescarbon@gmail.com>2018-05-20 16:03:57 +0200
commit109be6a61117844d1156f07fa2c54c62d410a56d (patch)
tree373a8da2ee44a5c6929c528dfdbe4acf613f55ce /rpc/rpc.py
parent20ac24f66da37cc011e2459c5a347a7083c3272c (diff)
relaying my blob from python to browser
Diffstat (limited to 'rpc/rpc.py')
-rw-r--r--rpc/rpc.py17
1 files changed, 10 insertions, 7 deletions
diff --git a/rpc/rpc.py b/rpc/rpc.py
index 19b405d..b6a67cc 100644
--- a/rpc/rpc.py
+++ b/rpc/rpc.py
@@ -30,10 +30,14 @@ class CortexRPC(object):
print("RPC connected...".format(val))
except zerorpc.TimeoutExpired:
print("RPC timeout :(")
- # print("defer sending a file...")
- # gevent.sleep(2)
- # self.send_file("test.png")
- return val
+ # return val
+ print("defer sending a file...")
+ gevent.sleep(1)
+ return self.get_last_frame()
+
+ def get_last_frame(self):
+ self.send_frame("test.png", '01234567' * 8 * 8 * 8 * 8 * 2)
+ return "ok"
def send_param(self, key, value):
print("aloha. {}: {}".format(key, value))
@@ -47,11 +51,10 @@ class CortexRPC(object):
print("Get params call received!")
return "lmao ok"
- def send_frame(self, frame):
+ def send_frame(self, fn, frame):
if self.relay is not None:
print("Sending a frame...")
- frame = '01234567' * 8 * 8 * 8 * 8 * 2
- self.relay.send_frame('frame_00000.png', frame)
+ self.relay.send_frame(fn, frame)
else:
print("Can't send frame, relay not ready...")