hcq/openGauss-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

!289 fix core when running mot hacheck

Browse Source 
Merge pull request !289 from chenxiaobin/catchup
This commit is contained in:
opengauss-bot
2020-10-09 16:21:16 +08:00
committed by Gitee
parent fb5782af38 f8743d10c8
commit 3eed9d4507
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/gausskernel/storage/replication/syncrep.cpp
View File

@ -1104,8 +1104,9 @@ static List* SyncRepGetSyncStandbysQuorum(bool* am_sync, List** catchup_standbys
/* Must be streaming */ /* Must be streaming */
if (walsnd->state != WALSNDSTATE_STREAMING) { if (walsnd->state != WALSNDSTATE_STREAMING) {
*catchup_standbys = if (catchup_standbys != NULL && walsnd->state == WALSNDSTATE_CATCHUP) {
walsnd->state == WALSNDSTATE_CATCHUP ? lappend_int(*catchup_standbys, i) : *catchup_standbys; *catchup_standbys = lappend_int(*catchup_standbys, i);
}
continue; continue;
} }
@ -1174,8 +1175,9 @@ static List* SyncRepGetSyncStandbysPriority(bool* am_sync, List** catchup_standb
/* Must be streaming */ /* Must be streaming */
if (walsnd->state != WALSNDSTATE_STREAMING) { if (walsnd->state != WALSNDSTATE_STREAMING) {
*catchup_standbys = if (catchup_standbys != NULL && walsnd->state == WALSNDSTATE_CATCHUP) {
walsnd->state == WALSNDSTATE_CATCHUP ? lappend_int(*catchup_standbys, i) : *catchup_standbys; *catchup_standbys = lappend_int(*catchup_standbys, i);
}
continue; continue;
} }