Resolve

gear-tech · Aug 27, 2024 · 245da03 · 245da03
1 parent ec60c9f
commit 245da03
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 20 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/relayer/src/message_relayer/event_listener.rs b/relayer/src/message_relayer/event_listener.rs
@@ -1,6 +1,5 @@
 use std::{
     sync::mpsc::{channel, Receiver, Sender},
-    thread,
     time::Duration,
 };
 
@@ -105,7 +104,7 @@ impl EventListener {
 
                 current_block = finalized_head + 1;
             } else {
-                thread::sleep(GEAR_BLOCK_TIME_APPROX);
+                tokio::time::sleep(GEAR_BLOCK_TIME_APPROX).await;
             }
         }
     }

diff --git a/relayer/src/message_relayer/merkle_root_listener.rs b/relayer/src/message_relayer/merkle_root_listener.rs
@@ -1,6 +1,5 @@
 use std::{
     sync::mpsc::{channel, Receiver, Sender},
-    thread,
     time::Duration,
 };
 
@@ -128,7 +127,7 @@ impl MerkleRootListener {
                 current_block = latest + 1;
                 self.metrics.latest_processed_block.inc();
             } else {
-                thread::sleep(ETHEREUM_BLOCK_TIME_APPROX / 2)
+                tokio::time::sleep(ETHEREUM_BLOCK_TIME_APPROX / 2).await;
             }
         }
     }

diff --git a/relayer/src/relay_merkle_roots.rs b/relayer/src/relay_merkle_roots.rs
@@ -1,9 +1,6 @@
 use prometheus::{Gauge, IntGauge};
 use prover::proving::GenesisConfig;
-use std::{
-    thread,
-    time::{Duration, Instant},
-};
+use std::time::{Duration, Instant};
 
 use crate::{
     proof_storage::ProofStorage,
@@ -108,7 +105,7 @@ impl MerkleRootRelayer {
 
             let main_loop_duration = now.elapsed();
             if main_loop_duration < MIN_MAIN_LOOP_DURATION {
-                thread::sleep(MIN_MAIN_LOOP_DURATION - main_loop_duration);
+                tokio::time::sleep(MIN_MAIN_LOOP_DURATION - main_loop_duration).await;
             }
         }
     }