mirror of
https://github.com/xcat2/confluent.git
synced 2026-02-19 06:04:25 +00:00
More fixes for asyncio support console usage
This commit is contained in:
@@ -429,7 +429,7 @@ class ConsoleHandler(object):
|
||||
|
||||
async def _got_disconnected(self):
|
||||
if self.connectstate != 'unconnected':
|
||||
self._console.close()
|
||||
await self._console.close()
|
||||
self.connectstate = 'unconnected'
|
||||
self.log(
|
||||
logdata='console disconnected', ltype=log.DataTypes.event,
|
||||
|
||||
@@ -350,11 +350,11 @@ class IpmiConsole(conapi.Console):
|
||||
except socket.gaierror as err:
|
||||
raise exc.TargetEndpointUnreachable(str(err))
|
||||
|
||||
def close(self):
|
||||
async def close(self):
|
||||
if self.solconnection is not None:
|
||||
# break the circular reference here
|
||||
self.solconnection.out_handler = _donothing
|
||||
self.solconnection.close()
|
||||
await self.solconnection.close()
|
||||
self.solconnection = None
|
||||
self.datacallback = None
|
||||
self.broken = True
|
||||
|
||||
Reference in New Issue
Block a user