From 2ee316b4542b56586cb2ad88033bdb02e6c47251 Mon Sep 17 00:00:00 2001 From: Christian Schwarz Date: Fri, 11 Apr 2025 16:46:41 +0200 Subject: [PATCH] minimize diff a bit --- .../src/tenant/storage_layer/delta_layer.rs | 15 ++++++++------- .../src/virtual_file/owned_buffers_io/write.rs | 3 ++- 2 files changed, 10 insertions(+), 8 deletions(-) diff --git a/pageserver/src/tenant/storage_layer/delta_layer.rs b/pageserver/src/tenant/storage_layer/delta_layer.rs index 12735352a2..33f5ebfd7b 100644 --- a/pageserver/src/tenant/storage_layer/delta_layer.rs +++ b/pageserver/src/tenant/storage_layer/delta_layer.rs @@ -27,6 +27,14 @@ //! "values" part. The actual page images and WAL records are stored in the //! "values" part. //! +use std::collections::{HashMap, VecDeque}; +use std::fs::File; +use std::ops::Range; +use std::os::unix::fs::FileExt; +use std::str::FromStr; +use std::sync::Arc; +use std::sync::atomic::AtomicU64; + use anyhow::{Context, Result, bail, ensure}; use camino::{Utf8Path, Utf8PathBuf}; use futures::StreamExt; @@ -38,13 +46,6 @@ use pageserver_api::models::ImageCompressionAlgorithm; use pageserver_api::shard::TenantShardId; use pageserver_api::value::Value; use serde::{Deserialize, Serialize}; -use std::collections::{HashMap, VecDeque}; -use std::fs::File; -use std::ops::Range; -use std::os::unix::fs::FileExt; -use std::str::FromStr; -use std::sync::Arc; -use std::sync::atomic::AtomicU64; use tokio::sync::OnceCell; use tokio_epoll_uring::IoBuf; use tokio_util::sync::CancellationToken; diff --git a/pageserver/src/virtual_file/owned_buffers_io/write.rs b/pageserver/src/virtual_file/owned_buffers_io/write.rs index 077bd1bc06..a87b9d175b 100644 --- a/pageserver/src/virtual_file/owned_buffers_io/write.rs +++ b/pageserver/src/virtual_file/owned_buffers_io/write.rs @@ -1,7 +1,6 @@ mod flush; use std::sync::Arc; -use super::io_buf_aligned::{IoBufAligned, IoBufAlignedMut}; use bytes::BufMut; pub(crate) use flush::FlushControl; use flush::FlushHandle; @@ -9,6 +8,8 @@ pub(crate) use flush::FlushTaskError; use tokio_epoll_uring::IoBuf; use tokio_util::sync::CancellationToken; +use super::io_buf_aligned::IoBufAligned; +use super::io_buf_aligned::IoBufAlignedMut; use super::io_buf_ext::{FullSlice, IoBufExt}; use crate::context::RequestContext; use crate::virtual_file::{IoBuffer, IoBufferMut};