| 2282 | } |
| 2283 | |
| 2284 | void StreamStateTest::TestGetOneZeroSizedRow(BufferedTupleStream& stream) { |
| 2285 | RowBatch read_batch(zero_sized_row_desc_, 1, &tracker_); |
| 2286 | uint8_t* read_ptr_before = stream.read_it_.read_ptr_; |
| 2287 | int64_t num_rows_before = stream.read_it_.read_page_rows_returned_; |
| 2288 | bool eos = false; |
| 2289 | Status status = stream.GetNext(&read_batch, &eos); |
| 2290 | ASSERT_OK(status); |
| 2291 | if (read_ptr_before != nullptr) { |
| 2292 | ASSERT_EQ(stream.read_it_.read_ptr_, read_ptr_before); |
| 2293 | } |
| 2294 | ASSERT_EQ(stream.read_it_.read_page_rows_returned_, num_rows_before + 1); |
| 2295 | } |
| 2296 | |
| 2297 | void StreamStateTest::TestAddAndGetZeroSizedRows() { |
| 2298 | Init(BUFFER_POOL_LIMIT); |