Method processBodyData

Libraries/Http/HttpConnection.cpp:534–730

        bodyFramingKind    = HttpBodyFramingKind::ContentLength;
        bodyBytesRemaining = getParser().contentLength;
        bodyComplete       = (bodyBytesRemaining == 0);
    }
    else if (allowCloseDelimited)
    {
        bodyFramingKind    = HttpBodyFramingKind::CloseDelimited;
        bodyBytesRemaining = 0;
        bodyComplete       = false;
    }
    else
    {
        bodyFramingKind    = HttpBodyFramingKind::None;
        bodyBytesRemaining = 0;
        bodyComplete       = true;
    }

    return initBodyStream(buffersPool, move(onReadRequest));
}

Result HttpIncomingMessage::processBodyData(AsyncReadableStream& sourceStream, AsyncBufferView::ID bufferID,
                                            Span<const char> readData, bool allowTrailingData)
{
    if (bodyFramingKind == HttpBodyFramingKind::None)
    {
        if (readData.sizeInBytes() > 0)
        {
            return Result::Error(HttpResultCategory, HttpError::UnexpectedBodyData);
        }
        return Result(true);
    }

    if (bodyFramingKind == HttpBodyFramingKind::ContentLength or bodyFramingKind == HttpBodyFramingKind::CloseDelimited)
    {
        if (bodyFramingKind == HttpBodyFramingKind::ContentLength and readData.sizeInBytes() > bodyBytesRemaining)
        {
            return Result::Error(HttpResultCategory, HttpError::BodyExceedsContentLength);
        }

        const uint64_t remainingBeforePush = bodyBytesRemaining;
        const bool     shouldContinue      = pushBodyData(bufferID, readData.sizeInBytes());
        if (not bodyStream.hasBeenDestroyed())
        {
            bodyStream.reactivate(shouldContinue);
        }
        if (bodyFramingKind == HttpBodyFramingKind::ContentLength)
        {
            if (bodyBytesRemaining == remainingBeforePush)
            {
                SC_TRY(consumeBodyBytes(readData.sizeInBytes()));
            }
            else
            {
                if (bodyBytesRemaining + readData.sizeInBytes() != remainingBeforePush)
                    return Result::Error(HttpResultCategory, HttpError::BodyStreamConsumptionMismatch);
            }
        }
        if (bodyFramingKind == HttpBodyFramingKind::ContentLength and bodyBytesRemaining == 0)
        {
            finishBodyStream();