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

WalProposer: Read WAL directly from WAL buffers in PG17 (#9171)

Browse Source 
This reduces the overhead of the WalProposer when it is not being
throttled by SK WAL acceptance rate
This commit is contained in:
Matthias van de Meent
2024-09-27 17:47:05 +02:00
committed by GitHub
parent d56c4e7a38
commit 5c5871111a
1 changed files with 27 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
pgxn/neon/walproposer_pg.c
View File

@@ -1473,11 +1473,33 @@ walprop_pg_wal_read(Safekeeper *sk, char *buf, XLogRecPtr startptr, Size count,
{ {
NeonWALReadResult res; NeonWALReadResult res;
res = NeonWALRead(sk->xlogreader, #if PG_MAJORVERSION_NUM >= 17
buf, if (!sk->wp->config->syncSafekeepers)
startptr, {
count, Size rbytes;
walprop_pg_get_timeline_id()); rbytes = WALReadFromBuffers(buf, startptr, count,
walprop_pg_get_timeline_id());
startptr += rbytes;
count -= rbytes;
}
#endif
if (count == 0)
{
res = NEON_WALREAD_SUCCESS;
}
else
{
Assert(count > 0);
/* Now read the remaining WAL from the WAL file */
res = NeonWALRead(sk->xlogreader,
buf,
startptr,
count,
walprop_pg_get_timeline_id());
}
if (res == NEON_WALREAD_SUCCESS) if (res == NEON_WALREAD_SUCCESS)
{ {