Method CleanUpBuffer

be/src/runtime/io/scan-buffer-manager.cc:130–139

}

void ScanBufferManager::CleanUpBuffer(const unique_lock<mutex>& scan_range_lock,
    const unique_ptr<BufferDescriptor> buffer_desc) {
  DCHECK(scan_range_->is_locked(scan_range_lock));
  DCHECK(buffer_desc != nullptr);
  DCHECK_EQ(buffer_desc->scan_range(), scan_range_);
  buffer_desc->Free();
  // Close the reader if there are no buffer in the reader or if no buffers will be
  // returned from the range in future.
  scan_range_->CloseReader(scan_range_lock);
}

void ScanBufferManager::CleanUpUnusedBuffers(const unique_lock<mutex>& scan_range_lock) {
  DCHECK(scan_range_->is_locked(scan_range_lock));