Method UpdateAllConfigObjects

lib/icingadb/icingadb-objects.cpp:211–546

}

void IcingaDB::UpdateAllConfigObjects()
{
	// This function performs an initial dump of all configuration objects into Redis, thus there are no
	// previously enqueued queries on m_RconWorker that we need to wait for. So, no Sync() call is necessary here.
	m_RconWorker->FireAndForgetQuery({"XADD", "icinga:schema", "MAXLEN", "1", "*", "version", "6"}, {}, true);

	Log(LogInformation, "IcingaDB") << "Starting initial config/status dump";
	double startTime = Utility::GetTime();

	SetOngoingDumpStart(startTime);

	Defer resetOngoingDumpStart ([this]() {
		SetOngoingDumpStart(0);
	});

	// Use a Workqueue to pack objects in parallel
	WorkQueue upq(25000, Configuration::Concurrency, LogNotice);
	upq.SetName("IcingaDB:ConfigDump");

	// Add a new type=* state=wip entry to the stream and remove all previous entries (MAXLEN 1).
	m_RconWorker->FireAndForgetQuery({"XADD", "icinga:dump", "MAXLEN", "1", "*", "key", "*", "state", "wip"});

	const std::vector<RedisConnection::QueryArg> globalKeys = {
		CONFIG_REDIS_KEY_PREFIX "customvar",
		CONFIG_REDIS_KEY_PREFIX "action:url",
		CONFIG_REDIS_KEY_PREFIX "notes:url",
		CONFIG_REDIS_KEY_PREFIX "icon:image",

		// These keys aren't tied to a specific Checkable type but apply to both "Host" and "Service" types,
		// and as such we've to make sure to clear them before we actually start dumping the actual objects.
		// This allows us to wait on both types to be dumped before we send a config dump done signal for those keys.
		CONFIG_REDIS_KEY_PREFIX "dependency:node",
		CONFIG_REDIS_KEY_PREFIX "dependency:edge",
		CONFIG_REDIS_KEY_PREFIX "dependency:edge:state",
		CONFIG_REDIS_KEY_PREFIX "redundancygroup",
		CONFIG_REDIS_KEY_PREFIX "redundancygroup:state",
	};
	DeleteKeys(m_RconWorker, globalKeys);
	DeleteKeys(m_RconWorker, {"icinga:nextupdate:host", "icinga:nextupdate:service"});
	m_RconWorker->Sync();

	Defer resetDumpedGlobals ([this]() {
		m_DumpedGlobals.CustomVar.Reset();
		m_DumpedGlobals.ActionUrl.Reset();
		m_DumpedGlobals.NotesUrl.Reset();
		m_DumpedGlobals.IconImage.Reset();
		m_DumpedGlobals.DependencyGroup.Reset();
	});

	upq.ParallelFor(l_SyncableTypes, false, [this](const SyncableTypeInfo& info) {
		// No structured binding is allowed here till C++20 (https://gcc.gnu.org/bugzilla/show_bug.cgi?id=85889).
		Type::Ptr type;
		QueryArgPair redisKeyPair;
		std::tie(type, redisKeyPair) = info;
		ConfigType *ctype = dynamic_cast<ConfigType *>(type.get());
		if (!ctype)
			return;