We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent acc6f92 commit 42f0c58Copy full SHA for 42f0c58
quickwit/quickwit-search/src/search_permit_provider.rs
@@ -163,10 +163,10 @@ impl SearchPermitActor {
163
permits.push(SearchPermitFuture(rx));
164
}
165
self.assign_available_permits();
166
- permit_sender
167
- .send(permits)
168
- // This is a request response pattern, so we can safely ignore the error.
169
- .expect("Receiver lives longer than sender");
+ // The receiver could be dropped in the (unlikely) situation
+ // where the future requesting these permits is cancelled before
+ // this message is processed.
+ let _ = permit_sender.send(permits);
170
171
SearchPermitMessage::UpdateMemory { memory_delta } => {
172
if self.total_memory_allocated as i64 + memory_delta < 0 {
0 commit comments