Skip to content

Commit 0bd0cc6

Browse files
committed
stops pushing LegacyContactInfo updates over gossip
We no longer use LegacyContactInfo and don't need to push updates over gossip.
1 parent 7770cca commit 0bd0cc6

File tree

3 files changed

+14
-24
lines changed

3 files changed

+14
-24
lines changed

gossip/src/cluster_info.rs

+7-17
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,6 @@ use {
3434
duplicate_shred::DuplicateShred,
3535
epoch_slots::EpochSlots,
3636
gossip_error::GossipError,
37-
legacy_contact_info::LegacyContactInfo,
3837
ping_pong::Pong,
3938
protocol::{
4039
split_gossip_messages, Ping, PingCache, Protocol, PruneData,
@@ -284,18 +283,12 @@ impl ClusterInfo {
284283

285284
// TODO kill insert_info, only used by tests
286285
pub fn insert_info(&self, node: ContactInfo) {
287-
let entries: Vec<_> = [
288-
LegacyContactInfo::try_from(&node)
289-
.map(CrdsData::LegacyContactInfo)
290-
.expect("Operator must spin up node with valid contact-info"),
291-
CrdsData::ContactInfo(node),
292-
]
293-
.into_iter()
294-
.map(|entry| CrdsValue::new(entry, &self.keypair()))
295-
.collect();
296-
let mut gossip_crds = self.gossip.crds.write().unwrap();
297-
for entry in entries {
298-
let _ = gossip_crds.insert(entry, timestamp(), GossipRoute::LocalMessage);
286+
let entry = CrdsValue::new(CrdsData::ContactInfo(node), &self.keypair());
287+
if let Err(err) = {
288+
let mut gossip_crds = self.gossip.crds.write().unwrap();
289+
gossip_crds.insert(entry, timestamp(), GossipRoute::LocalMessage)
290+
} {
291+
error!("ClusterInfo.insert_info: {err:?}");
299292
}
300293
}
301294

@@ -1184,9 +1177,6 @@ impl ClusterInfo {
11841177
node.clone()
11851178
};
11861179
let entries: Vec<_> = [
1187-
LegacyContactInfo::try_from(&node)
1188-
.map(CrdsData::LegacyContactInfo)
1189-
.expect("Operator must spin up node with valid contact-info"),
11901180
CrdsData::ContactInfo(node),
11911181
CrdsData::NodeInstance(instance),
11921182
]
@@ -1829,7 +1819,7 @@ impl ClusterInfo {
18291819
score
18301820
};
18311821
let score = match response.data() {
1832-
CrdsData::LegacyContactInfo(_) | CrdsData::ContactInfo(_) => 2 * score,
1822+
CrdsData::ContactInfo(_) => 2 * score,
18331823
_ => score,
18341824
};
18351825
((addr, response), score)

gossip/src/contact_info.rs

+1
Original file line numberDiff line numberDiff line change
@@ -615,6 +615,7 @@ fn sanitize_entries(addrs: &[IpAddr], sockets: &[SocketEntry]) -> Result<(), Err
615615
}
616616

617617
// Verifies that the other socket is at QUIC_PORT_OFFSET from the first one.
618+
#[cfg(test)]
618619
pub(crate) fn sanitize_quic_offset(
619620
socket: &Option<SocketAddr>, // udp
620621
other: &Option<SocketAddr>, // quic: udp + QUIC_PORT_OFFSET

gossip/src/legacy_contact_info.rs

+6-7
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,10 @@
11
#[cfg(test)]
2-
use crate::contact_info::{get_quic_socket, sanitize_socket};
2+
use crate::contact_info::{
3+
get_quic_socket, sanitize_quic_offset, sanitize_socket, ContactInfo, Error, Protocol,
4+
SOCKET_ADDR_UNSPECIFIED,
5+
};
36
use {
4-
crate::{
5-
contact_info::{
6-
sanitize_quic_offset, ContactInfo, Error, Protocol, SOCKET_ADDR_UNSPECIFIED,
7-
},
8-
crds_data::MAX_WALLCLOCK,
9-
},
7+
crate::crds_data::MAX_WALLCLOCK,
108
solana_pubkey::Pubkey,
119
solana_sanitize::{Sanitize, SanitizeError},
1210
solana_streamer::socket::SocketAddrSpace,
@@ -169,6 +167,7 @@ impl LegacyContactInfo {
169167
}
170168
}
171169

170+
#[cfg(test)]
172171
impl TryFrom<&ContactInfo> for LegacyContactInfo {
173172
type Error = Error;
174173

0 commit comments

Comments
 (0)