diff options
| author | Alex Auvolat <alex@adnab.me> | 2020-04-23 14:40:59 +0000 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2020-04-23 14:40:59 +0000 |
| commit | 2fe82be3bcb326af04c4c862431237c576ed1152 (patch) | |
| tree | 5535f595b6a7e879f9998a9abcd8f19d9d92640d /src/table_sync.rs | |
| parent | 37f880bc09bc4d9eb6aaeaec299a8d1d2043f674 (diff) | |
| download | garage-2fe82be3bcb326af04c4c862431237c576ed1152.tar.gz garage-2fe82be3bcb326af04c4c862431237c576ed1152.zip | |
RPC to ourself do not pass through serialization + HTTPS
Diffstat (limited to 'src/table_sync.rs')
| -rw-r--r-- | src/table_sync.rs | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/table_sync.rs b/src/table_sync.rs index 603c7aa6..60d5c4df 100644 --- a/src/table_sync.rs +++ b/src/table_sync.rs @@ -457,8 +457,8 @@ where .table .rpc_client .call( - &who, - &TableRPC::<F>::SyncRPC(SyncRPC::GetRootChecksumRange( + who, + TableRPC::<F>::SyncRPC(SyncRPC::GetRootChecksumRange( partition.begin.clone(), partition.end.clone(), )), @@ -496,8 +496,8 @@ where .table .rpc_client .call( - &who, - &TableRPC::<F>::SyncRPC(SyncRPC::Checksums(step, retain)), + who, + TableRPC::<F>::SyncRPC(SyncRPC::Checksums(step, retain)), TABLE_SYNC_RPC_TIMEOUT, ) .await?; @@ -523,7 +523,7 @@ where } } if retain && diff_items.len() > 0 { - self.table.handle_update(diff_items).await?; + self.table.handle_update(&diff_items[..]).await?; } if items_to_send.len() > 0 { self.send_items(who, items_to_send).await?; @@ -555,7 +555,7 @@ where let rpc_resp = self .table .rpc_client - .call(&who, &TableRPC::<F>::Update(values), TABLE_SYNC_RPC_TIMEOUT) + .call(who, TableRPC::<F>::Update(values), TABLE_SYNC_RPC_TIMEOUT) .await?; if let TableRPC::<F>::Ok = rpc_resp { Ok(()) |