rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2025-12-23 06:09:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

cargo fmt

Browse Source
This commit is contained in:
Heikki Linnakangas
2025-07-31 20:47:52 +03:00
parent e1c7d79e2a
commit b72f410b6e
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
pgxn/neon/communicator/src/integrated_cache.rs
View File

@@ -486,7 +486,9 @@ impl<'t> IntegratedCacheWriteAccess<'t> {
cache_block: AtomicU64::new(cache_block), cache_block: AtomicU64::new(cache_block),
pinned: AtomicU64::new(0), pinned: AtomicU64::new(0),
referenced: AtomicBool::new(true), referenced: AtomicBool::new(true),
}).is_ok() { })
.is_ok()
{
break; break;
} else { } else {
// The hash map was full. Evict an entry and retry. // The hash map was full. Evict an entry and retry.
@@ -543,7 +545,9 @@ impl<'t> IntegratedCacheWriteAccess<'t> {
cache_block: AtomicU64::new(cache_block), cache_block: AtomicU64::new(cache_block),
pinned: AtomicU64::new(0), pinned: AtomicU64::new(0),
referenced: AtomicBool::new(true), referenced: AtomicBool::new(true),
}).is_ok() { })
.is_ok()
{
break; break;
} else { } else {
// The hash map was full. Evict an entry and retry. // The hash map was full. Evict an entry and retry.
@@ -885,7 +889,9 @@ impl<'t> IntegratedCacheReadAccess<'t> {
cache_block: AtomicU64::new(INVALID_CACHE_BLOCK), cache_block: AtomicU64::new(INVALID_CACHE_BLOCK),
pinned: AtomicU64::new(0), pinned: AtomicU64::new(0),
referenced: AtomicBool::new(true), referenced: AtomicBool::new(true),
}).is_ok() { })
.is_ok()
{
false false
} else { } else {
// The hash table is full. // The hash table is full.