Method CleanUpReadyBuffers

be/src/runtime/io/scan-buffer-manager.cc:148–154

}

void ScanBufferManager::CleanUpReadyBuffers(const unique_lock<mutex>& scan_range_lock) {
  DCHECK(scan_range_->is_locked(scan_range_lock));
  while (!ready_buffers_.empty()) {
    CleanUpBuffer(scan_range_lock, move(ready_buffers_.front()));
    ready_buffers_.pop_front();
  }
}

bool ScanBufferManager::PopFirstReadyBuffer(const unique_lock<mutex>& scan_range_lock,
    unique_ptr<BufferDescriptor>* buffer) {