MCPcopy
hub / github.com/benoitc/gunicorn / _handle_event

Method _handle_event

gunicorn/http2/async_connection.py:194–230  ·  view source on GitHub ↗

Handle a single h2 event. Args: event: h2 event object Returns: HTTP2Request if a request is complete, None otherwise

(self, event)

Source from the content-addressed store, hash-verified

192 return completed_requests
193
194 def _handle_event(self, event):
195 """Handle a single h2 event.
196
197 Args:
198 event: h2 event object
199
200 Returns:
201 HTTP2Request if a request is complete, None otherwise
202 """
203 if isinstance(event, _h2_events.RequestReceived):
204 return self._handle_request_received(event)
205
206 elif isinstance(event, _h2_events.DataReceived):
207 return self._handle_data_received(event)
208
209 elif isinstance(event, _h2_events.StreamEnded):
210 return self._handle_stream_ended(event)
211
212 elif isinstance(event, _h2_events.StreamReset):
213 self._handle_stream_reset(event)
214
215 elif isinstance(event, _h2_events.WindowUpdated):
216 pass # Flow control update, handled by h2
217
218 elif isinstance(event, _h2_events.PriorityUpdated):
219 self._handle_priority_updated(event)
220
221 elif isinstance(event, _h2_events.SettingsAcknowledged):
222 pass # Settings ACK received
223
224 elif isinstance(event, _h2_events.ConnectionTerminated):
225 self._handle_connection_terminated(event)
226
227 elif isinstance(event, _h2_events.TrailersReceived):
228 return self._handle_trailers_received(event)
229
230 return None
231
232 def _handle_request_received(self, event):
233 """Handle RequestReceived event (HEADERS frame)."""

Callers 1

receive_dataMethod · 0.95

Tested by

no test coverage detected