IMPORTANT: To view this page as Markdown, append `.md` to the URL (e.g. /max/get-started.md). For the complete documentation index, see llms.txt.
Skip to main content
For the complete documentation index, see llms.txt. Markdown versions of all pages are available by appending .md to any URL (e.g. /max/get-started.md).

Mojo struct

KVLoad2CvtProducer

struct KVLoad2CvtProducer[dtype: DType, config: MLA_SM100_Decode_Config]

Fields​

  • ​pipe (KVLoad2CvtProducer[dtype, config].KVPipeType):
  • ​smem_upper_fp8 (UnsafePointer[Scalar[dtype], MutAnyOrigin, address_space=AddressSpace.SHARED]):

Implemented traits​

AnyType, Copyable, ImplicitlyCopyable, ImplicitlyDeletable, Movable, RegisterPassable, TrivialRegisterPassable

comptime members​

bf16_stage_elems​

comptime bf16_stage_elems = (config * config)

fp8_stage_stride_elems​

comptime fp8_stage_stride_elems = (2 * KVLoad2CvtProducer[dtype, config].bf16_stage_elems)

KVPipeType​

comptime KVPipeType = KVPipelineGeneric[config.num_kv_stages, 1, (1 + 32 if (config > 0) else 0), (WARPGROUP_SIZE + 2)]

Methods​

__init__​

def __init__(pipe: KVPipelineGeneric[config.num_kv_stages, 1, (1 + 32 if (config > 0) else 0), (WARPGROUP_SIZE + 2)], smem_upper_fp8: UnsafePointer[Scalar[dtype], MutAnyOrigin, address_space=AddressSpace.SHARED]) -> Self

init​

def init(self)

stage_base_ptr​

def stage_base_ptr[*, qk_stage: Int = 0](self) -> UnsafePointer[Scalar[dtype], MutAnyOrigin, address_space=AddressSpace.SHARED]

Returns:

UnsafePointer[Scalar[dtype], MutAnyOrigin, address_space=AddressSpace.SHARED]

producer_mbar​

def producer_mbar[*, qk_stage: Int = 0](self) -> MBarType

Returns:

MBarType

acquire​

def acquire[*, qk_stage: Int = 0](self)

commit_step​

def commit_step(mut self)