| 301 | } |
| 302 | |
| 303 | Status BufferedTupleStream::PinPageIfNeeded(Page* page, bool stream_pinned) { |
| 304 | int new_pin_count = ExpectedPinCount(stream_pinned, page); |
| 305 | if (new_pin_count != page->pin_count()) { |
| 306 | DCHECK_EQ(new_pin_count, page->pin_count() + 1); |
| 307 | RETURN_IF_ERROR(PinPage(page)); |
| 308 | } |
| 309 | return Status::OK(); |
| 310 | } |
| 311 | |
| 312 | void BufferedTupleStream::UnpinPageIfNeeded(Page* page, bool stream_pinned) { |
| 313 | int new_pin_count = ExpectedPinCount(stream_pinned, page); |