Method DequeueRpc

src/tabletnode/rpc_schedule.cc:39–64

}

bool RpcSchedule::DequeueRpc(RpcTask** rpc) {
  MutexLock lock(&mutex_);
  if (pending_task_count_ == 0) {
    return false;
  }

  TableList::iterator it = policy_->Pick(&table_list_);
  CHECK(it != table_list_.end());

  ScheduleEntity* entity = (ScheduleEntity*)it->second;
  TaskQueue* task_queue = (TaskQueue*)entity->user_ptr;
  CHECK_GT(task_queue->size(), 0U);

  *rpc = task_queue->front();
  task_queue->pop();

  task_queue->pending_count--;
  task_queue->running_count++;
  pending_task_count_--;
  running_task_count_++;

  if (task_queue->pending_count == 0) {
    policy_->Disable(entity);
  }
  return true;
}

bool RpcSchedule::FinishRpc(const std::string& table_name) {
  MutexLock lock(&mutex_);