arno/gns3-server
1
0
Fork 0
mirror of https://github.com/GNS3/gns3-server synced 2025-07-04 22:02:39 +00:00
Code Issues Releases Wiki Activity

Add shutdown method

Browse Source
This commit is contained in:
John Fleming 2024-01-28 09:05:57 -05:00
parent ada755cd4b
commit 9774fe9468
1 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
gns3server/compute/base_node.py
View File

@ -399,7 +399,7 @@ class BaseNode:
# echo=True # echo=True
#) #)
server = SFTelnetProxyMuxer(binary=True, echo=True, remote_port=self._internal_console_port, listen_port=self.console) server = SFTelnetProxyMuxer(binary=True, echo=True, remote_port=self._internal_console_port, listen_port=self.console)
await server.start_proxy() self._wrapper_telnet_server = await server.start_proxy()
# warning: this will raise OSError exception if there is a problem... # warning: this will raise OSError exception if there is a problem...
#log.info(f"self._manager.port_manager.console_host: {self._manager.port_manager.console_host}") #log.info(f"self._manager.port_manager.console_host: {self._manager.port_manager.console_host}")
#log.info(f"self.console {self.console}") #log.info(f"self.console {self.console}")
@ -417,16 +417,18 @@ class BaseNode:
Stops the telnet proxy. Stops the telnet proxy.
""" """
if self._wrapper_telnet_server: #if self._wrapper_telnet_server:
self._wrap_console_writer.close() # self._wrap_console_writer.close()
if sys.version_info >= (3, 7, 0): # if sys.version_info >= (3, 7, 0):
try: # try:
await self._wrap_console_writer.wait_closed() # await self._wrap_console_writer.wait_closed()
except ConnectionResetError: # except ConnectionResetError:
pass # pass
self._wrapper_telnet_server.close() # self._wrapper_telnet_server.close()
await self._wrapper_telnet_server.wait_closed() # await self._wrapper_telnet_server.wait_closed()
self._wrapper_telnet_server = None # self._wrapper_telnet_server = None
self._wrapper_telnet_server.shutdown()
self._wrapper_telnet_server = None
async def reset_wrap_console(self): async def reset_wrap_console(self):
""" """