diff options
| author | Alex Auvolat <alex@adnab.me> | 2020-04-16 14:50:49 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2020-04-16 14:50:49 +0200 |
| commit | f01c1e71b5421d8941d1484e224cd6fd75525651 (patch) | |
| tree | ce076bbd0a5c63506bece06184942712b79f2ee5 /src/membership.rs | |
| parent | 43ce5e4ab4ebe317bb9263de5d56b90dc68ea7eb (diff) | |
| download | garage-f01c1e71b5421d8941d1484e224cd6fd75525651.tar.gz garage-f01c1e71b5421d8941d1484e224cd6fd75525651.zip | |
Begin work on sync...
Diffstat (limited to 'src/membership.rs')
| -rw-r--r-- | src/membership.rs | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/membership.rs b/src/membership.rs index 89550b67..368e9355 100644 --- a/src/membership.rs +++ b/src/membership.rs @@ -157,7 +157,7 @@ impl Ring { self.walk_ring_from_pos(start, n) } - fn walk_ring_from_pos(&self, start: usize, n: usize) -> Vec<UUID> { + pub fn walk_ring_from_pos(&self, start: usize, n: usize) -> Vec<UUID> { let mut ret = vec![]; let mut datacenters = vec![]; @@ -282,13 +282,13 @@ impl System { .collect::<Vec<_>>(); self.clone().ping_nodes(bootstrap_peers).await; - self.background - .clone() + self.clone() + .background .spawn_worker(|stop_signal| self.ping_loop(stop_signal).map(Ok)) .await; } - pub async fn ping_nodes(self: Arc<Self>, peers: Vec<(SocketAddr, Option<UUID>)>) { + async fn ping_nodes(self: Arc<Self>, peers: Vec<(SocketAddr, Option<UUID>)>) { let ping_msg = self.make_ping(); let ping_resps = join_all(peers.iter().map(|(addr, id_option)| { let sys = self.clone(); |