diff --git a/substrate/core/network/src/service.rs b/substrate/core/network/src/service.rs index f4011b11eeb1235eeef6e95fcb09ca7ae7156598..cc5f6ffeea80fdf0c4ff8ff90f1a5cd9392358f0 100644 --- a/substrate/core/network/src/service.rs +++ b/substrate/core/network/src/service.rs @@ -35,7 +35,7 @@ use runtime_primitives::traits::{Block as BlockT, NumberFor}; use crate::specialization::NetworkSpecialization; use tokio::prelude::task::AtomicTask; -use tokio::runtime::Runtime; +use tokio::runtime::Builder as RuntimeBuilder; pub use network_libp2p::PeerId; @@ -458,7 +458,7 @@ fn start_thread<B: BlockT + 'static, S: NetworkSpecialization<B>>( let (close_tx, close_rx) = oneshot::channel(); let service_clone = service.clone(); - let mut runtime = Runtime::new()?; + let mut runtime = RuntimeBuilder::new().name_prefix("libp2p-").build()?; let thread = thread::Builder::new().name("network".to_string()).spawn(move || { let fut = run_thread(protocol_sender, service_clone, network_port, protocol_id) .select(close_rx.then(|_| Ok(()))) diff --git a/substrate/node/cli/src/lib.rs b/substrate/node/cli/src/lib.rs index 4485fa50f69e2cd9b53f631bd1cd09586a6662b9..5586a9b1913575fcdcc364d01f1cc7ea1d7ea73a 100644 --- a/substrate/node/cli/src/lib.rs +++ b/substrate/node/cli/src/lib.rs @@ -24,7 +24,7 @@ pub mod chain_spec; mod service; use tokio::prelude::Future; -use tokio::runtime::Runtime; +use tokio::runtime::{Builder as RuntimeBuilder, Runtime}; pub use cli::{VersionInfo, IntoExit, NoCustom}; use substrate_service::{ServiceFactory, Roles as ServiceRoles}; use std::ops::Deref; @@ -87,7 +87,8 @@ pub fn run<I, T, E>(args: I, exit: E, version: cli::VersionInfo) -> error::Resul info!("Chain specification: {}", config.chain_spec.name()); info!("Node name: {}", config.name); info!("Roles: {:?}", config.roles); - let runtime = Runtime::new().map_err(|e| format!("{:?}", e))?; + let runtime = RuntimeBuilder::new().name_prefix("main-tokio-").build() + .map_err(|e| format!("{:?}", e))?; let executor = runtime.executor(); match config.roles { ServiceRoles::LIGHT => run_until_exit(