moves DATA_PLANE_FANOUT to turbine (#32744)
This commit is contained in:
parent
fa3506631a
commit
0511753276
|
@ -99,8 +99,6 @@ use {
|
||||||
thiserror::Error,
|
thiserror::Error,
|
||||||
};
|
};
|
||||||
|
|
||||||
/// The Data plane fanout size, also used as the neighborhood size
|
|
||||||
pub const DATA_PLANE_FANOUT: usize = 200;
|
|
||||||
/// milliseconds we sleep for between gossip requests
|
/// milliseconds we sleep for between gossip requests
|
||||||
pub const GOSSIP_SLEEP_MILLIS: u64 = 100;
|
pub const GOSSIP_SLEEP_MILLIS: u64 = 100;
|
||||||
/// The maximum size of a bloom filter
|
/// The maximum size of a bloom filter
|
||||||
|
|
|
@ -44,11 +44,8 @@ fn get_retransmit_peers_deterministic(
|
||||||
0,
|
0,
|
||||||
0,
|
0,
|
||||||
);
|
);
|
||||||
let _retransmit_peers = cluster_nodes.get_retransmit_peers(
|
let _retransmit_peers =
|
||||||
slot_leader,
|
cluster_nodes.get_retransmit_peers(slot_leader, &shred.id(), /*fanout:*/ 200);
|
||||||
&shred.id(),
|
|
||||||
solana_gossip::cluster_info::DATA_PLANE_FANOUT,
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -5,7 +5,7 @@ use {
|
||||||
rand::{seq::SliceRandom, Rng, SeedableRng},
|
rand::{seq::SliceRandom, Rng, SeedableRng},
|
||||||
rand_chacha::ChaChaRng,
|
rand_chacha::ChaChaRng,
|
||||||
solana_gossip::{
|
solana_gossip::{
|
||||||
cluster_info::{ClusterInfo, DATA_PLANE_FANOUT},
|
cluster_info::ClusterInfo,
|
||||||
contact_info::{LegacyContactInfo as ContactInfo, LegacyContactInfo, Protocol},
|
contact_info::{LegacyContactInfo as ContactInfo, LegacyContactInfo, Protocol},
|
||||||
crds::GossipRoute,
|
crds::GossipRoute,
|
||||||
crds_gossip_pull::CRDS_GOSSIP_PULL_CRDS_TIMEOUT_MS,
|
crds_gossip_pull::CRDS_GOSSIP_PULL_CRDS_TIMEOUT_MS,
|
||||||
|
@ -36,6 +36,7 @@ use {
|
||||||
thiserror::Error,
|
thiserror::Error,
|
||||||
};
|
};
|
||||||
|
|
||||||
|
const DATA_PLANE_FANOUT: usize = 200;
|
||||||
pub(crate) const MAX_NUM_TURBINE_HOPS: usize = 4;
|
pub(crate) const MAX_NUM_TURBINE_HOPS: usize = 4;
|
||||||
|
|
||||||
#[derive(Debug, Error)]
|
#[derive(Debug, Error)]
|
||||||
|
|
Loading…
Reference in New Issue