diff options
| author | Alex Auvolat <alex@adnab.me> | 2021-03-12 21:52:19 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2021-03-12 21:52:19 +0100 |
| commit | 831eb35763fdaeecb7b6d6aa13ebd78da14db04e (patch) | |
| tree | 375405c95250acb49e627c91c8f457c8fb9e2d1b /src/table/sync.rs | |
| parent | c475471e7a8e7544f2be490898f4249cf27a17e9 (diff) | |
| download | garage-831eb35763fdaeecb7b6d6aa13ebd78da14db04e.tar.gz garage-831eb35763fdaeecb7b6d6aa13ebd78da14db04e.zip | |
cargo fmt
Diffstat (limited to 'src/table/sync.rs')
| -rw-r--r-- | src/table/sync.rs | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/src/table/sync.rs b/src/table/sync.rs index aae65852..6c8792d2 100644 --- a/src/table/sync.rs +++ b/src/table/sync.rs @@ -347,10 +347,13 @@ where ) -> Result<(), Error> { let values = items.iter().map(|(_k, v)| v.clone()).collect::<Vec<_>>(); - self.rpc_client.try_call_many( - &nodes[..], - SyncRPC::Items(values), - RequestStrategy::with_quorum(nodes.len()).with_timeout(TABLE_SYNC_RPC_TIMEOUT)).await?; + self.rpc_client + .try_call_many( + &nodes[..], + SyncRPC::Items(values), + RequestStrategy::with_quorum(nodes.len()).with_timeout(TABLE_SYNC_RPC_TIMEOUT), + ) + .await?; // All remote nodes have written those items, now we can delete them locally let mut not_removed = 0; |