Method requestNewBuffer

Libraries/AsyncStreams/AsyncStreams.cpp:146–175

}

Result AsyncBuffersPool::requestNewBuffer(size_t minimumSizeInBytes, AsyncBufferView::ID& bufferID, Span<char>& data)
{
    for (AsyncBufferView& buffer : buffers)
    {
        if (buffer.type == AsyncBufferView::Type::Empty)
            continue;
        if (buffer.refs == 0)
        {
            if (buffer.type == AsyncBufferView::Type::Growable)
            {
                AsyncBufferView::GrowableStorage storage;

                auto da             = buffer.getGrowableBuffer(storage, true)->getDirectAccess();
                buffer.writableData = {static_cast<char*>(da.data), da.sizeInBytes};
                (void)buffer.getGrowableBuffer(storage, false); // destruct
            }
            if (buffer.writableData.sizeInBytes() >= minimumSizeInBytes)
            {
                buffer.refs   = 1;
                buffer.offset = 0;
                buffer.length = buffer.writableData.sizeInBytes();

                bufferID =
                    AsyncBufferView::ID(static_cast<AsyncBufferView::ID::NumericType>(&buffer - buffers.begin()));
                return getWritableData(bufferID, data);
            }
        }
    }
    return Result::Error("AsyncBuffersPool::requestNewBuffer failed");
}

void AsyncBuffersPool::setNewBufferSize(AsyncBufferView::ID bufferID, size_t newSizeInBytes)
{