From: Razvan Becheriu <razvan@isc.org>
Date: Mon, 8 Dec 2025 16:36:38 +0000 (+0200)
Subject: [#4248] add log messages
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=852aaa2eb2b8a9f1c8feadb025adeca0c441de36;p=thirdparty%2Fkea.git

[#4248] add log messages
---

diff --git a/config-report.sh.in b/config-report.sh.in
index 9b13c6f578..a7ead344ec 100755
--- a/config-report.sh.in
+++ b/config-report.sh.in
@@ -57,8 +57,8 @@ HERE_DOCUMENT
 
 add_to_report <<HERE_DOCUMENT
 IO Event Handling:
-  select            yes
-  poll              yes
+  select              yes
+  poll                yes
 
 HERE_DOCUMENT
 
diff --git a/src/lib/dhcp/dhcp_log.h b/src/lib/dhcp/dhcp_log.h
index b4f9032ba8..948f01a691 100644
--- a/src/lib/dhcp/dhcp_log.h
+++ b/src/lib/dhcp/dhcp_log.h
@@ -13,7 +13,7 @@
 namespace isc {
 namespace dhcp {
 
-/// \brief DHCP library Logger
+/// @brief DHCP library Logger
 ///
 /// Define the logger used to log messages.  We could define it in multiple
 /// modules, but defining in a single module and linking to it saves time and
diff --git a/src/lib/dhcp/dhcp_messages.cc b/src/lib/dhcp/dhcp_messages.cc
index 3180325449..7f6014e4e6 100644
--- a/src/lib/dhcp/dhcp_messages.cc
+++ b/src/lib/dhcp/dhcp_messages.cc
@@ -7,6 +7,9 @@
 namespace isc {
 namespace dhcp {
 
+extern const isc::log::MessageID DHCP_ADD_EXTERNAL_SOCKET = "DHCP_ADD_EXTERNAL_SOCKET";
+extern const isc::log::MessageID DHCP_DELETE_ALL_EXTERNAL_SOCKETS = "DHCP_DELETE_ALL_EXTERNAL_SOCKETS";
+extern const isc::log::MessageID DHCP_DELETE_EXTERNAL_SOCKET = "DHCP_DELETE_EXTERNAL_SOCKET";
 
 } // namespace dhcp
 } // namespace isc
@@ -14,6 +17,9 @@ namespace dhcp {
 namespace {
 
 const char* values[] = {
+    "DHCP_ADD_EXTERNAL_SOCKET", "Attempted to register external socket %1 from different thread %2",
+    "DHCP_DELETE_ALL_EXTERNAL_SOCKETS", "Attempted to unregister external sockets from different thread %1",
+    "DHCP_DELETE_EXTERNAL_SOCKET", "Attempted to unregister external socket %1 from different thread %2",
     NULL
 };
 
diff --git a/src/lib/dhcp/dhcp_messages.h b/src/lib/dhcp/dhcp_messages.h
index a320114820..931a2c28c3 100644
--- a/src/lib/dhcp/dhcp_messages.h
+++ b/src/lib/dhcp/dhcp_messages.h
@@ -8,6 +8,9 @@
 namespace isc {
 namespace dhcp {
 
+extern const isc::log::MessageID DHCP_ADD_EXTERNAL_SOCKET;
+extern const isc::log::MessageID DHCP_DELETE_ALL_EXTERNAL_SOCKETS;
+extern const isc::log::MessageID DHCP_DELETE_EXTERNAL_SOCKET;
 
 } // namespace dhcp
 } // namespace isc
diff --git a/src/lib/dhcp/dhcp_messages.mes b/src/lib/dhcp/dhcp_messages.mes
index 19b6e6bd8f..44c90424cf 100644
--- a/src/lib/dhcp/dhcp_messages.mes
+++ b/src/lib/dhcp/dhcp_messages.mes
@@ -6,3 +6,20 @@
 
 $NAMESPACE isc::dhcp
 
+% DHCP_ADD_EXTERNAL_SOCKET Attempted to register external socket %1 from different thread %2
+This error message indicates that a different thread than the main thread has
+registered an external socket. This is a programming error and should be fixed.
+Only the main thread is allowed to perform operations on the external sockets.
+The file descritptor and the respective thread id are included in the message.
+
+% DHCP_DELETE_ALL_EXTERNAL_SOCKETS Attempted to unregister external sockets from different thread %1
+This error message indicates that a different thread than the main thread has
+deleted all external sockets. This is a programming error and should be fixed.
+Only the main thread is allowed to perform operations on the external sockets.
+The respective thread id is included in the message.
+
+% DHCP_DELETE_EXTERNAL_SOCKET Attempted to unregister external socket %1 from different thread %2
+This error message indicates that a different thread than the main thread has
+unregistered an external socket. This is a programming error and should be fixed.
+Only the main thread is allowed to perform operations on the external sockets.
+The file descritptor and the respective thread id are included in the message.
diff --git a/src/lib/dhcp/iface_mgr.cc b/src/lib/dhcp/iface_mgr.cc
index 0e6b52c4c6..3e6b6856bf 100644
--- a/src/lib/dhcp/iface_mgr.cc
+++ b/src/lib/dhcp/iface_mgr.cc
@@ -10,6 +10,8 @@
 #include <asiolink/udp_endpoint.h>
 #include <dhcp/dhcp4.h>
 #include <dhcp/dhcp6.h>
+#include <dhcp/dhcp_log.h>
+#include <dhcp/dhcp_messages.h>
 #include <dhcp/iface_mgr.h>
 #include <dhcp/iface_mgr_error_handler.h>
 #include <dhcp/pkt_filter_inet.h>
@@ -332,11 +334,11 @@ IfaceMgr::addExternalSocket(int socketfd, SocketCallback callback) {
         isc_throw(BadValue, "Attempted to install callback for invalid socket "
                   << socketfd);
     }
-    // @todo: remove comment when exclusively allow external sockets actions on main thread.
-    //if (std::this_thread::get_id() != id_) {
-    //    isc_throw(InvalidOperation, "Attempted to register external socket from different thread "
-    //              << std::this_thread::get_id());
-    //}
+    if (std::this_thread::get_id() != id_) {
+        LOG_ERROR(dhcp_logger, DHCP_ADD_EXTERNAL_SOCKET)
+                .arg(socketfd)
+                .arg(std::this_thread::get_id());
+    }
     std::lock_guard<std::mutex> lock(callbacks_mutex_);
     for (SocketCallbackInfo& s : callbacks_) {
         // There's such a socket description there already.
@@ -363,11 +365,11 @@ IfaceMgr::deleteExternalSocket(int socketfd) {
 
 void
 IfaceMgr::deleteExternalSocketInternal(int socketfd) {
-    // @todo: remove comment when exclusively allow external sockets actions on main thread.
-    //if (std::this_thread::get_id() != id_) {
-    //    isc_throw(InvalidOperation, "Attempted to unregister external socket from different thread "
-    //              << std::this_thread::get_id());
-    //}
+    if (std::this_thread::get_id() != id_) {
+        LOG_ERROR(dhcp_logger, DHCP_DELETE_EXTERNAL_SOCKET)
+                .arg(socketfd)
+                .arg(std::this_thread::get_id());
+    }
     for (SocketCallbackInfoContainer::iterator s = callbacks_.begin();
          s != callbacks_.end(); ++s) {
         if (s->socket_ == socketfd) {
@@ -403,11 +405,10 @@ IfaceMgr::isExternalSocketUnusable(int fd) {
 
 void
 IfaceMgr::deleteAllExternalSockets() {
-    // @todo: remove comment when exclusively allow external sockets actions on main thread.
-    //if (std::this_thread::get_id() != id_) {
-    //    isc_throw(InvalidOperation, "Attempted to unregister external sockets from different thread "
-    //              << std::this_thread::get_id());
-    //}
+    if (std::this_thread::get_id() != id_) {
+        LOG_ERROR(dhcp_logger, DHCP_DELETE_ALL_EXTERNAL_SOCKETS)
+                .arg(std::this_thread::get_id());
+    }
     std::lock_guard<std::mutex> lock(callbacks_mutex_);
     callbacks_.clear();
 }