From 9379dabecb42a5503e49821a236db9bba8063edf Mon Sep 17 00:00:00 2001 From: wangw Date: Fri, 21 Jan 2022 08:59:05 +0800 Subject: [PATCH] Add more logs --- src/backend/replication/pgoutput/pgoutput.c | 1 + src/backend/replication/walsender.c | 6 ++++++ 2 files changed, 7 insertions(+) diff --git a/src/backend/replication/pgoutput/pgoutput.c b/src/backend/replication/pgoutput/pgoutput.c index 30dc4192cf..70b0c72fa9 100644 --- a/src/backend/replication/pgoutput/pgoutput.c +++ b/src/backend/replication/pgoutput/pgoutput.c @@ -655,6 +655,7 @@ pgoutput_change(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, case REORDER_BUFFER_CHANGE_INSERT: if (!relentry->pubactions.pubinsert) { + elog(LOG, "before invoking update progress"); OutputPluginUpdateProgress(ctx); return; } diff --git a/src/backend/replication/walsender.c b/src/backend/replication/walsender.c index d6270ac8cd..e02dc0b90b 100644 --- a/src/backend/replication/walsender.c +++ b/src/backend/replication/walsender.c @@ -3618,10 +3618,16 @@ WalSndKeepaliveIfNecessary(void) * we're doing something not partaking in timeouts. */ if (wal_sender_timeout <= 0 || last_reply_timestamp <= 0) + { + elog(LOG, "return because wal_sender_timeout or last_reply_timestamp"); return; + } if (waiting_for_ping_response) + { + elog(LOG, "return because waiting_for_ping_response"); return; + } /* * If half of wal_sender_timeout has lapsed without receiving any reply -- 2.18.4