Method AllocateBuffersForRange

be/src/runtime/io/scan-range.cc:680–693

}

Status ScanRange::AllocateBuffersForRange(
    BufferPool::ClientHandle* bp_client, int64_t max_bytes,
    int64_t min_buffer_size, int64_t max_buffer_size) {
  vector<unique_ptr<BufferDescriptor>> buffers;
  Status status = buffer_manager_->AllocateBuffersForRange(bp_client, max_bytes, buffers,
      min_buffer_size, max_buffer_size);
  if (!status.ok() && !buffers.empty()) {
    unique_lock<mutex> lock(lock_);
    buffer_manager_->CleanUpBuffers(lock, move(buffers));
  } else {
    AddUnusedBuffers(move(buffers), false);
  }
  return status;
}

void ScanRange::ScheduleScanRange() {
  unique_lock<mutex> reader_lock(reader_->lock_);