postgres.git / summary / log / commit / refs

commit    47698b4b62e3b7aad7e35d86b7ccdaa62799b435
Author:   Michael Paquier <michael@paquier.xyz>
Date:     Fri Oct 18 05:27:04 2019 +0000
First released in: 13.0, 10.11, 11.6, 12.1

    Fix timeout handling in logical replication worker
    
    The timestamp tracking the last moment a message is received in a
    logical replication worker was initialized in each loop checking if a
    message was received or not, causing wal_receiver_timeout to be ignored
    in basically any logical replication deployments.  This also broke the
    ping sent to the server when reaching half of wal_receiver_timeout.
    
    This simply moves the initialization of the timestamp out of the apply
    loop to the beginning of LogicalRepApplyLoop().
    
    Reported-by: Jehan-Guillaume De Rorthais
    Author: Julien Rouhaud
    Discussion: https://postgr.es/m/CAOBaU_ZHESFcWva8jLjtZdCLspMj7vqaB2k++rjHLY897ZxbYw@mail.gmail.com
    Backpatch-through: 10


 src/backend/replication/logical/worker.c | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/backend/replication/logical/worker.c b/src/backend/replication/logical/worker.c
index bd600945761..737c40c1e72 100644
--- a/src/backend/replication/logical/worker.c
+++ b/src/backend/replication/logical/worker.c
@@ -1035,6 +1035,8 @@ UpdateWorkerStats(XLogRecPtr last_lsn, TimestampTz send_time, bool reply)
 static void
 LogicalRepApplyLoop(XLogRecPtr last_received)
 {
+	TimestampTz last_recv_timestamp = GetCurrentTimestamp();
+
 	/*
 	 * Init the ApplyMessageContext which we clean up after each replication
 	 * protocol message.
@@ -1053,7 +1055,6 @@ LogicalRepApplyLoop(XLogRecPtr last_received)
 		int			len;
 		char	   *buf = NULL;
 		bool		endofstream = false;
-		TimestampTz last_recv_timestamp = GetCurrentTimestamp();
 		bool		ping_sent = false;
 		long		wait_time;
 


[parent: 0d9fcbada992]