From 639ed3cb3cde2ddfeab9b9b74ef86af46c41b1d7 Mon Sep 17 00:00:00 2001 From: Christian Schwarz Date: Wed, 31 Jan 2024 12:26:27 +0100 Subject: [PATCH] clippy + compile errors --- pageserver/src/walredo.rs | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/pageserver/src/walredo.rs b/pageserver/src/walredo.rs index 9052d0addd..d1d9af7a1d 100644 --- a/pageserver/src/walredo.rs +++ b/pageserver/src/walredo.rs @@ -27,7 +27,6 @@ use std::collections::VecDeque; use std::io; use std::io::prelude::*; use std::ops::{Deref, DerefMut}; -use std::os::unix::io::AsRawFd; use std::os::unix::prelude::CommandExt; use std::process::Stdio; use std::process::{Child, Command}; @@ -36,7 +35,7 @@ use std::time::Duration; use std::time::Instant; use tokio::io::{AsyncReadExt, AsyncWriteExt}; use tracing::*; -use utils::{bin_ser::BeSer, lsn::Lsn, nonblock::set_nonblock}; +use utils::{bin_ser::BeSer, lsn::Lsn}; #[cfg(feature = "testing")] use std::sync::atomic::{AtomicUsize, Ordering}; @@ -818,7 +817,7 @@ impl WalRedoProcess { } async fn apply_wal_records0(&self, writebuf: &[u8]) -> anyhow::Result { - let input = self.stdin.lock().await; + let mut input = self.stdin.lock().await; input .stdin .write_all(writebuf)