Method UpdateDependenciesState

lib/icingadb/icingadb-objects.cpp:1372–1434

* Update the dependency state information of the given checkable and its associated dependency groups in Redis. * * This function serializes the dependency state information of the provided Checkable object and its associated * DependencyGroup into Redis HMSETs and streams the state updates to the runtime state stream. It's intended to * be called by the background worker when processing runti

 * @param dependencyGroup The dependency group to process for the given checkable.
 */
void IcingaDB::UpdateDependenciesState(const Checkable::Ptr& checkable, const DependencyGroup::Ptr& dependencyGroup) const
{
	RedisConnection::Queries streamStates;
	auto addDependencyStateToStream([&streamStates](std::string_view redisKey, const Dictionary::Ptr& stateAttrs) {
		RedisConnection::Query xAdd{
			"XADD", "icinga:runtime:state", "MAXLEN", "~", "1000000", "*", "runtime_type", "upsert",
			"redis_key", redisKey
		};
		ObjectLock olock(stateAttrs);
		for (auto& [key, value] : stateAttrs) {
			xAdd.emplace_back(key);
			xAdd.emplace_back(IcingaToStreamValue(value));
		}
		streamStates.emplace_back(std::move(xAdd));
	});

	std::map<RedisConnection::QueryArg, RedisConnection::Query> hMSets;
	auto dependencies(dependencyGroup->GetDependenciesForChild(checkable.get()));
	std::sort(dependencies.begin(), dependencies.end(), [](const Dependency::Ptr& lhs, const Dependency::Ptr& rhs) {
		return lhs->GetParent() < rhs->GetParent();
	});
	for (auto it(dependencies.begin()); it != dependencies.end(); /* no increment */) {
		const auto& dependency(*it);

		Dictionary::Ptr stateAttrs;
		// Note: The following loop is intended to cover some possible special cases but may not occur in practice
		// that often. That is, having two or more dependency objects that point to the same parent Checkable.
		// So, traverse all those duplicates and merge their relevant state information into a single edge.
		for (; it != dependencies.end() && (*it)->GetParent() == dependency->GetParent(); ++it) {
			if (!stateAttrs || stateAttrs->Get("failed") == false) {
				stateAttrs = SerializeDependencyEdgeState(dependencyGroup, *it);
			}
		}

		addDependencyStateToStream(CONFIG_REDIS_KEY_PREFIX "dependency:edge:state", stateAttrs);
		AddDataToHmSets(hMSets, CONFIG_REDIS_KEY_PREFIX "dependency:edge:state", stateAttrs->Get("id"), stateAttrs);
	}

	if (dependencyGroup->IsRedundancyGroup()) {
		Dictionary::Ptr stateAttrs(SerializeRedundancyGroupState(checkable, dependencyGroup));

		Dictionary::Ptr sharedGroupState(stateAttrs->ShallowClone());
		sharedGroupState->Remove("redundancy_group_id");
		sharedGroupState->Remove("is_reachable");
		sharedGroupState->Remove("last_state_change");

		addDependencyStateToStream(CONFIG_REDIS_KEY_PREFIX "redundancygroup:state", stateAttrs);
		addDependencyStateToStream(CONFIG_REDIS_KEY_PREFIX "dependency:edge:state", sharedGroupState);
		AddDataToHmSets(hMSets, CONFIG_REDIS_KEY_PREFIX "redundancygroup:state", dependencyGroup->GetIcingaDBIdentifier(), stateAttrs);
		AddDataToHmSets(hMSets, CONFIG_REDIS_KEY_PREFIX "dependency:edge:state", dependencyGroup->GetIcingaDBIdentifier(), sharedGroupState);
	}

	if (!streamStates.empty()) {
		RedisConnection::Queries queries;
		for (auto& [redisKey, query] : hMSets) {
			query.insert(query.begin(), {"HSET", redisKey});
			queries.emplace_back(std::move(query));
		}