Merge pull request #916 from oatpp/monitor_invalidate_all

network::monitor::ConnectionMonitor: invalidateAll() method
oatpp · Feb 5, 2024 · 17ef2a7 · 17ef2a7
2 parents a85ee40 + d95e763
commit 17ef2a7
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 0 deletions.
diff --git a/src/oatpp/network/monitor/ConnectionMonitor.cpp b/src/oatpp/network/monitor/ConnectionMonitor.cpp
@@ -198,6 +198,14 @@ void ConnectionMonitor::Monitor::removeConnection(v_uint64 id) {
   m_connections.erase(id);
 }
 
+void ConnectionMonitor::Monitor::invalidateAll() {
+  std::lock_guard<std::mutex> lock(m_connectionsMutex);
+  for(v_uint64 caddr : m_connections) {
+    auto connection = reinterpret_cast<ConnectionProxy*>(caddr);
+    connection->invalidate();
+  }
+}
+
 void ConnectionMonitor::Monitor::addStatCollector(const std::shared_ptr<StatCollector>& collector) {
   std::lock_guard<std::mutex> lock(m_checkMutex);
   m_statCollectors.insert({collector->metricName(), collector});
@@ -332,6 +340,10 @@ void ConnectionMonitor::addMetricsChecker(const std::shared_ptr<MetricsChecker>&
   m_monitor->addMetricsChecker(checker);
 }
 
+void ConnectionMonitor::invalidateAll() {
+  m_monitor->invalidateAll();
+}
+
 void ConnectionMonitor::stop() {
   m_monitor->stop();
 }

diff --git a/src/oatpp/network/monitor/ConnectionMonitor.hpp b/src/oatpp/network/monitor/ConnectionMonitor.hpp
@@ -111,6 +111,8 @@ class ConnectionMonitor : public ClientConnectionProvider, public ServerConnecti
     void freeConnectionStats(ConnectionStats& stats);
     void removeConnection(v_uint64 id);
 
+    void invalidateAll();
+
     void addStatCollector(const std::shared_ptr<StatCollector>& collector);
     void removeStatCollector(const oatpp::String& metricName);
 
@@ -147,6 +149,11 @@ class ConnectionMonitor : public ClientConnectionProvider, public ServerConnecti
    */
   void addMetricsChecker(const std::shared_ptr<MetricsChecker>& checker);
 
+  /**
+   * Invalidate all currently active connections.
+   */
+  void invalidateAll();
+
   void stop() override;
 
 };