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

report a datapoint

This commit is contained in:
Haoran Yi 2022-08-26 14:29:01 -05:00 committed by HaoranYi
parent 7e722f15f2
commit 8f3c1e3ebb
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
runtime/src/accounts_background_service.rs
View File

@ -68,7 +68,7 @@ impl PrunedBankQueueLenReporter {
if q_len > MAX_DROP_BANK_SIGNAL_QUEUE_SIZE
&& now.saturating_sub(last_report_time) > BANK_DROP_SIGNAL_CHANNEL_REPORT_INTERVAL
{
warn!("Excessive pruned_bank_channel_len: {}", q_len);
datapoint_warn!("excessive_pruned_bank_channel_len", ("len", q_len, i64));
self.last_report_time.store(now, Ordering::Release);
}
}
@ -87,13 +87,9 @@ pub struct SendDroppedBankCallback {
impl DropCallback for SendDroppedBankCallback {
fn callback(&self, bank: &Bank) {
BANK_DROP_QUEUE_REPORTER.report(self.sender.len());
match self.sender.send((bank.slot(), bank.bank_id())) {
Err(SendError(_)) => {
if let Err(SendError(_)) = self.sender.send((bank.slot(), bank.bank_id())) {
info!("bank DropCallback signal queue disconnected.");
}
// success
Ok(_) => {}
}
}
fn clone_box(&self) -> Box<dyn DropCallback + Send + Sync> {
@ -109,7 +105,7 @@ impl Debug for SendDroppedBankCallback {
impl SendDroppedBankCallback {
pub fn new(sender: DroppedSlotsSender) -> Self {
Self { sender: sender }
Self { sender }
}
}