AcctIdx: move background() to AccountsIndexStorage (#19948)

runtime/src/accounts_index_storage.rs

@@ -3,6 +3,7 @@ use crate::bucket_map_holder::BucketMapHolder;
 use crate::in_mem_accounts_index::InMemAccountsIndex;
 use crate::waitable_condvar::WaitableCondvar;
 use std::fmt::Debug;
+use std::time::Duration;
 use std::{
     sync::{
         atomic::{AtomicBool, Ordering},
@@ -51,16 +52,16 @@ impl<T: IndexValue> AccountsIndexStorage<T> {
             .map(|bin| Arc::new(InMemAccountsIndex::new(&storage, bin)))
             .collect();
 
-        let storage_ = storage.clone();
+        let storage_ = Arc::clone(&storage);
         let exit = Arc::new(AtomicBool::default());
-        let exit_ = exit.clone();
+        let exit_ = Arc::clone(&exit);
         let wait = Arc::new(WaitableCondvar::default());
-        let wait_ = wait.clone();
+        let wait_ = Arc::clone(&wait);
         let handle = Some(
             Builder::new()
                 .name("solana-index-flusher".to_string())
                 .spawn(move || {
-                    storage_.background(exit_, wait_);
+                    Self::background(storage_, exit_, wait_);
                 })
                 .unwrap(),
         );
@@ -77,4 +78,19 @@ impl<T: IndexValue> AccountsIndexStorage<T> {
     pub fn storage(&self) -> &Arc<BucketMapHolder<T>> {
         &self.storage
     }
+
+    // intended to execute in a bg thread
+    pub fn background(
+        storage: Arc<BucketMapHolder<T>>,
+        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;
+            }
+            storage.stats.report_stats();
+        }
+    }
 }

runtime/src/bucket_map_holder.rs

@@ -1,10 +1,6 @@
 use crate::accounts_index::IndexValue;
 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
 pub struct BucketMapHolder<T: IndexValue> {
@@ -25,14 +21,4 @@ impl<T: IndexValue> BucketMapHolder<T> {
             _phantom: std::marker::PhantomData::<T>::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();
-        }
-    }
 }