Method read_message

gunicorn/dirty/protocol.py:520–557

Read a complete message from socket (sync). Args: sock: Socket to read from Returns: dict: Message dict with 'type', 'id', and payload fields Raises: DirtyProtocolError: If read fails or message is malformed

(sock: socket.socket)

    @staticmethod
    def read_message(sock: socket.socket) -> dict:
        """
        Read a complete message from socket (sync).

        Args:
            sock: Socket to read from

        Returns:
            dict: Message dict with 'type', 'id', and payload fields

        Raises:
            DirtyProtocolError: If read fails or message is malformed
        """
        # Read header
        header = BinaryProtocol._recv_exactly(sock, HEADER_SIZE)
        msg_type, request_id, length = BinaryProtocol.decode_header(header)

        # Read payload
        if length > 0:
            payload_data = BinaryProtocol._recv_exactly(sock, length)
            try:
                payload_dict = TLVEncoder.decode_full(payload_data)
            except DirtyProtocolError:
                raise
            except Exception as e:
                raise DirtyProtocolError(
                    f"Failed to decode TLV payload: {e}",
                    raw_data=payload_data[:50]
                )
        else:
            payload_dict = {}

        # Build response dict
        msg_type_str = MSG_TYPE_TO_STR[msg_type]
        result = {"type": msg_type_str, "id": request_id}
        result.update(payload_dict)

        return result

    @staticmethod
    def write_message(sock: socket.socket, message: dict) -> None: