Skip to content

Commit e2bccdf

Browse files
committed
In WAL replay, restore GIN metapage unconditionally to avoid torn page.
We don't take a full-page image of the GIN metapage; instead, the WAL record contains all the information required to reconstruct it from scratch. But to avoid torn page hazards, we must re-initialize it from the WAL record every time, even if it already has a greater LSN, similar to how normal full page images are restored. This was highly unlikely to cause any problems in practice, because the GIN metapage is small. We rely on an update smaller than a 512 byte disk sector to be atomic elsewhere, at least in pg_control. But better safe than sorry, and this would be easy to overlook if more fields are added to the metapage so that it's no longer small. Reported by Noah Misch. Backpatch to all supported versions.
1 parent d411d6e commit e2bccdf

File tree

1 file changed

+13
-14
lines changed

1 file changed

+13
-14
lines changed

src/backend/access/gin/ginxlog.c

Lines changed: 13 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -487,18 +487,20 @@ ginRedoUpdateMetapage(XLogRecPtr lsn, XLogRecord *record)
487487
Page metapage;
488488
Buffer buffer;
489489

490+
/*
491+
* Restore the metapage. This is essentially the same as a full-page image,
492+
* so restore the metapage unconditionally without looking at the LSN, to
493+
* avoid torn page hazards.
494+
*/
490495
metabuffer = XLogReadBuffer(data->node, GIN_METAPAGE_BLKNO, false);
491496
if (!BufferIsValid(metabuffer))
492497
return; /* assume index was deleted, nothing to do */
493498
metapage = BufferGetPage(metabuffer);
494499

495-
if (!XLByteLE(lsn, PageGetLSN(metapage)))
496-
{
497-
memcpy(GinPageGetMeta(metapage), &data->metadata, sizeof(GinMetaPageData));
498-
PageSetLSN(metapage, lsn);
499-
PageSetTLI(metapage, ThisTimeLineID);
500-
MarkBufferDirty(metabuffer);
501-
}
500+
memcpy(GinPageGetMeta(metapage), &data->metadata, sizeof(GinMetaPageData));
501+
PageSetLSN(metapage, lsn);
502+
PageSetTLI(metapage, ThisTimeLineID);
503+
MarkBufferDirty(metabuffer);
502504

503505
if (data->ntuples > 0)
504506
{
@@ -637,13 +639,10 @@ ginRedoDeleteListPages(XLogRecPtr lsn, XLogRecord *record)
637639
return; /* assume index was deleted, nothing to do */
638640
metapage = BufferGetPage(metabuffer);
639641

640-
if (!XLByteLE(lsn, PageGetLSN(metapage)))
641-
{
642-
memcpy(GinPageGetMeta(metapage), &data->metadata, sizeof(GinMetaPageData));
643-
PageSetLSN(metapage, lsn);
644-
PageSetTLI(metapage, ThisTimeLineID);
645-
MarkBufferDirty(metabuffer);
646-
}
642+
memcpy(GinPageGetMeta(metapage), &data->metadata, sizeof(GinMetaPageData));
643+
PageSetLSN(metapage, lsn);
644+
PageSetTLI(metapage, ThisTimeLineID);
645+
MarkBufferDirty(metabuffer);
647646

648647
for (i = 0; i < data->ndeleted; i++)
649648
{

0 commit comments

Comments
 (0)