rdelaage
/
postgresql
mirror of https://git.postgresql.org/git/postgresql.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix inconsistency with replay of hash squeeze record for clean buffers 

aa5edbe379 has tweaked _hash_freeovflpage() so as the write buffer's
LSN is updated only when necessary, when REGBUF_NO_CHANGE is not used.

The replay code was not consistent with that, causing the write buffer's
LSN to be updated and its page to be marked as dirty even if the buffer
was registered in a "clean" state.  This was possible for the case of a
squeeze record when there are no tuples to add to the write buffer, for
(is_prim_bucket_same_wrt && !is_prev_bucket_same_wrt).

I have performed some validation of this commit with
wal_consistency_checking and a change in WAL that logs REGBUF_NO_CHANGE
to a new BKPIMAGE_*.  Thanks to that, it is possible to know at replay
if a buffer was clean when it was registered, then cross-checked the LSN
of the "clean" page copy coming from WAL with the LSN of the block once
the record has been replayed.  This eats one bit in bimg_info, which is
not acceptable to be integrated as-is, but it could become handy in the
future.  I didn't spot other areas than the one fixed by this commit at
the extent of what the main regression test suite covers.

As this is an oversight in aa5edbe379, no backpatch is required.

Reported-by: Zubeyr Eryilmaz
Author: Hayato Kuroda
Reviewed-by: Amit Kapila, Michael Paquier
Discussion: https://postgr.es/m/ZbyVVG_7eW3YD5-A@paquier.xyz
This commit is contained in:
Michael Paquier 2024-04-11 09:20:51 +09:00
parent 5392dd3d2a
commit f56a9def71
1 changed files with 19 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/backend/access/hash/hash_xlog.c
View File

@ -666,6 +666,7 @@ hash_xlog_squeeze_page(XLogReaderState *record)
char *data;
Size datalen;
uint16 ninserted = 0;
bool mod_wbuf = false;
data = begin = XLogRecGetBlockData(record, 1, &datalen);
@ -695,6 +696,17 @@ hash_xlog_squeeze_page(XLogReaderState *record)
ninserted++;
}
mod_wbuf = true;
}
else
{
/*
* Ensure that the required flags are set when there are no
* tuples. See _hash_freeovflpage().
*/
Assert(xldata->is_prim_bucket_same_wrt ||
xldata->is_prev_bucket_same_wrt);
}
/*
@ -711,10 +723,15 @@ hash_xlog_squeeze_page(XLogReaderState *record)
HashPageOpaque writeopaque = HashPageGetOpaque(writepage);
writeopaque->hasho_nextblkno = xldata->nextblkno;
mod_wbuf = true;
}
PageSetLSN(writepage, lsn);
MarkBufferDirty(writebuf);
/* Set LSN and mark writebuf dirty iff it is modified */
if (mod_wbuf)
{
PageSetLSN(writepage, lsn);
MarkBufferDirty(writebuf);
}
}
/* replay the record for initializing overflow buffer */