| 60 | } |
| 61 | |
| 62 | void ScannerContext::TryIncreaseReservation(int64_t ideal_reservation) { |
| 63 | total_reservation_ = scan_node_->IncreaseReservationIncrementally( |
| 64 | total_reservation_, ideal_reservation); |
| 65 | } |
| 66 | |
| 67 | void ScannerContext::ReleaseCompletedResources(bool done) { |
| 68 | for (int i = 0; i < streams_.size(); ++i) { |
no test coverage detected