diff --git a/chain/src/init.rs b/chain/src/init.rs index 4dc9d2d919..e352ed43ab 100644 --- a/chain/src/init.rs +++ b/chain/src/init.rs @@ -2,11 +2,11 @@ //! Bootstrap InitLoadUnverified, PreloadUnverifiedBlock, ChainService and ConsumeUnverified threads. use crate::chain_service::ChainService; -use crate::consume_unverified::ConsumeUnverifiedBlocks; use crate::init_load_unverified::InitLoadUnverified; use crate::orphan_broker::OrphanBroker; use crate::preload_unverified_blocks_channel::PreloadUnverifiedBlocksChannel; use crate::utils::orphan_block_pool::OrphanBlockPool; +use crate::verify::ConsumeUnverifiedBlocks; use crate::{chain_controller::ChainController, LonelyBlockHash, UnverifiedBlock}; use ckb_channel::{self as channel, SendError}; use ckb_constant::sync::BLOCK_DOWNLOAD_WINDOW; @@ -37,7 +37,7 @@ pub fn start_chain_services(builder: ChainServicesBuilder) -> ChainController { let is_pending_verify: Arc> = Arc::new(DashSet::new()); let consumer_unverified_thread = thread::Builder::new() - .name("consume_unverified_blocks".into()) + .name("verify_blocks".into()) .spawn({ let shared = builder.shared.clone(); let is_pending_verify = Arc::clone(&is_pending_verify); diff --git a/chain/src/lib.rs b/chain/src/lib.rs index 5ffd268222..34b61ef562 100644 --- a/chain/src/lib.rs +++ b/chain/src/lib.rs @@ -16,7 +16,6 @@ use std::sync::Arc; mod chain_controller; mod chain_service; -pub mod consume_unverified; mod init; mod init_load_unverified; mod orphan_broker; @@ -24,6 +23,7 @@ mod preload_unverified_blocks_channel; #[cfg(test)] mod tests; mod utils; +pub mod verify; pub use chain_controller::ChainController; use ckb_logger::{error, info}; diff --git a/chain/src/tests/find_fork.rs b/chain/src/tests/find_fork.rs index 93fa67f118..2c39cfd0ca 100644 --- a/chain/src/tests/find_fork.rs +++ b/chain/src/tests/find_fork.rs @@ -1,5 +1,5 @@ -use crate::consume_unverified::ConsumeUnverifiedBlockProcessor; use crate::utils::forkchanges::ForkChanges; +use crate::verify::ConsumeUnverifiedBlockProcessor; use crate::{start_chain_services, UnverifiedBlock}; use ckb_chain_spec::consensus::{Consensus, ProposalWindow}; use ckb_proposal_table::ProposalTable; diff --git a/chain/src/consume_unverified.rs b/chain/src/verify.rs similarity index 99% rename from chain/src/consume_unverified.rs rename to chain/src/verify.rs index cf09abdaba..1b2a007aa1 100644 --- a/chain/src/consume_unverified.rs +++ b/chain/src/verify.rs @@ -103,7 +103,7 @@ impl ConsumeUnverifiedBlocks { }, }, recv(self.stop_rx) -> _ => { - info!("consume_unverified_blocks thread received exit signal, exit now"); + info!("verify_blocks thread received exit signal, exit now"); break; }