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

This commit is contained in:
Alexander A. Klimov 2020-12-01 18:22:02 +01:00
parent 7772022da5
commit 3c15e71e19

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,6 +146,28 @@ static void FireSuppressedNotifications(Checkable* checkable)
int subtract = 0; int subtract = 0;
{
LazyInit<bool> wasLastParentRecoveryRecent ([&checkable]() {
auto cr (checkable->GetLastCheckResult());
if (!cr) {
return true;
}
auto threshold (cr->GetExecutionStart());
for (auto& dep : checkable->GetDependencies()) {
auto parent (dep->GetParent());
ObjectLock oLock (parent);
if (!parent->GetProblem() && parent->GetLastStateChange() >= threshold) {
return true;
}
}
return false;
});
for (auto type : {NotificationProblem, NotificationRecovery, NotificationFlappingStart, NotificationFlappingEnd}) { for (auto type : {NotificationProblem, NotificationRecovery, NotificationFlappingStart, NotificationFlappingEnd}) {
if (suppressed_types & type) { if (suppressed_types & type) {
bool still_applies; bool still_applies;
@ -205,7 +228,7 @@ static void FireSuppressedNotifications(Checkable* checkable)
still_suppressed = checkable->GetNextCheck() <= Utility::GetTime() + threshold; still_suppressed = checkable->GetNextCheck() <= Utility::GetTime() + threshold;
} }
if (!still_suppressed) { if (!still_suppressed && !wasLastParentRecoveryRecent.Get()) {
Checkable::OnNotificationsRequested(checkable, type, cr, "", "", nullptr); Checkable::OnNotificationsRequested(checkable, type, cr, "", "", nullptr);
subtract |= type; subtract |= type;
@ -215,6 +238,7 @@ static void FireSuppressedNotifications(Checkable* checkable)
} }
} }
} }
}
if (subtract) { if (subtract) {
ObjectLock olock (checkable); ObjectLock olock (checkable);