Method getWritableData

Libraries/AsyncStreams/AsyncStreams.cpp:103–134

}

Result AsyncBuffersPool::getWritableData(AsyncBufferView::ID bufferID, Span<char>& data)
{
    AsyncBufferView* buffer = getBuffer(bufferID);
    SC_TRY_MSG(buffer != nullptr, "AsyncBuffersPool::getWritableData - Invalid bufferID");
    switch (buffer->type)
    {
    case AsyncBufferView::Type::Writable:
        SC_TRY(buffer->writableData.sliceStartLength(buffer->offset, buffer->length, data));
        break;
    case AsyncBufferView::Type::Child: {
        AsyncBufferView* parent = getBuffer(buffer->parentID);
        SC_TRY_MSG(parent != nullptr, "AsyncBuffersPool::getWritableData - Invalid parentID");
        if (parent->type == AsyncBufferView::Type::Growable)
        {
            AsyncBufferView::GrowableStorage storage;

            auto       da           = parent->getGrowableBuffer(storage, true)->getDirectAccess();
            Span<char> rootFullData = {static_cast<char*>(da.data), da.sizeInBytes};
            SC_TRY(rootFullData.sliceStartLength(buffer->offset, buffer->length, data));
            buffer->writableData = data;                     // Update for debugging visibility
            (void)parent->getGrowableBuffer(storage, false); // destruct
        }
        else
        {
            data = buffer->writableData;
        }
        break;
    }
    default: return Result::Error("AsyncBuffersPool::getWritableData - Readonly or Growable buffer");
    }
    return Result(true);
}

AsyncBufferView* AsyncBuffersPool::getBuffer(AsyncBufferView::ID bufferID)
{