diff options
Diffstat (limited to 'rpc/rpc.py')
| -rw-r--r-- | rpc/rpc.py | 17 |
1 files changed, 10 insertions, 7 deletions
@@ -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...") |