add stat for disk buckets flushed (#30850)
This commit is contained in:
parent
d69f60229d
commit
3ebfda5aef
|
@ -41,6 +41,7 @@ pub struct BucketMapHolderStats {
|
||||||
pub failed_to_evict: AtomicU64,
|
pub failed_to_evict: AtomicU64,
|
||||||
pub keys: AtomicU64,
|
pub keys: AtomicU64,
|
||||||
pub deletes: AtomicU64,
|
pub deletes: AtomicU64,
|
||||||
|
pub buckets_scanned: AtomicU64,
|
||||||
pub inserts: AtomicU64,
|
pub inserts: AtomicU64,
|
||||||
count: AtomicUsize,
|
count: AtomicUsize,
|
||||||
pub bg_waiting_us: AtomicU64,
|
pub bg_waiting_us: AtomicU64,
|
||||||
|
@ -372,6 +373,11 @@ impl BucketMapHolderStats {
|
||||||
("items", self.items.swap(0, Ordering::Relaxed), i64),
|
("items", self.items.swap(0, Ordering::Relaxed), i64),
|
||||||
("keys", self.keys.swap(0, Ordering::Relaxed), i64),
|
("keys", self.keys.swap(0, Ordering::Relaxed), i64),
|
||||||
("ms_per_age", ms_per_age, i64),
|
("ms_per_age", ms_per_age, i64),
|
||||||
|
(
|
||||||
|
"buckets_scanned",
|
||||||
|
self.buckets_scanned.swap(0, Ordering::Relaxed),
|
||||||
|
i64
|
||||||
|
),
|
||||||
(
|
(
|
||||||
"flush_scan_us",
|
"flush_scan_us",
|
||||||
self.flush_scan_us.swap(0, Ordering::Relaxed),
|
self.flush_scan_us.swap(0, Ordering::Relaxed),
|
||||||
|
|
|
@ -1109,6 +1109,7 @@ impl<T: IndexValue, U: DiskIndexValue + From<T> + Into<T>> InMemAccountsIndex<T,
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Self::update_stat(&self.stats().buckets_scanned, 1);
|
||||||
// scan in-mem map for items that we may evict
|
// scan in-mem map for items that we may evict
|
||||||
let FlushScanResult {
|
let FlushScanResult {
|
||||||
mut evictions_age_possible,
|
mut evictions_age_possible,
|
||||||
|
|
Loading…
Reference in New Issue