Mojo struct
DecodeKVConsumer
struct DecodeKVConsumer[dtype: DType, config: MLA_SM100_Decode_Config, num_producer: Int = 1]
Fieldsβ
- βpipe (
DecodeKVConsumer[dtype, config, num_producer].KVPipeType): - βsmem (
UnsafePointer[Scalar[dtype], MutAnyOrigin, address_space=AddressSpace.SHARED]):
Implemented traitsβ
AnyType,
Copyable,
ImplicitlyCopyable,
ImplicitlyDestructible,
Movable,
RegisterPassable,
TrivialRegisterPassable
comptime membersβ
kv_stage_elemsβ
comptime kv_stage_elems = (config * config)
KVPipeTypeβ
comptime KVPipeType = KVPipelineGeneric[config.num_kv_stages, 1, num_producer, 2]
Methodsβ
__init__β
__init__(pipe: KVPipelineGeneric[config.num_kv_stages, 1, num_producer, 2], smem: UnsafePointer[Scalar[dtype], MutAnyOrigin, address_space=AddressSpace.SHARED]) -> Self
stage_base_ptrβ
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]
stage_indexβ
waitβ
wait[*, qk_stage: Int = 0](self)
releaseβ
release[*, qk_stage: Int = 0](mut self, e: Int32)
Was this page helpful?
Thank you! We'll create more content like this.
Thank you for helping us improve!