From 0f4552a54433abfb98144a6c5922002831c610fe Mon Sep 17 00:00:00 2001 From: Bojan Serafimov Date: Thu, 23 Jun 2022 12:59:20 -0400 Subject: [PATCH] Update TODO --- pageserver/src/tenant_threads.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pageserver/src/tenant_threads.rs b/pageserver/src/tenant_threads.rs index 50d321dc75..349a1f7060 100644 --- a/pageserver/src/tenant_threads.rs +++ b/pageserver/src/tenant_threads.rs @@ -129,13 +129,14 @@ pub fn init_tenant_task_pool() -> anyhow::Result<()> { // TODO cancel all running tasks break }, - // TODO don't spawn if already running tenantid = gc_recv.recv() => { let tenantid = tenantid.expect("Gc task channel closed unexpectedly"); + // TODO cancel existing loop, if any. tokio::spawn(gc_loop(tenantid)); }, tenantid = compaction_recv.recv() => { let tenantid = tenantid.expect("Compaction task channel closed unexpectedly"); + // TODO cancel existing loop, if any. tokio::spawn(compaction_loop(tenantid)); }, }