use super::{Kernel, Q5K_SUPER_BLOCK_BYTES, Q5K_SUPER_BLOCK_SIZE};
use crate::ptx::builder::{PtxArithmetic, PtxComparison, PtxControl};
use crate::ptx::{PtxKernel, PtxReg, PtxType};
#[derive(Debug, Clone)]
pub struct Q5KKernel {
pub m: u32,
pub n: u32,
pub k: u32,
pub tile_size: u32,
}
impl Q5KKernel {
#[must_use]
pub fn new(m: u32, n: u32, k: u32) -> Self {
Self {
m,
n,
k,
tile_size: 32,
}
}
#[must_use]
pub const fn with_tile_size(mut self, tile_size: u32) -> Self {
self.tile_size = tile_size;
self
}
#[must_use]
pub const fn num_super_blocks_per_row(&self) -> u32 {
self.k / Q5K_SUPER_BLOCK_SIZE
}
}
impl Kernel for Q5KKernel {
fn name(&self) -> &str {
"q5k_gemm_ggml"
}
fn build_ptx(&self) -> PtxKernel {
let tile_size = self.tile_size;
let smem_size = Q5K_SUPER_BLOCK_SIZE * 4;
PtxKernel::new("q5k_gemm_ggml")
.param(PtxType::U64, "a_ptr")
.param(PtxType::U64, "b_quant_ptr")
.param(PtxType::U64, "c_ptr")
.param(PtxType::U32, "m")
.param(PtxType::U32, "n")
.param(PtxType::U32, "k")
.shared_memory(smem_size as usize)
.build(|ctx| {
let tid = ctx.special_reg(PtxReg::TidX);
let ctaid_x = ctx.special_reg(PtxReg::CtaIdX);
let ctaid_y = ctx.special_reg(PtxReg::CtaIdY);
let m_param = ctx.load_param_u32("m");
let n_param = ctx.load_param_u32("n");
let k_param = ctx.load_param_u32("k");
let a_ptr = ctx.load_param_u64("a_ptr");
let b_quant_ptr = ctx.load_param_u64("b_quant_ptr");
let c_ptr = ctx.load_param_u64("c_ptr");
let tile_size_reg = ctx.mov_u32_imm(tile_size);
let out_row = ctx.mul_u32_reg(ctaid_y, tile_size_reg);
let out_col = ctx.mul_u32_reg(ctaid_x, tile_size_reg);
let local_row = ctx.div_u32(tid, tile_size);
let local_col = ctx.rem_u32(tid, tile_size);
let global_row = ctx.add_u32_reg(out_row, local_row);
let global_col = ctx.add_u32_reg(out_col, local_col);
let row_oob = ctx.setp_ge_u32(global_row, m_param);
let col_oob = ctx.setp_ge_u32(global_col, n_param);
let one = ctx.mov_u32_imm(1);
let m_minus_1 = ctx.sub_u32_reg(m_param, one);
let n_minus_1 = ctx.sub_u32_reg(n_param, one);
let clamped_row = ctx.min_u32(global_row, m_minus_1);
let clamped_col = ctx.min_u32(global_col, n_minus_1);
let acc = ctx.mov_f32_imm(0.0);
let num_k_super_blocks = ctx.div_u32(k_param, Q5K_SUPER_BLOCK_SIZE);
let sb_idx = ctx.mov_u32_imm(0);
ctx.label("sb_loop");
let sb_done = ctx.setp_ge_u32(sb_idx, num_k_super_blocks);
ctx.branch_if(sb_done, "sb_loop_done");
let sb_per_row = num_k_super_blocks;
let row_sb_offset = ctx.mul_u32_reg(clamped_col, sb_per_row);
let total_sb_offset = ctx.add_u32_reg(row_sb_offset, sb_idx);
let byte_offset = ctx.mul_wide_u32(total_sb_offset, Q5K_SUPER_BLOCK_BYTES);
let sb_addr = ctx.add_u64(b_quant_ptr, byte_offset);
let d_f16 = ctx.ld_global_f16(sb_addr);
let d = ctx.cvt_f32_f16(d_f16);
let two = ctx.mov_u64_imm(2);
let dmin_addr = ctx.add_u64(sb_addr, two);
let dmin_f16 = ctx.ld_global_f16(dmin_addr);
let dmin = ctx.cvt_f32_f16(dmin_f16);
let sub_block_idx = ctx.mov_u32_imm(0);
let eight = ctx.mov_u32_imm(8);
let thirty_two = ctx.mov_u32_imm(32);
ctx.label("sub_block_loop");
let sub_done = ctx.setp_ge_u32(sub_block_idx, eight);
ctx.branch_if(sub_done, "sub_block_done");
let bit_offset = ctx.mul_u32(sub_block_idx, 12);
let byte_idx = ctx.div_u32(bit_offset, 8);
let bit_in_byte = ctx.rem_u32(bit_offset, 8);
let four = ctx.mov_u64_imm(4);
let scales_base = ctx.add_u64(sb_addr, four);
let byte_idx_64 = ctx.cvt_u64_u32(byte_idx);
let scales_addr = ctx.add_u64(scales_base, byte_idx_64);
let scale_b0 = ctx.ld_global_u8(scales_addr);
let one_64 = ctx.mov_u64_imm(1);
let scales_addr1 = ctx.add_u64(scales_addr, one_64);
let scale_b1 = ctx.ld_global_u8(scales_addr1);
let b0_32 = ctx.cvt_u32_u8(scale_b0);
let b1_32 = ctx.cvt_u32_u8(scale_b1);
let eight_shift = ctx.mov_u32_imm(8);
let b1_shifted = ctx.shl_u32(b1_32, eight_shift);
let combined = ctx.or_u32(b0_32, b1_shifted);
let bits_12 = ctx.shr_u32(combined, bit_in_byte);
let mask_6bit = ctx.mov_u32_imm(0x3F);
let scale_6bit = ctx.and_u32(bits_12, mask_6bit);
let six_shift = ctx.mov_u32_imm(6);
let min_shifted = ctx.shr_u32(bits_12, six_shift);
let min_6bit = ctx.and_u32(min_shifted, mask_6bit);
let scale_f32 = ctx.cvt_f32_u32(scale_6bit);
let min_f32 = ctx.cvt_f32_u32(min_6bit);
let inv_63 = ctx.mov_f32_imm(1.0 / 63.0);
let scale_norm = ctx.mul_f32(scale_f32, inv_63);
let min_norm = ctx.mul_f32(min_f32, inv_63);
let lane = ctx.rem_u32(tid, 32);
let sixteen = ctx.mov_u64_imm(16);
let qs_base = ctx.add_u64(sb_addr, sixteen);
let sub_block_offset = ctx.mul_u32(sub_block_idx, 16);
let sub_block_offset_64 = ctx.cvt_u64_u32(sub_block_offset);
let qs_sub_base = ctx.add_u64(qs_base, sub_block_offset_64);
let byte_in_sub = ctx.div_u32(lane, 2);
let nibble_idx = ctx.rem_u32(lane, 2);
let byte_in_sub_64 = ctx.cvt_u64_u32(byte_in_sub);
let qs_addr = ctx.add_u64(qs_sub_base, byte_in_sub_64);
let packed_ql = ctx.ld_global_u8(qs_addr);
let shift_amt = ctx.mul_u32(nibble_idx, 4);
let packed_ql_32 = ctx.cvt_u32_u8(packed_ql);
let shifted_ql = ctx.shr_u32(packed_ql_32, shift_amt);
let mask_4bit = ctx.mov_u32_imm(0xF);
let ql = ctx.and_u32(shifted_ql, mask_4bit);
let qh_base_offset = ctx.mov_u64_imm(144);
let qh_base = ctx.add_u64(sb_addr, qh_base_offset);
let global_bit_idx = ctx.mul_u32(sub_block_idx, 32);
let global_bit_idx_full = ctx.add_u32_reg(global_bit_idx, lane);
let qh_byte_idx = ctx.div_u32(global_bit_idx_full, 8);
let qh_bit_idx = ctx.rem_u32(global_bit_idx_full, 8);
let qh_byte_idx_64 = ctx.cvt_u64_u32(qh_byte_idx);
let qh_addr = ctx.add_u64(qh_base, qh_byte_idx_64);
let qh_byte = ctx.ld_global_u8(qh_addr);
let qh_byte_32 = ctx.cvt_u32_u8(qh_byte);
let qh_shifted = ctx.shr_u32(qh_byte_32, qh_bit_idx);
let mask_1bit = ctx.mov_u32_imm(1);
let qh = ctx.and_u32(qh_shifted, mask_1bit);
let sixteen_u32 = ctx.mov_u32_imm(16);
let qh_scaled = ctx.mul_u32_reg(qh, sixteen_u32);
let quant = ctx.add_u32_reg(ql, qh_scaled);
let quant_f32 = ctx.cvt_f32_u32(quant);
let d_scale = ctx.mul_f32(d, scale_norm);
let scaled = ctx.mul_f32(d_scale, quant_f32);
let dmin_min = ctx.mul_f32(dmin, min_norm);
let dequant = ctx.sub_f32(scaled, dmin_min);
let two_fifty_six = ctx.mov_u32_imm(256);
let sb_k_offset = ctx.mul_u32_reg(sb_idx, two_fifty_six);
let sub_k_offset = ctx.mul_u32_reg(sub_block_idx, thirty_two);
let k_offset = ctx.add_u32_reg(sb_k_offset, sub_k_offset);
let k_offset_full = ctx.add_u32_reg(k_offset, lane);
let a_row_offset = ctx.mul_wide_u32_reg(clamped_row, k_param);
let k_offset_64 = ctx.cvt_u64_u32(k_offset_full);
let a_elem_offset = ctx.add_u64(a_row_offset, k_offset_64);
let a_elem_bytes = ctx.mul_u64(a_elem_offset, 4);
let a_addr = ctx.add_u64(a_ptr, a_elem_bytes);
let a_val = ctx.ld_global_f32(a_addr);
let prod = ctx.mul_f32(a_val, dequant);
let shuffled_16 = ctx.shfl_down_f32(prod, 16, 0xFFFF_FFFF);
let prod_1 = ctx.add_f32(prod, shuffled_16);
let shuffled_8 = ctx.shfl_down_f32(prod_1, 8, 0xFFFF_FFFF);
let prod_2 = ctx.add_f32(prod_1, shuffled_8);
let shuffled_4 = ctx.shfl_down_f32(prod_2, 4, 0xFFFF_FFFF);
let prod_3 = ctx.add_f32(prod_2, shuffled_4);
let shuffled_2 = ctx.shfl_down_f32(prod_3, 2, 0xFFFF_FFFF);
let prod_4 = ctx.add_f32(prod_3, shuffled_2);
let shuffled_1 = ctx.shfl_down_f32(prod_4, 1, 0xFFFF_FFFF);
let sub_block_sum = ctx.add_f32(prod_4, shuffled_1);
let broadcast_sum = ctx.shfl_idx_f32(sub_block_sum, 0, 0xFFFF_FFFF);
ctx.add_f32_inplace(acc, broadcast_sum);
ctx.add_u32_inplace(sub_block_idx, 1);
ctx.branch("sub_block_loop");
ctx.label("sub_block_done");
ctx.add_u32_inplace(sb_idx, 1);
ctx.branch("sb_loop");
ctx.label("sb_loop_done");
ctx.branch_if(row_oob, "exit");
ctx.branch_if(col_oob, "exit");
let c_row_offset = ctx.mul_wide_u32_reg(global_row, n_param);
let global_col_64 = ctx.cvt_u64_u32(global_col);
let c_elem_offset = ctx.add_u64(c_row_offset, global_col_64);
let c_elem_bytes = ctx.mul_u64(c_elem_offset, 4);
let c_addr = ctx.add_u64(c_ptr, c_elem_bytes);
ctx.st_global_f32(c_addr, acc);
ctx.label("exit");
ctx.ret();
})
}
}
#[derive(Debug, Clone)]
pub struct Q5KGemvKernel {
pub k: u32,
pub n: u32,
}
impl Q5KGemvKernel {
#[must_use]
pub fn new(k: u32, n: u32) -> Self {
Self { k, n }
}
}
impl Kernel for Q5KGemvKernel {
fn name(&self) -> &str {
"q5k_gemv_warp_reduce"
}
fn build_ptx(&self) -> PtxKernel {
PtxKernel::new("q5k_gemv_warp_reduce")
.param(PtxType::U64, "y_ptr")
.param(PtxType::U64, "w_ptr")
.param(PtxType::U64, "x_ptr")
.param(PtxType::U32, "k_dim")
.param(PtxType::U32, "n_dim")
.build(|ctx| {
let block_id = ctx.special_reg(PtxReg::CtaIdX);
let thread_id = ctx.special_reg(PtxReg::TidX);
let n_dim = ctx.load_param_u32("n_dim");
let oob = ctx.setp_ge_u32(block_id, n_dim);
ctx.branch_if(oob, "exit");
let k_dim = ctx.load_param_u32("k_dim");
let y_ptr = ctx.load_param_u64("y_ptr");
let w_ptr = ctx.load_param_u64("w_ptr");
let x_ptr = ctx.load_param_u64("x_ptr");
let acc = ctx.mov_f32_imm(0.0);
let k_rounded = ctx.add_u32(k_dim, Q5K_SUPER_BLOCK_SIZE - 1);
let num_super_blocks = ctx.div_u32(k_rounded, Q5K_SUPER_BLOCK_SIZE);
let sb_bytes = ctx.mov_u32_imm(Q5K_SUPER_BLOCK_BYTES);
let row_bytes = ctx.mul_u32_reg(num_super_blocks, sb_bytes);
let row_offset = ctx.mul_wide_u32_reg(block_id, row_bytes);
let row_base = ctx.add_u64(w_ptr, row_offset);
let sb_idx = ctx.mov_u32_imm(0);
ctx.label("sb_loop");
let sb_done = ctx.setp_ge_u32(sb_idx, num_super_blocks);
ctx.branch_if(sb_done, "sb_loop_end");
let sb_offset = ctx.mul_wide_u32(sb_idx, Q5K_SUPER_BLOCK_BYTES);
let sb_addr = ctx.add_u64(row_base, sb_offset);
let d_f16 = ctx.ld_global_f16(sb_addr);
let d = ctx.cvt_f32_f16(d_f16);
let two = ctx.mov_u64_imm(2);
let dmin_addr = ctx.add_u64(sb_addr, two);
let dmin_f16 = ctx.ld_global_f16(dmin_addr);
let dmin = ctx.cvt_f32_f16(dmin_f16);
let thread_partial = ctx.mov_f32_imm(0.0);
let offsets: [u32; 8] = [0, 32, 64, 96, 128, 160, 192, 224];
for offset in offsets {
let offset_reg = ctx.mov_u32_imm(offset);
let val_idx = ctx.add_u32_reg(thread_id, offset_reg);
let sub_block = ctx.div_u32(val_idx, 32);
let four_64 = ctx.mov_u64_imm(4);
let scales_base = ctx.add_u64(sb_addr, four_64);
let four_u32 = ctx.mov_u32_imm(4);
let is_simple = ctx.setp_lt_u32(sub_block, four_u32);
let sub_block_64 = ctx.cvt_u64_u32(sub_block);
let scales_j_addr = ctx.add_u64(scales_base, sub_block_64);
let scales_j = ctx.ld_global_u8(scales_j_addr);
let scales_j_32 = ctx.cvt_u32_u8(scales_j);
let sub_block_plus_4 = ctx.add_u32_reg(sub_block, four_u32);
let sub_block_plus_4_64 = ctx.cvt_u64_u32(sub_block_plus_4);
let scales_j4_addr = ctx.add_u64(scales_base, sub_block_plus_4_64);
let scales_j4 = ctx.ld_global_u8(scales_j4_addr);
let scales_j4_32 = ctx.cvt_u32_u8(scales_j4);
let mask_6bit = ctx.mov_u32_imm(0x3F);
let scale_simple = ctx.and_u32(scales_j_32, mask_6bit);
let min_simple = ctx.and_u32(scales_j4_32, mask_6bit);
let zero_safe = ctx.mov_u32_imm(0);
let sub_block_minus_4_raw = ctx.sub_u32_reg(sub_block, four_u32);
let sub_block_minus_4 =
ctx.selp_u32(is_simple, zero_safe, sub_block_minus_4_raw);
let sub_block_minus_4_64 = ctx.cvt_u64_u32(sub_block_minus_4);
let scales_jm4_addr = ctx.add_u64(scales_base, sub_block_minus_4_64);
let scales_jm4 = ctx.ld_global_u8(scales_jm4_addr);
let scales_jm4_32 = ctx.cvt_u32_u8(scales_jm4);
let mask_4bit = ctx.mov_u32_imm(0x0F);
let six = ctx.mov_u32_imm(6);
let s_j4_lo = ctx.and_u32(scales_j4_32, mask_4bit);
let s_jm4_hi = ctx.shr_u32(scales_jm4_32, six);
let s_jm4_hi_shifted = ctx.shl_u32(s_jm4_hi, four_u32);
let scale_complex = ctx.or_u32(s_j4_lo, s_jm4_hi_shifted);
let s_j4_hi = ctx.shr_u32(scales_j4_32, four_u32);
let s_j_hi = ctx.shr_u32(scales_j_32, six);
let s_j_hi_shifted = ctx.shl_u32(s_j_hi, four_u32);
let min_complex = ctx.or_u32(s_j4_hi, s_j_hi_shifted);
let scale_6bit = ctx.selp_u32(is_simple, scale_simple, scale_complex);
let min_6bit = ctx.selp_u32(is_simple, min_simple, min_complex);
let scale_f32 = ctx.cvt_f32_u32(scale_6bit);
let min_f32 = ctx.cvt_f32_u32(min_6bit);
let chunk_idx = ctx.div_u32(val_idx, 64);
let val_in_chunk = ctx.rem_u32(val_idx, 64);
let byte_in_chunk = ctx.rem_u32(val_in_chunk, 32);
let qs_offset_64 = ctx.mov_u64_imm(48);
let qs_base = ctx.add_u64(sb_addr, qs_offset_64);
let chunk_offset = ctx.mul_u32(chunk_idx, 32);
let qs_byte_offset = ctx.add_u32_reg(chunk_offset, byte_in_chunk);
let qs_byte_offset_64 = ctx.cvt_u64_u32(qs_byte_offset);
let qs_addr = ctx.add_u64(qs_base, qs_byte_offset_64);
let packed = ctx.ld_global_u8(qs_addr);
let packed_32 = ctx.cvt_u32_u8(packed);
let four = ctx.mov_u32_imm(4);
let mask_4bit = ctx.mov_u32_imm(0xF);
let val_in_chunk_div_32 = ctx.div_u32(val_in_chunk, 32);
let shift_amount = ctx.mul_u32_reg(val_in_chunk_div_32, four);
let shifted = ctx.shr_u32(packed_32, shift_amount);
let ql = ctx.and_u32(shifted, mask_4bit);
let qh_offset = ctx.mov_u64_imm(16);
let qh_base = ctx.add_u64(sb_addr, qh_offset);
let qh_byte_idx = ctx.div_u32(val_idx, 8);
let qh_bit_idx = ctx.rem_u32(val_idx, 8);
let qh_byte_idx_64 = ctx.cvt_u64_u32(qh_byte_idx);
let qh_addr = ctx.add_u64(qh_base, qh_byte_idx_64);
let qh_byte = ctx.ld_global_u8(qh_addr);
let qh_byte_32 = ctx.cvt_u32_u8(qh_byte);
let qh_shifted = ctx.shr_u32(qh_byte_32, qh_bit_idx);
let mask_1bit = ctx.mov_u32_imm(1);
let qh = ctx.and_u32(qh_shifted, mask_1bit);
let sixteen_u32 = ctx.mov_u32_imm(16);
let qh_scaled = ctx.mul_u32_reg(qh, sixteen_u32);
let quant = ctx.add_u32_reg(ql, qh_scaled);
let quant_f32 = ctx.cvt_f32_u32(quant);
let d_scale = ctx.mul_f32(d, scale_f32);
let scaled = ctx.mul_f32(d_scale, quant_f32);
let dmin_min = ctx.mul_f32(dmin, min_f32);
let dequant = ctx.sub_f32(scaled, dmin_min);
let sb_k_base = ctx.mul_u32(sb_idx, Q5K_SUPER_BLOCK_SIZE);
let x_idx = ctx.add_u32_reg(sb_k_base, val_idx);
let x_idx_64 = ctx.cvt_u64_u32(x_idx);
let x_bytes = ctx.mul_u64(x_idx_64, 4);
let x_addr = ctx.add_u64(x_ptr, x_bytes);
let x_val = ctx.ld_global_f32(x_addr);
ctx.fma_f32_inplace(thread_partial, x_val, dequant);
}
ctx.add_f32_inplace(acc, thread_partial);
ctx.add_u32_inplace(sb_idx, 1);
ctx.branch("sb_loop");
ctx.label("sb_loop_end");
let tmp16 = ctx.shfl_down_f32(acc, 16, 0xFFFF_FFFF);
ctx.add_f32_inplace(acc, tmp16);
let tmp8 = ctx.shfl_down_f32(acc, 8, 0xFFFF_FFFF);
ctx.add_f32_inplace(acc, tmp8);
let tmp4 = ctx.shfl_down_f32(acc, 4, 0xFFFF_FFFF);
ctx.add_f32_inplace(acc, tmp4);
let tmp2 = ctx.shfl_down_f32(acc, 2, 0xFFFF_FFFF);
ctx.add_f32_inplace(acc, tmp2);
let tmp1 = ctx.shfl_down_f32(acc, 1, 0xFFFF_FFFF);
ctx.add_f32_inplace(acc, tmp1);
let one_u32 = ctx.mov_u32_imm(1);
let is_thread0 = ctx.setp_lt_u32(thread_id, one_u32);
ctx.branch_if_not(is_thread0, "exit");
let y_offset = ctx.mul_wide_u32(block_id, 4);
let y_addr = ctx.add_u64(y_ptr, y_offset);
ctx.st_global_f32(y_addr, acc);
ctx.label("exit");
ctx.ret();
})
}
}