Source code for shinken.objects.hostdependency

#!/usr/bin/python

# -*- coding: utf-8 -*-

# Copyright (C) 2009-2014:
#    Gabes Jean, naparuba@gmail.com
#    Gerhard Lausser, Gerhard.Lausser@consol.de
#    Gregory Starck, g.starck@gmail.com
#    Hartmut Goebel, h.goebel@goebel-consult.de
#
# This file is part of Shinken.
#
# Shinken is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# Shinken 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 Affero General Public License for more details.
#
# You should have received a copy of the GNU Affero General Public License
# along with Shinken.  If not, see <http://www.gnu.org/licenses/>.

from item import Item, Items

from shinken.property import BoolProp, StringProp, ListProp
from shinken.log import logger


[docs]class Hostdependency(Item): id = 0 my_type = 'hostdependency' # F is dep of D # host_name Host B # service_description Service D # dependent_host_name Host C # dependent_service_description Service F # execution_failure_criteria o # notification_failure_criteria w,u # inherits_parent 1 # dependency_period 24x7 properties = Item.properties.copy() properties.update({ 'dependent_host_name': StringProp(), 'dependent_hostgroup_name': StringProp(default=''), 'host_name': StringProp(), 'hostgroup_name': StringProp(default=''), 'inherits_parent': BoolProp(default=False), 'execution_failure_criteria': ListProp(default=['n'], split_on_coma=True), 'notification_failure_criteria': ListProp(default=['n'], split_on_coma=True), 'dependency_period': StringProp(default='') }) # Give a nice name output, for debugging purpose # (debugging happens more often than expected...)
[docs] def get_name(self): dependent_host_name = 'unknown' if getattr(self, 'dependent_host_name', None): dependent_host_name = getattr( getattr(self, 'dependent_host_name'), 'host_name', 'unknown' ) host_name = 'unknown' if getattr(self, 'host_name', None): host_name = getattr(getattr(self, 'host_name'), 'host_name', 'unknown') return dependent_host_name + '/' + host_name
[docs]class Hostdependencies(Items): inner_class = Hostdependency # use for know what is in items
[docs] def delete_hostsdep_by_id(self, ids): for id in ids: del self[id] # We create new hostdep if necessary (host groups and co)
[docs] def explode(self, hostgroups): # The "old" dependencies will be removed. All dependencies with # more than one host or a host group will be in it hstdep_to_remove = [] # Then for every host create a copy of the dependency with just the host # because we are adding services, we can't just loop in it hostdeps = self.items.keys() for id in hostdeps: hd = self.items[id] # We explode first the dependent (son) part dephnames = [] if hasattr(hd, 'dependent_hostgroup_name'): dephg_names = [n.strip() for n in hd.dependent_hostgroup_name.split(',')] for dephg_name in dephg_names: dephg = hostgroups.find_by_name(dephg_name) if dephg is None: err = "ERROR: the hostdependency got " \ "an unknown dependent_hostgroup_name '%s'" % dephg_name hd.configuration_errors.append(err) continue dephnames.extend([m.strip() for m in dephg.members]) if hasattr(hd, 'dependent_host_name'): dephnames.extend([n.strip() for n in hd.dependent_host_name.split(',')]) # Ok, and now the father part :) hnames = [] if hasattr(hd, 'hostgroup_name'): hg_names = [n.strip() for n in hd.hostgroup_name.split(',')] for hg_name in hg_names: hg = hostgroups.find_by_name(hg_name) if hg is None: err = "ERROR: the hostdependency got" \ " an unknown hostgroup_name '%s'" % hg_name hd.configuration_errors.append(err) continue hnames.extend([m.strip() for m in hg.members]) if hasattr(hd, 'host_name'): hnames.extend([n.strip() for n in hd.host_name.split(',')]) # Loop over all sons and fathers to get S*F host deps for dephname in dephnames: dephname = dephname.strip() for hname in hnames: new_hd = hd.copy() new_hd.dependent_host_name = dephname new_hd.host_name = hname self.add_item(new_hd) hstdep_to_remove.append(id) self.delete_hostsdep_by_id(hstdep_to_remove)
[docs] def linkify(self, hosts, timeperiods): self.linkify_hd_by_h(hosts) self.linkify_hd_by_tp(timeperiods) self.linkify_h_by_hd()
[docs] def linkify_hd_by_h(self, hosts): for hd in self: try: h_name = hd.host_name dh_name = hd.dependent_host_name h = hosts.find_by_name(h_name) if h is None: err = "Error: the host dependency got a bad host_name definition '%s'" % h_name hd.configuration_errors.append(err) dh = hosts.find_by_name(dh_name) if dh is None: err = "Error: the host dependency got " \ "a bad dependent_host_name definition '%s'" % dh_name hd.configuration_errors.append(err) hd.host_name = h hd.dependent_host_name = dh except AttributeError, exp: err = "Error: the host dependency miss a property '%s'" % exp hd.configuration_errors.append(err) # We just search for each hostdep the id of the host # and replace the name by the id
[docs] def linkify_hd_by_tp(self, timeperiods): for hd in self: try: tp_name = hd.dependency_period tp = timeperiods.find_by_name(tp_name) hd.dependency_period = tp except AttributeError, exp: logger.error("[hostdependency] fail to linkify by timeperiod: %s", exp) # We backport host dep to host. So HD is not need anymore
[docs] def linkify_h_by_hd(self): for hd in self: # if the host dep conf is bad, pass this one if getattr(hd, 'host_name', None) is None or\ getattr(hd, 'dependent_host_name', None) is None: continue # Ok, link! depdt_hname = hd.dependent_host_name dp = getattr(hd, 'dependency_period', None) depdt_hname.add_host_act_dependency( hd.host_name, hd.notification_failure_criteria, dp, hd.inherits_parent ) depdt_hname.add_host_chk_dependency( hd.host_name, hd.execution_failure_criteria, dp, hd.inherits_parent )
[docs] def is_correct(self): r = super(Hostdependencies, self).is_correct() return r and self.no_loop_in_parents("host_name", "dependent_host_name")
Read the Docs v: latest
Versions
latest
stable
branch-1.4
2.4.1
2.2
2.0.3
1.4.2
Downloads
pdf
htmlzip
epub
On Read the Docs
Project Home
Builds

Free document hosting provided by Read the Docs.