feat: wait rocksdb finish

ola_core/src/bin/ola_node.rs

@@ -47,6 +47,9 @@ async fn main() -> anyhow::Result<()> {
         },
     }
     stop_sender.send(true).ok();
+    tokio::task::spawn_blocking(olaos_storage::db::RocksDB::await_rocksdb_termination)
+        .await
+        .unwrap();
     tokio::time::sleep(Duration::from_secs(5)).await;
     health_check_handle.stop().await;
     olaos_logs::info!("Stopped");

ola_core/src/sequencer/batch_executor/mod.rs

@@ -247,7 +247,10 @@ impl BatchExecutor {
             .context_mode
             .operator_address()
             .to_fixed_bytes();
-        olaos_logs::info!("BlockExeManager::new with db path{}", secondary_storage_path.clone());
+        olaos_logs::info!(
+            "BlockExeManager::new with db path{}",
+            secondary_storage_path.clone()
+        );
         let mut block_exe_manager = BlockExeManager::new(
             secondary_storage_path,
             network_config.ola_network_id as u64,

storage/src/db.rs

@@ -368,7 +368,6 @@ impl<CF: NamedColumnFamily> RocksDB<CF> {
         let raw_batch_bytes = raw_batch.data().to_vec();
         let mut retries = self.stalled_writes_retries.intervals();
         let mut stalled_write_reported = false;
-        let started_at = Instant::now();
         loop {
             match self.write_inner(raw_batch) {
                 Ok(()) => {

types/src/events.rs

@@ -169,4 +169,4 @@ static PUBLISHED_BYTECODE_SIGNATURE: Lazy<H256> = Lazy::new(|| {
     //     "MarkedAsKnown",
     //     &[ethabi::ParamType::FixedBytes(32), ethabi::ParamType::Bool],
     // )
-});
+});