From 764c7b0403b1d72187cdb62c3d988fec1aac44fb Mon Sep 17 00:00:00 2001 From: carllin Date: Wed, 24 Jun 2020 12:09:55 -0700 Subject: [PATCH] Disable entire codepath (#10767) Co-authored-by: Carl --- core/src/repair_service.rs | 12 +++++++++--- local-cluster/tests/local_cluster.rs | 1 + 2 files changed, 10 insertions(+), 3 deletions(-) diff --git a/core/src/repair_service.rs b/core/src/repair_service.rs index 33bdf725a..b18ea8a92 100644 --- a/core/src/repair_service.rs +++ b/core/src/repair_service.rs @@ -151,7 +151,7 @@ impl RepairService { Self::initialize_lowest_slot(id, blockstore, &cluster_info); let mut repair_stats = RepairStats::default(); 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( blockstore, &cluster_info, @@ -169,7 +169,7 @@ impl RepairService { Self::update_lowest_slot(&id, lowest_slot, &cluster_info); Self::update_completed_slots(&repair_info.completed_slots_receiver, &cluster_info); 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, blockstore, cluster_slots, @@ -191,7 +191,7 @@ impl RepairService { &serve_repair, &mut repair_stats, &repair_socket, - ); + );*/ Self::generate_repairs( blockstore, root_bank.slot(), @@ -299,6 +299,7 @@ impl RepairService { Ok(repairs) } + #[allow(dead_code)] fn generate_duplicate_repairs_for_slot( blockstore: &Blockstore, slot: Slot, @@ -323,6 +324,7 @@ impl RepairService { } } + #[allow(dead_code)] fn generate_and_send_duplicate_repairs( duplicate_slot_repair_statuses: &mut HashMap, cluster_slots: &ClusterSlots, @@ -363,6 +365,7 @@ impl RepairService { }) } + #[allow(dead_code)] fn serialize_and_send_request( repair_type: &RepairType, repair_socket: &UdpSocket, @@ -378,6 +381,7 @@ impl RepairService { Ok(()) } + #[allow(dead_code)] fn update_duplicate_slot_repair_addr( slot: Slot, status: &mut DuplicateSlotRepairStatus, @@ -395,6 +399,7 @@ impl RepairService { } } + #[allow(dead_code)] fn process_new_duplicate_slots( new_duplicate_slots: &[Slot], duplicate_slot_repair_statuses: &mut HashMap, @@ -438,6 +443,7 @@ impl RepairService { } } + #[allow(dead_code)] fn find_new_duplicate_slots( duplicate_slot_repair_statuses: &HashMap, blockstore: &Blockstore, diff --git a/local-cluster/tests/local_cluster.rs b/local-cluster/tests/local_cluster.rs index 736ebffa5..06fa4e2e4 100644 --- a/local-cluster/tests/local_cluster.rs +++ b/local-cluster/tests/local_cluster.rs @@ -1071,6 +1071,7 @@ fn test_snapshots_restart_validity() { #[test] #[serial] #[allow(unused_attributes)] +#[ignore] fn test_fail_entry_verification_leader() { test_faulty_node(BroadcastStageType::FailEntryVerification); }