Method VerifyStreamState

be/src/runtime/buffered-tuple-stream-test.cc:2228–2235

}

void StreamStateTest::VerifyStreamState(BufferedTupleStream* stream, int num_page,
    int num_pinned_page, int num_unpinned_page, int buffer_size) {
  ASSERT_EQ(stream->pages_.size(), num_page);
  ASSERT_EQ(stream->num_pages_, num_page);
  ASSERT_EQ(stream->BytesPinned(false), buffer_size * num_pinned_page);
  ASSERT_EQ(stream->bytes_unpinned(), buffer_size * num_unpinned_page);
  stream->CheckConsistencyFull(stream->read_it_);
}

TEST_F(StreamStateTest, DeferAdvancingReadPage) {
  TestDeferAdvancingReadPage();