Method read_message_async

gunicorn/ctl/protocol.py:133–156

Read one message from an async reader. Args: reader: asyncio StreamReader Returns: Decoded message dictionary

(reader)

    @staticmethod
    async def read_message_async(reader) -> dict:
        """
        Read one message from an async reader.

        Args:
            reader: asyncio StreamReader

        Returns:
            Decoded message dictionary
        """
        # Read length prefix
        length_data = await reader.readexactly(4)
        length = struct.unpack('>I', length_data)[0]

        if length > ControlProtocol.MAX_MESSAGE_SIZE:
            raise ProtocolError(f"Message too large: {length}")

        # Read payload
        payload_data = await reader.readexactly(length)

        try:
            return json.loads(payload_data.decode('utf-8'))
        except json.JSONDecodeError as e:
            raise ProtocolError(f"Invalid JSON: {e}")

    @staticmethod
    async def write_message_async(writer, data: dict):