gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Disable entire codepath (#10767)

Browse Source 
Co-authored-by: Carl <carl@solana.com>
This commit is contained in:
carllin
2020-06-24 12:09:55 -07:00
committed by GitHub
parent 0b14ae5725
commit 764c7b0403
2 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
core/src/repair_service.rs
View File

@ -151,7 +151,7 @@ impl RepairService {
Self::initialize_lowest_slot(id, blockstore, &cluster_info); Self::initialize_lowest_slot(id, blockstore, &cluster_info);
let mut repair_stats = RepairStats::default(); let mut repair_stats = RepairStats::default();
let mut last_stats = Instant::now(); let mut last_stats = Instant::now();
let mut duplicate_slot_repair_statuses = HashMap::new(); let duplicate_slot_repair_statuses = HashMap::new();
Self::initialize_epoch_slots( Self::initialize_epoch_slots(
blockstore, blockstore,
&cluster_info, &cluster_info,
@ -169,7 +169,7 @@ impl RepairService {
Self::update_lowest_slot(&id, lowest_slot, &cluster_info); Self::update_lowest_slot(&id, lowest_slot, &cluster_info);
Self::update_completed_slots(&repair_info.completed_slots_receiver, &cluster_info); Self::update_completed_slots(&repair_info.completed_slots_receiver, &cluster_info);
cluster_slots.update(new_root, &cluster_info, &repair_info.bank_forks); cluster_slots.update(new_root, &cluster_info, &repair_info.bank_forks);
let new_duplicate_slots = Self::find_new_duplicate_slots( /*let new_duplicate_slots = Self::find_new_duplicate_slots(
&duplicate_slot_repair_statuses, &duplicate_slot_repair_statuses,
blockstore, blockstore,
cluster_slots, cluster_slots,
@ -191,7 +191,7 @@ impl RepairService {
&serve_repair, &serve_repair,
&mut repair_stats, &mut repair_stats,
&repair_socket, &repair_socket,
); );*/
Self::generate_repairs( Self::generate_repairs(
blockstore, blockstore,
root_bank.slot(), root_bank.slot(),
@ -299,6 +299,7 @@ impl RepairService {
Ok(repairs) Ok(repairs)
} }
#[allow(dead_code)]
fn generate_duplicate_repairs_for_slot( fn generate_duplicate_repairs_for_slot(
blockstore: &Blockstore, blockstore: &Blockstore,
slot: Slot, slot: Slot,
@ -323,6 +324,7 @@ impl RepairService {
} }
} }
#[allow(dead_code)]
fn generate_and_send_duplicate_repairs( fn generate_and_send_duplicate_repairs(
duplicate_slot_repair_statuses: &mut HashMap<Slot, DuplicateSlotRepairStatus>, duplicate_slot_repair_statuses: &mut HashMap<Slot, DuplicateSlotRepairStatus>,
cluster_slots: &ClusterSlots, cluster_slots: &ClusterSlots,
@ -363,6 +365,7 @@ impl RepairService {
}) })
} }
#[allow(dead_code)]
fn serialize_and_send_request( fn serialize_and_send_request(
repair_type: &RepairType, repair_type: &RepairType,
repair_socket: &UdpSocket, repair_socket: &UdpSocket,
@ -378,6 +381,7 @@ impl RepairService {
Ok(()) Ok(())
} }
#[allow(dead_code)]
fn update_duplicate_slot_repair_addr( fn update_duplicate_slot_repair_addr(
slot: Slot, slot: Slot,
status: &mut DuplicateSlotRepairStatus, status: &mut DuplicateSlotRepairStatus,
@ -395,6 +399,7 @@ impl RepairService {
} }
} }
#[allow(dead_code)]
fn process_new_duplicate_slots( fn process_new_duplicate_slots(
new_duplicate_slots: &[Slot], new_duplicate_slots: &[Slot],
duplicate_slot_repair_statuses: &mut HashMap<Slot, DuplicateSlotRepairStatus>, duplicate_slot_repair_statuses: &mut HashMap<Slot, DuplicateSlotRepairStatus>,
@ -438,6 +443,7 @@ impl RepairService {
} }
} }
#[allow(dead_code)]
fn find_new_duplicate_slots( fn find_new_duplicate_slots(
duplicate_slot_repair_statuses: &HashMap<Slot, DuplicateSlotRepairStatus>, duplicate_slot_repair_statuses: &HashMap<Slot, DuplicateSlotRepairStatus>,
blockstore: &Blockstore, blockstore: &Blockstore,

1
local-cluster/tests/local_cluster.rs
View File

@ -1071,6 +1071,7 @@ fn test_snapshots_restart_validity() {
#[test] #[test]
#[serial] #[serial]
#[allow(unused_attributes)] #[allow(unused_attributes)]
#[ignore]
fn test_fail_entry_verification_leader() { fn test_fail_entry_verification_leader() {
test_faulty_node(BroadcastStageType::FailEntryVerification); test_faulty_node(BroadcastStageType::FailEntryVerification);
} }