* Enqueue the registration of a dependency child to a dependency group. * * This function adds a pending item to the queue for processing the registration of a child checkable * to a dependency group. If there is no active Redis connection available, this function is a no-op. * * @param depGroup The dependency group to which the child is being registered. * @param child The child checkable b
| 288 | * @param child The child checkable being registered to the dependency group. |
| 289 | */ |
| 290 | void IcingaDB::EnqueueDependencyChildRegistered(const DependencyGroup::Ptr& depGroup, const Checkable::Ptr& child) |
| 291 | { |
| 292 | if (GetActive() && m_RconWorker && m_RconWorker->IsConnected()) { |
| 293 | { |
| 294 | std::lock_guard lock(m_PendingItemsMutex); |
| 295 | m_PendingItems.emplace(icingadb::task_queue::PendingDependencyEdgeItem{depGroup, child}); |
| 296 | } |
| 297 | m_PendingItemsCV.notify_one(); |
| 298 | } |
| 299 | } |
| 300 | |
| 301 | /** |
| 302 | * Enqueue the removal of a dependency child from a dependency group. |
no test coverage detected