cargo fmt

pageserver/src/tenant/disk_btree.rs

@@ -29,13 +29,17 @@ use std::{
     io,
     iter::Rev,
     ops::{Range, RangeInclusive},
-    result, time::Duration,
+    result,
+    time::Duration,
 };
 use thiserror::Error;
 use tracing::error;
 
 use crate::{
-    context::{DownloadBehavior, RequestContext}, log_if_slow, task_mgr::TaskKind, tenant::block_io::{BlockReader, BlockWriter}
+    context::{DownloadBehavior, RequestContext},
+    log_if_slow,
+    task_mgr::TaskKind,
+    tenant::block_io::{BlockReader, BlockWriter},
 };
 
 // The maximum size of a value stored in the B-tree. 5 bytes is enough currently.

pageserver/src/tenant/storage_layer/layer/tests.rs

@@ -9,7 +9,10 @@ use utils::{
 
 use super::failpoints::{Failpoint, FailpointKind};
 use super::*;
-use crate::{context::DownloadBehavior, tenant::storage_layer::{IoConcurrency, LayerVisibilityHint}};
+use crate::{
+    context::DownloadBehavior,
+    tenant::storage_layer::{IoConcurrency, LayerVisibilityHint},
+};
 use crate::{task_mgr::TaskKind, tenant::harness::TenantHarness};
 
 /// Used in tests to advance a future to wanted await point, and not futher.

pageserver/src/tenant/timeline.rs

@@ -3454,7 +3454,6 @@ impl Timeline {
                         )));
                     }
                 }
-
             }
         }
         trace!("futures completed");

pageserver/src/virtual_file/io_engine.rs

@@ -111,7 +111,8 @@ pub(crate) fn get() -> IoEngine {
 
 use std::{
     os::unix::prelude::FileExt,
-    sync::atomic::{AtomicU8, Ordering}, time::Duration,
+    sync::atomic::{AtomicU8, Ordering},
+    time::Duration,
 };
 
 use super::{