|
@@ -26,6 +26,7 @@ class TesseractNetwork(mp.Process):
|
|
|
self.run_in_background(await_ready=True)
|
|
|
|
|
|
def run(self) -> None:
|
|
|
+ print('started', self.pid)
|
|
|
loop = asyncio.new_event_loop()
|
|
|
asyncio.set_event_loop(loop)
|
|
|
loop.run_until_complete(self.server.listen(self.port))
|
|
@@ -52,6 +53,7 @@ class TesseractNetwork(mp.Process):
|
|
|
def shutdown(self) -> None:
|
|
|
""" Shuts down the network process """
|
|
|
if self.is_alive():
|
|
|
+ print('terminated', self.pid)
|
|
|
self.kill()
|
|
|
else:
|
|
|
warnings.warn("Network shutdown has no effect: network process is already not alive")
|