diff options
| author | Jules Laplace <julescarbon@gmail.com> | 2018-05-26 15:58:21 +0200 |
|---|---|---|
| committer | Jules Laplace <julescarbon@gmail.com> | 2018-05-26 15:58:21 +0200 |
| commit | 96e19464f98b868bd93b76ac842ec5b32a17cfb6 (patch) | |
| tree | a232cfecd631d49fae8d1402371a284296aeec87 /rpc/rpc.py | |
| parent | 28f4bd59314df8162548a1100b280bd256436eaa (diff) | |
means to run remote commands and get output
Diffstat (limited to 'rpc/rpc.py')
| -rw-r--r-- | rpc/rpc.py | 29 |
1 files changed, 0 insertions, 29 deletions
@@ -15,7 +15,6 @@ class CortexRPC(object): self._get_fn = get_fn self._set_fn = set_fn self._cmd_fn = cmd_fn - self.working = False self.connect(ready_fn) def connect(self, ready_fn): @@ -38,34 +37,6 @@ class CortexRPC(object): except zerorpc.TimeoutExpired: print('RPC timeout :(') return val - # print('defer sending a file...') - # gevent.sleep(1) - # return self.get_last_frame() - - """ - def get_last_frame(self): - if self.working: - self.working = False - return 'working' - path = os.getenv('TEST_FRAMES_PATH') - onlyfiles = sorted([f for f in os.listdir(path) if os.path.isfile(os.path.join(path, f))]) - self.working = True - - for f in onlyfiles: - gevent.sleep(1/10) - if not self.working: - return - output = BytesIO() - im = Image.open(os.path.join(path, f)) - # im = im.convert('RGB') - im.save(output, format='JPEG') - frame = output.getvalue() - output.close() - self.send_frame(f.replace('png', 'jpg'), frame) - - self.working = False - return 'ok' - """ def send_command(self, cmd, payload): print('your command, {}: {}'.format(cmd, payload)) |
