summaryrefslogtreecommitdiff
path: root/rpc
diff options
context:
space:
mode:
authorJules Laplace <julescarbon@gmail.com>2018-05-26 15:58:21 +0200
committerJules Laplace <julescarbon@gmail.com>2018-05-26 15:58:21 +0200
commit96e19464f98b868bd93b76ac842ec5b32a17cfb6 (patch)
treea232cfecd631d49fae8d1402371a284296aeec87 /rpc
parent28f4bd59314df8162548a1100b280bd256436eaa (diff)
means to run remote commands and get output
Diffstat (limited to 'rpc')
-rw-r--r--rpc/rpc.py29
1 files changed, 0 insertions, 29 deletions
diff --git a/rpc/rpc.py b/rpc/rpc.py
index 4df4a5b..a00fd2c 100644
--- a/rpc/rpc.py
+++ b/rpc/rpc.py
@@ -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))