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

recycle_store_count is moved to try_recycle_store (#27797)

This commit is contained in:
kirill lykov 2022-09-15 21:27:09 +02:00 committed by GitHub
parent aae07807cb
commit 1a4b8b5b79
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
runtime/src/accounts_db.rs
View File

@ -5088,6 +5088,9 @@ impl AccountsDb {
ret.get_path(), ret.get_path(),
old_id old_id
); );
self.stats
.recycle_store_count
.fetch_add(1, Ordering::Relaxed);
return Some(ret); return Some(ret);
} }
} }
@ -5135,17 +5138,12 @@ impl AccountsDb {
if store.try_available() { if store.try_available() {
let ret = store.clone(); let ret = store.clone();
drop(slot_stores); drop(slot_stores);
if create_extra { if create_extra
if self && self
.try_recycle_and_insert_store(slot, size as u64, std::u64::MAX) .try_recycle_and_insert_store(slot, size as u64, std::u64::MAX)
.is_none() .is_none()
{ {
self.create_and_insert_store(slot, self.file_size, "store extra"); self.create_and_insert_store(slot, self.file_size, "store extra");
} else {
self.stats
.recycle_store_count
.fetch_add(1, Ordering::Relaxed);
}
} }
find_existing.stop(); find_existing.stop();
self.stats self.stats
@ -5166,9 +5164,6 @@ impl AccountsDb {
.fetch_add(find_existing.as_us(), Ordering::Relaxed); .fetch_add(find_existing.as_us(), Ordering::Relaxed);
let store = if let Some(store) = self.try_recycle_store(slot, size as u64, std::u64::MAX) { let store = if let Some(store) = self.try_recycle_store(slot, size as u64, std::u64::MAX) {
self.stats
.recycle_store_count
.fetch_add(1, Ordering::Relaxed);
store store
} else { } else {
self.create_store(slot, self.file_size, "store", &self.paths) self.create_store(slot, self.file_size, "store", &self.paths)
@ -5797,10 +5792,6 @@ impl AccountsDb {
.is_none() .is_none()
{ {
self.create_and_insert_store(slot, special_store_size, "large create"); self.create_and_insert_store(slot, special_store_size, "large create");
} else {
self.stats
.recycle_store_count
.fetch_add(1, Ordering::Relaxed);
} }
} }
continue; continue;