From 9f76fabaedd95b468494798d394b5c3ff4e9b9c2 Mon Sep 17 00:00:00 2001
From: James Wilson <james@jsdw.me>
Date: Mon, 9 Aug 2021 11:36:46 +0100
Subject: [PATCH] give tokio threads a more convenient name for monitoring
 purposes

---
 backend/telemetry_core/benches/subscribe.rs | 1 +
 backend/telemetry_core/src/main.rs          | 1 +
 backend/telemetry_shard/src/main.rs         | 1 +
 3 files changed, 3 insertions(+)

diff --git a/backend/telemetry_core/benches/subscribe.rs b/backend/telemetry_core/benches/subscribe.rs
index 58be23c..9b3c7de 100644
--- a/backend/telemetry_core/benches/subscribe.rs
+++ b/backend/telemetry_core/benches/subscribe.rs
@@ -33,6 +33,7 @@ pub fn benchmark_subscribe_speed(c: &mut Criterion) {
                     },
                     CoreOpts {
                         worker_threads: Some(16),
+                        num_aggregators: Some(1),
                         ..Default::default()
                     },
                     ShardOpts {
diff --git a/backend/telemetry_core/src/main.rs b/backend/telemetry_core/src/main.rs
index 4fe7278..b02b3f3 100644
--- a/backend/telemetry_core/src/main.rs
+++ b/backend/telemetry_core/src/main.rs
@@ -98,6 +98,7 @@ fn main() {
     tokio::runtime::Builder::new_multi_thread()
         .enable_all()
         .worker_threads(worker_threads)
+        .thread_name("telemetry_core_worker")
         .build()
         .unwrap()
         .block_on(async {
diff --git a/backend/telemetry_shard/src/main.rs b/backend/telemetry_shard/src/main.rs
index 75ebd37..722d173 100644
--- a/backend/telemetry_shard/src/main.rs
+++ b/backend/telemetry_shard/src/main.rs
@@ -107,6 +107,7 @@ fn main() {
     tokio::runtime::Builder::new_multi_thread()
         .enable_all()
         .worker_threads(worker_threads)
+        .thread_name("telemetry_shard_worker")
         .build()
         .unwrap()
         .block_on(async {