From 6b820bb4237934d5ec0df22fe33bae6099b37dac Mon Sep 17 00:00:00 2001 From: Christian Schwarz Date: Fri, 5 Apr 2024 16:42:35 +0000 Subject: [PATCH] fixup env var value parsing --- pageserver/src/task_mgr.rs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/pageserver/src/task_mgr.rs b/pageserver/src/task_mgr.rs index d91fdf29a3..2528eb9c24 100644 --- a/pageserver/src/task_mgr.rs +++ b/pageserver/src/task_mgr.rs @@ -126,10 +126,10 @@ impl FromStr for TokioRuntimeMode { fn from_str(s: &str) -> Result { match s { "current_thread" => Ok(TokioRuntimeMode::SingleThreaded), - "multi_thread:default" => Ok(TokioRuntimeMode::MultiThreaded { - num_workers: *TOKIO_WORKER_THREADS, - }), - s => match s.strip_prefix("multi:") { + s => match s.strip_prefix("multi_thread:") { + Some("default") => Ok(TokioRuntimeMode::MultiThreaded { + num_workers: *TOKIO_WORKER_THREADS, + }), Some(suffix) => { let num_workers = suffix.parse::().map_err(|e| { format!( @@ -138,7 +138,7 @@ impl FromStr for TokioRuntimeMode { })?; Ok(TokioRuntimeMode::MultiThreaded { num_workers }) } - None => Err(format!("invalid runtime config: {}", s)), + None => Err(format!("invalid runtime config: {s:?}")), }, } }