aboutsummaryrefslogtreecommitdiff
path: root/src/table_sync.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2020-04-23 14:40:59 +0000
committerAlex Auvolat <alex@adnab.me>2020-04-23 14:40:59 +0000
commit2fe82be3bcb326af04c4c862431237c576ed1152 (patch)
tree5535f595b6a7e879f9998a9abcd8f19d9d92640d /src/table_sync.rs
parent37f880bc09bc4d9eb6aaeaec299a8d1d2043f674 (diff)
downloadgarage-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.rs12
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(())