Reconsider when to wait for WAL flushes/syncrep during commit.

Up to now RecordTransactionCommit() waited for WAL to be flushed (if
synchronous_commit != off) and to be synchronously replicated (if
enabled), even if a transaction did not have a xid assigned. The primary
reason for that is that sequence's nextval() did not assign a xid, but
are worthwhile to wait for on commit.

This can be problematic because sometimes read only transactions do
write WAL, e.g. HOT page prune records. That then could lead to read only
transactions having to wait during commit. Not something people expect
in a read only transaction.

This lead to such strange symptoms as backends being seemingly stuck
during connection establishment when all synchronous replicas are
down. Especially annoying when said stuck connection is the standby
trying to reconnect to allow syncrep again...

This behavior also is involved in a rather complicated <= 9.4 bug where
the transaction started by catchup interrupt processing waited for
syncrep using latches, but didn't get the wakeup because it was already
running inside the same overloaded signal handler. Fix the issue here
doesn't properly solve that issue, merely papers over the problems. In
9.5 catchup interrupts aren't processed out of signal handlers anymore.

To fix all this, make nextval() acquire a top level xid, and only wait for
transaction commit if a transaction both acquired a xid and emitted WAL
records.  If only a xid has been assigned we don't uselessly want to
wait just because of writes to temporary/unlogged tables; if only WAL
has been written we don't want to wait just because of HOT prunes.

The xid assignment in nextval() is unlikely to cause overhead in
real-world workloads. For one it only happens SEQ_LOG_VALS/32 values
anyway, for another only usage of nextval() without using the result in
an insert or similar is affected.

Discussion: 20150223165359.GF30784@awork2.anarazel.de,
    369698E947874884A77849D8FE3680C2@maumau,
    5CF4ABBA67674088B3941894E22A0D25@maumau

Per complaint from maumau and Thom Brown

Backpatch all the way back; 9.0 doesn't have syncrep, but it seems
better to be consistent behavior across all maintained branches.

diff --git a/src/backend/access/transam/xact.c b/src/backend/access/transam/xact.c
index 97000ef616c9732e7b8b9748b52544df1841e0e7..89769eac072d48c356446057569148df44d4d04f 100644 (file)
--- a/src/backend/access/transam/xact.c
+++ b/src/backend/access/transam/xact.c
@@ -1031,10 +1031,9 @@ RecordTransactionCommit(void)
 
                /*
                 * If we didn't create XLOG entries, we're done here; otherwise we
-                * should flush those entries the same as a commit record.  (An
-                * example of a possible record that wouldn't cause an XID to be
-                * assigned is a sequence advance record due to nextval() --- we want
-                * to flush that to disk before reporting commit.)
+                * should trigger flushing those entries the same as a commit record
+                * would.  This will primarily happen for HOT pruning and the like; we
+                * want these to be flushed to disk in due time.
                 */
                if (!wrote_xlog)
                        goto cleanup;
@@ -1153,11 +1152,13 @@ RecordTransactionCommit(void)
        /*
         * Check if we want to commit asynchronously.  We can allow the XLOG flush
         * to happen asynchronously if synchronous_commit=off, or if the current
-        * transaction has not performed any WAL-logged operation.  The latter
-        * case can arise if the current transaction wrote only to temporary
-        * and/or unlogged tables.  In case of a crash, the loss of such a
-        * transaction will be irrelevant since temp tables will be lost anyway,
-        * and unlogged tables will be truncated.  (Given the foregoing, you might
+        * transaction has not performed any WAL-logged operation or didn't assign
+        * a xid.  The transaction can end up not writing any WAL, even if it has
+        * a xid, if it only wrote to temporary and/or unlogged tables.  It can
+        * end up having written WAL without an xid if it did HOT pruning.  In
+        * case of a crash, the loss of such a transaction will be irrelevant;
+        * temp tables will be lost anyway, unlogged tables will be truncated and
+        * HOT pruning will be done again later. (Given the foregoing, you might
         * think that it would be unnecessary to emit the XLOG record at all in
         * this case, but we don't currently try to do that.  It would certainly
         * cause problems at least in Hot Standby mode, where the
@@ -1173,7 +1174,8 @@ RecordTransactionCommit(void)
         * if all to-be-deleted tables are temporary though, since they are lost
         * anyway if we crash.)
         */
-       if ((wrote_xlog && synchronous_commit > SYNCHRONOUS_COMMIT_OFF) ||
+       if ((wrote_xlog && markXidCommitted &&
+                synchronous_commit > SYNCHRONOUS_COMMIT_OFF) ||
                forceSyncCommit || nrels > 0)
        {
                XLogFlush(XactLastRecEnd);
@@ -1222,12 +1224,15 @@ RecordTransactionCommit(void)
        latestXid = TransactionIdLatest(xid, nchildren, children);
 
        /*
-        * Wait for synchronous replication, if required.
+        * Wait for synchronous replication, if required. Similar to the decision
+        * above about using committing asynchronously we only want to wait if
+        * this backend assigned a xid and wrote WAL.  No need to wait if a xid
+        * was assigned due to temporary/unlogged tables or due to HOT pruning.
         *
         * Note that at this stage we have marked clog, but still show as running
         * in the procarray and continue to hold locks.
         */
-       if (wrote_xlog)
+       if (wrote_xlog && markXidCommitted)
                SyncRepWaitForLSN(XactLastRecEnd);
 
        /* Reset XactLastRecEnd until the next transaction writes something */

diff --git a/src/backend/commands/sequence.c b/src/backend/commands/sequence.c
index 622ccf751845498f886fc9fe0d993fa299d1ec20..0070c4f34ef3207ec7df2aab53619185972ce2cc 100644 (file)
--- a/src/backend/commands/sequence.c
+++ b/src/backend/commands/sequence.c
@@ -17,6 +17,7 @@
 #include "access/htup_details.h"
 #include "access/multixact.h"
 #include "access/transam.h"
+#include "access/xact.h"
 #include "access/xlog.h"
 #include "access/xloginsert.h"
 #include "access/xlogutils.h"
@@ -358,6 +359,10 @@ fill_seq_with_data(Relation rel, HeapTuple tuple)
        tuple->t_data->t_infomask |= HEAP_XMAX_INVALID;
        ItemPointerSet(&tuple->t_data->t_ctid, 0, FirstOffsetNumber);
 
+       /* check the comment above nextval_internal()'s equivalent call. */
+       if (RelationNeedsWAL(rel))
+               GetTopTransactionId();
+
        START_CRIT_SECTION();
 
        MarkBufferDirty(buf);
@@ -438,6 +443,10 @@ AlterSequence(AlterSeqStmt *stmt)
        /* Note that we do not change the currval() state */
        elm->cached = elm->last;
 
+       /* check the comment above nextval_internal()'s equivalent call. */
+       if (RelationNeedsWAL(seqrel))
+               GetTopTransactionId();
+
        /* Now okay to update the on-disk tuple */
        START_CRIT_SECTION();
 
@@ -679,6 +688,16 @@ nextval_internal(Oid relid)
 
        last_used_seq = elm;
 
+       /*
+        * If something needs to be WAL logged, acquire an xid, so this
+        * transaction's commit will trigger a WAL flush and wait for
+        * syncrep. It's sufficient to ensure the toplevel transaction has a xid,
+        * no need to assign xids subxacts, that'll already trigger a appropriate
+        * wait.  (Have to do that here, so we're outside the critical section)
+        */
+       if (logit && RelationNeedsWAL(seqrel))
+               GetTopTransactionId();
+
        /* ready to change the on-disk (or really, in-buffer) tuple */
        START_CRIT_SECTION();
 
@@ -867,6 +886,10 @@ do_setval(Oid relid, int64 next, bool iscalled)
        /* In any case, forget any future cached numbers */
        elm->cached = elm->last;
 
+       /* check the comment above nextval_internal()'s equivalent call. */
+       if (RelationNeedsWAL(seqrel))
+               GetTopTransactionId();
+
        /* ready to change the on-disk (or really, in-buffer) tuple */
        START_CRIT_SECTION();