parent
622a6fba7f
commit
7eb793a55e
|
@ -5530,7 +5530,7 @@ dependencies = [
|
|||
"bincode",
|
||||
"chrono",
|
||||
"crossbeam-channel",
|
||||
"futures 0.3.16",
|
||||
"futures 0.3.17",
|
||||
"futures-util",
|
||||
"log 0.4.14",
|
||||
"prost",
|
||||
|
@ -5541,7 +5541,7 @@ dependencies = [
|
|||
"solana-rpc",
|
||||
"solana-runtime",
|
||||
"solana-sdk",
|
||||
"tokio 1.10.1",
|
||||
"tokio 1.11.0",
|
||||
"tonic",
|
||||
"tonic-build",
|
||||
]
|
||||
|
|
|
@ -12181,10 +12181,8 @@ pub mod tests {
|
|||
assert!(db.storage.get_slot_storage_entries(*slot).is_none());
|
||||
assert!(db.accounts_cache.slot_cache(*slot).is_none());
|
||||
let account_in_slot = slot_to_pubkey_map[slot];
|
||||
assert!(db
|
||||
.accounts_index
|
||||
.get_account_read_entry(&account_in_slot)
|
||||
.is_none());
|
||||
let item = db.accounts_index.get_account_read_entry(&account_in_slot);
|
||||
assert!(item.is_none(), "item: {:?}", item);
|
||||
}
|
||||
|
||||
// Wait for flush to finish before starting next trial
|
||||
|
|
|
@ -133,6 +133,12 @@ pub struct ReadAccountMapEntry<T: IsCached> {
|
|||
slot_list_guard: RwLockReadGuard<'this, SlotList<T>>,
|
||||
}
|
||||
|
||||
impl<T: IsCached> Debug for ReadAccountMapEntry<T> {
|
||||
fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
|
||||
write!(f, "{:?}", self.borrow_owned_entry())
|
||||
}
|
||||
}
|
||||
|
||||
impl<T: IsCached> ReadAccountMapEntry<T> {
|
||||
pub fn from_account_map_entry(account_map_entry: AccountMapEntry<T>) -> Self {
|
||||
ReadAccountMapEntryBuilder {
|
||||
|
|
Loading…
Reference in New Issue