Method GetTask

src/sdk/sdk_task.cc:123–138

}

SdkTask* SdkTimeoutManager::GetTask(int64_t task_id) {
  uint32_t shard_id = Shard(task_id);
  TaskMap& map = map_shard_[shard_id];
  Mutex& mutex = mutex_shard_[shard_id];

  MutexLock l(&mutex);
  IdHashMap::iterator it = map.id_hash_map.find(task_id);
  if (it != map.id_hash_map.end()) {
    SdkTask* task = it->second;
    CHECK_EQ(task->GetId(), task_id);
    task->IncRef();
    return task;
  } else {
    return NULL;
  }
}

SdkTask* SdkTimeoutManager::PopTask(int64_t task_id) {
  uint32_t shard_id = Shard(task_id);