blockworks-foundation
/
solana
mirror of https://github.com/blockworks-foundation/solana.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

AcctIdx: generate index goes to mem not disk (#21709)

This commit is contained in:
Jeff Washington (jwash) 2021-12-08 19:48:12 -06:00 committed by GitHub
parent 54862eba0d
commit e020960f49
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 33 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
runtime/src/in_mem_accounts_index.rs
View File

@ -532,9 +532,39 @@ impl<T: IndexValue> InMemAccountsIndex<T> {
}
Entry::Vacant(vacant) => {
// not in cache, look on disk
let already_existed =
self.upsert_on_disk(vacant, new_entry, &mut Vec::default(), false);
(false, already_existed)
let initial_insert_directly_to_disk = false;
if initial_insert_directly_to_disk {
// This is more direct, but becomes too slow with very large acct #.
// disk buckets will be improved to make them more performant. Tuning the disks may also help.
// This may become a config tuning option.
let already_existed =
self.upsert_on_disk(vacant, new_entry, &mut Vec::default(), false);
(false, already_existed)
} else {
let disk_entry = self.load_account_entry_from_disk(vacant.key());
self.stats().insert_or_delete_mem(true, self.bin);
if let Some(disk_entry) = disk_entry {
let (slot, account_info) = new_entry.into();
InMemAccountsIndex::lock_and_update_slot_list(
&disk_entry,
(slot, account_info),
&mut Vec::default(),
false,
);
vacant.insert(disk_entry);
(
false, /* found in mem */
true, /* already existed */
)
} else {
// not on disk, so insert new thing and we're done
let new_entry: AccountMapEntry<T> =
new_entry.into_account_map_entry(&self.storage);
assert!(new_entry.dirty());
vacant.insert(new_entry);
(false, false)
}
}
}
};
drop(map);