tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-04-08 17:05:25 +02:00
Code Issues Packages Projects Releases Wiki Activity

IcingaDB#Send*(): don't enqueue any history once stopped

Browse Source
This commit is contained in:
Alexander A. Klimov 2022-02-15 10:30:09 +01:00
parent 2ab52d5c59
commit f1a942681f
1 changed files with 33 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
lib/icingadb/icingadb-objects.cpp
View File

@ -1621,6 +1621,10 @@ unsigned short GetPreviousState(const Checkable::Ptr& checkable, const Service::
void IcingaDB::SendStateChange(const ConfigObject::Ptr& object, const CheckResult::Ptr& cr, StateType type)
{
if (!GetActive()) {
return;
}
Checkable::Ptr checkable = dynamic_pointer_cast<Checkable>(object);
if (!checkable)
return;
@ -1710,6 +1714,10 @@ void IcingaDB::SendSentNotification(
NotificationType type, const CheckResult::Ptr& cr, const String& author, const String& text, double sendTime
)
{
if (!GetActive()) {
return;
}
Host::Ptr host;
Service::Ptr service;
tie(host, service) = GetHostService(checkable);
@ -1776,6 +1784,10 @@ void IcingaDB::SendSentNotification(
void IcingaDB::SendStartedDowntime(const Downtime::Ptr& downtime)
{
if (!GetActive()) {
return;
}
SendConfigUpdate(downtime, true);
auto checkable (downtime->GetCheckable());
@ -1859,6 +1871,10 @@ void IcingaDB::SendStartedDowntime(const Downtime::Ptr& downtime)
void IcingaDB::SendRemovedDowntime(const Downtime::Ptr& downtime)
{
if (!GetActive()) {
return;
}
auto checkable (downtime->GetCheckable());
auto triggeredBy (Downtime::GetByName(downtime->GetTriggeredBy()));
@ -1946,7 +1962,7 @@ void IcingaDB::SendRemovedDowntime(const Downtime::Ptr& downtime)
void IcingaDB::SendAddedComment(const Comment::Ptr& comment)
{
if (comment->GetEntryType() != CommentUser)
if (comment->GetEntryType() != CommentUser || !GetActive())
return;
auto checkable (comment->GetCheckable());
@ -2002,6 +2018,10 @@ void IcingaDB::SendAddedComment(const Comment::Ptr& comment)
void IcingaDB::SendRemovedComment(const Comment::Ptr& comment)
{
if (!GetActive()) {
return;
}
auto checkable (comment->GetCheckable());
Host::Ptr host;
@ -2067,6 +2087,10 @@ void IcingaDB::SendRemovedComment(const Comment::Ptr& comment)
void IcingaDB::SendFlappingChange(const Checkable::Ptr& checkable, double changeTime, double flappingLastChange)
{
if (!GetActive()) {
return;
}
Host::Ptr host;
Service::Ptr service;
tie(host, service) = GetHostService(checkable);
@ -2155,6 +2179,10 @@ void IcingaDB::SendNextUpdate(const Checkable::Ptr& checkable)
void IcingaDB::SendAcknowledgementSet(const Checkable::Ptr& checkable, const String& author, const String& comment, AcknowledgementType type, bool persistent, double changeTime, double expiry)
{
if (!GetActive()) {
return;
}
Host::Ptr host;
Service::Ptr service;
tie(host, service) = GetHostService(checkable);
@ -2209,6 +2237,10 @@ void IcingaDB::SendAcknowledgementSet(const Checkable::Ptr& checkable, const Str
void IcingaDB::SendAcknowledgementCleared(const Checkable::Ptr& checkable, const String& removedBy, double changeTime, double ackLastChange)
{
if (!GetActive()) {
return;
}
Host::Ptr host;
Service::Ptr service;
tie(host, service) = GetHostService(checkable);