rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-06-03 21:40:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use GetCurrentReplayRecPtr instead of GetXLogReplayRecPtr in the check for returned page LSN

Browse Source
This commit is contained in:
Konstantin Knizhnik
2025-07-14 08:44:05 +03:00
parent 00826b4082
commit 1db119c657
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
pgxn/neon/communicator.c
View File

@@ -2230,14 +2230,18 @@ Retry:
if (resp->lsn != UINT64_MAX) /* replica */
{
XLogRecPtr page_lsn = PageGetLSN((Page)getpage_resp->page);
XLogRecPtr replay_lsn = GetXLogReplayRecPtr(NULL);
#if PG_VERSION_NUM >= 150000
XLogRecPtr replay_lsn = GetCurrentReplayRecPtr(NULL);
#else
XLogRecPtr replay_lsn = Max(GetXLogReplayRecPtr(NULL), resp->lsn);
#endif
if (replay_lsn != 0 && page_lsn > replay_lsn)
{
/* Alternative to throw error is to repeat the query with request_lsn=replay_lsn */
ereport(ERROR,
(errcode(ERRCODE_IO_ERROR),
errmsg("There is no more version of page %u of relation %u/%u/%u.%u at LSN %X/%X at page server, latest version is at LSN %X/%X",
blockno, RelFileInfoFmt(rinfo), forkNum, LSN_FORMAT_ARGS(replay_lsn), LSN_FORMAT_ARGS(page_lsn))));
errmsg("There is no more version of page %u of relation %u/%u/%u.%u at LSN %X/%X at page server, request LSN %X/%X, latest version is at LSN %X/%X",
blockno, RelFileInfoFmt(rinfo), forkNum, LSN_FORMAT_ARGS(replay_lsn), LSN_FORMAT_ARGS(resp->lsn), LSN_FORMAT_ARGS(page_lsn))));
}
}
memcpy(buffer, getpage_resp->page, BLCKSZ);