From 18afcf446561eaf7e079f7b2514b2f0830f384f6 Mon Sep 17 00:00:00 2001 From: Otto Moerbeek Date: Wed, 8 Jan 2025 09:50:57 +0100 Subject: [PATCH] rec: explictly log port of listening addresses --- pdns/recursordist/pdns_recursor.cc | 4 +++- pdns/recursordist/rec-tcp.cc | 5 +++-- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/pdns/recursordist/pdns_recursor.cc b/pdns/recursordist/pdns_recursor.cc index 8f022abb8c..15d1f57e01 100644 --- a/pdns/recursordist/pdns_recursor.cc +++ b/pdns/recursordist/pdns_recursor.cc @@ -2687,6 +2687,7 @@ unsigned int makeUDPServerSockets(deferredAdd_t& deferredAdds, Logr::log_t log, { int one = 1; vector localAddresses; + vector logVec; stringtok(localAddresses, ::arg()["local-address"], " ,"); if (localAddresses.empty()) { @@ -2700,6 +2701,7 @@ unsigned int makeUDPServerSockets(deferredAdd_t& deferredAdds, Logr::log_t log, if (socketFd < 0) { throw PDNSException("Making a UDP server socket for resolver: " + stringerror()); } + logVec.emplace_back(address.toStringWithPort()); if (!setSocketTimestamps(socketFd)) { SLOG(g_log << Logger::Warning << "Unable to enable timestamp reporting for socket" << endl, log->info(Logr::Warning, "Unable to enable timestamp reporting for socket")); @@ -2774,7 +2776,7 @@ unsigned int makeUDPServerSockets(deferredAdd_t& deferredAdds, Logr::log_t log, g_listenSocketsAddresses[socketFd] = address; // this is written to only from the startup thread, not from the workers } if (doLog) { - log->info(Logr::Info, "Listening for queries", "proto", Logging::Loggable("UDP"), "addresses", Logging::IterLoggable(localAddresses.cbegin(), localAddresses.cend()), "socketInstances", Logging::Loggable(instances), "reuseport", Logging::Loggable(g_reusePort)); + log->info(Logr::Info, "Listening for queries", "proto", Logging::Loggable("UDP"), "addresses", Logging::IterLoggable(logVec.cbegin(), logVec.cend()), "socketInstances", Logging::Loggable(instances), "reuseport", Logging::Loggable(g_reusePort)); } return localAddresses.size(); } diff --git a/pdns/recursordist/rec-tcp.cc b/pdns/recursordist/rec-tcp.cc index e2d417e724..4ef2bb182b 100644 --- a/pdns/recursordist/rec-tcp.cc +++ b/pdns/recursordist/rec-tcp.cc @@ -1090,6 +1090,7 @@ LWResult::Result arecvtcp(PacketBuffer& data, const size_t len, shared_ptr& tcpSockets, Logr::log_t log, bool doLog, unsigned int instances) { vector localAddresses; + vector logVec; stringtok(localAddresses, ::arg()["local-address"], " ,"); if (localAddresses.empty()) { @@ -1106,7 +1107,7 @@ unsigned int makeTCPServerSockets(deferredAdd_t& deferredAdds, std::set& tc if (socketFd < 0) { throw PDNSException("Making a TCP server socket for resolver: " + stringerror()); } - + logVec.emplace_back(address.toStringWithPort()); setCloseOnExec(socketFd); int tmp = 1; @@ -1193,7 +1194,7 @@ unsigned int makeTCPServerSockets(deferredAdd_t& deferredAdds, std::set& tc #endif } if (doLog) { - log->info(Logr::Info, "Listening for queries", "protocol", Logging::Loggable("TCP"), "addresses", Logging::IterLoggable(localAddresses.cbegin(), localAddresses.cend()), "socketInstances", Logging::Loggable(instances), "reuseport", Logging::Loggable(g_reusePort)); + log->info(Logr::Info, "Listening for queries", "protocol", Logging::Loggable("TCP"), "addresses", Logging::IterLoggable(logVec.cbegin(), logVec.cend()), "socketInstances", Logging::Loggable(instances), "reuseport", Logging::Loggable(g_reusePort)); } return localAddresses.size(); } -- 2.47.2