Another small fix
This commit is contained in:
@@ -138,6 +138,7 @@ class AIO(asyncio.Protocol):
|
|||||||
else:
|
else:
|
||||||
self.logger.debug("{} chunk complete ({} bytes)".format(self.peer, self.length))
|
self.logger.debug("{} chunk complete ({} bytes)".format(self.peer, self.length))
|
||||||
self.length = None
|
self.length = None
|
||||||
|
self.fsize = 0
|
||||||
|
|
||||||
except (RuntimeError, IndexError, IOError, struct.error) as e:
|
except (RuntimeError, IndexError, IOError, struct.error) as e:
|
||||||
self.logger.warning("{} warning: {}".format(self.peer, e))
|
self.logger.warning("{} warning: {}".format(self.peer, e))
|
||||||
|
|||||||
Reference in New Issue
Block a user