32 lines
860 B
Rust
32 lines
860 B
Rust
|
use crate::bucket_map_holder_stats::BucketMapHolderStats;
|
||
|
|
use crate::waitable_condvar::WaitableCondvar;
|
||
|
|
use std::fmt::Debug;
|
||
|
|
use std::sync::atomic::{AtomicBool, Ordering};
|
||
|
|
use std::sync::Arc;
|
||
|
|
use std::time::Duration;
|
||
|
|
|
||
|
|
// will eventually hold the bucket map
|
||
|
|
#[derive(Debug, Default)]
|
||
|
|
pub struct BucketMapHolder {
|
||
|
|
pub stats: BucketMapHolderStats,
|
||
|
|
}
|
||
|
|
|
||
|
|
impl BucketMapHolder {
|
||
|
|
pub fn new() -> Self {
|
||
|
|
Self {
|
||
|
|
stats: BucketMapHolderStats::default(),
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// intended to execute in a bg thread
|
||
|
|
pub fn background(&self, exit: Arc<AtomicBool>, wait: Arc<WaitableCondvar>) {
|
||
|
|
loop {
|
||
|
|
wait.wait_timeout(Duration::from_millis(10000)); // account index stats every 10 s
|
||
|
|
if exit.load(Ordering::Relaxed) {
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
self.stats.report_stats();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|