rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-05-18 05:30:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Don't try to read from two WAL files in one read() call.

Browse Source 
That obviously won't work, you have to stop at the WAL file boundary,
and open the next file.
This commit is contained in:
Heikki Linnakangas
2021-04-19 10:34:51 +03:00
parent 8d1bf152cf
commit 9809613c6f
2 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
vendor/postgres vendored

Submodule vendor/postgres updated: ea5a673983...167196910d

9
walkeeper/src/wal_service.rs
View File

@@ -1023,7 +1023,14 @@ impl Connection {
}
}
}
let send_size = min((end_pos - start_pos) as usize, MAX_SEND_SIZE);
let xlogoff = XLogSegmentOffset(start_pos, wal_seg_size) as usize;
// How much to read and send in message? We cannot cross the WAL file
// boundary, and we don't want send more than MAX_SEND_SIZE.
let send_size = (end_pos - start_pos) as usize;
let send_size = min(send_size, wal_seg_size - xlogoff);
let send_size = min(send_size, MAX_SEND_SIZE);
let msg_size = LIBPQ_HDR_SIZE + XLOG_HDR_SIZE + send_size;
let data_start = LIBPQ_HDR_SIZE + XLOG_HDR_SIZE;
let data_end = data_start + send_size;