RomanNum3ral
/
scrapy
mirror of https://github.com/scrapy/scrapy.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Ignore server-initiated events

This commit is contained in:
Adrián Chaves 2020-11-18 16:42:44 +01:00
parent 269fe35d6d
commit bde96a5ad9
1 changed files with 20 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
scrapy/core/http2/protocol.py
View File

@ -349,10 +349,16 @@ class H2ClientProtocol(Protocol, TimeoutMixin):
])
def data_received(self, event: DataReceived) -> None:
self.streams[event.stream_id].receive_data(event.data, event.flow_controlled_length)
try:
self.streams[event.stream_id].receive_data(event.data, event.flow_controlled_length)
except KeyError:
logger.debug(f'Ignoring server-initiated event {event}')
def response_received(self, event: ResponseReceived) -> None:
self.streams[event.stream_id].receive_headers(event.headers)
try:
self.streams[event.stream_id].receive_headers(event.headers)
except KeyError:
logger.debug(f'Ignoring server-initiated event {event}')
def settings_acknowledged(self, event: SettingsAcknowledged) -> None:
self.metadata['settings_acknowledged'] = True
@ -365,12 +371,20 @@ class H2ClientProtocol(Protocol, TimeoutMixin):
self.metadata['certificate'] = Certificate(self.transport.getPeerCertificate())
def stream_ended(self, event: StreamEnded) -> None:
stream = self.pop_stream(event.stream_id)
stream.close(StreamCloseReason.ENDED, from_protocol=True)
try:
stream = self.pop_stream(event.stream_id)
except KeyError:
logger.debug(f'Ignoring server-initiated event {event}')
else:
stream.close(StreamCloseReason.ENDED, from_protocol=True)
def stream_reset(self, event: StreamReset) -> None:
stream = self.pop_stream(event.stream_id)
stream.close(StreamCloseReason.RESET, from_protocol=True)
try:
stream = self.pop_stream(event.stream_id)
except KeyError:
logger.debug(f'Ignoring server-initiated event {event}')
else:
stream.close(StreamCloseReason.RESET, from_protocol=True)
def window_updated(self, event: WindowUpdated) -> None:
if event.stream_id != 0: