Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

call blob_completed when is_validated is true

Browse source
This commit is contained in:
Jack 2016-08-18 06:23:27 -04:00
parent c046cd02d5
commit 8e7b8af180
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
lbrynet/reflector/server/server.py
View file

@ -85,11 +85,12 @@ class ReflectorServer(Protocol):
def determine_blob_needed(self, blob): def determine_blob_needed(self, blob):
if blob.is_validated(): if blob.is_validated():
return {'send_blob': False} d = self.blob_manager.blob_completed(blob)
d.addCallback(lambda _: {'send_blob': False})
return d
else: else:
self.incoming_blob = blob self.incoming_blob = blob
self.blob_finished_d, self.blob_write, self.cancel_write = blob.open_for_writing(self.peer) self.blob_finished_d, self.blob_write, self.cancel_write = blob.open_for_writing(self.peer)
self.blob_finished_d.addCallback(lambda _: self.blob_manager.blob_completed(blob))
return {'send_blob': True} return {'send_blob': True}
def close_blob(self): def close_blob(self):