| 79 | } |
| 80 | |
| 81 | std::shared_ptr<XQueue> XQueueManager::Get(XQueueHandle xq_h) |
| 82 | { |
| 83 | std::lock_guard<std::mutex> lock(mtx_); |
| 84 | auto it = xqs_.find(xq_h); |
| 85 | if (it == xqs_.end()) return nullptr; |
| 86 | return it->second; |
| 87 | } |
| 88 | |
| 89 | XResult XQueueManager::ForEachWaitAll() |
| 90 | { |
nothing calls this directly
no outgoing calls
no test coverage detected