Method EnqueueConfigObject

lib/icingadb/icingadb-worker.cpp:245–268

* Enqueue a configuration object for processing in the pending objects thread. * * @param object The configuration object to be enqueued for processing. * @param bits The dirty bits indicating the type of changes to be processed for the object. */

 * @param bits The dirty bits indicating the type of changes to be processed for the object.
 */
void IcingaDB::EnqueueConfigObject(const ConfigObject::Ptr& object, uint32_t bits)
{
	namespace queue = icingadb::task_queue;

	if (!GetActive() || !m_RconWorker || !m_RconWorker->IsConnected()) {
		return; // No need to enqueue anything if we're not connected.
	}

	{
		std::lock_guard lock(m_PendingItemsMutex);
		if (auto [it, inserted] = m_PendingItems.emplace(queue::PendingConfigItem{object, bits}); !inserted) {
			m_PendingItems.modify(it, [bits](queue::PendingQueueItem& item) {
				auto& configItem = std::get<queue::PendingConfigItem>(item.Item);
				if (bits & queue::ConfigDelete) {
					configItem.DirtyBits &= ~(queue::ConfigUpdate | queue::FullState);
				} else if (bits & queue::ConfigUpdate) {
					configItem.DirtyBits &= ~queue::ConfigDelete;
				}
				configItem.DirtyBits |= bits & queue::DirtyBitsAll;
			});
		}
	}
	m_PendingItemsCV.notify_one();
}

void IcingaDB::EnqueueDependencyGroupStateUpdate(const DependencyGroup::Ptr& depGroup)
{