getClusterNodes now excludes validators with a different shred version

This commit is contained in:
Michael Vines 2020-01-28 11:14:25 -07:00
parent e6803daf10
commit c4faccc77f
1 changed files with 4 additions and 1 deletions

View File

@ -728,11 +728,14 @@ impl RpcSol for RpcSolImpl {
None
}
}
let shred_version = cluster_info.my_data().shred_version;
Ok(cluster_info
.all_peers()
.iter()
.filter_map(|(contact_info, _)| {
if ContactInfo::is_valid_address(&contact_info.gossip) {
if shred_version == contact_info.shred_version
&& ContactInfo::is_valid_address(&contact_info.gossip)
{
Some(RpcContactInfo {
pubkey: contact_info.id.to_string(),
gossip: Some(contact_info.gossip),