| 268 | } |
| 269 | |
| 270 | void IcingaDB::EnqueueDependencyGroupStateUpdate(const DependencyGroup::Ptr& depGroup) |
| 271 | { |
| 272 | if (GetActive() && m_RconWorker && m_RconWorker->IsConnected()) { |
| 273 | { |
| 274 | std::lock_guard lock(m_PendingItemsMutex); |
| 275 | m_PendingItems.emplace(icingadb::task_queue::PendingDependencyGroupStateItem{depGroup}); |
| 276 | } |
| 277 | m_PendingItemsCV.notify_one(); |
| 278 | } |
| 279 | } |
| 280 | |
| 281 | /** |
| 282 | * Enqueue the registration of a dependency child to a dependency group. |
no test coverage detected