| 101 | } |
| 102 | |
| 103 | XResult XQueueManager::ForEach(std::function<XResult(std::shared_ptr<XQueue>)> func) |
| 104 | { |
| 105 | std::lock_guard<std::mutex> lock(mtx_); |
| 106 | for (auto it : xqs_) { |
| 107 | XResult res = func(it.second); |
| 108 | if (res != kXSchedSuccess) return res; |
| 109 | } |
| 110 | return kXSchedSuccess; |
| 111 | } |
| 112 | |
| 113 | XResult XQueueManager::AutoCreate(std::function<XResult(HwQueueHandle *)> create_hwq) |
| 114 | { |
nothing calls this directly
no outgoing calls
no test coverage detected