2012-05-10 12:06:41 +02:00
|
|
|
/******************************************************************************
|
|
|
|
* Icinga 2 *
|
2013-09-25 07:43:57 +02:00
|
|
|
* Copyright (C) 2012-2013 Icinga Development Team (http://www.icinga.org/) *
|
2012-05-10 12:06:41 +02:00
|
|
|
* *
|
|
|
|
* 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 *
|
2012-05-11 13:33:57 +02:00
|
|
|
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA. *
|
2012-05-10 12:06:41 +02:00
|
|
|
******************************************************************************/
|
|
|
|
|
2013-03-17 20:19:29 +01:00
|
|
|
#include "icinga/icingaapplication.h"
|
2013-03-16 21:18:53 +01:00
|
|
|
#include "base/dynamictype.h"
|
|
|
|
#include "base/logger_fwd.h"
|
|
|
|
#include "base/objectlock.h"
|
2013-03-22 14:40:55 +01:00
|
|
|
#include "base/convert.h"
|
2013-08-28 08:18:58 +02:00
|
|
|
#include "base/debug.h"
|
|
|
|
#include "base/utility.h"
|
2013-03-18 11:02:18 +01:00
|
|
|
#include "base/timer.h"
|
2013-09-10 16:03:36 +02:00
|
|
|
#include "base/scriptvariable.h"
|
2013-10-08 12:37:21 +02:00
|
|
|
#include "base/initialize.h"
|
2013-03-16 21:18:53 +01:00
|
|
|
#include <boost/smart_ptr/make_shared.hpp>
|
2012-03-31 16:29:53 +02:00
|
|
|
|
2012-12-04 08:42:24 +01:00
|
|
|
using namespace icinga;
|
|
|
|
|
2013-03-18 11:02:18 +01:00
|
|
|
static Timer::Ptr l_RetentionTimer;
|
|
|
|
|
2013-03-01 12:07:52 +01:00
|
|
|
REGISTER_TYPE(IcingaApplication);
|
2013-10-08 12:37:21 +02:00
|
|
|
INITIALIZE_ONCE(IcingaApplication, &IcingaApplication::StaticInitialize);
|
2012-12-04 08:42:24 +01:00
|
|
|
|
2012-04-01 20:04:30 +02:00
|
|
|
#ifndef _WIN32
|
2012-04-01 19:45:30 +02:00
|
|
|
# include "icinga-version.h"
|
|
|
|
# define ICINGA_VERSION GIT_MESSAGE
|
|
|
|
#endif /* _WIN32 */
|
|
|
|
|
2013-10-08 12:37:21 +02:00
|
|
|
void IcingaApplication::StaticInitialize(void)
|
2013-10-08 11:57:35 +02:00
|
|
|
{
|
2013-10-08 12:37:21 +02:00
|
|
|
ScriptVariable::Set("IcingaEnableNotifications", true);
|
|
|
|
ScriptVariable::Set("IcingaEnableEventHandlers", true);
|
|
|
|
ScriptVariable::Set("IcingaEnableFlapping", true);
|
|
|
|
ScriptVariable::Set("IcingaEnableChecks", true);
|
|
|
|
ScriptVariable::Set("IcingaEnablePerfdata", true);
|
2013-10-08 11:57:35 +02:00
|
|
|
}
|
|
|
|
|
2012-05-15 16:24:04 +02:00
|
|
|
/**
|
|
|
|
* The entry point for the Icinga application.
|
|
|
|
*
|
|
|
|
* @returns An exit status.
|
|
|
|
*/
|
2013-02-02 23:22:27 +01:00
|
|
|
int IcingaApplication::Main(void)
|
2012-03-31 16:29:53 +02:00
|
|
|
{
|
2013-03-16 21:18:53 +01:00
|
|
|
Log(LogDebug, "icinga", "In IcingaApplication::Main()");
|
2012-04-01 20:04:30 +02:00
|
|
|
|
2012-08-03 18:17:47 +02:00
|
|
|
m_StartTime = Utility::GetTime();
|
2012-06-27 23:38:50 +02:00
|
|
|
|
2012-08-05 03:10:53 +02:00
|
|
|
/* periodically dump the program state */
|
2013-03-18 11:02:18 +01:00
|
|
|
l_RetentionTimer = boost::make_shared<Timer>();
|
|
|
|
l_RetentionTimer->SetInterval(300);
|
|
|
|
l_RetentionTimer->OnTimerExpired.connect(boost::bind(&IcingaApplication::DumpProgramState, this));
|
|
|
|
l_RetentionTimer->Start();
|
2012-08-05 03:10:53 +02:00
|
|
|
|
2012-03-31 16:29:53 +02:00
|
|
|
RunEventLoop();
|
|
|
|
|
2013-03-16 21:18:53 +01:00
|
|
|
Log(LogInformation, "icinga", "Icinga has shut down.");
|
2012-07-24 15:38:19 +02:00
|
|
|
|
2012-04-02 13:09:33 +02:00
|
|
|
return EXIT_SUCCESS;
|
|
|
|
}
|
|
|
|
|
2013-02-24 01:10:34 +01:00
|
|
|
void IcingaApplication::OnShutdown(void)
|
|
|
|
{
|
2013-03-07 16:00:10 +01:00
|
|
|
ASSERT(!OwnsLock());
|
2013-03-02 09:07:47 +01:00
|
|
|
|
|
|
|
{
|
|
|
|
ObjectLock olock(this);
|
2013-03-18 11:02:18 +01:00
|
|
|
l_RetentionTimer->Stop();
|
2013-03-02 09:07:47 +01:00
|
|
|
}
|
2013-02-24 01:10:34 +01:00
|
|
|
|
|
|
|
DumpProgramState();
|
|
|
|
}
|
|
|
|
|
|
|
|
void IcingaApplication::DumpProgramState(void)
|
|
|
|
{
|
2012-08-07 14:17:36 +02:00
|
|
|
DynamicObject::DumpObjects(GetStatePath());
|
2012-07-24 13:13:02 +02:00
|
|
|
}
|
|
|
|
|
2012-06-27 18:43:34 +02:00
|
|
|
IcingaApplication::Ptr IcingaApplication::GetInstance(void)
|
|
|
|
{
|
|
|
|
return static_pointer_cast<IcingaApplication>(Application::GetInstance());
|
|
|
|
}
|
|
|
|
|
2012-07-13 11:29:23 +02:00
|
|
|
Dictionary::Ptr IcingaApplication::GetMacros(void) const
|
|
|
|
{
|
2013-09-10 16:03:36 +02:00
|
|
|
return ScriptVariable::Get("IcingaMacros");
|
2012-07-13 11:29:23 +02:00
|
|
|
}
|
|
|
|
|
2012-08-03 18:17:47 +02:00
|
|
|
double IcingaApplication::GetStartTime(void) const
|
2012-06-27 23:38:50 +02:00
|
|
|
{
|
2013-03-02 09:07:47 +01:00
|
|
|
ObjectLock olock(this);
|
|
|
|
|
2012-06-27 23:38:50 +02:00
|
|
|
return m_StartTime;
|
|
|
|
}
|
2012-09-03 10:28:14 +02:00
|
|
|
|
2013-04-16 10:55:23 +02:00
|
|
|
bool IcingaApplication::ResolveMacro(const String& macro, const Dictionary::Ptr&, String *result) const
|
2013-02-24 01:10:34 +01:00
|
|
|
{
|
2013-02-28 10:27:33 +01:00
|
|
|
double now = Utility::GetTime();
|
|
|
|
|
2013-03-22 14:40:55 +01:00
|
|
|
if (macro == "TIMET") {
|
|
|
|
*result = Convert::ToString((long)now);
|
|
|
|
return true;
|
|
|
|
} else if (macro == "LONGDATETIME") {
|
|
|
|
*result = Utility::FormatDateTime("%Y-%m-%d %H:%M:%S %z", now);
|
|
|
|
return true;
|
|
|
|
} else if (macro == "SHORTDATETIME") {
|
|
|
|
*result = Utility::FormatDateTime("%Y-%m-%d %H:%M:%S", now);
|
|
|
|
return true;
|
|
|
|
} else if (macro == "DATE") {
|
|
|
|
*result = Utility::FormatDateTime("%Y-%m-%d", now);
|
|
|
|
return true;
|
|
|
|
} else if (macro == "TIME") {
|
|
|
|
*result = Utility::FormatDateTime("%H:%M:%S %z", now);
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
Dictionary::Ptr macros = GetMacros();
|
|
|
|
|
|
|
|
if (macros && macros->Contains(macro)) {
|
|
|
|
*result = macros->Get(macro);
|
|
|
|
return true;
|
|
|
|
}
|
2013-02-24 01:10:34 +01:00
|
|
|
|
2013-03-22 14:40:55 +01:00
|
|
|
return false;
|
2013-02-24 01:10:34 +01:00
|
|
|
}
|
2013-10-08 11:57:35 +02:00
|
|
|
|
|
|
|
bool IcingaApplication::GetEnableNotifications(void) const
|
|
|
|
{
|
|
|
|
if (!m_OverrideEnableNotifications.IsEmpty())
|
|
|
|
return m_OverrideEnableNotifications;
|
|
|
|
else
|
2013-10-08 12:22:16 +02:00
|
|
|
return ScriptVariable::Get("IcingaEnableNotifications");
|
2013-10-08 11:57:35 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
void IcingaApplication::SetEnableNotifications(bool enabled)
|
|
|
|
{
|
|
|
|
m_OverrideEnableNotifications = enabled;
|
|
|
|
}
|
|
|
|
|
|
|
|
void IcingaApplication::ClearEnableNotifications(void)
|
|
|
|
{
|
|
|
|
m_OverrideEnableNotifications = Empty;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool IcingaApplication::GetEnableEventHandlers(void) const
|
|
|
|
{
|
|
|
|
if (!m_OverrideEnableEventHandlers.IsEmpty())
|
|
|
|
return m_OverrideEnableEventHandlers;
|
|
|
|
else
|
2013-10-08 12:22:16 +02:00
|
|
|
return ScriptVariable::Get("IcingaEnableEventHandlers");
|
2013-10-08 11:57:35 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
void IcingaApplication::SetEnableEventHandlers(bool enabled)
|
|
|
|
{
|
|
|
|
m_OverrideEnableEventHandlers = enabled;
|
|
|
|
}
|
|
|
|
|
|
|
|
void IcingaApplication::ClearEnableEventHandlers(void)
|
|
|
|
{
|
|
|
|
m_OverrideEnableEventHandlers = Empty;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool IcingaApplication::GetEnableFlapping(void) const
|
|
|
|
{
|
|
|
|
if (!m_OverrideEnableFlapping.IsEmpty())
|
|
|
|
return m_OverrideEnableFlapping;
|
|
|
|
else
|
2013-10-08 12:22:16 +02:00
|
|
|
return ScriptVariable::Get("IcingaEnableFlapping");
|
2013-10-08 11:57:35 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
void IcingaApplication::SetEnableFlapping(bool enabled)
|
|
|
|
{
|
|
|
|
m_OverrideEnableFlapping = enabled;
|
|
|
|
}
|
|
|
|
|
|
|
|
void IcingaApplication::ClearEnableFlapping(void)
|
|
|
|
{
|
|
|
|
m_OverrideEnableFlapping = Empty;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool IcingaApplication::GetEnableChecks(void) const
|
|
|
|
{
|
|
|
|
if (!m_OverrideEnableChecks.IsEmpty())
|
|
|
|
return m_OverrideEnableChecks;
|
|
|
|
else
|
2013-10-08 12:22:16 +02:00
|
|
|
return ScriptVariable::Get("IcingaEnableChecks");
|
2013-10-08 11:57:35 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
void IcingaApplication::SetEnableChecks(bool enabled)
|
|
|
|
{
|
|
|
|
m_OverrideEnableChecks = enabled;
|
|
|
|
}
|
|
|
|
|
|
|
|
void IcingaApplication::ClearEnableChecks(void)
|
|
|
|
{
|
|
|
|
m_OverrideEnableChecks = Empty;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool IcingaApplication::GetEnablePerfdata(void) const
|
|
|
|
{
|
|
|
|
if (!m_OverrideEnablePerfdata.IsEmpty())
|
|
|
|
return m_OverrideEnablePerfdata;
|
|
|
|
else
|
2013-10-08 12:22:16 +02:00
|
|
|
return ScriptVariable::Get("IcingaEnablePerfdata");
|
2013-10-08 11:57:35 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
void IcingaApplication::SetEnablePerfdata(bool enabled)
|
|
|
|
{
|
|
|
|
m_OverrideEnablePerfdata = enabled;
|
|
|
|
}
|
|
|
|
|
|
|
|
void IcingaApplication::ClearEnablePerfdata(void)
|
|
|
|
{
|
|
|
|
m_OverrideEnablePerfdata = Empty;
|
|
|
|
}
|
|
|
|
|
|
|
|
void IcingaApplication::InternalSerialize(const Dictionary::Ptr& bag, int attributeTypes) const
|
|
|
|
{
|
|
|
|
DynamicObject::InternalSerialize(bag, attributeTypes);
|
|
|
|
|
|
|
|
if (attributeTypes & Attribute_State) {
|
|
|
|
bag->Set("override_enable_notifications", m_OverrideEnableNotifications);
|
|
|
|
bag->Set("override_enable_event_handlers", m_OverrideEnableEventHandlers);
|
|
|
|
bag->Set("override_enable_flapping", m_OverrideEnableFlapping);
|
|
|
|
bag->Set("override_enable_checks", m_OverrideEnableChecks);
|
|
|
|
bag->Set("override_enable_perfdata", m_OverrideEnablePerfdata);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void IcingaApplication::InternalDeserialize(const Dictionary::Ptr& bag, int attributeTypes)
|
|
|
|
{
|
|
|
|
DynamicObject::InternalDeserialize(bag, attributeTypes);
|
|
|
|
|
|
|
|
if (attributeTypes & Attribute_State) {
|
|
|
|
m_OverrideEnableNotifications = bag->Get("override_enable_notifications");
|
|
|
|
m_OverrideEnableEventHandlers = bag->Get("override_enable_event_handlers");
|
|
|
|
m_OverrideEnableFlapping = bag->Get("override_enable_flapping");
|
|
|
|
m_OverrideEnableChecks = bag->Get("override_enable_checks");
|
|
|
|
m_OverrideEnablePerfdata = bag->Get("override_enable_perfdata");
|
|
|
|
}
|
|
|
|
}
|