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/membership.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/membership.rs')
| -rw-r--r-- | src/membership.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/membership.rs b/src/membership.rs index f9ffa3b4..c0c88a43 100644 --- a/src/membership.rs +++ b/src/membership.rs @@ -297,7 +297,7 @@ impl System { let (update_ring, ring) = watch::channel(Arc::new(ring)); let rpc_http_client = Arc::new( - RpcHttpClient::new(config.max_concurrent_requests, &config.rpc_tls) + RpcHttpClient::new(config.max_concurrent_rpc_requests, &config.rpc_tls) .expect("Could not create RPC client"), ); @@ -633,7 +633,7 @@ impl System { async move { let resp = self .rpc_client - .call(&peer, Message::PullStatus, PING_TIMEOUT) + .call(peer, Message::PullStatus, PING_TIMEOUT) .await; if let Ok(Message::AdvertiseNodesUp(nodes)) = resp { let _: Result<_, _> = self.handle_advertise_nodes_up(&nodes).await; @@ -644,7 +644,7 @@ impl System { pub async fn pull_config(self: Arc<Self>, peer: UUID) { let resp = self .rpc_client - .call(&peer, Message::PullConfig, PING_TIMEOUT) + .call(peer, Message::PullConfig, PING_TIMEOUT) .await; if let Ok(Message::AdvertiseConfig(config)) = resp { let _: Result<_, _> = self.handle_advertise_config(&config).await; |