| 1059 | } |
| 1060 | |
| 1061 | void completeSourceFetch(const RelocateData& results) { |
| 1062 | ASSERT(fetchingSourcesQueue.count(results)); |
| 1063 | |
| 1064 | // logRelocation( results, "GotSourceServers" ); |
| 1065 | |
| 1066 | fetchingSourcesQueue.erase(results); |
| 1067 | queueMap.insert(results.keys, results); |
| 1068 | for (int i = 0; i < results.src.size(); i++) { |
| 1069 | queue[results.src[i]].insert(results); |
| 1070 | } |
| 1071 | updateLastAsSource(results.src); |
| 1072 | serverCounter.increaseForTeam(results.src, results.reason, ServerCounter::CountType::QueuedSource); |
| 1073 | } |
| 1074 | |
| 1075 | void logRelocation(const RelocateData& rd, const char* title) { |
| 1076 | std::string busyString; |
no test coverage detected