Bugfix for handling a RPC goodbye header
This commit is contained in:
parent
5af5df69d0
commit
3ce46291b3
@ -131,7 +131,7 @@ class PacketStream(object):
|
|||||||
async def _read(self):
|
async def _read(self):
|
||||||
try:
|
try:
|
||||||
header = await self.connection.read()
|
header = await self.connection.read()
|
||||||
if not header:
|
if not header or header == b'\x00' * 9:
|
||||||
return
|
return
|
||||||
flags, length, req = struct.unpack('>BIi', header)
|
flags, length, req = struct.unpack('>BIi', header)
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user