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

bypass retransmission for slots without propagated stats (#22176)

Browse Source
This commit is contained in:
Jeff Biseda
2021-12-30 16:07:34 -08:00
committed by GitHub
parent 4e4577afbe
commit 95dfcc546a
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
core/src/replay_stage.rs
View File

@ -857,7 +857,11 @@ impl ReplayStage {
) { ) {
let start_slot = poh_recorder.lock().unwrap().start_slot(); let start_slot = poh_recorder.lock().unwrap().start_slot();
if let Some(latest_leader_slot) = progress.get_latest_leader_slot(start_slot) { if let Some(latest_leader_slot) = progress.get_latest_leader_slot(start_slot) {
if !progress.is_propagated(latest_leader_slot) { if !progress
.get_propagated_stats(latest_leader_slot)
.map(|stats| stats.is_propagated)
.unwrap_or(true)
{
warn!("Slot not propagated: slot={}", latest_leader_slot); warn!("Slot not propagated: slot={}", latest_leader_slot);
let retransmit_info = progress.get_retransmit_info(latest_leader_slot).unwrap(); let retransmit_info = progress.get_retransmit_info(latest_leader_slot).unwrap();
if retransmit_info.reached_retransmit_threshold() { if retransmit_info.reached_retransmit_threshold() {