aboutsummaryrefslogtreecommitdiff
path: root/src/peering
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2021-10-12 13:07:34 +0200
committerAlex Auvolat <alex@adnab.me>2021-10-12 13:07:34 +0200
commit7753b789b7aca87db4db7aed20e79a41ecb0b225 (patch)
treef5b67a3d52736eb60d88cdd8772957ada62654fb /src/peering
parent90f8fb28361cba1087a0e608e8a8deb6abb5bd39 (diff)
downloadnetapp-7753b789b7aca87db4db7aed20e79a41ecb0b225.tar.gz
netapp-7753b789b7aca87db4db7aed20e79a41ecb0b225.zip
Upgrade to tokio 1.0
Diffstat (limited to 'src/peering')
-rw-r--r--src/peering/basalt.rs4
-rw-r--r--src/peering/fullmesh.rs2
2 files changed, 3 insertions, 3 deletions
diff --git a/src/peering/basalt.rs b/src/peering/basalt.rs
index 3c1fc9e..abfe1e4 100644
--- a/src/peering/basalt.rs
+++ b/src/peering/basalt.rs
@@ -321,7 +321,7 @@ impl Basalt {
async fn run_pushpull_loop(self: Arc<Self>) {
loop {
- tokio::time::delay_for(self.param.exchange_interval).await;
+ tokio::time::sleep(self.param.exchange_interval).await;
let peers = self.view.read().unwrap().sample(2);
if peers.len() == 2 {
@@ -368,7 +368,7 @@ impl Basalt {
async fn run_reset_loop(self: Arc<Self>) {
loop {
- tokio::time::delay_for(self.param.reset_interval).await;
+ tokio::time::sleep(self.param.reset_interval).await;
{
debug!("KYEV R {}", self.param.reset_count);
diff --git a/src/peering/fullmesh.rs b/src/peering/fullmesh.rs
index a4b9248..9b55180 100644
--- a/src/peering/fullmesh.rs
+++ b/src/peering/fullmesh.rs
@@ -241,7 +241,7 @@ impl FullMeshPeeringStrategy {
}
// 4. Sleep before next loop iteration
- tokio::time::delay_for(LOOP_DELAY).await;
+ tokio::time::sleep(LOOP_DELAY).await;
}
}