AcctIdx: streamline metric update (#21936)
This commit is contained in:
parent
1e0d3f13e6
commit
82672b40fd
|
@ -710,6 +710,7 @@ impl<T: IndexValue> InMemAccountsIndex<T> {
|
||||||
assert!(self.get_stop_flush()); // caller should be controlling the lifetime of how long this needs to be present
|
assert!(self.get_stop_flush()); // caller should be controlling the lifetime of how long this needs to be present
|
||||||
let m = Measure::start("range");
|
let m = Measure::start("range");
|
||||||
|
|
||||||
|
let mut added_to_mem = 0;
|
||||||
// load from disk
|
// load from disk
|
||||||
if let Some(disk) = self.bucket.as_ref() {
|
if let Some(disk) = self.bucket.as_ref() {
|
||||||
let mut map = self.map().write().unwrap();
|
let mut map = self.map().write().unwrap();
|
||||||
|
@ -724,11 +725,13 @@ impl<T: IndexValue> InMemAccountsIndex<T> {
|
||||||
}
|
}
|
||||||
Entry::Vacant(vacant) => {
|
Entry::Vacant(vacant) => {
|
||||||
vacant.insert(self.disk_to_cache_entry(item.slot_list, item.ref_count));
|
vacant.insert(self.disk_to_cache_entry(item.slot_list, item.ref_count));
|
||||||
self.stats().insert_or_delete_mem(true, self.bin);
|
added_to_mem += 1;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
self.stats()
|
||||||
|
.insert_or_delete_mem_count(true, self.bin, added_to_mem);
|
||||||
|
|
||||||
Self::update_time_stat(&self.stats().get_range_us, m);
|
Self::update_time_stat(&self.stats().get_range_us, m);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue