Method ProcessQueueItem

lib/icingadb/icingadb-worker.cpp:124–180

* Execute the pending configuration item. * * This function processes the pending configuration item by performing the necessary Redis operations based * on the dirty bits set for the associated configuration object. It handles configuration deletions, updates, * and state updates for checkable objects. * * @param item The queue item to process. */

 * @param item The queue item to process.
 */
void IcingaDB::ProcessQueueItem(const icingadb::task_queue::PendingConfigItem& item)
{
	namespace queue = icingadb::task_queue;

	ObjectLock olock(item.Object);

	if (item.DirtyBits & queue::ConfigDelete) {
		auto redisKeyPair = GetSyncableTypeRedisKeys(item.Object->GetReflectionType());
		m_RconWorker->FireAndForgetQueries(
			{
				{"HDEL", redisKeyPair.ObjectKey, GetObjectIdentifier(item.Object)},
				{"HDEL", redisKeyPair.ChecksumKey, GetObjectIdentifier(item.Object)},
				{
					"XADD",
					"icinga:runtime",
					"MAXLEN",
					"~",
					"1000000",
					"*",
					"redis_key",
					redisKeyPair.ObjectKey,
					"id",
					GetObjectIdentifier(item.Object),
					"runtime_type",
					"delete"
				}
			}
		);
	}

	if (item.DirtyBits & queue::ConfigUpdate) {
		std::map<RedisConnection::QueryArg, RedisConnection::Query> hMSets;
		std::vector<Dictionary::Ptr> runtimeUpdates;
		CreateConfigUpdate(item.Object, GetSyncableTypeRedisKeys(item.Object->GetReflectionType()), hMSets, runtimeUpdates, true);
		ExecuteRedisTransaction(m_RconWorker, hMSets, runtimeUpdates);
	}

	if (auto checkable = dynamic_pointer_cast<Checkable>(item.Object); checkable) {
		if (item.DirtyBits & queue::FullState) {
			UpdateState(checkable, item.DirtyBits);
		}
		if (item.DirtyBits & queue::NextUpdate) {
			std::string_view redisKey;
			if (dynamic_pointer_cast<Service>(checkable)) {
				redisKey = CONFIG_REDIS_KEY_PREFIX "nextupdate:service";
			} else {
				redisKey = CONFIG_REDIS_KEY_PREFIX "nextupdate:host";
			}
			auto ID = GetObjectIdentifier(checkable);
			if (checkable->GetEnableActiveChecks() && !checkable->GetExtension("ConfigObjectDeleted")) {
				m_RconWorker->FireAndForgetQuery({"ZADD", redisKey, Convert::ToString(checkable->GetNextUpdate()), ID});
			} else {
				m_RconWorker->FireAndForgetQuery({"ZREM", redisKey, ID});
			}
		}
	}
}