Skip to content
This repository was archived by the owner on Jan 13, 2021. It is now read-only.

Commit 1b5444b

Browse files
committed
Delete streams when not emitting RST_STREAM
1 parent 2ab9328 commit 1b5444b

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

hyper/http20/connection.py

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -504,6 +504,14 @@ def _close_stream(self, stream_id, error_code=None):
504504
# at all.
505505
if error_code:
506506
self._send_rst_frame(stream_id, error_code)
507+
else:
508+
# Just delete the stream.
509+
try:
510+
del self.streams[stream_id]
511+
except KeyError as e: # pragma: no cover
512+
log.warn(
513+
"Stream with id %d does not exist: %s",
514+
stream_id, e)
507515

508516
def _send_cb(self, frame, tolerate_peer_gone=False):
509517
"""
@@ -522,9 +530,6 @@ def _send_cb(self, frame, tolerate_peer_gone=False):
522530

523531
self._out_flow_control_window -= len(frame.data)
524532

525-
if frame.type == RstStreamFrame.type:
526-
import pdb; pdb.set_trace()
527-
528533
data = frame.serialize()
529534

530535
max_frame_size = self._settings[SettingsFrame.SETTINGS_MAX_FRAME_SIZE]

0 commit comments

Comments
 (0)