Method prepareBodyStream

Libraries/Http/HttpConnection.cpp:487–532

void HttpIncomingMessage::abortBodyStream() { bodyStream.destroy(); }

Result HttpIncomingMessage::prepareBodyStream(AsyncBuffersPool& buffersPool, Function<Result()>&& onReadRequest,
                                              bool allowCloseDelimited)
{
    StringSpan transferEncoding;
    StringSpan contentLengthValue;
    const bool hasTransferEncoding = getHeader("Transfer-Encoding", transferEncoding);
    if (hasTransferEncoding and getHeader("Content-Length", contentLengthValue))
    {
        return Result::Error("HttpIncomingMessage conflicting Content-Length and Transfer-Encoding");
    }

    if (hasTransferEncoding)
    {
        if (not scHttpTransferEncodingIsChunked(transferEncoding))
        {
            return Result::Error("HttpIncomingMessage unsupported Transfer-Encoding");
        }
        bodyFramingKind       = HttpBodyFramingKind::Chunked;
        bodyBytesRemaining    = 0;
        bodyComplete          = false;
        chunkedState          = ChunkedState::Size;
        chunkedChunkSize      = 0;
        chunkedBytesRemaining = 0;
        chunkedSizeHasDigits  = false;
    }
    else if (getHeader("Content-Length", contentLengthValue))
    {
        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)