From ce621e447e79127c7db124cef4558b7ac68a9c52 Mon Sep 17 00:00:00 2001 From: Louis Dureuil Date: Thu, 16 Jan 2025 11:37:37 +0100 Subject: [PATCH] Release writer_receiver as soon as writing to db panics --- crates/milli/src/update/new/indexer/mod.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/crates/milli/src/update/new/indexer/mod.rs b/crates/milli/src/update/new/indexer/mod.rs index d4c4841bc..e68a1ad4d 100644 --- a/crates/milli/src/update/new/indexer/mod.rs +++ b/crates/milli/src/update/new/indexer/mod.rs @@ -110,7 +110,7 @@ where }, ); - let (extractor_sender, mut writer_receiver) = pool + let (extractor_sender, writer_receiver) = pool .install(|| extractor_writer_bbqueue(&mut bbbuffers, total_bbbuffer_capacity, 1000)) .unwrap(); @@ -425,6 +425,7 @@ where let mut arroy_writers = arroy_writers?; { + let mut writer_receiver = writer_receiver; let span = tracing::trace_span!(target: "indexing::write_db", "all"); let _entered = span.enter();