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

rename moved_verified_blob as saved_verified_blob

Browse source
This commit is contained in:
Kay Kurokawa 2017-10-06 17:04:27 -04:00
parent d9cc81766d
commit 043758c11f
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
lbrynet/blob/blob_file.py
View file

@ -40,7 +40,7 @@ class BlobFile(object):
self.blob_dir = blob_dir self.blob_dir = blob_dir
self.file_path = os.path.join(blob_dir, self.blob_hash) self.file_path = os.path.join(blob_dir, self.blob_hash)
self.blob_write_lock = defer.DeferredLock() self.blob_write_lock = defer.DeferredLock()
self.moved_verified_blob = False self.saved_verified_blob = False
if os.path.isfile(self.file_path): if os.path.isfile(self.file_path):
self.set_length(os.path.getsize(self.file_path)) self.set_length(os.path.getsize(self.file_path))
# This assumes that the hash of the blob has already been # This assumes that the hash of the blob has already been
@ -92,7 +92,7 @@ class BlobFile(object):
""" """
if not self.writers and not self.readers: if not self.writers and not self.readers:
self._verified = False self._verified = False
self.moved_verified_blob = False self.saved_verified_blob = False
def delete_from_file_system(): def delete_from_file_system():
if os.path.isfile(self.file_path): if os.path.isfile(self.file_path):
@ -225,12 +225,12 @@ class BlobFile(object):
@defer.inlineCallbacks @defer.inlineCallbacks
def _save_verified_blob(self, writer): def _save_verified_blob(self, writer):
if self.moved_verified_blob is False: if self.saved_verified_blob is False:
writer.write_handle.seek(0) writer.write_handle.seek(0)
out_path = os.path.join(self.blob_dir, self.blob_hash) out_path = os.path.join(self.blob_dir, self.blob_hash)
producer = FileBodyProducer(writer.write_handle) producer = FileBodyProducer(writer.write_handle)
yield producer.startProducing(open(out_path, 'wb')) yield producer.startProducing(open(out_path, 'wb'))
self.moved_verified_blob = True self.saved_verified_blob = True
defer.returnValue(True) defer.returnValue(True)
else: else:
raise DownloadCanceledError() raise DownloadCanceledError()