Method DecrementPerUser

be/src/scheduling/admission-controller.cc:939–949

}

void AdmissionController::PoolStats::DecrementPerUser(const string& user) {
  int64_t agg_count_after_decrement = agg_user_loads_.decrement(user);
  if (agg_count_after_decrement == 0) {
    metrics_.agg_current_users->Remove(user);
  }
  int64_t local_count_after_decrement =
      ImpalaServer::DecrementCount(local_stats_.user_loads, user);
  if (local_count_after_decrement == 0) {
    metrics_.local_current_users->Remove(user);
  }
}

void AdmissionController::PoolStats::Dequeue(bool timed_out) {
  agg_num_queued_ -= 1;