Method readData

Core/CodedInputData.cpp:144–160

}

MMBuffer CodedInputData::readData(bool copy, bool exactly) {
    int32_t size = this->readRawVarint32();
    if (size < 0) {
        throw length_error("InvalidProtocolBuffer negativeSize");
    }

    auto s_size = static_cast<size_t>(size);
    bool isSizeValid = exactly ? (s_size == m_size - m_position) : (s_size <= m_size - m_position);
    if (isSizeValid) {
        size_t pos = m_position;
        m_position += s_size;
        auto copyFlag = copy ? MMBufferCopy : MMBufferNoCopy;
        return MMBuffer(((int8_t *) m_ptr) + pos, s_size, copyFlag);
    } else {
        throw out_of_range("InvalidProtocolBuffer truncatedMessage");
    }
}

void CodedInputData::readData(KeyValueHolder &kvHolder) {
    int32_t size = this->readRawVarint32();