mirror of
https://github.com/solero/houdini.git
synced 2024-11-25 15:07:24 +00:00
Call _client_disconnected
method immediately when close()
is called
This commit is contained in:
parent
85726627b1
commit
82a3753d0d
@ -87,6 +87,8 @@ class Spheniscidae:
|
|||||||
async def close(self):
|
async def close(self):
|
||||||
self.__writer.close()
|
self.__writer.close()
|
||||||
|
|
||||||
|
await self._client_disconnected()
|
||||||
|
|
||||||
async def __handle_xt_data(self, data):
|
async def __handle_xt_data(self, data):
|
||||||
self.logger.debug(f'Received XT data: {data}')
|
self.logger.debug(f'Received XT data: {data}')
|
||||||
parsed_data = data.split('%')[1:-1]
|
parsed_data = data.split('%')[1:-1]
|
||||||
@ -186,7 +188,8 @@ class Spheniscidae:
|
|||||||
except BaseException as e:
|
except BaseException as e:
|
||||||
self.logger.exception(e.__traceback__)
|
self.logger.exception(e.__traceback__)
|
||||||
|
|
||||||
await self._client_disconnected()
|
if self.peer_name in self.server.peers_by_ip:
|
||||||
|
await self._client_disconnected()
|
||||||
|
|
||||||
def __repr__(self):
|
def __repr__(self):
|
||||||
return f'<Spheniscidae {self.peer_name}>'
|
return f'<Spheniscidae {self.peer_name}>'
|
||||||
|
Loading…
Reference in New Issue
Block a user