Function test_get_minimum_stake

rpc/tests/integration_test.rs:231–260

()

    let key_store_path = temp_dir.path().to_str().unwrap().to_string();

    let server = SummitRpcServer::new(
        key_store_path,
        mailbox,
        TEST_GENESIS_HASH,
        b"_SUMMIT",
        None,
        #[cfg(feature = "permissioned")]
        Arc::new(AtomicBool::new(false)),
    );

    let cap = MAX_CONCURRENT_STATE_PROOFS;

    // Keep cap - 1 proof requests in flight, held open by the gated mock.
    let mut held = Vec::new();
    for _ in 0..(cap - 1) {
        let server = server.clone();
        held.push(tokio::spawn(async move {
            let _ = server.get_state_proof(vec!["epoch".to_string()]).await;
        }));
    }

    // Start the cap-th request; it acquires the last slot and hands its permit
    // to the (gated) proof task.
    let cancel = {
        let server = server.clone();
        tokio::spawn(async move {
            let _ = server.get_state_proof(vec!["epoch".to_string()]).await;
        })
    };

    // Wait until every request has reached the mock, so all cap slots are
    // acquired and all permits are now owned by the mock's detached tasks.
    let deadline = tokio::time::Instant::now() + Duration::from_secs(5);