Refactor platform-specific code into src/mcp/os directory structure

Per @dsp-ant's review feedback, reorganize platform-specific utilities:
- Create src/mcp/os/ with win32/ and posix/ subdirectories
- Move all Windows-specific code to mcp.os.win32.utilities
- Extract POSIX process termination to mcp.os.posix.utilities
- Update logger to use __name__ instead of hardcoded string
- Rename timeout parameter to timeout_seconds for clarity
- Document that missing PID means no process to terminate

This structure allows platform utilities to be shared across client,
server, and other components as needed.

Author: felixweinberger

src/mcp/client/stdio/__init__.py

@@ -1,6 +1,5 @@
 import logging
 import os
-import signal
 import sys
 from contextlib import asynccontextmanager
 from pathlib import Path
@@ -14,16 +13,16 @@
 from pydantic import BaseModel, Field
 
 import mcp.types as types
-from mcp.shared.message import SessionMessage
-
-from .win32 import (
+from mcp.os.posix.utilities import terminate_posix_process_tree
+from mcp.os.win32.utilities import (
     FallbackProcess,
     create_windows_process,
     get_windows_executable_command,
     terminate_windows_process_tree,
 )
+from mcp.shared.message import SessionMessage
 
-logger = logging.getLogger("client.stdio")
+logger = logging.getLogger(__name__)
 
 # Environment variables to inherit by default
 DEFAULT_INHERITED_ENV_VARS = (
@@ -247,47 +246,18 @@ async def _create_platform_compatible_process(
     return process
 
 
-async def _terminate_process_tree(process: Process | FallbackProcess, timeout: float = 2.0) -> None:
+async def _terminate_process_tree(process: Process | FallbackProcess, timeout_seconds: float = 2.0) -> None:
     """
     Terminate a process and all its children using platform-specific methods.
 
     Unix: Uses os.killpg() for atomic process group termination
     Windows: Uses Job Objects via pywin32 for reliable child process cleanup
+
+    Args:
+        process: The process to terminate
+        timeout_seconds: Timeout in seconds before force killing (default: 2.0)
     """
     if sys.platform == "win32":
-        await terminate_windows_process_tree(process, timeout)
+        await terminate_windows_process_tree(process, timeout_seconds)
     else:
-        pid = getattr(process, "pid", None) or getattr(getattr(process, "popen", None), "pid", None)
-        if not pid:
-            return
-
-        try:
-            pgid = os.getpgid(pid)
-            os.killpg(pgid, signal.SIGTERM)
-
-            with anyio.move_on_after(timeout):
-                while True:
-                    try:
-                        # Check if process group still exists (signal 0 = check only)
-                        os.killpg(pgid, 0)
-                        await anyio.sleep(0.1)
-                    except ProcessLookupError:
-                        return
-
-            try:
-                os.killpg(pgid, signal.SIGKILL)
-            except ProcessLookupError:
-                pass
-
-        except (ProcessLookupError, PermissionError, OSError) as e:
-            logger.warning(f"Process group termination failed for PID {pid}: {e}, falling back to simple terminate")
-            try:
-                process.terminate()
-                with anyio.fail_after(timeout):
-                    await process.wait()
-            except Exception as term_error:
-                logger.warning(f"Process termination failed for PID {pid}: {term_error}, attempting force kill")
-                try:
-                    process.kill()
-                except Exception as kill_error:
-                    logger.error(f"Failed to kill process {pid}: {kill_error}")
+        await terminate_posix_process_tree(process, timeout_seconds)

src/mcp/os/__init__.py

@@ -0,0 +1 @@
+"""Platform-specific utilities for MCP."""

src/mcp/os/posix/__init__.py

@@ -0,0 +1 @@
+"""POSIX-specific utilities for MCP."""

src/mcp/os/posix/utilities.py

@@ -0,0 +1,66 @@
+"""
+POSIX-specific functionality for stdio client operations.
+"""
+
+import logging
+import os
+import signal
+from typing import TYPE_CHECKING, Union
+
+import anyio
+from anyio.abc import Process
+
+if TYPE_CHECKING:
+    from mcp.os.win32.utilities import FallbackProcess
+
+logger = logging.getLogger(__name__)
+
+
+async def terminate_posix_process_tree(
+    process: Union[Process, "FallbackProcess"], timeout_seconds: float = 2.0
+) -> None:
+    """
+    Terminate a process and all its children on POSIX systems.
+
+    Uses os.killpg() for atomic process group termination.
+
+    Args:
+        process: The process to terminate
+        timeout_seconds: Timeout in seconds before force killing (default: 2.0)
+    """
+    pid = getattr(process, "pid", None) or getattr(getattr(process, "popen", None), "pid", None)
+    if not pid:
+        # No PID means there's no process to terminate - it either never started,
+        # already exited, or we have an invalid process object
+        return
+
+    try:
+        pgid = os.getpgid(pid)
+        os.killpg(pgid, signal.SIGTERM)
+
+        with anyio.move_on_after(timeout_seconds):
+            while True:
+                try:
+                    # Check if process group still exists (signal 0 = check only)
+                    os.killpg(pgid, 0)
+                    await anyio.sleep(0.1)
+                except ProcessLookupError:
+                    return
+
+        try:
+            os.killpg(pgid, signal.SIGKILL)
+        except ProcessLookupError:
+            pass
+
+    except (ProcessLookupError, PermissionError, OSError) as e:
+        logger.warning(f"Process group termination failed for PID {pid}: {e}, falling back to simple terminate")
+        try:
+            process.terminate()
+            with anyio.fail_after(timeout_seconds):
+                await process.wait()
+        except Exception as term_error:
+            logger.warning(f"Process termination failed for PID {pid}: {term_error}, attempting force kill")
+            try:
+                process.kill()
+            except Exception as kill_error:
+                logger.error(f"Failed to kill process {pid}: {kill_error}")

src/mcp/os/win32/__init__.py

@@ -0,0 +1 @@
+"""Windows-specific utilities for MCP."""

src/mcp/client/stdio/win32.py renamed to src/mcp/os/win32/utilities.py

@@ -278,12 +278,16 @@ def _maybe_assign_process_to_job(process: Process | FallbackProcess, job: JobHan
             win32api.CloseHandle(job)
 
 
-async def terminate_windows_process_tree(process: Process | FallbackProcess, timeout: float = 2.0) -> None:
+async def terminate_windows_process_tree(process: Process | FallbackProcess, timeout_seconds: float = 2.0) -> None:
     """
     Terminate a process and all its children on Windows.
 
     If the process has an associated job object, it will be terminated.
     Otherwise, falls back to basic process termination.
+
+    Args:
+        process: The process to terminate
+        timeout_seconds: Timeout in seconds before force killing (default: 2.0)
     """
     if sys.platform != "win32":
         return