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

wip

Browse Source
This commit is contained in:
Bojan Serafimov
2023-12-04 14:19:45 -05:00
parent 13b076401a
commit dd4ff8ef9e
1 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
pageserver/src/walingest.rs
View File

@@ -2159,9 +2159,13 @@ mod tests {
let prof_guard = crate::profiling::profpoint_start();
let started_at = std::time::Instant::now();
// Decode and ingest wal. We process the wal in chunks because
// that's what happens when we get bytes from safekeepers.
for chunk in bytes[xlogoff..].chunks(50) {
// Decode and ingest wal.
//
// NOTE We process the wal in chunks because that's what happens
// when we get bytes from safekeepers. We use size 1906 because
// that was the average chunk size during the test that generated
// this data.
for chunk in bytes[xlogoff..].chunks(1906) {
decoder.feed_bytes(chunk);
while let Some((lsn, recdata)) = decoder.poll_decode().unwrap() {
walingest
@@ -2169,6 +2173,11 @@ mod tests {
.await
.unwrap();
}
// Do operations we do on every XLogData message
// TODO check if 50 is the right chunk size
// TODO there's more operations to include here
tline.check_checkpoint_distance().await.unwrap();
}
drop(prof_guard);