From 9ca92e3010dad5837d9b5a1f35068b6015fc993f Mon Sep 17 00:00:00 2001
From: Xiao__Ma <maxiang9527@126.com>
Date: Wed, 31 Mar 2021 16:34:16 +0800
Subject: [PATCH] rto

---
 src/gausskernel/storage/replication/walreceiverfuncs.cpp | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/src/gausskernel/storage/replication/walreceiverfuncs.cpp b/src/gausskernel/storage/replication/walreceiverfuncs.cpp
index 78672a4b7..60f0218ce 100644
--- a/src/gausskernel/storage/replication/walreceiverfuncs.cpp
+++ b/src/gausskernel/storage/replication/walreceiverfuncs.cpp
@@ -403,6 +403,13 @@ void ShutdownWalRcv(void)
  */
 void RequestXLogStreaming(XLogRecPtr *recptr, const char *conninfo, ReplConnTarget conn_target, const char *slotname)
 {
+    knl_g_disconn_node_context_data disconn_node =
+        g_instance.comm_cxt.localinfo_cxt.disable_conn_node.disable_conn_node_data;
+    if (disconn_node.conn_mode == PROHIBIT_CONNECTION) {
+        ereport(LOG, (errmsg("Stop to start walreceiver in disable connect mode")));
+        return;
+    }
+
     /* use volatile pointer to prevent code rearrangement */
     volatile WalRcvData *walrcv = t_thrd.walreceiverfuncs_cxt.WalRcv;
     pg_time_t now = (pg_time_t)time(NULL);