Thread manager instantiation in the validator

thread-manager/src/lib.rs

@@ -17,7 +17,7 @@ pub use {
     tokio_runtime::{TokioConfig, TokioRuntime},
 };
 
-pub const MAX_THREAD_NAME_CHARS: usize = 12;
+pub const MAX_THREAD_NAME_CHARS: usize = 16;
 
 #[derive(Default, Debug)]
 pub struct ThreadManagerInner {

thread-manager/src/native_thread_runtime.rs

@@ -103,7 +103,7 @@ impl<T> Drop for JoinHandle<T> {
 
 impl NativeThreadRuntime {
     pub fn new(name: String, cfg: NativeConfig) -> Self {
-        debug_assert!(name.len() < MAX_THREAD_NAME_CHARS, "Thread name too long");
+        debug_assert!(name.len() <= MAX_THREAD_NAME_CHARS, "Thread name too long");
         Self {
             inner: Arc::new(NativeThreadRuntimeInner {
                 id_count: AtomicUsize::new(0),

thread-manager/src/rayon_runtime.rs

@@ -62,7 +62,7 @@ impl Deref for RayonRuntime {
 
 impl RayonRuntime {
     pub fn new(name: String, config: RayonConfig) -> anyhow::Result<Self> {
-        debug_assert!(name.len() < MAX_THREAD_NAME_CHARS, "Thread name too long");
+        debug_assert!(name.len() <= MAX_THREAD_NAME_CHARS, "Thread name too long");
         let core_allocation = config.core_allocation.clone();
         let chosen_cores_mask = Mutex::new(core_allocation.as_core_mask_vector());
         let priority = config.priority;

thread-manager/src/tokio_runtime.rs

@@ -69,7 +69,7 @@ impl TokioRuntime {
     }
 
     pub fn new(name: String, cfg: TokioConfig) -> anyhow::Result<Self> {
-        debug_assert!(name.len() < MAX_THREAD_NAME_CHARS, "Thread name too long");
+        debug_assert!(name.len() <= MAX_THREAD_NAME_CHARS, "Thread name too long");
         let num_workers = if cfg.worker_threads == 0 {
             num_cpus::get()
         } else {