fix: notify_recv after send_reset() in reset_on_recv_stream_err() to …

…ensure local stream is released properly Similar to what have been done in fn send_reset<B>(), we should notify RecvStream that is parked after send_reset().
hyperium · Oct 7, 2024 · 3d173e9 · 3d173e9
1 parent c0d9feb
commit 3d173e9
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/proto/streams/streams.rs b/src/proto/streams/streams.rs
@@ -1549,6 +1549,9 @@ impl Actions {
                 // Reset the stream.
                 self.send
                     .send_reset(reason, initiator, buffer, stream, counts, &mut self.task);
+                self.recv.enqueue_reset_expiration(stream, counts);
+                // if a RecvStream is parked, ensure it's notified
+                stream.notify_recv();
                 Ok(())
             } else {
                 tracing::warn!(