close blob server transport on sendfile failing

2019-02-01 11:38:10 -05:00 · 2019-02-01 11:38:10 -05:00 · 0a08f445a4
commit 0a08f445a4
parent 3eac99c509
1 changed files with 2 additions and 0 deletions
--- a/lbrynet/blob_exchange/server.py
+++ b/lbrynet/blob_exchange/server.py
@ -61,6 +61,8 @@ class BlobServerProtocol(asyncio.Protocol):
                try:
                    sent = await blob.sendfile(self)
                except (ConnectionResetError, BrokenPipeError, RuntimeError, OSError):
+                    if self.transport:
+                        self.transport.close()
                    return
                log.info("sent %s (%i bytes) to %s:%i", blob.blob_hash[:8], sent, peer_address, peer_port)
        if responses: