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

Disable repeated slot dumping (#10606)

Browse Source 
* Disable repeated slot dumping

* Disable entire codepath

Co-authored-by: Carl <carl@solana.com>
This commit is contained in:
carllin
2020-06-15 18:00:23 -07:00
committed by GitHub
parent d396a5f45a
commit 43cd5f3730
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

@ -128,7 +128,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,
@ -146,7 +146,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,
@ -168,7 +168,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(),
@ -274,6 +274,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,
@ -298,6 +299,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,
@ -334,6 +336,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,
@ -347,6 +350,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,
@ -364,6 +368,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>,
@ -407,6 +412,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

@ -1069,6 +1069,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);
} }