database/postgres
database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-04-27 22:56:53 +03:00
Code

Don't test HEAP_XMAX_INVALID when freezing xmax.

Browse Source 
We shouldn't ever need to rely on whether HEAP_XMAX_INVALID is set in
t_infomask when considering whether or not an xmax should be deemed
already frozen, since that status flag is just a hint.  The only
acceptable representation for an "xmax_already_frozen" raw xmax field is
the transaction ID value zero (also known as InvalidTransactionId).

Adjust code that superficially appeared to rely on HEAP_XMAX_INVALID to
make the rule about xmax_already_frozen clear.  Also avoid needlessly
rereading the tuple's raw xmax.

Oversight in bugfix commit d2599ecf.  There is no evidence that this
ever led to incorrect behavior, so no backpatch.  The worst consequence
of this bug was that VACUUM could hypothetically fail to notice and
report on certain kinds of corruption, which seems fairly benign.

Author: Peter Geoghegan <pg@bowt.ie>
Discussion: https://postgr.es/m/CAH2-Wzkh3DMCDRPfhZxj9xCq9v3WmzvmbiCpf1dNKUBPadhCbQ@mail.gmail.com
This commit is contained in:
Peter Geoghegan 2022-11-23 10:49:39 -08:00
parent b425bf0081
commit 02d647bbf0
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/backend/access/heap/heapam.c
View File

@ -6542,6 +6542,7 @@ heap_prepare_freeze_tuple(HeapTupleHeader tuple,
if (tuple->t_infomask & HEAP_XMAX_IS_MULTI) if (tuple->t_infomask & HEAP_XMAX_IS_MULTI)
{ {
/* Raw xmax is a MultiXactId */
TransactionId newxmax; TransactionId newxmax;
uint16 flags; uint16 flags;
TransactionId mxid_oldest_xid_out = *relfrozenxid_out; TransactionId mxid_oldest_xid_out = *relfrozenxid_out;
@ -6640,6 +6641,7 @@ heap_prepare_freeze_tuple(HeapTupleHeader tuple,
} }
else if (TransactionIdIsNormal(xid)) else if (TransactionIdIsNormal(xid))
{ {
/* Raw xmax is normal XID */
if (TransactionIdPrecedes(xid, relfrozenxid)) if (TransactionIdPrecedes(xid, relfrozenxid))
ereport(ERROR, ereport(ERROR,
(errcode(ERRCODE_DATA_CORRUPTED), (errcode(ERRCODE_DATA_CORRUPTED),
@ -6670,9 +6672,10 @@ heap_prepare_freeze_tuple(HeapTupleHeader tuple,
*relfrozenxid_out = xid; *relfrozenxid_out = xid;
} }
} }
else if ((tuple->t_infomask & HEAP_XMAX_INVALID) || else if (!TransactionIdIsValid(xid))
!TransactionIdIsValid(HeapTupleHeaderGetRawXmax(tuple)))
{ {
/* Raw xmax is InvalidTransactionId XID */
Assert((tuple->t_infomask & HEAP_XMAX_IS_MULTI) == 0);
freeze_xmax = false; freeze_xmax = false;
xmax_already_frozen = true; xmax_already_frozen = true;
/* No need for relfrozenxid_out handling for already-frozen xmax */ /* No need for relfrozenxid_out handling for already-frozen xmax */