summaryrefslogtreecommitdiff
path: root/src/leap/soledad/client/_db/blobs/__init__.py
diff options
context:
space:
mode:
authordrebs <drebs@leap.se>2017-12-05 11:48:20 -0200
committerdrebs <drebs@leap.se>2017-12-05 11:48:25 -0200
commitd7894eddd3a1c5241c4a79f58c227a7d30610b9a (patch)
treec8282034d62482bd58eecd783f9a17baf0382747 /src/leap/soledad/client/_db/blobs/__init__.py
parent7f2eec3df3ee5e0eecdb25f064353992d1ec2436 (diff)
[bug] transfer maximum allowed number of blobs
-- Closes: #9004
Diffstat (limited to 'src/leap/soledad/client/_db/blobs/__init__.py')
-rw-r--r--src/leap/soledad/client/_db/blobs/__init__.py10
1 files changed, 4 insertions, 6 deletions
diff --git a/src/leap/soledad/client/_db/blobs/__init__.py b/src/leap/soledad/client/_db/blobs/__init__.py
index 86e45381..95814d46 100644
--- a/src/leap/soledad/client/_db/blobs/__init__.py
+++ b/src/leap/soledad/client/_db/blobs/__init__.py
@@ -309,17 +309,15 @@ class BlobManager(BlobsSynchronizer):
yield self.local.update_sync_status(
doc.blob_id, SyncStatus.PENDING_UPLOAD, namespace=namespace,
priority=priority)
- yield self._send(doc.blob_id, namespace, 1, 1)
+ yield self._send(doc.blob_id, namespace)
- def _send(self, blob_id, namespace, i, total):
+ def _send(self, blob_id, namespace):
lock = self.locks[blob_id]
- d = lock.run(self.__send, blob_id, namespace, i, total)
+ d = lock.run(self.__send, blob_id, namespace)
return d
@defer.inlineCallbacks
- def __send(self, blob_id, namespace, i, total):
- logger.info("Sending blob to server (%d/%d): %s"
- % (i, total, blob_id))
+ def __send(self, blob_id, namespace):
# In fact, some kind of pipe is needed here, where each write on db
# handle gets forwarded into a write on the connection handle
fd = yield self.local.get(blob_id, namespace=namespace)