/usr/lib/python2.7/dist-packages/shinken/arbiterlink.py is in shinken-common 1.4-2.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 | #!/usr/bin/env python
# -*- coding: utf-8 -*-
#
# Copyright (C) 2009-2012:
# 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/>.
import socket
from shinken.satellitelink import SatelliteLink, SatelliteLinks
from shinken.property import BoolProp, IntegerProp, StringProp, ListProp
import shinken.pyro_wrapper as pyro
Pyro = pyro.Pyro
from shinken.log import logger
""" TODO: Add some comment about this class for the doc"""
class ArbiterLink(SatelliteLink):
id = 0
my_type = 'arbiter'
properties = SatelliteLink.properties.copy()
properties.update({
'arbiter_name': StringProp(),
'host_name': StringProp(default=socket.gethostname()),
'port': IntegerProp(default='7770'),
})
def get_name(self):
return self.arbiter_name
def get_config(self):
return self.con.get_config()
# Check is required when prop are set:
# contacts OR contactgroups is need
def is_correct(self):
state = True
cls = self.__class__
for prop, entry in cls.properties.items():
if not hasattr(self, prop) and entry.required:
# This should raise an error afterwards?
# Log the issue
logger.warning("%s arbiterlink is missing %s property" % (self.get_name(), prop))
self.debug("%s arbiterlink is missing %s property" % (self.get_name(), prop))
state = False # Bad boy...
return state
# Look for ourself as an arbiter. If we search for a specific arbiter name, go forit
# If not look be our fqdn name, or if not, our hostname
def is_me(self, lookup_name):
logger.info("And arbiter is launched with the hostname:%s from an arbiter point of view of addr:%s" % (self.host_name, socket.getfqdn()))
if lookup_name:
return lookup_name == self.get_name()
else:
return self.host_name == socket.getfqdn() or self.host_name == socket.gethostname()
def give_satellite_cfg(self):
return {'port': self.port, 'address': self.address, 'name': self.arbiter_name}
def do_not_run(self):
if self.con is None:
self.create_connection()
try:
self.con.do_not_run()
return True
except Pyro.errors.URIError, exp:
self.con = None
return False
except Pyro.errors.ProtocolError, exp:
self.con = None
return False
def get_satellite_list(self, daemon_type):
if self.con is None:
self.create_connection()
try:
r = self.con.get_satellite_list(daemon_type)
return r
except Pyro.errors.URIError, exp:
self.con = None
return []
except Pyro.errors.ProtocolError, exp:
self.con = None
return []
def get_satellite_status(self, daemon_type, name):
if self.con is None:
self.create_connection()
try:
r = self.con.get_satellite_status(daemon_type, name)
return r
except Pyro.errors.URIError, exp:
self.con = None
return {}
except Pyro.errors.ProtocolError, exp:
self.con = None
return {}
def get_all_states(self):
if self.con is None:
self.create_connection()
try:
r = self.con.get_all_states()
return r
except Pyro.errors.URIError, exp:
self.con = None
return None
except Pyro.errors.ProtocolError, exp:
self.con = None
return None
def get_objects_properties(self, table, *properties):
if self.con is None:
self.create_connection()
try:
r = self.con.get_objects_properties(table, *properties)
return r
except Pyro.errors.URIError, exp:
self.con = None
return None
except Pyro.errors.ProtocolError, exp:
self.con = None
return None
class ArbiterLinks(SatelliteLinks):
name_property = "name"
inner_class = ArbiterLink
# We must have a realm property, so we find our realm
def linkify(self, modules):
self.linkify_s_by_plug(modules)
|