1berry/postgres
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fetch XIDs atomically during vac_truncate_clog().

Browse Source 
Because vac_update_datfrozenxid() updates datfrozenxid and datminmxid
in-place, it's unsafe to assume that successive reads of those values will
give consistent results.  Fetch each one just once to ensure sane behavior
in the minimum calculation.  Noted while reviewing Alexander Korotkov's
patch in the same area.

Discussion: <8564.1464116473@sss.pgh.pa.us>
This commit is contained in:
Tom Lane 2016-05-24 15:47:51 -04:00
parent fe1731fca2
commit 5551dac59c
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/backend/commands/vacuum.c
View File

@ -797,6 +797,12 @@ vac_truncate_clog(TransactionId frozenXID)
/* /*
* Scan pg_database to compute the minimum datfrozenxid * Scan pg_database to compute the minimum datfrozenxid
* *
* Since vac_update_datfrozenxid updates datfrozenxid in-place,
* the values could change while we look at them. Fetch each one just
* once to ensure sane behavior of the comparison logic. (Here, as in
* many other places, we assume that fetching or updating an XID in shared
* storage is atomic.)
*
* Note: we need not worry about a race condition with new entries being * Note: we need not worry about a race condition with new entries being
* inserted by CREATE DATABASE. Any such entry will have a copy of some * inserted by CREATE DATABASE. Any such entry will have a copy of some
* existing DB's datfrozenxid, and that source DB cannot be ours because * existing DB's datfrozenxid, and that source DB cannot be ours because
@ -812,15 +818,16 @@ vac_truncate_clog(TransactionId frozenXID)
while ((tuple = heap_getnext(scan, ForwardScanDirection)) != NULL) while ((tuple = heap_getnext(scan, ForwardScanDirection)) != NULL)
{ {
Form_pg_database dbform = (Form_pg_database) GETSTRUCT(tuple); volatile FormData_pg_database *dbform = (Form_pg_database) GETSTRUCT(tuple);
TransactionId datfrozenxid = dbform->datfrozenxid;
Assert(TransactionIdIsNormal(dbform->datfrozenxid)); Assert(TransactionIdIsNormal(datfrozenxid));
if (TransactionIdPrecedes(nextXID, dbform->datfrozenxid)) if (TransactionIdPrecedes(nextXID, datfrozenxid))
frozenAlreadyWrapped = true; frozenAlreadyWrapped = true;
else if (TransactionIdPrecedes(dbform->datfrozenxid, frozenXID)) else if (TransactionIdPrecedes(datfrozenxid, frozenXID))
{ {
frozenXID = dbform->datfrozenxid; frozenXID = datfrozenxid;
oldest_datoid = HeapTupleGetOid(tuple); oldest_datoid = HeapTupleGetOid(tuple);
} }
} }