tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-28 16:14:09 +02:00
Code Issues Packages Projects Releases Wiki Activity

Don't fire suppressed notifications if last parent recovery >= last check result

Browse Source
This commit is contained in:
Alexander A. Klimov 2020-12-01 18:22:02 +01:00
parent 338d0aaa8c
commit 668bf06424
1 changed files with 46 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
lib/icinga/checkable-notification.cpp
View File

@ -10,6 +10,7 @@
#include "base/exception.hpp" #include "base/exception.hpp"
#include "base/context.hpp" #include "base/context.hpp"
#include "base/convert.hpp" #include "base/convert.hpp"
#include "base/lazy-init.hpp"
#include "remote/apilistener.hpp" #include "remote/apilistener.hpp"
using namespace icinga; using namespace icinga;
@ -145,35 +146,58 @@ static void FireSuppressedNotifications(Checkable* checkable)
int subtract = 0; int subtract = 0;
for (auto type : {NotificationProblem, NotificationRecovery, NotificationFlappingStart, NotificationFlappingEnd}) { {
if (suppressed_types & type) { LazyInit<bool> wasLastParentRecoveryRecent ([&checkable]() {
bool still_applies = checkable->NotificationReasonApplies(type); auto cr (checkable->GetLastCheckResult());
if (still_applies) { if (!cr) {
bool still_suppressed; return true;
}
switch (type) { auto threshold (cr->GetExecutionStart());
case NotificationProblem:
/* Fall through. */ for (auto& dep : checkable->GetDependencies()) {
case NotificationRecovery: auto parent (dep->GetParent());
still_suppressed = !checkable->IsReachable(DependencyNotification) || checkable->IsInDowntime() || checkable->IsAcknowledged(); ObjectLock oLock (parent);
break;
case NotificationFlappingStart: if (!parent->GetProblem() && parent->GetLastStateChange() >= threshold) {
/* Fall through. */ return true;
case NotificationFlappingEnd:
still_suppressed = checkable->IsInDowntime();
break;
default:
break;
} }
}
if (!still_suppressed && !checkable->IsLikelyToBeCheckedSoon()) { return false;
Checkable::OnNotificationsRequested(checkable, type, checkable->GetLastCheckResult(), "", "", nullptr); });
for (auto type : {NotificationProblem, NotificationRecovery, NotificationFlappingStart, NotificationFlappingEnd}) {
if (suppressed_types & type) {
bool still_applies = checkable->NotificationReasonApplies(type);
if (still_applies) {
bool still_suppressed;
switch (type) {
case NotificationProblem:
/* Fall through. */
case NotificationRecovery:
still_suppressed = !checkable->IsReachable(DependencyNotification) || checkable->IsInDowntime() || checkable->IsAcknowledged();
break;
case NotificationFlappingStart:
/* Fall through. */
case NotificationFlappingEnd:
still_suppressed = checkable->IsInDowntime();
break;
default:
break;
}
if (!still_suppressed && !checkable->IsLikelyToBeCheckedSoon() && !wasLastParentRecoveryRecent.Get()) {
Checkable::OnNotificationsRequested(checkable, type, checkable->GetLastCheckResult(), "", "", nullptr);
subtract |= type;
}
} else {
subtract |= type; subtract |= type;
} }
} else {
subtract |= type;
} }
} }
} }