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

some cleanup work

Browse Source
This commit is contained in:
Christian Schwarz
2024-01-31 12:17:05 +01:00
parent a93be15360
commit 8012b80a45
1 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
pageserver/src/walredo.rs
View File

@@ -826,14 +826,10 @@ impl WalRedoProcess {
async fn apply_wal_records0(&self, writebuf: &[u8]) -> anyhow::Result<Bytes> {
let input = self.stdin.lock().await;
let mut proc = { input }; // TODO: remove this legacy rename, but this keep the patch small.
proc.stdin.write_all(writebuf).await.unwrap(); // TODO: bring back timeout & error handling
let request_no = proc.n_requests;
proc.n_requests += 1;
drop(proc);
input.stdin.write_all(writebuf).await.unwrap(); // TODO: bring back timeout & error handling
let request_no = input.n_requests;
input.n_requests += 1;
drop(input);
// To improve walredo performance we separate sending requests and receiving
// responses. Them are protected by different mutexes (output and input).