rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-16 18:02:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix some minor warnings

Browse Source
This commit is contained in:
Christian Schwarz
2024-12-21 20:37:21 +01:00
parent d776ee66d7
commit d844ed098a
3 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
pageserver/client/src/page_service.rs
View File

@@ -1,4 +1,3 @@
use std::pin::Pin;
use futures::{
stream::{SplitSink, SplitStream},

4
pageserver/src/tenant/storage_layer.rs
View File

@@ -249,7 +249,7 @@ impl IoConcurrency {
trace!(task_id, "spawning");
tokio::spawn(async move {
trace!("start");
scopeguard::defer!({ trace!("end") });
scopeguard::defer!{ trace!("end") };
type IosRx = tokio::sync::mpsc::UnboundedReceiver<IoFuture>;
type BarrierReqRx =
tokio::sync::mpsc::UnboundedReceiver<tokio::sync::oneshot::Sender<()>>;
@@ -426,7 +426,7 @@ impl IoConcurrency {
let io_num = IO_NUM.fetch_add(1, std::sync::atomic::Ordering::Relaxed);
let fut = async move {
trace!("start");
scopeguard::defer!({ trace!("end") });
scopeguard::defer!(trace!("end"));
fut.await
}
.instrument(tracing::trace_span!("spawned_io", %io_num));

2
pageserver/src/virtual_file/io_engine.rs
View File

@@ -15,7 +15,6 @@ pub(super) mod tokio_epoll_uring_ext;
use tokio_epoll_uring::IoBuf;
use tracing::Instrument;
use crate::log_if_slow;
pub(crate) use super::api::IoEngineKind;
#[derive(Clone, Copy)]
@@ -112,7 +111,6 @@ pub(crate) fn get() -> IoEngine {
use std::{
os::unix::prelude::FileExt,
sync::atomic::{AtomicU8, Ordering},
time::Duration,
};
use super::{