diff --git a/confluent_server/confluent/consoleserver.py b/confluent_server/confluent/consoleserver.py index 9bdfd700..9303d5b6 100644 --- a/confluent_server/confluent/consoleserver.py +++ b/confluent_server/confluent/consoleserver.py @@ -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, diff --git a/confluent_server/confluent/plugins/hardwaremanagement/ipmi.py b/confluent_server/confluent/plugins/hardwaremanagement/ipmi.py index 3f7e3ef0..99552ae0 100644 --- a/confluent_server/confluent/plugins/hardwaremanagement/ipmi.py +++ b/confluent_server/confluent/plugins/hardwaremanagement/ipmi.py @@ -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