Skip to content
This repository was archived by the owner on Jan 22, 2025. It is now read-only.

Commit 0511753

Browse files
authored
moves DATA_PLANE_FANOUT to turbine (#32744)
1 parent fa35066 commit 0511753

File tree

3 files changed

+4
-8
lines changed

3 files changed

+4
-8
lines changed

gossip/src/cluster_info.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -99,8 +99,6 @@ use {
9999
thiserror::Error,
100100
};
101101

102-
/// The Data plane fanout size, also used as the neighborhood size
103-
pub const DATA_PLANE_FANOUT: usize = 200;
104102
/// milliseconds we sleep for between gossip requests
105103
pub const GOSSIP_SLEEP_MILLIS: u64 = 100;
106104
/// The maximum size of a bloom filter

turbine/benches/cluster_nodes.rs

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -44,11 +44,8 @@ fn get_retransmit_peers_deterministic(
4444
0,
4545
0,
4646
);
47-
let _retransmit_peers = cluster_nodes.get_retransmit_peers(
48-
slot_leader,
49-
&shred.id(),
50-
solana_gossip::cluster_info::DATA_PLANE_FANOUT,
51-
);
47+
let _retransmit_peers =
48+
cluster_nodes.get_retransmit_peers(slot_leader, &shred.id(), /*fanout:*/ 200);
5249
}
5350
}
5451

turbine/src/cluster_nodes.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ use {
55
rand::{seq::SliceRandom, Rng, SeedableRng},
66
rand_chacha::ChaChaRng,
77
solana_gossip::{
8-
cluster_info::{ClusterInfo, DATA_PLANE_FANOUT},
8+
cluster_info::ClusterInfo,
99
contact_info::{LegacyContactInfo as ContactInfo, LegacyContactInfo, Protocol},
1010
crds::GossipRoute,
1111
crds_gossip_pull::CRDS_GOSSIP_PULL_CRDS_TIMEOUT_MS,
@@ -36,6 +36,7 @@ use {
3636
thiserror::Error,
3737
};
3838

39+
const DATA_PLANE_FANOUT: usize = 200;
3940
pub(crate) const MAX_NUM_TURBINE_HOPS: usize = 4;
4041

4142
#[derive(Debug, Error)]

0 commit comments

Comments
 (0)