From e5311bd6a1eaa95204ea156cd9cef66497bcea3e Mon Sep 17 00:00:00 2001 From: dongning12 Date: Tue, 1 Aug 2023 17:06:47 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90=E8=B5=84=E6=BA=90=E6=B1=A0=E5=8C=96?= =?UTF-8?q?=E3=80=91DMS=E4=BE=A7=E6=B6=88=E6=81=AF=E8=B6=85=E6=97=B6?= =?UTF-8?q?=E6=97=B6=E9=97=B4=E9=BB=98=E8=AE=A410s?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/gausskernel/ddes/adapter/ss_init.cpp | 1 + src/include/ddes/dms/ss_common_attr.h | 2 ++ 2 files changed, 3 insertions(+) diff --git a/src/gausskernel/ddes/adapter/ss_init.cpp b/src/gausskernel/ddes/adapter/ss_init.cpp index 54b437919b..a4f862cbc0 100644 --- a/src/gausskernel/ddes/adapter/ss_init.cpp +++ b/src/gausskernel/ddes/adapter/ss_init.cpp @@ -377,6 +377,7 @@ static void setDMSProfile(dms_profile_t* profile) profile->enable_reform = (unsigned char)dms_attr->enable_reform; profile->load_balance_mode = 1; /* primary-standby */ profile->parallel_thread_num = dms_attr->parallel_thread_num; + profile->max_wait_time = DMS_MSG_MAX_WAIT_TIME; if (dms_attr->enable_ssl && g_instance.attr.attr_security.EnableSSL) { InitDmsSSL(); diff --git a/src/include/ddes/dms/ss_common_attr.h b/src/include/ddes/dms/ss_common_attr.h index c04d0a63a0..fca52f775b 100644 --- a/src/include/ddes/dms/ss_common_attr.h +++ b/src/include/ddes/dms/ss_common_attr.h @@ -186,6 +186,8 @@ #define SS_ACQUIRE_LOCK_DO_NOT_WAIT 0 #define SS_ACQUIRE_LOCK_RETRY_INTERVAL (50) // 50ms +#define DMS_MSG_MAX_WAIT_TIME (10 * 1000) // 10s + typedef enum SSBroadcastOp { BCAST_GET_XMIN = 0, BCAST_CANCEL_TRX_FOR_SWITCHOVER, -- Gitee