Method new

crates/bench-api/src/lib.rs:467–551

(
        mut options: CommonOptions,
        compilation_timer: *mut u8,
        compilation_start: extern "C" fn(*mut u8),
        compilation_end: extern "C" fn(*mut u8),
        instantiation_time

impl BenchState {
    fn new(
        mut options: CommonOptions,
        compilation_timer: *mut u8,
        compilation_start: extern "C" fn(*mut u8),
        compilation_end: extern "C" fn(*mut u8),
        instantiation_timer: *mut u8,
        instantiation_start: extern "C" fn(*mut u8),
        instantiation_end: extern "C" fn(*mut u8),
        execution_timer: *mut u8,
        execution_start: extern "C" fn(*mut u8),
        execution_end: extern "C" fn(*mut u8),
        make_wasi_cx: impl FnMut() -> Result<WasiP1Ctx> + 'static,
        make_component_wasi_cx: impl FnMut() -> Result<ComponentHostState> + 'static,
    ) -> Result<Self> {
        let mut config = options.config(None)?;
        // NB: always disable the compilation cache.
        config.cache(None);
        let engine = Engine::new(&config)?;
        let mut linker = Linker::<HostState>::new(&engine);
        let mut component_linker = wasmtime::component::Linker::<ComponentHostState>::new(&engine);

        // Define the benchmarking start/end functions.
        let execution_timer = unsafe {
            // Safe because this bench API's contract requires that its methods
            // are only ever called from a single thread.
            UnsafeSendSync::new(execution_timer)
        };
        linker.func_wrap("bench", "start", move || {
            execution_start(*execution_timer.get());
            Ok(())
        })?;
        linker.func_wrap("bench", "end", move || {
            execution_end(*execution_timer.get());
            Ok(())
        })?;

        // Define the same benchmarking functions on the component linker.
        let mut bench_instance = component_linker.instance("bench")?;
        bench_instance.func_wrap(
            "start",
            move |_: wasmtime::StoreContextMut<'_, ComponentHostState>, (): ()| {
                execution_start(*execution_timer.get());
                Ok(())
            },
        )?;
        bench_instance.func_wrap(
            "end",
            move |_: wasmtime::StoreContextMut<'_, ComponentHostState>, (): ()| {
                execution_end(*execution_timer.get());
                Ok(())
            },
        )?;

        let epoch_interruption = options.wasm.epoch_interruption.unwrap_or(false);
        let fuel = options.wasm.fuel;

        if options.wasi.common != Some(false) {
            wasmtime_wasi::p1::add_to_linker_sync(&mut linker, |cx| &mut cx.wasi)?;