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

Fix bug in walproposer voting

Browse Source
This commit is contained in:
Arthur Petukhovsky
2023-08-29 14:11:04 +00:00
parent d801ba7248
commit 0dc262a84a
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

@@ -1455,6 +1455,7 @@ static void
DetermineEpochStartLsn(void)
{
TermHistory *dth;
int n_ready = 0;
propEpochStartLsn = InvalidXLogRecPtr;
donorEpoch = 0;
@@ -1465,6 +1466,8 @@ DetermineEpochStartLsn(void)
{
if (safekeeper[i].state == SS_IDLE)
{
n_ready++;
if (GetEpoch(&safekeeper[i]) > donorEpoch ||
(GetEpoch(&safekeeper[i]) == donorEpoch &&
safekeeper[i].voteResponse.flushLsn > propEpochStartLsn))
@@ -1491,6 +1494,9 @@ DetermineEpochStartLsn(void)
}
}
if (n_ready < quorum)
walprop_log(FATAL, "missing majority of votes, expected %d, got %d", n_votes, n_ready);
/*
* If propEpochStartLsn is 0 everywhere, we are bootstrapping -- nothing
* was committed yet. Start streaming then from the basebackup LSN.