fn return_conn(&mut self, conn: Conn) {
        // NOTE: we're not in async context here, so we can't block or return NotReady
        // any and all cleanup work _has_ to be done in the spawned recycler

        // fast-path for when the connection is immediately ready to be reused
        if conn.inner.stream.is_some()
            && !conn.inner.disconnected
            && !conn.expired()
            && !conn.inner.in_transaction
            && conn.inner.has_result.is_none()
            && !self.inner.close.load(atomic::Ordering::Acquire)
            && self.inner.idle.len() < self.pool_constraints.min()
        {
            self.inner
                .idle
                .push(conn)
                .expect("more connections than max");
            self.inner.wake(1);
        } else {
            self.drop
                .try_send(Some(conn))
                .expect("recycler is active as long as any Pool is");
        }
    }
/// A way to return connection taken from a pool.
A way to return connection taken from a pool.
A way to return connection taken from a pool .
fn return_conn(&mut self, conn: Conn) {
        // NOTE: we're not in async context here, so we can't block or return NotReady
        // any and all cleanup work _has_ to be done in the spawned recycler
        // fast-path for when the connection is immediately ready to be reused
        if conn.inner.stream.is_some()
            && !conn.inner.disconnected
            && !conn.expired()
            && !conn.inner.in_transaction
            && conn.inner.has_result.is_none()
            && !self.inner.close.load(atomic::Ordering::Acquire)
            && self.inner.idle.len() < self.pool_constraints.min()
        {
            self.inner
                .idle
                .push(conn)
                .expect("more connections than max");
            self.inner.wake(1);
        } else {
            self.drop
                .try_send(Some(conn))
                .expect("recycler is active as long as any Pool is");
        }
    }
fn return_conn ( & mut self , conn : Conn ) { // NOTE: we're not in async context here, so we can't block or return NotReady // any and all cleanup work _has_ to be done in the spawned recycler // fast-path for when the connection is immediately ready to be reused if conn . inner . stream . is_some ( ) && ! conn . inner . disconnected && ! conn . expired ( ) && ! conn . inner . in_transaction && conn . inner . has_result . is_none ( ) && ! self . inner . close . load ( atomic :: Ordering :: Acquire ) && self . inner . idle . len ( ) < self . pool_constraints . min ( ) { self . inner . idle . push ( conn ) . expect ( " " ) ; self . inner . wake ( 1 ) ; } else { self . drop . try_send ( Some ( conn ) ) . expect ( " " ) ; } }
A way to return connection taken from a pool.
A way to return connection taken from a pool .
&mut self
conn
Conn
&mut self
conn
Conn