|
|
|
@ -333,7 +333,17 @@ class BaseNode:
|
|
|
|
|
"""
|
|
|
|
|
if not self._wrap_console:
|
|
|
|
|
return
|
|
|
|
|
(reader, writer) = yield from asyncio.open_connection(host="127.0.0.1", port=self._internal_console_port)
|
|
|
|
|
remaining_trial = 60
|
|
|
|
|
while True:
|
|
|
|
|
try:
|
|
|
|
|
(reader, writer) = yield from asyncio.open_connection(host="127.0.0.1", port=self._internal_console_port)
|
|
|
|
|
break
|
|
|
|
|
except (OSError, ConnectionRefusedError) as e:
|
|
|
|
|
print(self._internal_console_port)
|
|
|
|
|
if remaining_trial <= 0:
|
|
|
|
|
raise e
|
|
|
|
|
yield from asyncio.sleep(0.1)
|
|
|
|
|
remaining_trial -= 1
|
|
|
|
|
yield from AsyncioTelnetServer.write_client_intro(writer, echo=True)
|
|
|
|
|
server = AsyncioTelnetServer(reader=reader, writer=writer, binary=True, echo=True)
|
|
|
|
|
self._wrapper_telnet_server = yield from asyncio.start_server(server.run, self._manager.port_manager.console_host, self.console)
|
|
|
|
|