Co-authored-by: Konstantin Knizhnik <knizhnik@neon.tech>
This commit is contained in:
MMeent
2022-11-28 15:34:07 +01:00
committed by GitHub
parent 3ba92d238e
commit 0c1195c30d
2 changed files with 2 additions and 1 deletions

View File

@@ -314,6 +314,7 @@ impl PageServerHandler {
let copy_data_bytes = match msg? {
Some(FeMessage::CopyData(bytes)) => bytes,
Some(FeMessage::Terminate) => break,
Some(m) => {
bail!("unexpected message: {m:?} during COPY");
}

View File

@@ -267,7 +267,7 @@ readahead_buffer_resize(int newsize, void *extra)
nfree = newsize;
PrefetchState *newPState;
Size newprfs_size = offsetof(PrefetchState, prf_buffer) + (
sizeof(PrefetchRequest) * readahead_buffer_size
sizeof(PrefetchRequest) * newsize
);
/* don't try to re-initialize if we haven't initialized yet */