Re: Buffer locking is special (hints, checksums, AIO writes)
Andres Freund <andres@anarazel.de>
Hi, On 2026-03-31 19:02:33 +0300, Yura Sokolov wrote: > 27.03.2026 23:00, Andres Freund wrote: > > On 2026-03-25 18:35:55 -0400, Andres Freund wrote: > >> Running it through valgrind and then will work on reading through one more > >> time and pushing them. > > > > And done. > > > > Phew, this project took way longer than I'd though it'd take. > > In addition to bug with BM_IO_ERROR [1] , I found race condition in > PinBuffer in this lines of code: > > if (unlikely(skip_if_not_valid && !(old_buf_state & BM_VALID))) > return false; > > /* > * We're not allowed to increase the refcount while the buffer > * header spinlock is held. Wait for the lock to be released. > */ > if (old_buf_state & BM_LOCKED) > old_buf_state = WaitBufHdrUnlocked(buf); > > While we waited for buffer header for being unlocked, it may become > invalid, isn't it? > Therefore, check related to skip_if_not_valid have to happen after waiting. Yea, that does seem wrong. Not sure how it ended up that way. I think it may be better to add a continue after the WaitBufHdrUnlocked(), so that we restart the loop, rather than moving the skip_if_not_valid check. > .... > > Another question: previously we had to wait for buffer for being unlocked > because UnlockBufHdr wrote to buf->state unconditionally, therefore our pin > increment could be lost. > Now UnlockBufHdr and UnlockBufHdrExt does proper atomic operations and > preserves concurrent changes. Are we still need to wait? Yes. > Most of time PinBuffer is called protected by BufTable's partition LWLock, > therefore buffer may not be changed in dramatic way. I don't think the partition locks are sufficient protection for everything. We have a few places in the code that want to be able to modify the buffer state depending on whether the buffer is already pinned, and I don't think all of them currently hold the relevant buffer mapping partition's lock. If pinning were not to wait for an existing header lock, such checks would not easily be doable. Perhaps we could fix all the relevant places by acquiring the partition lock in a few more places. But I think that'd be going in exactly the opposite direction we should to. The partition locks are quite contended locks and we should work on getting rid of them eventually. Building them into the protection model seems quite unwise. I think many of the places that currently do rely on the buffer header spinlock can be converted to CAS loops. I'm not really sure how much that's worth though - the WaitBufHdrLocked() in PinBuffer() is pretty hard to hit in realistic workloads. What would be really nice, is to be able to replace the CAS() with an atomic add (since those are considerably faster), but that's not really possible regardless of the need for WaitBufHdrLocked(), because we can't just add BUF_USAGECOUNT_ONE, as that would allow increasing the usage count too far. I would like to eventually narrow the definition of the buffer header spinlock to just be about the "identity" of the buffer, which then would only be needed by things like DropRelationBuffers() and when changing the buffer's identity. > But call in ReadRecentBuffer is the exception. It is not protected by > partition lock and have to make additional checks. That is why you > introduced skip_if_not_valid. > > Does optimization of ReadRecentBuffer pays for WaitBufHdrUnlocked? As mentioned above, I don't think it's just ReadRecentBuffer that relies on the buffer header spinlock preventing new pins. Greetings, Andres Freund
Commits
GET /api/v1/messages/:b64id/commits
the thread's linked commits as JSON, with link sources.
API reference →
-
bufmgr: Fix ordering of checks in PinBuffer()
- c0af4eb4e71e 19 (unreleased) landed
-
Use UnlockReleaseBuffer() in more places
- 8df3c48e466c 19 (unreleased) landed
-
bufmgr: Make UnlockReleaseBuffer() more efficient
- f39cb8c01106 19 (unreleased) landed
-
bufmgr: Don't copy pages while writing out
- 41d3d64e87af 19 (unreleased) landed
-
Fix use of wrong variable in _hash_kill_items()
- f5eb854ab6d6 19 (unreleased) landed
-
Fix bug due to confusion about what IsMVCCSnapshot means
- ce5d489166e5 19 (unreleased) landed
-
bufmgr: Switch to standard order in MarkBufferDirtyHint()
- a766125efd60 19 (unreleased) landed
-
bufmgr: Remove the, now obsolete, BM_JUST_DIRTIED
- b0f4ff3c9266 19 (unreleased) landed
-
Require share-exclusive lock to set hint bits and to flush
- 82467f627bd4 19 (unreleased) landed
-
heapam: Don't mimic MarkBufferDirtyHint() in inplace updates
- f4a4ce52c0d1 19 (unreleased) landed
-
bufmgr: Allow conditionally locking of already locked buffer
- 333f586372aa 19 (unreleased) landed
-
bufmgr: Avoid spurious compiler warning after fcb9c977aa5
- 84705b37273d 19 (unreleased) landed
-
lwlock: Remove ForEachLWLockHeldByMe
- 55fbfb738b00 19 (unreleased) landed
-
lwlock: Remove support for disowned lwlwocks
- d40fd85187d0 19 (unreleased) landed
-
bufmgr: Implement buffer content locks independently of lwlocks
- fcb9c977aa5f 19 (unreleased) landed
-
bufmgr: Change BufferDesc.state to be a 64-bit atomic
- dac328c8a682 19 (unreleased) landed
-
lwlock: Improve local variable name
- 556c92a68972 19 (unreleased) landed
-
lwlock: Invert meaning of LW_FLAG_RELEASE_OK
- 9a385f61666c 19 (unreleased) landed
-
bufmgr: Make definitions related to buffer descriptor easier to modify
- ff219c198789 19 (unreleased) landed
-
heapam: Add batch mode mvcc check and use it in page mode
- 0b96e734c590 19 (unreleased) landed
-
freespace: Don't modify page without any lock
- 45f658dacb9c 19 (unreleased) landed
-
heapam: Move logic to handle HEAP_MOVED into a helper function
- 548de59d93d5 19 (unreleased) landed
-
bufmgr: Optimize & harmonize LockBufHdr(), LWLockWaitListLock()
- 09ae2c8bac8d 19 (unreleased) landed
-
bufmgr: Add one-entry cache for private refcount
- 30df61990c67 19 (unreleased) landed
-
bufmgr: Separate keys for private refcount infrastructure
- edbaaea0a95e 19 (unreleased) landed
-
Add pg_atomic_unlocked_write_u64
- 7902a47c20b1 19 (unreleased) landed
-
Rename BUFFERPIN wait event class to BUFFER
- 6c5c393b7403 19 (unreleased) landed
-
bufmgr: Turn BUFFER_LOCK_* into an enum
- 156680055dc5 19 (unreleased) landed
-
lwlock: Fix, currently harmless, bug in LWLockWakeup()
- 81f773895321 19 (unreleased) landed
- da3971496531 15.16 landed
- 89c8a1b9069f 16.12 landed
- 427e886a79a5 17.8 landed
- 332693e75969 14.21 landed
- 8082b759d9b5 18.2 landed
-
bufmgr: Use atomic sub for unpinning buffers
- 5310fac6e0fc 19 (unreleased) landed
-
bufmgr: Allow some buffer state modifications while holding header lock
- c75ebc657ffc 19 (unreleased) landed
-
bufmgr: Fix valgrind checking for buffers pinned in StrategyGetBuffer()
- c819d1017ddb 19 (unreleased) landed
-
bufmgr: Don't lock buffer header in StrategyGetBuffer()
- 5e8998592879 19 (unreleased) landed
-
bufmgr: fewer calls to BufferDescriptorGetContentLock
- 3baae90013df 19 (unreleased) landed
-
bufmgr: Fix signedness of mask variable in BufferSync()
- 2a2e1b470b9b 19 (unreleased) landed
-
bufmgr: Introduce FlushUnlockedBuffer
- 3c2b97b29ee3 19 (unreleased) landed
-
Improve ReadRecentBuffer() scalability
- 819dc118c0f6 19 (unreleased) landed