From 8763f363f122b29ac0a07949e89bfb052d8dcdc0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=BD=98=E6=B5=A9=E6=96=87?= Date: Thu, 5 Jan 2023 20:34:43 +0800 Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E5=BC=80=E5=90=AF=E6=9C=80?= =?UTF-8?q?=E5=A4=A7=E5=8F=AF=E7=94=A8=E6=A8=A1=E5=BC=8F=E5=90=8E=EF=BC=8C?= =?UTF-8?q?=E9=9B=86=E7=BE=A4=E6=97=A0=E6=B3=95=E5=90=AF=E5=8A=A8=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/gausskernel/storage/replication/syncrep.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/gausskernel/storage/replication/syncrep.cpp b/src/gausskernel/storage/replication/syncrep.cpp index cbb46e1b9..77fa9a0c6 100755 --- a/src/gausskernel/storage/replication/syncrep.cpp +++ b/src/gausskernel/storage/replication/syncrep.cpp @@ -571,7 +571,7 @@ void SyncRepInitConfig(void) SyncRepGetStandbyGroupAndPriority(&group, &priority); if (t_thrd.walsender_cxt.MyWalSnd->sync_standby_group != group || t_thrd.walsender_cxt.MyWalSnd->sync_standby_priority != priority) { - SpinLockAcquire(&t_thrd.walsender_cxt.MyWalSnd->mutex); + LWLockAcquire(SyncRepLock, LW_EXCLUSIVE); t_thrd.walsender_cxt.MyWalSnd->sync_standby_group = group; t_thrd.walsender_cxt.MyWalSnd->sync_standby_priority = priority; @@ -582,7 +582,7 @@ void SyncRepInitConfig(void) */ SyncRepCheckSyncStandbyAlive(); - SpinLockRelease(&t_thrd.walsender_cxt.MyWalSnd->mutex); + LWLockRelease(SyncRepLock); ereport(DEBUG1, (errmsg("standby \"%s\" now has synchronous standby group and priority: %d %d", u_sess->attr.attr_common.application_name, group, priority))); }