Name PubSubService tokio threads (#35331)
Also add logs for service starting/stopping
This commit is contained in:
parent
8be9930c98
commit
94698b8dd0
|
@ -91,7 +91,9 @@ impl PubSubService {
|
||||||
let thread_hdl = Builder::new()
|
let thread_hdl = Builder::new()
|
||||||
.name("solRpcPubSub".to_string())
|
.name("solRpcPubSub".to_string())
|
||||||
.spawn(move || {
|
.spawn(move || {
|
||||||
|
info!("PubSubService has started");
|
||||||
let runtime = tokio::runtime::Builder::new_multi_thread()
|
let runtime = tokio::runtime::Builder::new_multi_thread()
|
||||||
|
.thread_name("solRpcPubSubRt")
|
||||||
.worker_threads(pubsub_config.worker_threads)
|
.worker_threads(pubsub_config.worker_threads)
|
||||||
.enable_all()
|
.enable_all()
|
||||||
.build()
|
.build()
|
||||||
|
@ -102,8 +104,9 @@ impl PubSubService {
|
||||||
subscription_control,
|
subscription_control,
|
||||||
tripwire,
|
tripwire,
|
||||||
)) {
|
)) {
|
||||||
error!("pubsub service failed: {}", err);
|
error!("PubSubService has stopped due to error: {err}");
|
||||||
};
|
};
|
||||||
|
info!("PubSubService has stopped");
|
||||||
})
|
})
|
||||||
.expect("thread spawn failed");
|
.expect("thread spawn failed");
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue