diff options
| author | Alex Auvolat <alex@adnab.me> | 2020-04-19 17:59:59 +0000 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2020-04-19 17:59:59 +0000 |
| commit | ea75564851851b969ef23797537c813ba607b84a (patch) | |
| tree | d5bdb1a19a546cbbd92e35dbd496acfd16522dd9 /src/membership.rs | |
| parent | e325c7f47a9ad7777358b669f62a7c613f676ecd (diff) | |
| download | garage-ea75564851851b969ef23797537c813ba607b84a.tar.gz garage-ea75564851851b969ef23797537c813ba607b84a.zip | |
More aggressive sync timings & improve other stuff
Diffstat (limited to 'src/membership.rs')
| -rw-r--r-- | src/membership.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/membership.rs b/src/membership.rs index 412a83f8..fc21d0b5 100644 --- a/src/membership.rs +++ b/src/membership.rs @@ -362,7 +362,7 @@ impl System { let ring = self.ring.borrow().clone(); Message::Ping(PingMessage { id: self.id.clone(), - rpc_port: self.config.rpc_port, + rpc_port: self.config.rpc_bind_addr.port(), status_hash: status.hash.clone(), config_version: ring.config.version, state_info: self.state_info.clone(), @@ -539,7 +539,7 @@ impl System { for node in adv.iter() { if node.id == self.id { // learn our own ip address - let self_addr = SocketAddr::new(node.addr.ip(), self.config.rpc_port); + let self_addr = SocketAddr::new(node.addr.ip(), self.config.rpc_bind_addr.port()); let old_self = status.nodes.insert( node.id.clone(), StatusEntry { |