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

Don't push empty vecs into the unprocessed buffers (#4214)

Browse Source
This commit is contained in:
sakridge
2019-05-08 17:58:07 -07:00
committed by Pankaj Garg
parent 5a86f2506d
commit 9cdffc7d64
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
core/src/banking_stage.rs
View File

@@ -171,9 +171,11 @@ impl BankingStage {
if processed < verified_txs_len { if processed < verified_txs_len {
bank_shutdown = true; bank_shutdown = true;
} }
rebuffered_packets += new_unprocessed_indexes.len();
// Collect any unprocessed transactions in this batch for forwarding // Collect any unprocessed transactions in this batch for forwarding
unprocessed_packets.push((msgs.to_owned(), new_unprocessed_indexes)); if !new_unprocessed_indexes.is_empty() {
rebuffered_packets += new_unprocessed_indexes.len();
unprocessed_packets.push((msgs.to_owned(), new_unprocessed_indexes));
}
} }
inc_new_counter_info!("banking_stage-rebuffered_packets", rebuffered_packets); inc_new_counter_info!("banking_stage-rebuffered_packets", rebuffered_packets);
@@ -637,7 +639,9 @@ impl BankingStage {
bank_shutdown = true; bank_shutdown = true;
} }
// Collect any unprocessed transactions in this batch for forwarding // Collect any unprocessed transactions in this batch for forwarding
unprocessed_packets.push((msgs, unprocessed_indexes)); if !unprocessed_indexes.is_empty() {
unprocessed_packets.push((msgs, unprocessed_indexes));
}
new_tx_count += processed; new_tx_count += processed;
} }