From b17e58e7562784e9455a4f0f0cfa845d08b9aff5 Mon Sep 17 00:00:00 2001 From: "arcoalien@qq.com" Date: Wed, 30 Aug 2023 19:43:11 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96cm=5Fagent=E8=8E=B7=E5=8F=96?= =?UTF-8?q?=E5=BF=AB=E7=85=A7=E9=80=BB=E8=BE=91=EF=BC=8C=E4=B8=8D=E8=B5=B0?= =?UTF-8?q?dms=EF=BC=8C=E5=87=8F=E5=B0=91cm=5Fagent=E8=8E=B7=E5=8F=96?= =?UTF-8?q?=E7=8A=B6=E6=80=81=E5=BC=82=E5=B8=B8=E7=9A=84=E5=9C=BA=E6=99=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/gausskernel/ddes/adapter/ss_transaction.cpp | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/gausskernel/ddes/adapter/ss_transaction.cpp b/src/gausskernel/ddes/adapter/ss_transaction.cpp index d03c2d4814..a25033bb72 100644 --- a/src/gausskernel/ddes/adapter/ss_transaction.cpp +++ b/src/gausskernel/ddes/adapter/ss_transaction.cpp @@ -99,6 +99,12 @@ Snapshot SSGetSnapshotData(Snapshot snapshot) return NULL; } + /* For cm agent, it only query the system status using the parameter in memory. So don't need MVCC */ + if (u_sess->libpq_cxt.IsConnFromCmAgent) { + snapshot = SnapshotNow; + return snapshot; + } + if (!ENABLE_SS_BCAST_SNAPSHOT || (g_instance.dms_cxt.latest_snapshot_xmax == InvalidTransactionId && t_thrd.dms_cxt.latest_snapshot_xmax == InvalidTransactionId)) { -- Gitee