itsscb/sqlx
1
0
Fork 0
mirror of https://github.com/launchbadge/sqlx.git synced 2025-09-30 06:22:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

manually close connections in SharedPool::close

Browse Source
This commit is contained in:
Andrew Whitehead 2020-12-17 22:02:08 -08:00 committed by Ryan Leckey
parent f39d194b17
commit a445f9f431
No known key found for this signature in database
GPG Key ID: F8AA68C235AB08C9
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
sqlx-core/src/pool/inner.rs
View File

@ -47,10 +47,11 @@ impl<DB: Database> SharedPool<DB> {
// ensure we wait until the pool is actually closed
while self.size() > 0 {
let _ = self
.idle_conns
.pop()
.map(|idle| Floating::from_idle(idle, self));
if let Ok(idle) = self.idle_conns.pop() {
if let Err(e) = Floating::from_idle(idle, self).close().await {
log::warn!("error occurred while closing the pool connection: {}", e);
}
}
// yield to avoid starving the executor
sqlx_rt::yield_now().await;