rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-16 09:52:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix walproposer main loop

Browse Source
This commit is contained in:
Arthur Petukhovsky
2023-07-28 21:18:08 +00:00
parent 89bd7ab8a3
commit 095747afc0
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pgxn/neon/walproposer.c
View File

@@ -2299,7 +2299,9 @@ HandleSafekeeperResponse(void)
{
/* Get ReplicationFeedback fields from the most advanced safekeeper */
GetLatestNeonFeedback(&quorumFeedback.rf);
#ifndef SIMLIB
SetZenithCurrentClusterSize(quorumFeedback.rf.currentClusterSize);
#endif
}
if (minQuorumLsn > quorumFeedback.flushLsn || diskConsistentLsn != quorumFeedback.rf.ps_flushlsn)
@@ -2308,6 +2310,7 @@ HandleSafekeeperResponse(void)
if (minQuorumLsn > quorumFeedback.flushLsn)
quorumFeedback.flushLsn = minQuorumLsn;
#ifndef SIMLIB
/* advance the replication slot */
if (!syncSafekeepers)
ProcessStandbyReply(
@@ -2322,18 +2325,21 @@ HandleSafekeeperResponse(void)
*/
quorumFeedback.rf.ps_flushlsn,
GetCurrentTimestamp(), false);
#endif
}
CombineHotStanbyFeedbacks(&hsFeedback);
if (hsFeedback.ts != 0 && memcmp(&hsFeedback, &quorumFeedback.hs, sizeof hsFeedback) != 0)
{
quorumFeedback.hs = hsFeedback;
#ifndef SIMLIB
if (!syncSafekeepers)
ProcessStandbyHSFeedback(hsFeedback.ts,
XidFromFullTransactionId(hsFeedback.xmin),
EpochFromFullTransactionId(hsFeedback.xmin),
XidFromFullTransactionId(hsFeedback.catalog_xmin),
EpochFromFullTransactionId(hsFeedback.catalog_xmin));
#endif
}
/*