修改判断HA端口方式
This commit is contained in:
@ -1,4 +1,4 @@
|
||||
/* -------------------------------------------------------------------------
|
||||
/* -------------------------------------------------------------------------
|
||||
*
|
||||
* postmaster.cpp
|
||||
* This program acts as a clearing house for requests to the
|
||||
@ -3242,7 +3242,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")));
|
||||
|
Reference in New Issue
Block a user