From 94698b8dd0c2d48fe44da17fc24d6ec1dd05c322 Mon Sep 17 00:00:00 2001
From: steviez <steven@anza.xyz>
Date: Tue, 27 Feb 2024 14:59:07 -0600
Subject: [PATCH] Name PubSubService tokio threads (#35331)

Also add logs for service starting/stopping
---
 rpc/src/rpc_pubsub_service.rs | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/rpc/src/rpc_pubsub_service.rs b/rpc/src/rpc_pubsub_service.rs
index 76227b970..3e3250369 100644
--- a/rpc/src/rpc_pubsub_service.rs
+++ b/rpc/src/rpc_pubsub_service.rs
@@ -91,7 +91,9 @@ impl PubSubService {
         let thread_hdl = Builder::new()
             .name("solRpcPubSub".to_string())
             .spawn(move || {
+                info!("PubSubService has started");
                 let runtime = tokio::runtime::Builder::new_multi_thread()
+                    .thread_name("solRpcPubSubRt")
                     .worker_threads(pubsub_config.worker_threads)
                     .enable_all()
                     .build()
@@ -102,8 +104,9 @@ impl PubSubService {
                     subscription_control,
                     tripwire,
                 )) {
-                    error!("pubsub service failed: {}", err);
+                    error!("PubSubService has stopped due to error: {err}");
                 };
+                info!("PubSubService has stopped");
             })
             .expect("thread spawn failed");