v50-0007-Tablesync-early-exit.patch
application/octet-stream
Filename: v50-0007-Tablesync-early-exit.patch
Type: application/octet-stream
Part: 6
Patch
Format: format-patch
Series: patch v50-0007
Subject: Tablesync early exit.
| File | + | − |
|---|---|---|
| src/backend/replication/logical/worker.c | 10 | 0 |
From 03076070ff5911beb7b477a905b205dc20d531a3 Mon Sep 17 00:00:00 2001
From: Peter Smith <peter.b.smith@fujitsu.com>
Date: Sat, 6 Mar 2021 10:12:35 +1100
Subject: [PATCH v50] Tablesync early exit.
Give the tablesync worker an opportunity to see if it can exit immediately
(because it has already caught-up) without it needing to process a message
first before discovering that.
---
src/backend/replication/logical/worker.c | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/src/backend/replication/logical/worker.c b/src/backend/replication/logical/worker.c
index 9cccdef..1f3aa01 100644
--- a/src/backend/replication/logical/worker.c
+++ b/src/backend/replication/logical/worker.c
@@ -2252,6 +2252,16 @@ LogicalRepApplyLoop(XLogRecPtr last_received)
bool ping_sent = false;
TimeLineID tli;
+ if (am_tablesync_worker())
+ {
+ /*
+ * Give the tablesync worker an opportunity see if it can immediately
+ * exit, instead of always handling a message (which maybe the apply
+ * worker could have handled).
+ */
+ process_syncing_tables(last_received);
+ }
+
/*
* Init the ApplyMessageContext which we clean up after each replication
* protocol message.
--
1.8.3.1