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

Set request_lsn=max(gc_cutoff,request_lsn)

Browse Source
This commit is contained in:
Kosntantin Knizhnik
2025-07-12 15:55:41 +03:00
parent af61b7238d
commit c42c38138e
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
pgxn/neon/communicator.c
View File

@@ -2227,6 +2227,19 @@ Retry:
case T_NeonGetPageResponse:
{
NeonGetPageResponse* getpage_resp = (NeonGetPageResponse *) resp;
if (resp->lsn != UINT64_MAX) /* replica */
{
XLogRecPtr page_lsn = PageGetLSN((Page)getpage_resp->page);
XLogRecPtr replay_lsn = GetXLogReplayRecPtr(NULL);
if (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))));
}
}
memcpy(buffer, getpage_resp->page, BLCKSZ);
/*