Method parseData

Cutelyst/Server/protocolhttp2.cpp:333–386

}

int ProtocolHttp2::parseData(ProtoRequestHttp2 *request, QIODevice *io, const H2Frame &fr) const
{
    //    qCDebug(C_SERVER_H2) << "Consuming DATA" << fr.len;
    if (fr.streamId == 0) {
        return sendGoAway(io, request->maxStreamId, ErrorProtocolError);
    }

    quint8 padLength = 0;
    if (fr.flags & FlagDataPadded) {
        padLength = quint8(*(request->buffer + 9));
        if (padLength >= fr.len) {
            return sendGoAway(io, request->maxStreamId, ErrorProtocolError);
        }
    }

    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 if (stream->state == H2Stream::HalfClosed || stream->state == H2Stream::Closed) {
            return sendGoAway(io, request->maxStreamId, ErrorStreamClosed);
        }
    } else {
        return sendGoAway(io, request->maxStreamId, ErrorStreamClosed);
    }

    //    qCDebug(C_SERVER_H2) << "Frame data" << padLength << "state" << stream->state <<
    //    "content-length" << stream->contentLength;

    if (!stream->body) {
        stream->body = createBody(request->contentLength);
        if (!stream->body) {
            // Failed to create body to store data
            return sendGoAway(io, request->maxStreamId, ErrorInternalError);
        }
    }
    stream->body->write(request->buffer + 9, fr.len - padLength);

    stream->consumedData += fr.len - padLength;
    if (stream->contentLength != -1 &&
        ((fr.flags & FlagDataEndStream && stream->contentLength != stream->consumedData) ||
         (stream->contentLength > stream->consumedData))) {
        return sendGoAway(io, request->maxStreamId, ErrorProtocolError);
    }

    if (fr.flags & FlagDataEndStream) {
        queueStream(request->sock, stream);
    }

    return ErrorNoError;
}

int ProtocolHttp2::parseHeaders(ProtoRequestHttp2 *request, QIODevice *io, const H2Frame &fr) const
{