bump those coverage numbers, those are rookie coverage numbers

Author: markjm

tests/supervisors/test_multiprocess.py

@@ -50,8 +50,7 @@ def with_running_supervisor(supervisor: Multiprocess):
         # Signal supervisor to exit (in case test failed before sending SIGINT)
         supervisor.should_exit.set()
         thread.join(timeout=10)
-        if thread.is_alive():
-            raise RuntimeError("Supervisor thread did not exit in time")
+        assert not thread.is_alive()
 
 
 async def app(scope: Scope, receive: ASGIReceiveCallable, send: ASGISendCallable) -> None:
@@ -94,6 +93,54 @@ def test_process_is_alive_when_not_started() -> None:
     assert not process.is_alive(timeout=0.1)
 
 
+@new_console_in_windows
+def test_process_always_pong_exits_on_closed_socket() -> None:
+    """Test that always_pong exits gracefully when the peer socket is closed."""
+    process = Process(Config(app=app), target=lambda x: None, sockets=[])
+    thread = threading.Thread(target=process.always_pong, daemon=True)
+    thread.start()
+    process.parent_sock.close()
+    thread.join(timeout=2)
+    assert not thread.is_alive()
+
+
+@new_console_in_windows
+def test_process_join_with_socket_already_closed() -> None:
+    """Test that join handles an already-closed parent socket gracefully."""
+    process = Process(Config(app=app), target=run, sockets=[])
+    process.start()
+    time.sleep(0.5)
+    os.close(process.parent_sock.fileno())
+    process.terminate()
+    process.join()
+
+
+@new_console_in_windows
+def test_handle_int() -> None:
+    config = Config(app=app, workers=2)
+    supervisor = Multiprocess(config, target=run, sockets=[])
+    assert not supervisor.should_exit.is_set()
+    supervisor.handle_int()
+    assert supervisor.should_exit.is_set()
+
+
+@new_console_in_windows
+def test_handle_term() -> None:
+    config = Config(app=app, workers=2)
+    supervisor = Multiprocess(config, target=run, sockets=[])
+    assert not supervisor.should_exit.is_set()
+    supervisor.handle_term()
+    assert supervisor.should_exit.is_set()
+
+
+@new_console_in_windows
+def test_keep_subprocess_alive_noop_when_exiting() -> None:
+    config = Config(app=app, workers=2)
+    supervisor = Multiprocess(config, target=run, sockets=[])
+    supervisor.should_exit.set()
+    supervisor.keep_subprocess_alive()
+
+
 @new_console_in_windows
 def test_multiprocess_run() -> None:
     """