| 205 | } |
| 206 | |
| 207 | void ClearFailedWorkForPrefix(const std::string& prefix) { |
| 208 | std::lock_guard<std::mutex> lock(g_queueMutex); |
| 209 | for (auto it = g_failedPaths.begin(); it != g_failedPaths.end(); ) { |
| 210 | if (it->rfind(prefix, 0) == 0) it = g_failedPaths.erase(it); |
| 211 | else ++it; |
| 212 | } |
| 213 | } |
| 214 | |
| 215 | static void RequeueFailedWorkForPrefixLocked(const std::string& prefix) { |
| 216 | for (auto it = g_failedWorkItems.begin(); it != g_failedWorkItems.end(); ) { |
nothing calls this directly
no outgoing calls
no test coverage detected