gsadmin/noq
1
0
Fork 0
mirror of https://github.com/n0-computer/noq.git synced 2026-09-19 09:45:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

Clarify logic when a blocked or finishing stream is stopped

Browse Source
This commit is contained in:
Benjamin Saunders
2020-04-16 11:47:22 -07:00
parent 1533cc45b1
commit 703ab27cc6
1 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
quinn-proto/src/connection.rs
+10 -7
View File
@@ -857,14 +857,17 @@ where
let stop_reason = if stopped { Some(error_code) } else { None };
let status = self.streams.reset(stream_id, stop_reason);
if stopped {
if status == Some(streams::ResetStatus::WasFinishing) {
self.events.push_back(Event::StreamFinished {
stream: stream_id,
stop_reason,
if let Some(status) = status {
// The application is waiting for an event on this stream that will never come; notify it.
self.events.push_back(match status {
// Finish operation should fail due to stopping
streams::ResetStatus::WasFinishing => Event::StreamFinished {
stream: stream_id,
stop_reason,
},
// Stop will be observed on a future write/finish call.
streams::ResetStatus::WasBlocked => Event::StreamWritable { stream: stream_id },
});
} else if status == Some(streams::ResetStatus::WasBlocked) {
self.events
.push_back(Event::StreamWritable { stream: stream_id });
}
}