diff --git a/pageserver/src/tenant/blob_io.rs b/pageserver/src/tenant/blob_io.rs index 21327deb70..445d851917 100644 --- a/pageserver/src/tenant/blob_io.rs +++ b/pageserver/src/tenant/blob_io.rs @@ -234,7 +234,10 @@ impl BlobWriter { #[cfg(test)] mod tests { use super::*; - use crate::{context::DownloadBehavior, task_mgr::TaskKind, tenant::block_io::BlockReaderRef}; + use crate::{ + context::DownloadBehavior, task_mgr::TaskKind, tenant::block_io::BlockReaderRef, + virtual_file::Error, + }; use rand::{Rng, SeedableRng}; async fn round_trip_test(blobs: &[Vec]) -> Result<(), Error> { diff --git a/pageserver/src/tenant/block_io.rs b/pageserver/src/tenant/block_io.rs index d81cf1b8a0..28b7a142d0 100644 --- a/pageserver/src/tenant/block_io.rs +++ b/pageserver/src/tenant/block_io.rs @@ -6,7 +6,7 @@ use super::ephemeral_file::EphemeralFile; use super::storage_layer::delta_layer::{Adapter, DeltaLayerInner}; use crate::context::RequestContext; use crate::page_cache::{self, PageReadGuard, ReadBufResult, PAGE_SZ}; -use crate::virtual_file::VirtualFile; +use crate::virtual_file::{self, VirtualFile}; use bytes::Bytes; use std::ops::{Deref, DerefMut}; @@ -96,7 +96,7 @@ impl<'a> BlockReaderRef<'a> { #[cfg(test)] TestDisk(r) => r.read_blk(blknum), #[cfg(test)] - VirtualFile(r) => r.read_blk(blknum).await, + VirtualFile(r) => r.read_blk(blknum).await.map_err(virtual_file::Error::into), } } } @@ -174,6 +174,7 @@ impl FileBlockReader { self.file .read_exact_at(buf, blkno as u64 * PAGE_SZ as u64) .await + .map_err(virtual_file::Error::into) } /// Read a block. ///