Skip to content

Commit 9a8e265

Browse files
committed
rtic-sync: add explicit check for being closed
1 parent d0f6046 commit 9a8e265

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

rtic-sync/src/channel.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -332,6 +332,10 @@ impl<T, const N: usize> Sender<'_, T, N> {
332332
let idx = poll_fn(|cx| {
333333
// Do all this in one critical section, else there can be race conditions
334334
critical_section::with(|cs| {
335+
if self.is_closed() {
336+
return Poll::Ready(Err(()));
337+
}
338+
335339
let wq_empty = self.0.wait_queue.is_empty();
336340
let freeq_empty = self.0.access(cs).freeq.is_empty();
337341

0 commit comments

Comments
 (0)