init barrier in new_pipe_exec_layer_api

crates/pipe-exec-layer-ext-v2/src/lib.rs

@@ -91,19 +91,6 @@ struct PipeBarrier<Result> {
     inner: Mutex<PipeBarrierInner<Result>>,
 }
 
-impl<Result> Default for PipeBarrier<Result> {
-    fn default() -> Self {
-        Self {
-            inner: Mutex::new(PipeBarrierInner {
-                block_number: 0,
-                result: None,
-                waiters: Vec::new(),
-                closed: false,
-            }),
-        }
-    }
-}
-
 #[derive(Debug)]
 struct PipeBarrierInner<Result> {
     block_number: u64,
@@ -113,6 +100,17 @@ struct PipeBarrierInner<Result> {
 }
 
 impl<Result> PipeBarrier<Result> {
+    fn new(block_number: u64, result: Result) -> Self {
+        Self {
+            inner: Mutex::new(PipeBarrierInner {
+                block_number,
+                result: Some(result),
+                waiters: Vec::new(),
+                closed: false,
+            }),
+        }
+    }
+
     /// Wait until the block number is reached and return the result.
     /// Returns `None` if the barrier has been closed.
     async fn wait(&self, block_number: u64) -> Option<Result> {
@@ -169,16 +167,6 @@ impl<Result> PipeBarrier<Result> {
 impl<Storage: GravityStorage> PipeExecService<Storage> {
     async fn run(mut self, latest_block_header: Header, latest_block_hash: B256) {
         let mut latest_block_number = latest_block_header.number;
-        self.core
-            .execute_block_barrier
-            .notify(latest_block_number, latest_block_header)
-            .await
-            .unwrap();
-        self.core
-            .make_canonical_barrier
-            .notify(latest_block_number, latest_block_hash)
-            .await
-            .unwrap();
 
         loop {
             let ordered_block = match self.ordered_block_rx.recv().await {
@@ -479,8 +467,11 @@ pub fn new_pipe_exec_layer_api<Storage: GravityStorage>(
             evm_config: EthEvmConfig::new(chain_spec.clone()),
             chain_spec,
             event_tx,
-            execute_block_barrier: PipeBarrier::default(),
-            make_canonical_barrier: PipeBarrier::default(),
+            execute_block_barrier: PipeBarrier::new(
+                latest_block_header.number,
+                latest_block_header,
+            ),
+            make_canonical_barrier: PipeBarrier::new(latest_block_header.number, latest_block_hash),
         }),
         ordered_block_rx,
     };