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

优化代码结构

This commit is contained in:
luozihao 2021-05-14 10:35:39 +08:00
parent 2cc54fcbe0
commit 79eb60ec65
1 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/gausskernel/storage/replication/walsender.cpp
View File

@ -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")));
}
}