From 0058334106f870012b2bbc6a79e4eb6b9dbb03f5 Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Sun, 24 Dec 2017 20:24:35 -0300 Subject: [bug] add code to obey protocol pause and stop Stream production wasn't pausing or stopping as asked by protocol. --- src/leap/soledad/client/_db/blobs/upstream_producer.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/leap/soledad/client/_db/blobs/upstream_producer.py b/src/leap/soledad/client/_db/blobs/upstream_producer.py index 5c8f0530..cf69e966 100644 --- a/src/leap/soledad/client/_db/blobs/upstream_producer.py +++ b/src/leap/soledad/client/_db/blobs/upstream_producer.py @@ -67,6 +67,11 @@ class BlobsUpstreamProducer(object): """ consumer.write(json.dumps(self.blobs_lengths) + '\n') for blob_id, _ in self.blobs_lengths: + if self.stop: + break + if self.pause: + yield self.sleep(0.001) + continue blob_fd = yield self.db.get(blob_id, namespace=self.namespace) doc_info = DocInfo(blob_id, FIXED_REV) crypter = BlobEncryptor(doc_info, blob_fd, secret=self.secret, -- cgit v1.2.3