Make load order for objects more reliable

fixes #8770

lib/base/dynamicobject.cpp

@@ -187,6 +187,11 @@ void DynamicObject::OnAllConfigLoaded(void)
 	/* Nothing to do here. */
 }
 
+void DynamicObject::CreateChildObjects(const Type::Ptr& childType)
+{
+	/* Nothing to do here. */
+}
+
 void DynamicObject::OnStateLoaded(void)
 {
 	/* Nothing to do here. */

lib/base/dynamicobject.hpp

@@ -75,6 +75,7 @@ public:
 	virtual void Resume(void);
 
 	virtual void OnConfigLoaded(void);
+	virtual void CreateChildObjects(const Type::Ptr& childType);
 	virtual void OnAllConfigLoaded(void);
 	virtual void OnStateLoaded(void);
 

lib/config/configitem.cpp

@@ -284,9 +284,6 @@ bool ConfigItem::CommitNewItems(WorkQueue& upq)
 	typedef std::pair<ConfigItem::Ptr, bool> ItemPair;
 	std::vector<ItemPair> items;
 
-	do {
-		items.clear();
-
 	{
 		boost::mutex::scoped_lock lock(m_Mutex);
 
@@ -306,6 +303,9 @@ bool ConfigItem::CommitNewItems(WorkQueue& upq)
 		m_UnnamedItems.clear();
 	}
 
+	if (items.empty())
+		return true;
+
 	BOOST_FOREACH(const ItemPair& ip, items) {
 		upq.Enqueue(boost::bind(&ConfigItem::Commit, ip.first, ip.second));
 	}
@@ -324,8 +324,21 @@ bool ConfigItem::CommitNewItems(WorkQueue& upq)
 
 	std::set<String> types;
 
-		BOOST_FOREACH(const ConfigItem::Ptr& item, new_items) {
-			types.insert(item->m_Type);
+	std::vector<Type::Ptr> all_types;
+	Dictionary::Ptr globals = ScriptGlobal::GetGlobals();
+
+	{
+		ObjectLock olock(globals);
+		BOOST_FOREACH(const Dictionary::Pair& kv, globals) {
+			if (kv.second.IsObjectType<Type>())
+				all_types.push_back(kv.second);
+		}
+	}
+
+	Type::Ptr dotype = Type::GetByName("DynamicObject");
+	BOOST_FOREACH(const Type::Ptr& type, all_types) {
+		if (dotype->IsAssignableFrom(type))
+			types.insert(type->GetName());
 	}
 
 	std::set<String> completed_types;
@@ -338,6 +351,7 @@ bool ConfigItem::CommitNewItems(WorkQueue& upq)
 			Type::Ptr ptype = Type::GetByName(type);
 			bool unresolved_dep = false;
 
+			/* skip this type (for now) if there are unresolved load dependencies */
 			BOOST_FOREACH(const String& loadDep, ptype->GetLoadDependencies()) {
 				if (types.find(loadDep) != types.end() && completed_types.find(loadDep) == completed_types.end()) {
 					unresolved_dep = true;
@@ -345,13 +359,25 @@ bool ConfigItem::CommitNewItems(WorkQueue& upq)
 				}
 			}
 
-				if (!unresolved_dep) {
+			if (unresolved_dep)
+				continue;
+
 			BOOST_FOREACH(const ConfigItem::Ptr& item, new_items) {
 				if (item->m_Type == type)
 					upq.Enqueue(boost::bind(&DynamicObject::OnAllConfigLoaded, item->m_Object));
 			}
 
 			completed_types.insert(type);
+
+			upq.Join();
+
+			if (upq.HasExceptions())
+				return false;
+
+			BOOST_FOREACH(const String& loadDep, ptype->GetLoadDependencies()) {
+				BOOST_FOREACH(const ConfigItem::Ptr& item, new_items) {
+					if (item->m_Type == loadDep)
+						upq.Enqueue(boost::bind(&DynamicObject::CreateChildObjects, item->m_Object, ptype));
 				}
 			}
 
@@ -359,8 +385,11 @@ bool ConfigItem::CommitNewItems(WorkQueue& upq)
 
 			if (upq.HasExceptions())
 				return false;
+
+			if (!CommitNewItems(upq))
+				return false;
+		}
 	}
-	} while (!items.empty());
 
 	return true;
 }

lib/icinga/dependency-apply.cpp

@@ -74,7 +74,7 @@ bool Dependency::EvaluateApplyRuleInstance(const Checkable::Ptr& checkable, cons
 	builder->AddExpression(new OwnedExpression(rule.GetExpression()));
 
 	ConfigItem::Ptr dependencyItem = builder->Compile();
-	dependencyItem->Commit();
+	dependencyItem->Register();
 
 	return true;
 }

lib/icinga/host.cpp

@@ -54,10 +54,20 @@ void Host::OnAllConfigLoaded(void)
 				hg->ResolveGroupMembership(this, true);
 		}
 	}
+}
 
+void Host::CreateChildObjects(const Type::Ptr& childType)
+{
+	if (childType->GetName() == "ScheduledDowntime")
 		ScheduledDowntime::EvaluateApplyRules(this);
+
+	if (childType->GetName() == "Notification")
 		Notification::EvaluateApplyRules(this);
+
+	if (childType->GetName() == "Dependency")
 		Dependency::EvaluateApplyRules(this);
+
+	if (childType->GetName() == "Service")
 		Service::EvaluateApplyRules(this);
 }
 

lib/icinga/host.hpp

@@ -69,6 +69,7 @@ protected:
 	virtual void Stop(void);
 
 	virtual void OnAllConfigLoaded(void);
+	virtual void CreateChildObjects(const Type::Ptr& childType);
 
 private:
 	mutable boost::mutex m_ServicesMutex;

lib/icinga/notification-apply.cpp

@@ -73,7 +73,7 @@ bool Notification::EvaluateApplyRuleInstance(const Checkable::Ptr& checkable, co
 	builder->AddExpression(new OwnedExpression(rule.GetExpression()));
 
 	ConfigItem::Ptr notificationItem = builder->Compile();
-	notificationItem->Commit();
+	notificationItem->Register();
 
 	return true;
 }

lib/icinga/scheduleddowntime-apply.cpp

@@ -72,7 +72,7 @@ bool ScheduledDowntime::EvaluateApplyRuleInstance(const Checkable::Ptr& checkabl
 	builder->AddExpression(new OwnedExpression(rule.GetExpression()));
 
 	ConfigItem::Ptr downtimeItem = builder->Compile();
-	downtimeItem->Commit();
+	downtimeItem->Register();
 
 	return true;
 }

lib/icinga/service-apply.cpp

@@ -66,7 +66,7 @@ bool Service::EvaluateApplyRuleInstance(const Host::Ptr& host, const String& nam
 	builder->AddExpression(new OwnedExpression(rule.GetExpression()));
 
 	ConfigItem::Ptr serviceItem = builder->Compile();
-	serviceItem->Commit();
+	serviceItem->Register();
 
 	return true;
 }

lib/icinga/service.cpp

@@ -66,9 +66,17 @@ void Service::OnAllConfigLoaded(void)
 				sg->ResolveGroupMembership(this, true);
 		}
 	}
+}
 
+void Service::CreateChildObjects(const Type::Ptr& childType)
+{
+	if (childType->GetName() == "ScheduledDowntime")
 		ScheduledDowntime::EvaluateApplyRules(this);
+
+	if (childType->GetName() == "Notification")
 		Notification::EvaluateApplyRules(this);
+
+	if (childType->GetName() == "Dependency")
 		Dependency::EvaluateApplyRules(this);
 }
 

lib/icinga/service.hpp

@@ -57,6 +57,7 @@ public:
 
 protected:
 	virtual void OnAllConfigLoaded(void);
+	virtual void CreateChildObjects(const Type::Ptr& childType);
 
 private:
 	Host::Ptr m_Host;