Skip to content

Commit 488ed6a

Browse files
committed
chore(cubestore): Upgrade DF: Make tokio max_blocking_threads configurable from the env
1 parent 80781f9 commit 488ed6a

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

rust/cubestore/cubestore/src/bin/cubestored.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -77,6 +77,9 @@ fn main() {
7777
if let Ok(var) = std::env::var("CUBESTORE_EVENT_LOOP_WORKER_THREADS") {
7878
tokio_builder.worker_threads(var.parse().unwrap());
7979
}
80+
if let Ok(var) = std::env::var("CUBESTORE_EVENT_LOOP_MAX_BLOCKING_THREADS") {
81+
tokio_builder.max_blocking_threads(var.parse().unwrap());
82+
}
8083
let runtime = tokio_builder.build().unwrap();
8184
runtime.block_on(async move {
8285
init_agent_sender().await;

0 commit comments

Comments
 (0)