IcingaDB: add changes queue & RedisConnection enhancements

lib/checker/checkercomponent.cpp

@@ -136,16 +136,13 @@ void CheckerComponent::CheckThreadProc()
 
 		bool forced = checkable->GetForceNextCheck();
 		bool check = true;
-		bool notifyNextCheck = false;
 		double nextCheck = -1;
 
 		if (!forced) {
 			if (!checkable->IsReachable(DependencyCheckExecution)) {
 				Log(LogNotice, "CheckerComponent")
 					<< "Skipping check for object '" << checkable->GetName() << "': Dependency failed.";
-
 				check = false;
-				notifyNextCheck = true;
 			}
 
 			Host::Ptr host;
@@ -182,7 +179,6 @@ void CheckerComponent::CheckThreadProc()
 						<< Utility::FormatDateTime("%Y-%m-%d %H:%M:%S %z", nextCheck);
 
 					check = false;
-					notifyNextCheck = true;
 				}
 			}
 		}
@@ -201,11 +197,6 @@ void CheckerComponent::CheckThreadProc()
 				checkable->UpdateNextCheck();
 			}
 
-			if (notifyNextCheck) {
-				// Trigger update event for Icinga DB
-				Checkable::OnNextCheckUpdated(checkable);
-			}
-
 			lock.lock();
 
 			continue;

lib/icinga/dependency-group.cpp

@@ -144,6 +144,22 @@ void DependencyGroup::LoadParents(std::set<Checkable::Ptr>& parents) const
 	}
 }
 
+/**
+ * Retrieve any child Checkable from the current dependency group.
+ *
+ * @return - Returns the first child Checkable found in this group, or nullptr if there are no children.
+ */
+Checkable::Ptr DependencyGroup::GetAnyChild() const
+{
+	std::lock_guard lock(m_Mutex);
+	for (auto& [_, children] : m_Members) {
+		if (!children.empty()) {
+			return children.begin()->second->GetChild();
+		}
+	}
+	return nullptr;
+}
+
 /**
  * Retrieve the number of dependency objects in the current dependency group.
  *

lib/icinga/dependency.hpp

@@ -164,6 +164,7 @@ class DependencyGroup final : public SharedObject
 	void RemoveDependency(const Dependency::Ptr& dependency);
 	std::vector<Dependency::Ptr> GetDependenciesForChild(const Checkable* child) const;
 	void LoadParents(std::set<Checkable::Ptr>& parents) const;
+	Checkable::Ptr GetAnyChild() const;
 	size_t GetDependenciesCount() const;
 
 	void SetIcingaDBIdentifier(const String& identifier);

lib/icingadb/CMakeLists.txt

@@ -6,7 +6,7 @@ mkclass_target(icingadb.ti icingadb-ti.cpp icingadb-ti.hpp)
 mkembedconfig_target(icingadb-itl.conf icingadb-itl.cpp)
 
 set(icingadb_SOURCES
-  icingadb.cpp icingadb-objects.cpp icingadb-stats.cpp icingadb-utility.cpp redisconnection.cpp icingadb-ti.hpp
+  icingadb.cpp icingadb-objects.cpp icingadb-stats.cpp icingadb-utility.cpp icingadb-worker.cpp redisconnection.cpp icingadb-ti.hpp
   icingadbchecktask.cpp icingadb-itl.cpp
 )