blockworks-foundation
/
solana
mirror of https://github.com/blockworks-foundation/solana.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Track discard time of excess packets in sigverify (#22554) 

* discard time histogram

* closer to the if

* update
This commit is contained in:
anatoly yakovenko 2022-01-18 14:09:39 -08:00 committed by GitHub
parent 8dc6f9f589
commit e616a7ebfc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 29 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
core/src/sigverify_stage.rs
View File

@ -48,6 +48,7 @@ pub struct DisabledSigVerifier {}
struct SigVerifierStats { struct SigVerifierStats {
recv_batches_us_hist: histogram::Histogram, // time to call recv_batch recv_batches_us_hist: histogram::Histogram, // time to call recv_batch
verify_batches_pp_us_hist: histogram::Histogram, // per-packet time to call verify_batch verify_batches_pp_us_hist: histogram::Histogram, // per-packet time to call verify_batch
discard_packets_pp_us_hist: histogram::Histogram, // per-packet time to call verify_batch
batches_hist: histogram::Histogram, // number of packet batches per verify call batches_hist: histogram::Histogram, // number of packet batches per verify call
packets_hist: histogram::Histogram, // number of packets per verify call packets_hist: histogram::Histogram, // number of packets per verify call
total_batches: usize, total_batches: usize,
@ -98,6 +99,28 @@ impl SigVerifierStats {
self.verify_batches_pp_us_hist.mean().unwrap_or(0), self.verify_batches_pp_us_hist.mean().unwrap_or(0),
i64 i64
), ),
(
"discard_packets_pp_us_90pct",
self.discard_packets_pp_us_hist
.percentile(90.0)
.unwrap_or(0),
i64
),
(
"discard_packets_pp_us_min",
self.discard_packets_pp_us_hist.minimum().unwrap_or(0),
i64
),
(
"discard_packets_pp_us_max",
self.discard_packets_pp_us_hist.maximum().unwrap_or(0),
i64
),
(
"discard_packets_pp_us_mean",
self.discard_packets_pp_us_hist.mean().unwrap_or(0),
i64
),
( (
"batches_90pct", "batches_90pct",
self.batches_hist.percentile(90.0).unwrap_or(0), self.batches_hist.percentile(90.0).unwrap_or(0),
@ -183,10 +206,11 @@ impl SigVerifyStage {
timing::timestamp(), timing::timestamp(),
num_packets, num_packets,
); );
let mut discard_time = Measure::start("sigverify_discard_time");
if num_packets > MAX_SIGVERIFY_BATCH { if num_packets > MAX_SIGVERIFY_BATCH {
Self::discard_excess_packets(&mut batches, MAX_SIGVERIFY_BATCH); Self::discard_excess_packets(&mut batches, MAX_SIGVERIFY_BATCH);
} }
discard_time.stop();
let mut verify_batch_time = Measure::start("sigverify_batch_time"); let mut verify_batch_time = Measure::start("sigverify_batch_time");
sendr.send(verifier.verify_batches(batches))?; sendr.send(verifier.verify_batches(batches))?;
verify_batch_time.stop(); verify_batch_time.stop();
@ -208,6 +232,10 @@ impl SigVerifyStage {
.verify_batches_pp_us_hist .verify_batches_pp_us_hist
.increment(verify_batch_time.as_us() / (num_packets as u64)) .increment(verify_batch_time.as_us() / (num_packets as u64))
.unwrap(); .unwrap();
stats
.discard_packets_pp_us_hist
.increment(discard_time.as_us() / (num_packets as u64))
.unwrap();
stats.batches_hist.increment(batches_len as u64).unwrap(); stats.batches_hist.increment(batches_len as u64).unwrap();
stats.packets_hist.increment(num_packets as u64).unwrap(); stats.packets_hist.increment(num_packets as u64).unwrap();
stats.total_batches += batches_len; stats.total_batches += batches_len;