From acb17bd1ecc1e2539fbfb606108a19ee7ace9692 Mon Sep 17 00:00:00 2001
From: openGaussDev <zhangluyao5@huawei.com>
Date: Thu, 3 Mar 2022 23:39:12 +0800
Subject: [PATCH]  fix pitr restore startup thread pause

Offering: openGaussDev

More detail: Modify startup thread

Match-id-84834a5b1b36b79ed1d39f14f921c4d6bc20129c
---
 src/common/backend/pgxc_single/barrier/barrier.cpp | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/common/backend/pgxc_single/barrier/barrier.cpp b/src/common/backend/pgxc_single/barrier/barrier.cpp
index 8d1adb3a5..d327d233b 100755
--- a/src/common/backend/pgxc_single/barrier/barrier.cpp
+++ b/src/common/backend/pgxc_single/barrier/barrier.cpp
@@ -1017,7 +1017,7 @@ static void RequestXLogFromStream()
 
 static void barrier_redo_pause(char* barrierId)
 {
-    if (!is_barrier_pausable(barrierId)) {
+    if (!is_barrier_pausable(barrierId) || t_thrd.xlog_cxt.recoveryTarget == RECOVERY_TARGET_TIME_OBS) {
         return;
     }
     volatile WalRcvData *walrcv = t_thrd.walreceiverfuncs_cxt.WalRcv;
@@ -1035,7 +1035,7 @@ static void barrier_redo_pause(char* barrierId)
             SpinLockRelease(&walrcv->mutex);
             pg_usleep(1000L);
             RedoInterruptCallBack();
-            if(IS_OBS_DISASTER_RECOVER_MODE) {
+            if (IS_OBS_DISASTER_RECOVER_MODE) {
                 update_recovery_barrier();
             } else if (IS_DISASTER_RECOVER_MODE) {
                 RequestXLogFromStream();