aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2022-06-07 17:10:22 +0200
committerAlex Auvolat <alex@adnab.me>2022-06-07 17:10:22 +0200
commit1d408d52b9abd2705f68bbdb4c28b7990d147e53 (patch)
treea384d865aea2fdc886a9f8670d97659e803bd509
parenta3a01141ec8f8eefe1a31162bd53fbaa2d37e601 (diff)
downloadgarage-1d408d52b9abd2705f68bbdb4c28b7990d147e53.tar.gz
garage-1d408d52b9abd2705f68bbdb4c28b7990d147e53.zip
Simplify
-rw-r--r--src/block/manager.rs2
1 files changed, 0 insertions, 2 deletions
diff --git a/src/block/manager.rs b/src/block/manager.rs
index da86a2d5..aa0969f4 100644
--- a/src/block/manager.rs
+++ b/src/block/manager.rs
@@ -335,7 +335,6 @@ impl BlockManager {
// we will fecth it from someone.
let this = self.clone();
tokio::spawn(async move {
- tokio::time::sleep(Duration::from_secs(1)).await;
if let Err(e) = this.put_to_resync(&hash, 2 * BLOCK_RW_TIMEOUT) {
error!("Block {:?} could not be put in resync queue: {}.", hash, e);
}
@@ -354,7 +353,6 @@ impl BlockManager {
// after that delay has passed.
let this = self.clone();
tokio::spawn(async move {
- tokio::time::sleep(Duration::from_secs(1)).await;
if let Err(e) = this.put_to_resync(&hash, BLOCK_GC_DELAY + Duration::from_secs(10))
{
error!("Block {:?} could not be put in resync queue: {}.", hash, e);