Method FreeAll

be/src/runtime/mem-pool.cc:76–94

}

void MemPool::FreeAll() {
  DFAKE_SCOPED_LOCK(mutex_);
  int64_t total_bytes_released = 0;
  MonotonicStopWatch sw;
  sw.Start();
  for (auto& chunk: chunks_) {
    total_bytes_released += chunk.size;
    free(chunk.data);
    counters_.sys_free_duration.UpdateCounter(sw.Reset());
    counters_.freed_bytes.UpdateCounter(chunk.size);
  }
  chunks_.clear();
  next_chunk_size_ = INITIAL_CHUNK_SIZE;
  current_chunk_idx_ = -1;
  total_allocated_bytes_ = 0;
  total_reserved_bytes_ = 0;

  mem_tracker_->Release(total_bytes_released);
}

bool MemPool::FindChunk(int64_t min_size, bool check_limits) noexcept {
  // Try to allocate from a free chunk. We may have free chunks after the current chunk