Method CheckDecoding

cpp/src/arrow/ipc/message_internal_test.cc:228–257

  }

  void CheckDecoding(const std::shared_ptr<Buffer>& buffer, int64_t chunk_size,
                     const SampleMessage& sample_message) {
    std::unique_ptr<Message> message;
    auto listener = std::make_shared<AssignMessageDecoderListener>(&message);
    MessageDecoder decoder(listener);
    int64_t offset = 0;
    ASSERT_EQ(decoder.buffered_size(), 0);
    while (offset < buffer->size()) {
      // No message was decoded yet
      ASSERT_EQ(message, nullptr);
      // The decoder is expecting more data, but not more than remaining in our buffer
      ASSERT_GT(decoder.next_required_size(), 0);
      ASSERT_LE(decoder.next_required_size(), buffer->size() - offset);
      const auto to_consume = std::min(chunk_size, buffer->size() - offset);
      ASSERT_OK(decoder.Consume(SliceBuffer(buffer, offset, to_consume)));
      offset += to_consume;
      if (offset >= 4 && offset < buffer->size()) {
        // We went past the initial 4-byte continuation
        ASSERT_NE(decoder.state(), MessageDecoder::INITIAL);
        if (offset >= buffer->size() - sample_message.body_bytes->size()) {
          // The offset points in the body
          ASSERT_EQ(decoder.state(), MessageDecoder::BODY);
        }
      }
    }
    ASSERT_EQ(decoder.buffered_size(), 0);
    ASSERT_EQ(decoder.state(), MessageDecoder::INITIAL);
    ASSERT_NE(message, nullptr);
    CheckSampleMessage(*message, sample_message);
  }

  void TestDecoding(const SampleMessage& sample_message) {
    ASSERT_OK_AND_ASSIGN(auto buffer, ConcatenateMessage(sample_message));