Method test_async

crates/fuzzing/src/oom.rs:321–338

The same as `test` but `async`.

(&self, test_func: impl AsyncFn() -> Result<()>)

    /// The same as `test` but `async`.
    pub async fn test_async(&self, test_func: impl AsyncFn() -> Result<()>) -> Result<()> {
        let total_allocs = Self::count_allocations(&test_func).await?;

        let start = time::Instant::now();

        for i in 0..total_allocs {
            if self.max_iters.is_some_and(|n| i >= n)
                || self.max_duration.is_some_and(|d| start.elapsed() >= d)
            {
                break;
            }

            log::trace!("=== Injecting OOM after {i} allocations ===");
            self.run_one_oom_injection(&test_func, i).await?;
        }

        Ok(())
    }

    /// Similar to `test` but instead of exhaustively injecting OOMs on every
    /// allocation, randomly chooses which allocation to OOM each iteration.