From be038690792358661f4251e1f858ded3bafbe79c Mon Sep 17 00:00:00 2001
From: mujinqiang <1165845907@qq.com>
Date: Sat, 17 Jul 2021 11:26:56 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E6=AD=A4=E5=A4=84=E5=88=A4=E6=96=ADHA?=
 =?UTF-8?q?=E7=AB=AF=E5=8F=A3=E6=96=B9=E5=BC=8F=EF=BC=8CisLocalport?=
 =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E5=9C=A8=E8=B5=B0AF=5FUNIX=E5=8D=8F=E8=AE=AE?=
 =?UTF-8?q?=E6=97=B6=E4=B8=8D=E7=94=9F=E6=95=88?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/gausskernel/process/postmaster/postmaster.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/gausskernel/process/postmaster/postmaster.cpp b/src/gausskernel/process/postmaster/postmaster.cpp
index eabdf193..234adb24 100755
--- a/src/gausskernel/process/postmaster/postmaster.cpp
+++ b/src/gausskernel/process/postmaster/postmaster.cpp
@@ -3236,7 +3236,7 @@ int ProcessStartupPacket(Port* port, bool SSLdone)
 #endif
                 }
             } else if (strcmp(nameptr, "replication") == 0) {
-                if (IsLocalPort(u_sess->proc_cxt.MyProcPort) && g_instance.attr.attr_common.enable_thread_pool) {
+                if (!IsHAPort(u_sess->proc_cxt.MyProcPort) && g_instance.attr.attr_common.enable_thread_pool) {
                     ereport(elevel,
                         (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
                             errmsg("replication should connect HA port in thread_pool")));