Lines Matching defs:queueId
525 ITaskQueue::Ptr ObjectRegistry::GetTaskQueue(const BASE_NS::Uid& queueId) const
528 if (auto queue = queues_.find(queueId); queue != queues_.end()) {
531 CORE_LOG_W("Cannot get task queue, task queue not registered: %s", BASE_NS::to_string(queueId).data());
535 bool ObjectRegistry::RegisterTaskQueue(const ITaskQueue::Ptr& queue, const BASE_NS::Uid& queueId)
539 if (auto existing = queues_.find(queueId); existing != queues_.end()) {
546 queues_[queueId] = queue;
550 bool ObjectRegistry::UnregisterTaskQueue(const BASE_NS::Uid& queueId)
553 if (auto existing = queues_.find(queueId); existing != queues_.end()) {
560 bool ObjectRegistry::HasTaskQueue(const BASE_NS::Uid& queueId) const
563 return queues_.find(queueId) != queues_.end();