From: Otto Moerbeek Date: Wed, 26 Jan 2022 10:37:18 +0000 (+0100) Subject: Reformat X-Git-Tag: auth-4.7.0-alpha1~19^2~5 X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=9abbcebbb91d227583406fbd25394874ab7d58a5;p=thirdparty%2Fpdns.git Reformat --- diff --git a/pdns/recursordist/rec-main.cc b/pdns/recursordist/rec-main.cc index 79342bbf8a..4a98bbc0de 100644 --- a/pdns/recursordist/rec-main.cc +++ b/pdns/recursordist/rec-main.cc @@ -847,7 +847,6 @@ static void loggerBackend(const Logging::Entry& entry) g_log << u << buf.str() << endl; } - static int ratePercentage(uint64_t nom, uint64_t denom) { if (denom == 0) { @@ -1054,7 +1053,7 @@ void broadcastFunction(const pipefunc_t& func) unsigned int n = 0; for (const auto& threadInfo : RecThreadInfo::infos()) { - if (n++ == RecThreadInfo::id()) { + if (n++ == RecThreadInfo::id()) { func(); // don't write to ourselves! continue; } @@ -1535,7 +1534,7 @@ static int serviceMain(int argc, char* argv[]) if (RecThreadInfo::weDistributeQueries()) { /* first thread is the handler, then distributors */ for (unsigned int threadId = 1; threadId <= RecThreadInfo::numDistributors(); threadId++) { - auto& info = RecThreadInfo::info(threadId); + auto& info = RecThreadInfo::info(threadId); auto& deferredAdds = info.deferredAdds; auto& tcpSockets = info.tcpSockets; makeUDPServerSockets(deferredAdds); @@ -1545,7 +1544,7 @@ static int serviceMain(int argc, char* argv[]) else { /* first thread is the handler, there is no distributor here and workers are accepting queries */ for (unsigned int threadId = 1; threadId <= RecThreadInfo::numWorkers(); threadId++) { - auto& info = RecThreadInfo::info(threadId); + auto& info = RecThreadInfo::info(threadId); auto& deferredAdds = info.deferredAdds; auto& tcpSockets = info.tcpSockets; makeUDPServerSockets(deferredAdds); diff --git a/pdns/recursordist/rec-main.hh b/pdns/recursordist/rec-main.hh index 01d375e4ea..650df429b5 100644 --- a/pdns/recursordist/rec-main.hh +++ b/pdns/recursordist/rec-main.hh @@ -480,8 +480,6 @@ struct ThreadMSG bool wantAnswer; }; - - PacketBuffer GenUDPQueryResponse(const ComboAddress& dest, const string& query); bool checkProtobufExport(LocalStateHolder& luaconfsLocal); bool checkOutgoingProtobufExport(LocalStateHolder& luaconfsLocal);