Method EnqueueRpc

src/tabletnode/rpc_schedule.cc:17–37

RpcSchedule::~RpcSchedule() { delete policy_; }

void RpcSchedule::EnqueueRpc(const std::string& table_name, RpcTask* rpc) {
  MutexLock lock(&mutex_);

  ScheduleEntity* entity = NULL;
  TableList::iterator it = table_list_.find(table_name);
  if (it != table_list_.end()) {
    entity = it->second;
  } else {
    entity = table_list_[table_name] = policy_->NewScheEntity(new TaskQueue);
  }

  TaskQueue* task_queue = (TaskQueue*)entity->user_ptr;
  task_queue->push(rpc);

  task_queue->pending_count++;
  pending_task_count_++;

  if (task_queue->pending_count == 1) {
    policy_->Enable(entity);
  }
}

bool RpcSchedule::DequeueRpc(RpcTask** rpc) {
  MutexLock lock(&mutex_);