Skip to main content

PsaMergeAttnRuntimeOp

Struct PsaMergeAttnRuntimeOp 

Source
pub struct PsaMergeAttnRuntimeOp<D: Float + Send + Sync + 'static> { /* private fields */ }
Expand description

Runtime dispatch for the PSA attention-merge kernel (forward + backward).

Implementations§

Source§

impl<D: Float + Send + Sync + 'static> PsaMergeAttnRuntimeOp<D>

Source

pub fn new(key_dim: i32, num_heads: usize) -> Self

Builds forward/backward kernels for the given key dimension and head count.

Source

pub fn kernel_name(&self) -> &str

The forward kernel’s function name.

Source

pub fn forward_source(&self) -> &str

The forward kernel’s generated source.

Source

pub fn backward_source(&self) -> &str

The backward kernel’s generated source.

Trait Implementations§

Source§

impl<D: Float + Send + Sync + 'static> RuntimeOp for PsaMergeAttnRuntimeOp<D>

Source§

fn pack_backward_args( &self, _inputs: &[(RawPtr, &[usize])], _params: &[RawPtr], _output: RawPtr, output_shape: &[usize], grad_output: RawPtr, _grad_output_row_stride: i32, grad_inputs: &[RawPtr], _grad_params: &[RawPtr], visitor: &mut dyn ArgVisitor, )

kernel args: d_merged, d_lo, d_hi, c, H, W, num_heads

Source§

fn backward_grid( &self, _input_shapes: &[&[usize]], output_shape: &[usize], ) -> [u32; 3]

Grid = [BH * N, 1, 1] — same layout as the forward pass.

Source§

fn n_activation_inputs(&self) -> usize

Number of activation tensors taken from predecessor DAG nodes.
Source§

fn param_shapes(&self, _: &[&[usize]], _: &[usize]) -> Vec<Vec<usize>>

Shapes of additional parameter buffers (weights, biases) needed by this op. Called at LoadedModel::load() time to pre-allocate device buffers. input_shapes / output_shape are concrete (batch dim resolved).
Source§

fn pack_args( &self, inputs: &[(RawPtr, &[usize])], _params: &[RawPtr], output: RawPtr, output_shape: &[usize], _output_row_stride: i32, visitor: &mut dyn ArgVisitor, )

Pack all kernel arguments into visitor in the correct order. Read more
Source§

fn block(&self) -> [u32; 3]

Threads-per-CTA for this kernel (x, y, z).
Source§

fn grid(&self, output_shape: &[usize]) -> [u32; 3]

Number of CTAs to launch (x, y, z), given the concrete output shape.
Source§

fn has_backward(&self) -> bool

Returns true if this op has a backward (gradient) kernel.
Source§

fn backward_block(&self) -> [u32; 3]

Threads-per-CTA for the backward kernel.
§

fn param_names(&self) -> &'static [&'static str]

Names of parameter slots returned by [param_shapes], in the same order. Used as the suffix in the dotted key {node_name}.{slot_name}. Return an empty slice for ops that have no named parameters.
§

fn forward_output_row_stride(&self, output_shape: &[usize]) -> usize

Returns the required row stride (in elements) for the output buffer of this op’s forward kernel. The default is the natural row-major stride (output_shape[-1]). Kernels using TMA must round up to satisfy the 16-byte alignment constraint (e.g. 4 elements for f32).
§

fn param_init_data(&self, _param_idx: usize) -> Option<Vec<u8>>

Returns raw (little-endian) bytes to pre-populate parameter slot param_idx immediately after device buffer allocation. Return None to leave the slot zero-initialised (the default for trained parameters). Byte count must equal param_shapes()[param_idx].iter().product() * dtype_bytes.
§

fn compute_concrete_output_shape( &self, _input_shapes: &[&[usize]], resolved: &[usize], ) -> Vec<usize>

Override to compute the true concrete output shape from concrete input shapes. Read more
§

fn n_launches(&self) -> usize

Number of sequential kernel launches this op requires. Read more
§

fn pack_args_for_launch( &self, launch_idx: usize, inputs: &[(*mut c_void, &[usize])], params: &[*mut c_void], output: *mut c_void, output_shape: &[usize], output_row_stride: i32, visitor: &mut dyn ArgVisitor, )

Pack kernel arguments for launch i (0-indexed). Read more
§

fn grid_for_launch( &self, launch_idx: usize, input_shapes: &[&[usize]], output_shape: &[usize], ) -> [u32; 3]

Grid for launch i. Receives concrete input shapes so that per-chunk grids can be computed without storing them in the op. Read more
§

fn backward_grad_output_row_stride(&self, output_shape: &[usize]) -> usize

Returns the required row stride (in elements) for the grad_output buffer passed to pack_backward_args. The default is the natural row-major stride (output_shape[-1]). Kernels using TMA must round up to satisfy the 16-byte alignment constraint (e.g. 4 elements for f32).
§

fn n_backward_launches(&self) -> usize

Number of sequential kernel launches for the backward pass. Read more
§

fn pack_backward_args_for_launch( &self, launch_idx: usize, inputs: &[(*mut c_void, &[usize])], params: &[*mut c_void], output: *mut c_void, output_shape: &[usize], grad_output: *mut c_void, grad_output_row_stride: i32, grad_inputs: &[*mut c_void], grad_params: &[*mut c_void], visitor: &mut dyn ArgVisitor, )

Pack backward kernel arguments for launch i (0-indexed). Read more
§

fn backward_grid_for_launch( &self, launch_idx: usize, input_shapes: &[&[usize]], output_shape: &[usize], ) -> [u32; 3]

Grid for backward launch i. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more