Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commitd811d74

Browse files
committed
Fix race in SERIALIZABLE READ ONLY.
Commitbdaabb9 started skipping doomed transactions when building thelist of possible conflicts for SERIALIZABLE READ ONLY. That makessense, because doomed transactions won't commit, but a couple of subtlethings broke:1. If all uncommitted r/w transactions are doomed, a READ ONLYtransaction would arbitrarily not benefit from the safe snapshotoptimization. It would not be taken immediately, and yet no othertransaction would set SXACT_FLAG_RO_SAFE later.2. In the same circumstances but with DEFERRABLE, GetSafeSnapshot()would correctly exit its wait loop without sleeping and then take theoptimization in non-assert builds, but assert builds would fail a sanitycheck that SXACT_FLAG_RO_SAFE had been set by another transaction.This is similar to the case for PredXact->WritableSxactCount == 0. Weshould opt out immediately if our possibleUnsafeConflicts list is emptyafter filtering.The code to maintain the serializable global xmin is moved down belowthe new opt out site, because otherwise we'd have to reverse its effectsbefore returning.Back-patch to all supported releases. Bug #17368.Reported-by: Alexander Lakhin <exclusion@gmail.com>Discussion:https://postgr.es/m/17116-d6ca217acc180e30%40postgresql.orgDiscussion:https://postgr.es/m/20110707212159.GF76634%40csail.mit.edu
1 parent324281f commitd811d74

File tree

1 file changed

+31
-18
lines changed

1 file changed

+31
-18
lines changed

‎src/backend/storage/lmgr/predicate.c

Lines changed: 31 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -1846,24 +1846,6 @@ GetSerializableTransactionSnapshotInt(Snapshot snapshot,
18461846
returnsnapshot;
18471847
}
18481848

1849-
/* Maintain serializable global xmin info. */
1850-
if (!TransactionIdIsValid(PredXact->SxactGlobalXmin))
1851-
{
1852-
Assert(PredXact->SxactGlobalXminCount==0);
1853-
PredXact->SxactGlobalXmin=snapshot->xmin;
1854-
PredXact->SxactGlobalXminCount=1;
1855-
SerialSetActiveSerXmin(snapshot->xmin);
1856-
}
1857-
elseif (TransactionIdEquals(snapshot->xmin,PredXact->SxactGlobalXmin))
1858-
{
1859-
Assert(PredXact->SxactGlobalXminCount>0);
1860-
PredXact->SxactGlobalXminCount++;
1861-
}
1862-
else
1863-
{
1864-
Assert(TransactionIdFollows(snapshot->xmin,PredXact->SxactGlobalXmin));
1865-
}
1866-
18671849
/* Initialize the structure. */
18681850
sxact->vxid=vxid;
18691851
sxact->SeqNo.lastCommitBeforeSnapshot=PredXact->LastSxactCommitSeqNo;
@@ -1900,6 +1882,19 @@ GetSerializableTransactionSnapshotInt(Snapshot snapshot,
19001882
SetPossibleUnsafeConflict(sxact,othersxact);
19011883
}
19021884
}
1885+
1886+
/*
1887+
* If we didn't find any possibly unsafe conflicts because every
1888+
* uncommitted writable transaction turned out to be doomed, then we
1889+
* can "opt out" immediately. See comments above the earlier check for
1890+
* PredXact->WritableSxactCount == 0.
1891+
*/
1892+
if (SHMQueueEmpty(&sxact->possibleUnsafeConflicts))
1893+
{
1894+
ReleasePredXact(sxact);
1895+
LWLockRelease(SerializableXactHashLock);
1896+
returnsnapshot;
1897+
}
19031898
}
19041899
else
19051900
{
@@ -1908,6 +1903,24 @@ GetSerializableTransactionSnapshotInt(Snapshot snapshot,
19081903
(MaxBackends+max_prepared_xacts));
19091904
}
19101905

1906+
/* Maintain serializable global xmin info. */
1907+
if (!TransactionIdIsValid(PredXact->SxactGlobalXmin))
1908+
{
1909+
Assert(PredXact->SxactGlobalXminCount==0);
1910+
PredXact->SxactGlobalXmin=snapshot->xmin;
1911+
PredXact->SxactGlobalXminCount=1;
1912+
SerialSetActiveSerXmin(snapshot->xmin);
1913+
}
1914+
elseif (TransactionIdEquals(snapshot->xmin,PredXact->SxactGlobalXmin))
1915+
{
1916+
Assert(PredXact->SxactGlobalXminCount>0);
1917+
PredXact->SxactGlobalXminCount++;
1918+
}
1919+
else
1920+
{
1921+
Assert(TransactionIdFollows(snapshot->xmin,PredXact->SxactGlobalXmin));
1922+
}
1923+
19111924
MySerializableXact=sxact;
19121925
MyXactDidWrite= false;/* haven't written anything yet */
19131926

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp