aboutsummaryrefslogtreecommitdiff
path: root/src/model
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2021-03-12 21:52:19 +0100
committerAlex Auvolat <alex@adnab.me>2021-03-12 21:52:19 +0100
commit831eb35763fdaeecb7b6d6aa13ebd78da14db04e (patch)
tree375405c95250acb49e627c91c8f457c8fb9e2d1b /src/model
parentc475471e7a8e7544f2be490898f4249cf27a17e9 (diff)
downloadgarage-831eb35763fdaeecb7b6d6aa13ebd78da14db04e.tar.gz
garage-831eb35763fdaeecb7b6d6aa13ebd78da14db04e.zip
cargo fmt
Diffstat (limited to 'src/model')
-rw-r--r--src/model/block.rs8
1 files changed, 6 insertions, 2 deletions
diff --git a/src/model/block.rs b/src/model/block.rs
index 8b065c04..eccc2cbd 100644
--- a/src/model/block.rs
+++ b/src/model/block.rs
@@ -339,10 +339,14 @@ impl BlockManager {
);
let put_block_message = self.read_block(hash).await?;
- self.rpc_client.try_call_many(
+ self.rpc_client
+ .try_call_many(
&need_nodes[..],
put_block_message,
- RequestStrategy::with_quorum(need_nodes.len()).with_timeout(BLOCK_RW_TIMEOUT)).await?;
+ RequestStrategy::with_quorum(need_nodes.len())
+ .with_timeout(BLOCK_RW_TIMEOUT),
+ )
+ .await?;
}
trace!(
"Deleting block {:?}, offload finished ({} / {})",