Method _handle_client

gunicorn/ctl/server.py:224–263

Handle client connection. Args: reader: asyncio StreamReader writer: asyncio StreamWriter

(self, reader, writer)

                    pass

    async def _handle_client(self, reader, writer):
        """
        Handle client connection.

        Args:
            reader: asyncio StreamReader
            writer: asyncio StreamWriter
        """
        try:
            while self._running:
                try:
                    message = await asyncio.wait_for(
                        ControlProtocol.read_message_async(reader),
                        timeout=300.0  # 5 minute idle timeout
                    )
                except asyncio.TimeoutError:
                    # Client idle too long, close connection
                    break
                except asyncio.IncompleteReadError:
                    # Client disconnected
                    break
                except Exception:
                    # Protocol error
                    break

                # Process command
                response = await self._dispatch(message)

                # Send response
                await ControlProtocol.write_message_async(writer, response)

        except Exception as e:
            if self.arbiter.log:
                self.arbiter.log.debug("Control client error: %s", e)
        finally:
            writer.close()
            try:
                await writer.wait_closed()
            except Exception:
                pass

    async def _dispatch(self, message: dict) -> dict:
        """