summaryrefslogtreecommitdiff
path: root/rpc/rpc.py
diff options
context:
space:
mode:
Diffstat (limited to 'rpc/rpc.py')
-rw-r--r--rpc/rpc.py4
1 files changed, 3 insertions, 1 deletions
diff --git a/rpc/rpc.py b/rpc/rpc.py
index 4e87263..a375302 100644
--- a/rpc/rpc.py
+++ b/rpc/rpc.py
@@ -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):