mirror of
https://github.com/launchbadge/sqlx.git
synced 2026-03-19 08:39:44 +00:00
fix: run cargo fmt
This commit is contained in:
@@ -208,12 +208,14 @@ impl<DB: Database> PoolInner<DB> {
|
||||
}
|
||||
|
||||
#[inline(always)]
|
||||
async fn finish_acquire(self: &Arc<Self>, conn: ConnectedSlot<ConnectionInner<DB>>) -> Result<PoolConnection<DB>, DisconnectedSlot<ConnectionInner<DB>>> {
|
||||
let span = tracing::trace_span!(target: "sqlx::pool", "finish_acquire", connection_id=?conn.id);
|
||||
async fn finish_acquire(
|
||||
self: &Arc<Self>,
|
||||
conn: ConnectedSlot<ConnectionInner<DB>>,
|
||||
) -> Result<PoolConnection<DB>, DisconnectedSlot<ConnectionInner<DB>>> {
|
||||
let span =
|
||||
tracing::trace_span!(target: "sqlx::pool", "finish_acquire", connection_id=?conn.id);
|
||||
|
||||
finish_acquire(self, conn)
|
||||
.instrument(span)
|
||||
.await
|
||||
finish_acquire(self, conn).instrument(span).await
|
||||
}
|
||||
|
||||
pub(crate) async fn try_min_connections(
|
||||
|
||||
@@ -60,6 +60,12 @@ use std::pin::Pin;
|
||||
use std::sync::Arc;
|
||||
use std::task::{ready, Context, Poll};
|
||||
|
||||
pub use self::connect::{PoolConnectMetadata, PoolConnector};
|
||||
pub use self::connection::PoolConnection;
|
||||
use self::inner::PoolInner;
|
||||
#[doc(hidden)]
|
||||
pub use self::maybe::MaybePoolConnection;
|
||||
pub use self::options::{PoolConnectionMetadata, PoolOptions};
|
||||
use crate::connection::Connection;
|
||||
use crate::database::Database;
|
||||
use crate::error::Error;
|
||||
@@ -69,12 +75,6 @@ use crate::transaction::Transaction;
|
||||
use event_listener::EventListener;
|
||||
use futures_core::FusedFuture;
|
||||
use tracing::Instrument;
|
||||
pub use self::connect::{PoolConnectMetadata, PoolConnector};
|
||||
pub use self::connection::PoolConnection;
|
||||
use self::inner::PoolInner;
|
||||
#[doc(hidden)]
|
||||
pub use self::maybe::MaybePoolConnection;
|
||||
pub use self::options::{PoolConnectionMetadata, PoolOptions};
|
||||
|
||||
#[macro_use]
|
||||
mod executor;
|
||||
|
||||
Reference in New Issue
Block a user