IcingaDB: add changes queue & RedisConnection enhancements

lib/base/objectlock.cpp

@@ -37,6 +37,24 @@ ObjectLock::ObjectLock(const Object *object)
 		Lock();
 }
 
+/**
+ * Tries to lock the object without blocking.
+ *
+ * @returns true if the lock was acquired, false otherwise.
+ */
+bool ObjectLock::TryLock() noexcept
+{
+	ASSERT(!m_Locked && m_Object);
+
+	m_Locked = m_Object->m_Mutex.try_lock();
+#ifdef I2_DEBUG
+	if (m_Locked && ++m_Object->m_LockCount == 1u) {
+		m_Object->m_LockOwner.store(std::this_thread::get_id());
+	}
+#endif /* I2_DEBUG */
+	return m_Locked;
+}
+
 void ObjectLock::Lock()
 {
 	ASSERT(!m_Locked && m_Object);

lib/base/objectlock.hpp

@@ -23,6 +23,7 @@ struct ObjectLock
 
 	~ObjectLock();
 
+	bool TryLock() noexcept;
 	void Lock();
 	void Unlock();
 

lib/checker/checkercomponent.cpp

@@ -135,16 +135,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;
@@ -181,7 +178,6 @@ void CheckerComponent::CheckThreadProc()
 						<< Utility::FormatDateTime("%Y-%m-%d %H:%M:%S %z", nextCheck);
 
 					check = false;
-					notifyNextCheck = true;
 				}
 			}
 		}
@@ -200,11 +196,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

@@ -143,6 +143,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

@@ -163,6 +163,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

@@ -5,7 +5,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
 )