openvm_rv32im_circuit/shift/
cuda.rs

1use std::{mem::size_of, sync::Arc};
2
3use derive_new::new;
4use openvm_circuit::{arch::DenseRecordArena, utils::next_power_of_two_or_zero};
5use openvm_circuit_primitives::{
6    bitwise_op_lookup::BitwiseOperationLookupChipGPU, var_range::VariableRangeCheckerChipGPU, Chip,
7};
8use openvm_cuda_backend::{base::DeviceMatrix, prelude::F, GpuBackend};
9use openvm_cuda_common::copy::MemCopyH2D;
10use openvm_stark_backend::prover::AirProvingContext;
11
12use crate::{
13    adapters::{
14        Rv32BaseAluAdapterCols, Rv32BaseAluAdapterRecord, RV32_CELL_BITS, RV32_REGISTER_NUM_LIMBS,
15    },
16    cuda_abi::shift_cuda::tracegen as rv32_shift_tracegen,
17    ShiftCoreCols, ShiftCoreRecord,
18};
19
20#[derive(new)]
21pub struct Rv32ShiftChipGpu {
22    pub range_checker: Arc<VariableRangeCheckerChipGPU>,
23    pub bitwise_lookup: Arc<BitwiseOperationLookupChipGPU<RV32_CELL_BITS>>,
24    pub timestamp_max_bits: usize,
25}
26
27impl Chip<DenseRecordArena, GpuBackend> for Rv32ShiftChipGpu {
28    fn generate_proving_ctx(&self, arena: DenseRecordArena) -> AirProvingContext<GpuBackend> {
29        const RECORD_SIZE: usize = size_of::<(
30            Rv32BaseAluAdapterRecord,
31            ShiftCoreRecord<RV32_REGISTER_NUM_LIMBS, RV32_CELL_BITS>,
32        )>();
33        let records = arena.allocated();
34        if records.is_empty() {
35            return AirProvingContext::simple_no_pis(DeviceMatrix::dummy());
36        }
37        debug_assert_eq!(records.len() % RECORD_SIZE, 0);
38
39        let trace_width = Rv32BaseAluAdapterCols::<F>::width()
40            + ShiftCoreCols::<F, RV32_REGISTER_NUM_LIMBS, RV32_CELL_BITS>::width();
41        let trace_height = next_power_of_two_or_zero(records.len() / RECORD_SIZE);
42        let device_ctx = &self.range_checker.device_ctx;
43
44        let d_records = tracing::info_span!("trace_gen.h2d_records")
45            .in_scope(|| records.to_device_on(device_ctx))
46            .unwrap();
47        let d_trace = DeviceMatrix::<F>::with_capacity_on(trace_height, trace_width, device_ctx);
48        unsafe {
49            rv32_shift_tracegen(
50                d_trace.buffer(),
51                trace_height,
52                &d_records,
53                &self.range_checker.count,
54                &self.bitwise_lookup.count,
55                RV32_CELL_BITS,
56                self.timestamp_max_bits as u32,
57                device_ctx.stream.as_raw(),
58            )
59            .unwrap();
60        }
61
62        AirProvingContext::simple_no_pis(d_trace)
63    }
64}