make sure to close blob files when connection is lost on reflector client

This commit is contained in:
Kay Kurokawa 2017-10-02 15:48:47 -04:00
parent d33ebd60c4
commit 6268e43509

View file

@ -71,6 +71,9 @@ class EncryptedFileReflectorClient(Protocol):
d.addErrback(self.response_failure_handler)
def connectionLost(self, reason):
# make sure blob file readers get closed
self.set_not_uploading()
if reason.check(error.ConnectionDone):
if not self.needed_blobs:
log.info("Reflector has all blobs for %s (%s)",