File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -97,19 +97,14 @@ impl<DB: Database> PoolInner<DB> {
9797 self . mark_closed ( ) ;
9898
9999 async move {
100- for permits in 1 ..=self . options . max_connections {
101- // Close any currently idle connections in the pool.
102- while let Some ( idle) = self . idle_conns . pop ( ) {
103- let _ = idle. live . float ( ( * self ) . clone ( ) ) . close ( ) . await ;
104- }
105-
106- if self . size ( ) == 0 {
107- break ;
108- }
100+ let _permits = self . semaphore . acquire ( self . options . max_connections ) . await ;
109101
110- // Wait for all permits to be released.
111- let _permits = self . semaphore . acquire ( permits ) . await ;
102+ while let Some ( idle ) = self . idle_conns . pop ( ) {
103+ let _ = idle . live . raw . close ( ) . await ;
112104 }
105+
106+ self . num_idle . store ( 0 , Ordering :: Release ) ;
107+ self . size . store ( 0 , Ordering :: Release ) ;
113108 }
114109 }
115110
You can’t perform that action at this time.
0 commit comments