@@ -123,7 +123,7 @@ impl ReplayStage {
 | 
				
			|||||||
                        &leader_schedule_cache,
 | 
					                        &leader_schedule_cache,
 | 
				
			||||||
                    );
 | 
					                    );
 | 
				
			||||||
 | 
					
 | 
				
			||||||
                    let did_process_bank = Self::replay_active_banks(
 | 
					                    let did_complete_bank = Self::replay_active_banks(
 | 
				
			||||||
                        &blocktree,
 | 
					                        &blocktree,
 | 
				
			||||||
                        &bank_forks,
 | 
					                        &bank_forks,
 | 
				
			||||||
                        &my_pubkey,
 | 
					                        &my_pubkey,
 | 
				
			||||||
@@ -170,7 +170,7 @@ impl ReplayStage {
 | 
				
			|||||||
                        "replicate_stage-duration",
 | 
					                        "replicate_stage-duration",
 | 
				
			||||||
                        duration_as_ms(&now.elapsed()) as usize
 | 
					                        duration_as_ms(&now.elapsed()) as usize
 | 
				
			||||||
                    );
 | 
					                    );
 | 
				
			||||||
                    if did_process_bank {
 | 
					                    if did_complete_bank {
 | 
				
			||||||
                        //just processed a bank, skip the signal; maybe there's more slots available
 | 
					                        //just processed a bank, skip the signal; maybe there's more slots available
 | 
				
			||||||
                        continue;
 | 
					                        continue;
 | 
				
			||||||
                    }
 | 
					                    }
 | 
				
			||||||
@@ -421,7 +421,7 @@ impl ReplayStage {
 | 
				
			|||||||
        progress: &mut HashMap<u64, ForkProgress>,
 | 
					        progress: &mut HashMap<u64, ForkProgress>,
 | 
				
			||||||
        slot_full_sender: &Sender<(u64, Pubkey)>,
 | 
					        slot_full_sender: &Sender<(u64, Pubkey)>,
 | 
				
			||||||
    ) -> bool {
 | 
					    ) -> bool {
 | 
				
			||||||
        let mut did_process_bank = false;
 | 
					        let mut did_complete_bank = false;
 | 
				
			||||||
        let active_banks = bank_forks.read().unwrap().active_banks();
 | 
					        let active_banks = bank_forks.read().unwrap().active_banks();
 | 
				
			||||||
        trace!("active banks {:?}", active_banks);
 | 
					        trace!("active banks {:?}", active_banks);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@@ -444,7 +444,7 @@ impl ReplayStage {
 | 
				
			|||||||
            }
 | 
					            }
 | 
				
			||||||
            assert_eq!(*bank_slot, bank.slot());
 | 
					            assert_eq!(*bank_slot, bank.slot());
 | 
				
			||||||
            if bank.tick_height() == bank.max_tick_height() {
 | 
					            if bank.tick_height() == bank.max_tick_height() {
 | 
				
			||||||
                did_process_bank = true;
 | 
					                did_complete_bank = true;
 | 
				
			||||||
                Self::process_completed_bank(my_pubkey, bank, slot_full_sender);
 | 
					                Self::process_completed_bank(my_pubkey, bank, slot_full_sender);
 | 
				
			||||||
            } else {
 | 
					            } else {
 | 
				
			||||||
                trace!(
 | 
					                trace!(
 | 
				
			||||||
@@ -455,7 +455,7 @@ impl ReplayStage {
 | 
				
			|||||||
                );
 | 
					                );
 | 
				
			||||||
            }
 | 
					            }
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
        did_process_bank
 | 
					        did_complete_bank
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    fn generate_votable_banks(
 | 
					    fn generate_votable_banks(
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user