diff options
Diffstat (limited to 'rpc/rpc.py')
| -rw-r--r-- | rpc/rpc.py | 4 |
1 files changed, 3 insertions, 1 deletions
@@ -44,8 +44,8 @@ class CortexRPC(object): 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.fetching = True + for f in onlyfiles: gevent.sleep(1/30) output = BytesIO() @@ -55,6 +55,8 @@ class CortexRPC(object): frame = output.getvalue() output.close() self.send_frame(f.replace('png', 'jpg'), frame) + + self.fetching = False return "ok" def send_param(self, key, value): |
