Turn off WalSender keepalives by default, users can enable if desired

diff --git a/src/backend/replication/walsender.c b/src/backend/replication/walsender.c
index 53e134538f4d98a83903a8c209727296f92ddd99..3f060b82c09c0df3bf183f0cf90b160dd6adc426 100644 (file)
--- a/src/backend/replication/walsender.c
+++ b/src/backend/replication/walsender.c
@@ -834,7 +834,7 @@ WalSndLoop(void)
 
                        if (pq_is_send_pending())
                                wakeEvents |= WL_SOCKET_WRITEABLE;
-                       else
+                       else if (MyWalSnd->sendKeepalive)
                        {
                                WalSndKeepalive(output_message);
                                /* Try to flush pending output to the client */

diff --git a/src/include/replication/walsender_private.h b/src/include/replication/walsender_private.h
index 66234cd8b5925d81b535522983fdc75da1d40c75..45cd7444cdfc8558bf86e7afe275d721ee95b245 100644 (file)
--- a/src/include/replication/walsender_private.h
+++ b/src/include/replication/walsender_private.h
@@ -37,6 +37,7 @@ typedef struct WalSnd
        XLogRecPtr      sentPtr;                /* WAL has been sent up to this point */
        bool            needreload;             /* does currently-open file need to be
                                                                 * reloaded? */
+       bool            sendKeepalive;  /* do we send keepalives on this connection? */
 
        /*
         * The xlog locations that have been written, flushed, and applied by