blob_completed before moving to next one

otherwise blob files download to the blobfiles directory, but they are
never recorded in blobs.db
This commit is contained in:
Jack 2016-08-20 23:47:12 -04:00
parent 7a54894015
commit 5022ed2acc

View file

@ -89,6 +89,7 @@ class ReflectorServer(Protocol):
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):