Method rollbackToCheckpoint

src/IO/PeekableReadBuffer.cpp:112–136

}

void PeekableReadBuffer::rollbackToCheckpoint(bool drop)
{
    checkStateCorrect();

    assert(checkpoint);

    if (checkpointInOwnMemory() == currentlyReadFromOwnMemory())
    {
        /// Both checkpoint and position are in the same buffer.
        pos = *checkpoint;
    }
    else
    {
        /// Checkpoint is in own memory and position is not.
        assert(checkpointInOwnMemory());

        /// Switch to reading from own memory.
        BufferBase::set(memory.data(), peeked_size, *checkpoint - memory.data());
    }

    if (drop)
        dropCheckpoint();

    checkStateCorrect();
}

bool PeekableReadBuffer::nextImpl()
{