Method parseWindowUpdate

Cutelyst/Server/protocolhttp2.cpp:596–648

}

int ProtocolHttp2::parseWindowUpdate(ProtoRequestHttp2 *request,
                                     QIODevice *io,
                                     const H2Frame &fr) const
{
    if (fr.len != 4) {
        return sendGoAway(io, request->maxStreamId, ErrorFrameSizeError);
    }

    quint32 windowSizeIncrement = net_be32(request->buffer + 9);
    if (windowSizeIncrement == 0) {
        return sendGoAway(io, request->maxStreamId, ErrorProtocolError);
    }

    //    qDebug() << "Consuming WINDOW_UPDATE" << fr.streamId << "increment" << windowSizeIncrement
    //    << request;

    if (fr.streamId) {
        H2Stream *stream;
        auto streamIt = request->streams.constFind(fr.streamId);
        if (streamIt != request->streams.constEnd()) {
            stream = streamIt.value();

            if (stream->state == H2Stream::Idle) {
                return sendGoAway(io, request->maxStreamId, ErrorProtocolError);
            }
        } else {
            return sendGoAway(io, request->maxStreamId, ErrorStreamClosed);
        }

        const qint64 result = qint64(stream->windowSize) + windowSizeIncrement;
        if (result > 2147483647) {
            stream->state = H2Stream::Closed;
            return sendRstStream(io, fr.streamId, ErrorFlowControlError);
        }
        stream->windowSize = qint32(result);
        stream->windowUpdated();

    } else {
        const qint64 result = qint64(request->windowSize) + windowSizeIncrement;
        if (result > 2147483647) {
            return sendGoAway(io, request->maxStreamId, ErrorFlowControlError);
        }
        request->windowSize = qint32(result);

        if (result > 0) {
            for (const auto &stream : std::as_const(request->streams)) {
                stream->windowUpdated();
            }
        }
    }

    return 0;
}

int ProtocolHttp2::sendGoAway(QIODevice *io, quint32 lastStreamId, quint32 error) const
{