From 34909bdaa72f6f55d9200c3242b1e64481ccba48 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Cross-=E7=BD=97?= <1165977584@qq.com>
Date: Thu, 4 Nov 2021 10:23:09 +0000
Subject: [PATCH] =?UTF-8?q?=E9=99=90=E5=88=B6=E5=BD=92=E6=A1=A3=E5=A4=8D?=
 =?UTF-8?q?=E5=88=B6=E6=A7=BD=E5=8F=AA=E8=83=BD=E6=9C=890=E6=88=961?=
 =?UTF-8?q?=E4=B8=AA=EF=BC=8C=E5=9C=A8=E5=B7=B2=E6=9C=89=E5=BD=92=E6=A1=A3?=
 =?UTF-8?q?=E5=A4=8D=E5=88=B6=E6=A7=BD=E7=9A=84=E6=83=85=E5=86=B5=E4=B8=8B?=
 =?UTF-8?q?=E4=B8=8D=E5=85=81=E8=AE=B8=E5=88=9B=E5=BB=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/gausskernel/storage/replication/slotfuncs.cpp | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/gausskernel/storage/replication/slotfuncs.cpp b/src/gausskernel/storage/replication/slotfuncs.cpp
index c55b58b5..25c6bee1 100644
--- a/src/gausskernel/storage/replication/slotfuncs.cpp
+++ b/src/gausskernel/storage/replication/slotfuncs.cpp
@@ -1015,6 +1015,11 @@ XLogRecPtr create_physical_replication_slot_for_archive(const char* slot_name, b
         ereport(ERROR, (errcode(ERRCODE_DATATYPE_MISMATCH), errmsg("version must be bigger than 92260")));
     }
 
+    volatile int *slot_num = &g_instance.archive_obs_cxt.obs_slot_num;
+    if (*slot_num != 0) {
+        ereport(ERROR, (errmsg("Cannot create an archive replication slot because there is already one")));
+    }
+
     check_permissions();
 
     /* create persistent replication slot with extra archive configuration */