| 71 | } |
| 72 | |
| 73 | XResult XQueueManager::Exists(XQueueHandle xq_h) |
| 74 | { |
| 75 | std::lock_guard<std::mutex> lock(mtx_); |
| 76 | auto it = xqs_.find(xq_h); |
| 77 | if (it == xqs_.end()) return kXSchedErrorNotFound; |
| 78 | return kXSchedSuccess; |
| 79 | } |
| 80 | |
| 81 | std::shared_ptr<XQueue> XQueueManager::Get(XQueueHandle xq_h) |
| 82 | { |
nothing calls this directly
no outgoing calls
no test coverage detected