rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-06-02 13:00:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update TODO

Browse Source
This commit is contained in:
Bojan Serafimov
2022-06-23 12:59:20 -04:00
parent d7d4cc8c77
commit 0f4552a544
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
pageserver/src/tenant_threads.rs
View File

@@ -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));
},
}