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

metrics for poh_recorder.record (#15998)

This commit is contained in:
Jeff Washington (jwash) 2021-03-19 09:48:55 -05:00 committed by GitHub
parent 3da9ab5d83
commit ddc758439e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 27 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
core/src/poh_recorder.rs
View File

@ -77,6 +77,10 @@ pub struct PohRecorder {
poh_config: Arc<PohConfig>, poh_config: Arc<PohConfig>,
ticks_per_slot: u64, ticks_per_slot: u64,
record_lock_contention_us: u64, record_lock_contention_us: u64,
flush_cache_no_tick_us: u64,
flush_cache_tick_us: u64,
prepare_send_us: u64,
send_us: u64,
tick_lock_contention_us: u64, tick_lock_contention_us: u64,
tick_overhead_us: u64, tick_overhead_us: u64,
record_us: u64, record_us: u64,
@ -390,11 +394,13 @@ impl PohRecorder {
hash: poh_entry.hash, hash: poh_entry.hash,
transactions: vec![], transactions: vec![],
}; };
self.tick_overhead_us += timing::duration_as_us(&now.elapsed());
let now = Instant::now();
self.tick_cache.push((entry, self.tick_height)); self.tick_cache.push((entry, self.tick_height));
let _ = self.flush_cache(true); let _ = self.flush_cache(true);
self.flush_cache_tick_us += timing::duration_as_us(&now.elapsed());
} }
self.tick_overhead_us += timing::duration_as_us(&now.elapsed());
} }
fn report_metrics(&mut self, bank_slot: Slot) { fn report_metrics(&mut self, bank_slot: Slot) {
@ -404,6 +410,10 @@ impl PohRecorder {
("slot", bank_slot, i64), ("slot", bank_slot, i64),
("tick_lock_contention", self.tick_lock_contention_us, i64), ("tick_lock_contention", self.tick_lock_contention_us, i64),
("record_us", self.record_us, i64), ("record_us", self.record_us, i64),
("flush_cache_no_tick_us", self.flush_cache_no_tick_us, i64),
("flush_cache_tick_us", self.flush_cache_tick_us, i64),
("prepare_send_us", self.prepare_send_us, i64),
("send_us", self.send_us, i64),
("tick_overhead", self.tick_overhead_us, i64), ("tick_overhead", self.tick_overhead_us, i64),
( (
"record_lock_contention", "record_lock_contention",
@ -416,6 +426,10 @@ impl PohRecorder {
self.record_us = 0; self.record_us = 0;
self.tick_overhead_us = 0; self.tick_overhead_us = 0;
self.record_lock_contention_us = 0; self.record_lock_contention_us = 0;
self.flush_cache_no_tick_us = 0;
self.flush_cache_tick_us = 0;
self.prepare_send_us = 0;
self.send_us = 0;
self.last_metric = Instant::now(); self.last_metric = Instant::now();
} }
} }
@ -431,7 +445,9 @@ impl PohRecorder {
assert!(!transactions.is_empty(), "No transactions provided"); assert!(!transactions.is_empty(), "No transactions provided");
self.report_metrics(bank_slot); self.report_metrics(bank_slot);
loop { loop {
let now = Instant::now();
self.flush_cache(false)?; self.flush_cache(false)?;
self.flush_cache_no_tick_us += timing::duration_as_us(&now.elapsed());
let working_bank = self let working_bank = self
.working_bank .working_bank
@ -450,14 +466,18 @@ impl PohRecorder {
let res = poh_lock.record(mixin); let res = poh_lock.record(mixin);
drop(poh_lock); drop(poh_lock);
self.record_us += timing::duration_as_us(&now.elapsed()); self.record_us += timing::duration_as_us(&now.elapsed());
let now = Instant::now();
if let Some(poh_entry) = res { if let Some(poh_entry) = res {
let entry = Entry { let entry = Entry {
num_hashes: poh_entry.num_hashes, num_hashes: poh_entry.num_hashes,
hash: poh_entry.hash, hash: poh_entry.hash,
transactions, transactions,
}; };
self.sender let bank_clone = working_bank.bank.clone();
.send((working_bank.bank.clone(), (entry, self.tick_height)))?; self.prepare_send_us += timing::duration_as_us(&now.elapsed());
let now = Instant::now();
self.sender.send((bank_clone, (entry, self.tick_height)))?;
self.send_us += timing::duration_as_us(&now.elapsed());
return Ok(()); return Ok(());
} }
} }
@ -506,6 +526,10 @@ impl PohRecorder {
ticks_per_slot, ticks_per_slot,
poh_config: poh_config.clone(), poh_config: poh_config.clone(),
record_lock_contention_us: 0, record_lock_contention_us: 0,
flush_cache_tick_us: 0,
flush_cache_no_tick_us: 0,
prepare_send_us: 0,
send_us: 0,
tick_lock_contention_us: 0, tick_lock_contention_us: 0,
record_us: 0, record_us: 0,
tick_overhead_us: 0, tick_overhead_us: 0,