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
KVLoad2CvtConsumer
struct KVLoad2CvtConsumer[dtype: DType, config: MLA_SM100_Decode_Config]
Fields
- pipe (
KVLoad2CvtConsumer[dtype, config].PipeT): - 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 * KVLoad2CvtConsumer[dtype, config].bf16_stage_elems)
PipeT
comptime PipeT = 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
stage_base_ptr
def stage_base_ptr(self) -> UnsafePointer[Scalar[dtype], MutAnyOrigin, address_space=AddressSpace.SHARED]
Returns:
UnsafePointer[Scalar[dtype], MutAnyOrigin, address_space=AddressSpace.SHARED]
wait
def wait(self)
release_all
def release_all(mut self)
Was this page helpful?
Thank you! We'll create more content like this.
Thank you for helping us improve!