itsscb/sqlx
1
0
Fork 0
mirror of https://github.com/launchbadge/sqlx.git synced 2025-12-29 04:04:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Do not call connect it a bussy loop on connection refused.

Browse Source 
If the connection to the database is refused, it is not helpfull to hammer it with connection
attempts, instead we should wait a bit before connecting again. Here we start waiting 10ms,
doubling the wait time for every attempt before setteling out at 2s
This commit is contained in:
Jakob Truelsen 2020-12-21 20:45:22 +01:00 committed by Austin Bonander
parent b8839c6d90
commit 46f9f44d41
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -182,6 +182,7 @@ impl<DB: Database> SharedPool<DB> {
let start = Instant::now();
let deadline = start + self.options.connect_timeout;
let mut waited = !self.options.fair;
let mut backoff = 0.01;
// Unless the pool has been closed ...
while !self.is_closed() {
@ -201,7 +202,14 @@ impl<DB: Database> SharedPool<DB> {
match self.connection(deadline, guard).await {
Ok(Some(conn)) => return Ok(conn),
// [size] is internally decremented on _retry_ and _error_
Ok(None) => continue,
Ok(None) => {
// If the connection is refused wait in exponentially
// increasing steps for the server to come up, capped by
// two seconds.
sqlx_rt::sleep(std::time::Duration::from_secs_f64(backoff)).await;
backoff = f64::min(backoff * 2.0, 2.0);
continue;
}
Err(e) => return Err(e),
}
}