/****************************************************************************** * Icinga 2 * * Copyright (C) 2012-present 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. * ******************************************************************************/ #include "icinga/dependency.h" #include "icinga/service.h" #include "config/configitembuilder.h" #include "base/initialize.h" #include "base/dynamictype.h" #include "base/convert.h" #include "base/logger_fwd.h" #include "base/context.h" #include using namespace icinga; INITIALIZE_ONCE(&Dependency::RegisterApplyRuleHandler); void Dependency::RegisterApplyRuleHandler(void) { std::vector targets; targets.push_back("Host"); targets.push_back("Service"); ApplyRule::RegisterType("Dependency", targets, &Dependency::EvaluateApplyRules); } void Dependency::EvaluateApplyRule(const Checkable::Ptr& checkable, const ApplyRule& rule) { DebugInfo di = rule.GetDebugInfo(); std::ostringstream msgbuf; msgbuf << "Evaluating 'apply' rule (" << di << ")"; CONTEXT(msgbuf.str()); Host::Ptr host; Service::Ptr service; tie(host, service) = GetHostService(checkable); Dictionary::Ptr locals = make_shared(); locals->Set("host", host); if (service) locals->Set("service", service); if (!rule.EvaluateFilter(locals)) return; std::ostringstream msgbuf2; msgbuf2 << "Applying dependency '" << rule.GetName() << "' to object '" << checkable->GetName() << "' for rule " << di; Log(LogDebug, "icinga", msgbuf2.str()); ConfigItemBuilder::Ptr builder = make_shared(di); builder->SetType("Dependency"); builder->SetName(rule.GetName()); builder->SetScope(rule.GetScope()); builder->AddExpression(make_shared(&AExpression::OpSet, make_shared(&AExpression::OpLiteral, "child_host_name", di), make_shared(&AExpression::OpLiteral, host->GetName(), di), di)); if (service) { builder->AddExpression(make_shared(&AExpression::OpSet, make_shared(&AExpression::OpLiteral, "child_service_name", di), make_shared(&AExpression::OpLiteral, service->GetShortName(), di), di)); } builder->AddExpression(rule.GetExpression()); ConfigItem::Ptr dependencyItem = builder->Compile(); dependencyItem->Register(); DynamicObject::Ptr dobj = dependencyItem->Commit(); dobj->OnConfigLoaded(); } void Dependency::EvaluateApplyRules(const std::vector& rules) { BOOST_FOREACH(const Host::Ptr& host, DynamicType::GetObjects()) { CONTEXT("Evaluating 'apply' rules for host '" + host->GetName() + "'"); BOOST_FOREACH(const ApplyRule& rule, rules) { if (rule.GetTargetType() != "Host") continue; EvaluateApplyRule(host, rule); } } BOOST_FOREACH(const Service::Ptr& service, DynamicType::GetObjects()) { CONTEXT("Evaluating 'apply' rules for Service '" + service->GetName() + "'"); BOOST_FOREACH(const ApplyRule& rule, rules) { if (rule.GetTargetType() != "Service") continue; EvaluateApplyRule(service, rule); } } }