From 79eb60ec650526a11539461e38ec2e492dae97cb Mon Sep 17 00:00:00 2001 From: luozihao <1165977584@qq.com> Date: Fri, 14 May 2021 10:35:39 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81=E7=BB=93?= =?UTF-8?q?=E6=9E=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/gausskernel/storage/replication/walsender.cpp | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) diff --git a/src/gausskernel/storage/replication/walsender.cpp b/src/gausskernel/storage/replication/walsender.cpp index 8d85d3e6..b02c6993 100644 --- a/src/gausskernel/storage/replication/walsender.cpp +++ b/src/gausskernel/storage/replication/walsender.cpp @@ -3206,15 +3206,13 @@ static int WalSndLoop(WalSndSendDataCallback send_data) got_recptr = SyncRepGetSyncRecPtr(&receivePtr, &writePtr, &flushPtr, &replayPtr, &amSync, false); if (got_recptr) { ArchiveXlogOnStandby(flushPtr); + } else if (t_thrd.syncrep_cxt.SyncRepConfig == NULL || + (t_thrd.walsender_cxt.WalSndCtl->most_available_sync && + list_length(SyncRepGetSyncStandbys(&amSync)) == 0)) { + ArchiveXlogOnStandby(t_thrd.walsender_cxt.MyWalSnd->flush); } else { - if (t_thrd.syncrep_cxt.SyncRepConfig == NULL || - (t_thrd.walsender_cxt.WalSndCtl->most_available_sync && - list_length(SyncRepGetSyncStandbys(&amSync)) == 0)) { - ArchiveXlogOnStandby(t_thrd.walsender_cxt.MyWalSnd->flush); - } else { - ereport(WARNING, (errcode(ERRCODE_WARNING), - errmsg("ArchiveXlogOnStandby failed when call SyncRepGetSyncRecPtr"))); - } + ereport(WARNING, (errcode(ERRCODE_WARNING), + errmsg("ArchiveXlogOnStandby failed when call SyncRepGetSyncRecPtr"))); } }