summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorTeodor Sigaev <teodor@sigaev.ru>2018-05-03 20:09:47 +0300
committerTeodor Sigaev <teodor@sigaev.ru>2018-05-03 20:09:47 +0300
commitd3fc427f478f09153ea5995b460410614c2267ce (patch)
tree985db4ced6dddca2801e0fae607997387b130e37 /src
parent8fbdd63a52df670273990e126f1ab7895c14978a (diff)
Add HOLD_INTERRUPTS section into FinishPreparedTransaction.
If an interrupt arrives in the middle of FinishPreparedTransaction and any callback decide to call CHECK_FOR_INTERRUPTS (e.g. RemoveTwoPhaseFile can write a warning with ereport, which checks for interrupts) then it's possible to leave current GXact undeleted. Backpatch to all supported branches Stas Kelvich Discussion: ihttps://www.postgresql.org/message-id/3AD85097-A3F3-4EBA-99BD-C38EDF8D2949@postgrespro.ru
Diffstat (limited to 'src')
-rw-r--r--src/backend/access/transam/twophase.c5
1 files changed, 5 insertions, 0 deletions
diff --git a/src/backend/access/transam/twophase.c b/src/backend/access/transam/twophase.c
index a2804c8f033..161282b0794 100644
--- a/src/backend/access/transam/twophase.c
+++ b/src/backend/access/transam/twophase.c
@@ -1402,6 +1402,9 @@ FinishPreparedTransaction(const char *gid, bool isCommit)
/* compute latestXid among all children */
latestXid = TransactionIdLatest(xid, hdr->nsubxacts, children);
+ /* Prevent cancel/die interrupt while cleaning up */
+ HOLD_INTERRUPTS();
+
/*
* The order of operations here is critical: make the XLOG entry for
* commit or abort, then mark the transaction committed or aborted in
@@ -1489,6 +1492,8 @@ FinishPreparedTransaction(const char *gid, bool isCommit)
RemoveGXact(gxact);
MyLockedGxact = NULL;
+ RESUME_INTERRUPTS();
+
pfree(buf);
}