-/******************************************************************************
- * Icinga 2 *
- * Copyright (C) 2012-2015 Icinga Development Team (http://www.icinga.org) *
- * *
- * This program is free software; you can redistribute it and/or *
- * modify it under the terms of the GNU General Public License *
- * as published by the Free Software Foundation; either version 2 *
- * of the License, or (at your option) any later version. *
- * *
- * This program is distributed in the hope that it will be useful, *
- * but WITHOUT ANY WARRANTY; without even the implied warranty of *
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
- * GNU General Public License for more details. *
- * *
- * You should have received a copy of the GNU General Public License *
- * along with this program; if not, write to the Free Software Foundation *
- * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA. *
- ******************************************************************************/
+/* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */
#include "icinga/checkable.hpp"
#include "icinga/icingaapplication.hpp"
#include "base/exception.hpp"
#include "base/context.hpp"
#include "base/convert.hpp"
-#include <boost/foreach.hpp>
using namespace icinga;
boost::signals2::signal<void (const Notification::Ptr&, const Checkable::Ptr&, const std::set<User::Ptr>&,
- const NotificationType&, const CheckResult::Ptr&, const String&, const String&)> Checkable::OnNotificationSentToAllUsers;
-boost::signals2::signal<void (const Notification::Ptr&, const Checkable::Ptr&, const std::set<User::Ptr>&,
- const NotificationType&, const CheckResult::Ptr&, const String&, const String&)> Checkable::OnNotificationSendStart;
+ const NotificationType&, const CheckResult::Ptr&, const String&, const String&,
+ const MessageOrigin::Ptr&)> Checkable::OnNotificationSentToAllUsers;
boost::signals2::signal<void (const Notification::Ptr&, const Checkable::Ptr&, const User::Ptr&,
- const NotificationType&, const CheckResult::Ptr&, const String&, const String&, const String&)> Checkable::OnNotificationSentToUser;
+ const NotificationType&, const CheckResult::Ptr&, const NotificationResult::Ptr&, const String&,
+ const String&, const String&, const MessageOrigin::Ptr&)> Checkable::OnNotificationSentToUser;
-void Checkable::ResetNotificationNumbers(void)
+void Checkable::ResetNotificationNumbers()
{
- BOOST_FOREACH(const Notification::Ptr& notification, GetNotifications()) {
+ for (const Notification::Ptr& notification : GetNotifications()) {
ObjectLock olock(notification);
notification->ResetNotificationNumber();
}
void Checkable::SendNotifications(NotificationType type, const CheckResult::Ptr& cr, const String& author, const String& text)
{
- CONTEXT("Sending notifications for object '" + GetName() + "'");
+ String checkableName = GetName();
+
+ CONTEXT("Sending notifications for object '" + checkableName + "'");
bool force = GetForceNextNotification();
+ SetForceNextNotification(false);
+
if (!IcingaApplication::GetInstance()->GetEnableNotifications() || !GetEnableNotifications()) {
if (!force) {
Log(LogInformation, "Checkable")
- << "Notifications are disabled for service '" << GetName() << "'.";
+ << "Notifications are disabled for checkable '" << checkableName << "'.";
return;
}
-
- SetForceNextNotification(false);
}
- Log(LogInformation, "Checkable")
- << "Checking for configured notifications for object '" << GetName() << "'";
-
std::set<Notification::Ptr> notifications = GetNotifications();
- if (notifications.empty())
- Log(LogInformation, "Checkable")
- << "Checkable '" << GetName() << "' does not have any notifications.";
+ Log(LogInformation, "Checkable")
+ << "Checkable '" << checkableName << "' has " << notifications.size() << " notification(s). Proceeding with filters, successful sends will be logged.";
- Log(LogDebug, "Checkable")
- << "Checkable '" << GetName() << "' has " << notifications.size() << " notification(s).";
+ if (notifications.empty())
+ return;
- BOOST_FOREACH(const Notification::Ptr& notification, notifications) {
+ for (const Notification::Ptr& notification : notifications) {
try {
- notification->BeginExecuteNotification(type, cr, force, author, text);
+ if (!notification->IsPaused()) {
+ notification->BeginExecuteNotification(type, cr, force, false, author, text);
+ } else {
+ Log(LogNotice, "Notification")
+ << "Notification '" << notification->GetName() << "': HA cluster active, this endpoint does not have the authority (paused=true). Skipping.";
+ }
} catch (const std::exception& ex) {
Log(LogWarning, "Checkable")
- << "Exception occured during notification for service '"
- << GetName() << "': " << DiagnosticInformation(ex);
+ << "Exception occurred during notification '" << notification->GetName() << "' for checkable '"
+ << GetName() << "': " << DiagnosticInformation(ex, false);
}
}
}
-std::set<Notification::Ptr> Checkable::GetNotifications(void) const
+std::set<Notification::Ptr> Checkable::GetNotifications() const
{
boost::mutex::scoped_lock lock(m_NotificationMutex);
return m_Notifications;
}
-void Checkable::AddNotification(const Notification::Ptr& notification)
+void Checkable::RegisterNotification(const Notification::Ptr& notification)
{
boost::mutex::scoped_lock lock(m_NotificationMutex);
m_Notifications.insert(notification);
}
-void Checkable::RemoveNotification(const Notification::Ptr& notification)
+void Checkable::UnregisterNotification(const Notification::Ptr& notification)
{
boost::mutex::scoped_lock lock(m_NotificationMutex);
m_Notifications.erase(notification);