diff --git a/lbrynet/blob_exchange/client.py b/lbrynet/blob_exchange/client.py index 4270cbe24..05e0d9d9d 100644 --- a/lbrynet/blob_exchange/client.py +++ b/lbrynet/blob_exchange/client.py @@ -2,6 +2,7 @@ import asyncio import logging import typing import binascii +from lbrynet.error import InvalidBlobHashError, InvalidDataError from lbrynet.blob_exchange.serialization import BlobResponse, BlobRequest if typing.TYPE_CHECKING: from lbrynet.blob.blob_file import BlobFile @@ -111,6 +112,9 @@ class BlobExchangeClientProtocol(asyncio.Protocol): return False, True except asyncio.TimeoutError: return False, False + except (InvalidBlobHashError, InvalidDataError): + log.warning("invalid blob from %s:%i", self.peer_address, self.peer_port) + return False, False finally: await self.close()