| 100 | } |
| 101 | |
| 102 | void BufferedTupleStream::CheckConsistencyFull(const ReadIterator& read_it) const { |
| 103 | CheckConsistencyFast(read_it); |
| 104 | // The below checks require iterating over all the pages in the stream. |
| 105 | DCHECK_EQ(bytes_pinned_, CalcBytesPinned()) << DebugString(); |
| 106 | DCHECK_EQ(pages_.size(), num_pages_) << DebugString(); |
| 107 | for (const Page& page : pages_) CheckPageConsistency(&page); |
| 108 | } |
| 109 | |
| 110 | void BufferedTupleStream::CheckConsistencyFast(const ReadIterator& read_it) const { |
| 111 | // All the below checks should be O(1). |