AcctIdx: when no disk index, always wait for stats (#20248)
This commit is contained in:
parent
833f7761d2
commit
025261c05e
|
@ -158,7 +158,11 @@ impl<T: IndexValue> BucketMapHolder<T> {
|
|||
let bins = in_mem.len();
|
||||
let flush = self.disk.is_some();
|
||||
loop {
|
||||
if self.all_buckets_flushed_at_current_age() {
|
||||
if !flush {
|
||||
self.wait_dirty_or_aged.wait_timeout(Duration::from_millis(
|
||||
self.stats.remaining_until_next_interval(),
|
||||
));
|
||||
} else if self.all_buckets_flushed_at_current_age() {
|
||||
let wait = std::cmp::min(
|
||||
self.age_timer.remaining_until_next_interval(AGE_MS),
|
||||
self.stats.remaining_until_next_interval(),
|
||||
|
|
Loading…
Reference in New Issue