From 1f37fd240f2d381917595acbbc18d3b3ce714d2c Mon Sep 17 00:00:00 2001 From: Bharath Rupireddy Date: Tue, 29 Nov 2022 06:55:27 +0000 Subject: [PATCH v2] Convert lastImportantAt to 64-bit atomic for torn-free reads GetLastImportantRecPtr() currently reads lastImportantAt under WAL insertion lock acquire-release cycles to get torn-free reads. Converting lastImportantAt to 64-bit atomic from XLogRecPtr provides inherent benefit of torn-free reads and simplifies GetLastImportantRecPtr() a bit as the WAL insertion lock acquire-release cycles are no longer needed. --- src/backend/access/transam/xlog.c | 17 ++++++++--------- 1 file changed, 8 insertions(+), 9 deletions(-) diff --git a/src/backend/access/transam/xlog.c b/src/backend/access/transam/xlog.c index a31fbbff78..831a18d3bb 100644 --- a/src/backend/access/transam/xlog.c +++ b/src/backend/access/transam/xlog.c @@ -377,7 +377,7 @@ typedef struct { LWLock lock; XLogRecPtr insertingAt; - XLogRecPtr lastImportantAt; + pg_atomic_uint64 lastImportantAt; } WALInsertLock; /* @@ -873,7 +873,8 @@ XLogInsertRecord(XLogRecData *rdata, { int lockno = holdingAllLocks ? 0 : MyLockNo; - WALInsertLocks[lockno].l.lastImportantAt = StartPos; + pg_atomic_write_u64(&WALInsertLocks[lockno].l.lastImportantAt, + StartPos); } } else @@ -4603,7 +4604,8 @@ XLOGShmemInit(void) { LWLockInitialize(&WALInsertLocks[i].l.lock, LWTRANCHE_WAL_INSERT); WALInsertLocks[i].l.insertingAt = InvalidXLogRecPtr; - WALInsertLocks[i].l.lastImportantAt = InvalidXLogRecPtr; + pg_atomic_write_u64(&WALInsertLocks[i].l.lastImportantAt, + InvalidXLogRecPtr); } /* @@ -6124,13 +6126,10 @@ GetLastImportantRecPtr(void) XLogRecPtr last_important; /* - * Need to take a lock to prevent torn reads of the LSN, which are - * possible on some of the supported platforms. WAL insert locks only - * support exclusive mode, so we have to use that. + * We atomically read lastImportantAt which prevents torn reads. Hence + * no need to take WAL insert lock here. */ - LWLockAcquire(&WALInsertLocks[i].l.lock, LW_EXCLUSIVE); - last_important = WALInsertLocks[i].l.lastImportantAt; - LWLockRelease(&WALInsertLocks[i].l.lock); + last_important = pg_atomic_read_u64(&WALInsertLocks[i].l.lastImportantAt); if (res < last_important) res = last_important; -- 2.34.1