Method ReleaseMemoryForScannerThread

be/src/runtime/scanner-mem-limiter.cc:103–113

}

void ScannerMemLimiter::ReleaseMemoryForScannerThread(
    ScanNode* node, int64_t estimated_thread_mem) {
  shared_lock<shared_mutex> read_lock(registered_scans_lock_);
  auto it = registered_scans_.find(node);
  DCHECK(it != registered_scans_.end()) << node->id() << " not found.";
  RegisteredScan* scan = it->second.get();
  int64_t mem = scan->estimated_mem.Add(-estimated_thread_mem);
  DCHECK_GE(mem, 0);
  int64_t num_threads = scan->num_threads.Add(-1);
  DCHECK_GE(num_threads, 0);
}
}