Function holochain::conductor::p2p_agent_store::exchange_peer_info_sparse

source · 
pub async fn exchange_peer_info_sparse(
    envs: Vec<DbWrite<DbKindP2pAgents>>,
    connectivity: Vec<HashSet<usize>>
)
Expand description

Interconnect provided pair of conductors via their peer store databases, according to the connectivity matrix

Examples found in repository?
src/sweettest/sweet_conductor.rs (line 495)
483
484
485
486
487
488
489
490
491
492
493
494
495
496

    pub async fn exchange_peer_info_sampled(
        conductors: impl IntoIterator<Item = &Self>,
        rng: &mut StdRng,
        s: usize,
    ) {
        let mut all = Vec::new();
        for c in conductors.into_iter() {
            for env in c.spaces.get_from_spaces(|s| s.p2p_agents_db.clone()) {
                all.push(env.clone());
            }
        }
        let connectivity = covering(rng, all.len(), s);
        crate::conductor::p2p_agent_store::exchange_peer_info_sparse(all, connectivity).await;
    }