LuoGe
/
openGauss-server
forked from huawei/openGauss-server
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix pitr restore startup thread pause 

Offering: openGaussDev

More detail: Modify startup thread

Match-id-84834a5b1b36b79ed1d39f14f921c4d6bc20129c
This commit is contained in:
openGaussDev 2022-03-03 23:39:12 +08:00 committed by yanghao
parent 91c2c64911
commit acb17bd1ec
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/common/backend/pgxc_single/barrier/barrier.cpp
View File

@ -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();