Method _execute

gunicorn/dirty/stash.py:137–185

Execute a stash operation. Args: op: Operation code (STASH_OP_*) table: Table name key: Optional key value: Optional value pattern: Optional pattern for keys operation Returns: Result from the operatio

(self, op, table, key=None, value=None, pattern=None)

            self._sock = None

    def _execute(self, op, table, key=None, value=None, pattern=None):
        """
        Execute a stash operation.

        Args:
            op: Operation code (STASH_OP_*)
            table: Table name
            key: Optional key
            value: Optional value
            pattern: Optional pattern for keys operation

        Returns:
            Result from the operation
        """
        with self._lock:
            if self._sock is None:
                self._connect()

            request_id = self._get_request_id()
            message = make_stash_message(
                request_id, op, table,
                key=key, value=value, pattern=pattern
            )

            try:
                DirtyProtocol.write_message(self._sock, message)
                response = DirtyProtocol.read_message(self._sock)

                msg_type = response.get("type")
                if msg_type == DirtyProtocol.MSG_TYPE_RESPONSE:
                    return response.get("result")
                elif msg_type == DirtyProtocol.MSG_TYPE_ERROR:
                    error_info = response.get("error", {})
                    error_type = error_info.get("error_type", "StashError")
                    error_msg = error_info.get("message", "Unknown error")

                    if error_type == "StashTableNotFoundError":
                        raise StashTableNotFoundError(table)
                    if error_type == "StashKeyNotFoundError":
                        raise StashKeyNotFoundError(table, key)
                    raise StashError(error_msg)
                else:
                    raise StashError(f"Unexpected response type: {msg_type}")

            except Exception as e:
                self._close()
                if isinstance(e, StashError):
                    raise
                raise StashError(f"Stash operation failed: {e}") from e

    # -------------------------------------------------------------------------
    # Public API