| """A killed runner cannot leave a child holding its Mineflayer port."""
|
| import os
|
| import socket
|
| import subprocess
|
| import sys
|
| import time
|
| from pathlib import Path
|
|
|
| import pytest
|
|
|
| sys.path.insert(0, str(Path(__file__).resolve().parents[1]))
|
| from voyager_processes import stop_runner
|
|
|
|
|
| @pytest.mark.skipif(os.name != "posix", reason="POSIX runner sessions")
|
| def test_orphan_port_is_released_without_touching_the_parent():
|
| child = "import socket,time; s=socket.socket(); s.bind(('127.0.0.1',0)); s.listen(); print(s.getsockname()[1],flush=True); time.sleep(30)"
|
| leader = "import subprocess,sys,os; subprocess.Popen([sys.executable,'-u','-c',sys.argv[1]]); os._exit(75)"
|
| proc = subprocess.Popen([sys.executable, "-u", "-c", leader, child],
|
| stdout=subprocess.PIPE, text=True, start_new_session=True)
|
| port = int(proc.stdout.readline())
|
| proc.wait(timeout=5)
|
| try:
|
| with socket.create_connection(("127.0.0.1", port), timeout=1):
|
| pass
|
| stop_runner(proc)
|
| deadline = time.monotonic() + 1
|
| while True:
|
| try:
|
| connection = socket.create_connection(("127.0.0.1", port), timeout=0.1)
|
| connection.close()
|
| except OSError:
|
| break
|
| assert time.monotonic() < deadline, "orphan still holds the Mineflayer port"
|
| time.sleep(0.01)
|
| finally:
|
| stop_runner(proc)
|
|
|
