Function FireSuppressedNotifications

lib/notification/notificationcomponent.cpp:77–122

}

static inline
void FireSuppressedNotifications(const Notification::Ptr& notification)
{
	int suppressedTypes (notification->GetSuppressedNotifications());
	if (!suppressedTypes)
		return;

	int subtract = 0;
	auto checkable (notification->GetCheckable());

	auto tp (notification->GetPeriod());

	if ((!tp || tp->IsInside(Utility::GetTime())) && !checkable->IsLikelyToBeCheckedSoon()) {
		for (auto type : {NotificationProblem, NotificationRecovery, NotificationFlappingStart, NotificationFlappingEnd}) {
			if (!(suppressedTypes & type) || checkable->NotificationReasonSuppressed(type)) {
				continue;
			}

			if (!checkable->NotificationReasonApplies(type)) {
				subtract |= type;
				continue;
			}

			auto notificationName (notification->GetName());

			Log(LogNotice, "NotificationComponent")
				<< "Attempting to re-send previously suppressed notification '" << notificationName << "'.";

			subtract |= type;
			SubtractSuppressedNotificationTypes(notification, subtract);
			subtract = 0;

			try {
				notification->BeginExecuteNotification(type, checkable->GetLastCheckResult(), false, false);
			} catch (const std::exception& ex) {
				Log(LogWarning, "NotificationComponent")
					<< "Exception occurred during notification for object '"
					<< notificationName << "': " << DiagnosticInformation(ex, false);
			}
		}
	}

	if (subtract) {
		SubtractSuppressedNotificationTypes(notification, subtract);
	}
}

/**
 * Periodically sends notifications.