From 1622de3fda5a04c6679b6cad623fce745a543c70 Mon Sep 17 00:00:00 2001 From: Bojan Serafimov Date: Thu, 14 Apr 2022 13:42:35 -0400 Subject: [PATCH] Clippy --- pageserver/src/wal_metadata.rs | 6 +++--- pageserver/src/walingest.rs | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/pageserver/src/wal_metadata.rs b/pageserver/src/wal_metadata.rs index 53a9eee763..199024d5e6 100644 --- a/pageserver/src/wal_metadata.rs +++ b/pageserver/src/wal_metadata.rs @@ -12,14 +12,14 @@ //! only measure read performance. //! use anyhow::Result; -use bytes::{BufMut, Bytes, BytesMut}; +use bytes::{BufMut, BytesMut}; use once_cell::sync::OnceCell; use serde::{Deserialize, Serialize}; use std::fs::File; -use tokio::io::{AsyncReadExt, AsyncWriteExt}; +use tokio::io::AsyncReadExt; use zenith_utils::lsn::Lsn; -use crate::{config::PageServerConf, repository::Key, walrecord::DecodedBkpBlock}; +use crate::{config::PageServerConf, walrecord::DecodedBkpBlock}; pub static WAL_METADATA_FILE: OnceCell = OnceCell::new(); diff --git a/pageserver/src/walingest.rs b/pageserver/src/walingest.rs index 01ee4ec407..0f795fcf7c 100644 --- a/pageserver/src/walingest.rs +++ b/pageserver/src/walingest.rs @@ -255,7 +255,7 @@ impl<'a, R: Repository> WalIngest<'a, R> { lsn, size: recdata_len, affected_pages: decoded.blocks.iter().map(|blk| blk.into()).collect(), - }); + })?; // If checkpoint data was updated, store the new version in the repository if self.checkpoint_modified {