use crate::accounts_index::{AccountMapEntry, IsCached, WriteAccountMapEntry}; use solana_sdk::pubkey::Pubkey; use std::collections::{ hash_map::{Entry, Keys}, HashMap, }; use std::fmt::Debug; type K = Pubkey; // one instance of this represents one bin of the accounts index. #[derive(Debug, Default)] pub struct InMemAccountsIndex { // backing store map: HashMap>, } impl InMemAccountsIndex { pub fn new() -> Self { Self { map: HashMap::new(), } } pub fn entry(&mut self, pubkey: Pubkey) -> Entry> { self.map.entry(pubkey) } pub fn items(&self) -> Vec<(K, AccountMapEntry)> { self.map.iter().map(|(k, v)| (*k, v.clone())).collect() } pub fn keys(&self) -> Keys> { self.map.keys() } pub fn get(&self, key: &K) -> Option> { self.map.get(key).cloned() } pub fn remove(&mut self, key: &K) { self.map.remove(key); } // If the slot list for pubkey exists in the index and is empty, remove the index entry for pubkey and return true. // Return false otherwise. pub fn remove_if_slot_list_empty(&mut self, pubkey: Pubkey) -> bool { if let Entry::Occupied(index_entry) = self.map.entry(pubkey) { if index_entry.get().slot_list.read().unwrap().is_empty() { index_entry.remove(); return true; } } false } pub fn len(&self) -> usize { self.map.len() } pub fn is_empty(&self) -> bool { self.len() == 0 } // return None if item was created new // if entry for pubkey already existed, return Some(entry). Caller needs to call entry.update. pub fn insert_new_entry_if_missing_with_lock( &mut self, pubkey: Pubkey, new_entry: AccountMapEntry, ) -> Option<(WriteAccountMapEntry, T, Pubkey)> { let account_entry = self.map.entry(pubkey); match account_entry { Entry::Occupied(account_entry) => Some(( WriteAccountMapEntry::from_account_map_entry(account_entry.get().clone()), // extract the new account_info from the unused 'new_entry' new_entry.slot_list.write().unwrap().remove(0).1, *account_entry.key(), )), Entry::Vacant(account_entry) => { account_entry.insert(new_entry); None } } } }