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

Merge branch 'fix-close-writer'

Browse source 
* fix-close-writer:
  fix BlobFile._close_file
This commit is contained in:
Alex Grintsvayg 2017-08-15 12:34:09 -04:00
parent 518146396c 5d24f75ce2
commit 693eb379fd
2 changed files with 8 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
CHANGELOG.md
View file

@ -14,6 +14,12 @@ at anytime.
### Fixed ### Fixed
* *
* Fixed reflector server blocking the `received_blob` reply on the server announcing the blob to the dht
* Fixed non-blocking call in `BlobFile._close_writer`
* Fixed incorrect formatting of "amount" fields
* Fixed handling of SIGINT, SIGTERM.
* Fixed shutdown sequence
* Fix error when resolving an integer
* *
### Deprecated ### Deprecated

3
lbrynet/core/HashBlob.py
View file

@ -273,12 +273,13 @@ class BlobFile(HashBlob):
file_handle.close() file_handle.close()
self.readers -= 1 self.readers -= 1
@defer.inlineCallbacks
def _close_writer(self, writer): def _close_writer(self, writer):
if writer.write_handle is not None: if writer.write_handle is not None:
log.debug("Closing %s", str(self)) log.debug("Closing %s", str(self))
name = writer.write_handle.name name = writer.write_handle.name
writer.write_handle.close() writer.write_handle.close()
threads.deferToThread(os.remove, name) yield threads.deferToThread(os.remove, name)
writer.write_handle = None writer.write_handle = None
def _save_verified_blob(self, writer): def _save_verified_blob(self, writer):