minor fixups

tari-project · Nov 26, 2021 · e097c1a · e097c1a
1 parent 95b2794
commit e097c1a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 16 deletions.
diff --git a/base_layer/core/src/base_node/state_machine_service/state_machine.rs b/base_layer/core/src/base_node/state_machine_service/state_machine.rs
@@ -36,13 +36,10 @@ use crate::{
 use futures::{future, future::Either};
 use log::*;
 use randomx_rs::RandomXFlag;
-use std::{future::Future, sync::Arc, time::Duration};
+use std::{future::Future, sync::Arc};
 use tari_comms::{connectivity::ConnectivityRequester, PeerManager};
 use tari_shutdown::ShutdownSignal;
-use tokio::{
-    sync::{broadcast, watch},
-    time,
-};
+use tokio::sync::{broadcast, watch};
 
 const LOG_TARGET: &str = "c::bn::base_node";
 
@@ -223,7 +220,7 @@ impl<B: BlockchainBackend + 'static> BaseNodeStateMachine<B> {
             // Get the next `StateEvent`, returning a `UserQuit` state event if the interrupt signal is triggered
             let mut mdc = vec![];
             log_mdc::iter(|k, v| mdc.push((k.to_owned(), v.to_owned())));
-            let next_event = select_next_state_event(delayed(interrupt_signal), next_state_future).await;
+            let next_event = select_next_state_event(interrupt_signal, next_state_future).await;
             log_mdc::extend(mdc);
             // Publish the event on the event bus
             let _ = self.event_publisher.send(Arc::new(next_event.clone()));
@@ -275,11 +272,3 @@ where
         Either::Right((state, _)) => state,
     }
 }
-
-async fn delayed<F, R>(fut: F) -> R
-where F: Future<Output = R> {
-    let ret = fut.await;
-    error!(target: LOG_TARGET, "SLEEEPIN",);
-    time::sleep(Duration::from_secs(100)).await;
-    ret
-}
diff --git a/base_layer/core/src/chain_storage/lmdb_db/lmdb_db.rs b/base_layer/core/src/chain_storage/lmdb_db/lmdb_db.rs
@@ -838,7 +838,6 @@ impl LMDBDatabase {
         bitmap.remove(block_accum_data.deleted())?;
         bitmap.finish()?;
 
-        info!(target: LOG_TARGET, "delete accum {}", height);
         lmdb_delete(
             write_txn,
             &self.block_accumulated_data_db,
@@ -1124,7 +1123,6 @@ impl LMDBDatabase {
         header_height: u64,
         data: &BlockAccumulatedData,
     ) -> Result<(), ChainStorageError> {
-        info!(target: LOG_TARGET, "insert accum {}", data);
         lmdb_insert(
             txn,
             &self.block_accumulated_data_db,