Function get_memory_executor

src/executor/tests.rs:388–414

()

    use crate::executor::memory::executor::MemoryExecutor;

    async fn get_memory_executor() -> (
        SemaphorePermit<'static>,
        SemaphorePermit<'static>,
        MemoryExecutor,
    ) {
        static MEMORY_INIT: OnceCell<()> = OnceCell::const_new();
        static MEMORY_SEMAPHORE: OnceCell<Semaphore> = OnceCell::const_new();

        MEMORY_INIT
            .get_or_init(|| async {
                let executor = MemoryExecutor;
                let system_info = SystemInfo::new().unwrap();
                executor.setup(&system_info, None).await.unwrap();
                executor.grant_privileges().unwrap();
            })
            .await;

        let semaphore = MEMORY_SEMAPHORE
            .get_or_init(|| async { Semaphore::new(1) })
            .await;
        let permit = semaphore.acquire().await.unwrap();

        // Memory executor uses heaptrack which uses BPF-based instrumentation, which conflicts with valgrind.
        let _lock = acquire_bpf_instrumentation_lock().await;

        (permit, _lock, MemoryExecutor)
    }

    fn memory_config(command: &str) -> ExecutorConfig {
        ExecutorConfig {