Method _handle_data_received

gunicorn/http2/connection.py:243–275

Handle DataReceived event. Args: event: DataReceived event with body data Returns: None (request completion handled by StreamEnded)

(self, event)

        stream.receive_headers(headers, end_stream=False)

    def _handle_data_received(self, event):
        """Handle DataReceived event.

        Args:
            event: DataReceived event with body data

        Returns:
            None (request completion handled by StreamEnded)
        """
        stream_id = event.stream_id
        data = event.data

        stream = self.streams.get(stream_id)
        if stream is None:
            # Stream was reset or doesn't exist
            return None

        stream.receive_data(data, end_stream=False)

        # Increment flow control windows (only if data received)
        if len(data) > 0:
            try:
                # Update stream-level window
                self.h2_conn.increment_flow_control_window(len(data), stream_id=stream_id)
                # Update connection-level window
                self.h2_conn.increment_flow_control_window(len(data), stream_id=None)
                # Send WINDOW_UPDATE frames immediately
                self._send_pending_data()
            except (ValueError, _h2_exceptions.FlowControlError):
                # Window overflow - send FLOW_CONTROL_ERROR and close
                self.close(error_code=HTTP2ErrorCode.FLOW_CONTROL_ERROR)

        return None

    def _handle_stream_ended(self, event):
        """Handle StreamEnded event.