119
119
self.domain = domain
121
121
self.rename_count = 0
122
self.max_renames = max_renames
122
123
def rename(self):
123
124
"""Derived from the Avahi example code"""
124
125
if self.rename_count >= self.max_renames:
125
126
logger.critical(u"No suitable service name found after %i"
126
127
u" retries, exiting.", rename_count)
127
128
raise AvahiServiceError("Too many renames")
128
name = server.GetAlternativeServiceName(name)
129
logger.error(u"Changing name to %r ...", name)
129
self.name = server.GetAlternativeServiceName(self.name)
130
logger.info(u"Changing name to %r ...", str(self.name))
130
131
syslogger.setFormatter(logging.Formatter\
131
132
('Mandos (%s): %%(levelname)s:'
132
' %%(message)s' % name))
133
' %%(message)s' % self.name))
135
136
self.rename_count += 1
337
338
logger.info(u"Starting checker %r for %s",
338
339
command, self.name)
340
# We don't need to redirect stdout and stderr, since
341
# in normal mode, that is already done by daemon(),
342
# and in debug mode we don't want to. (Stdin is
343
# always replaced by /dev/null.)
339
344
self.checker = subprocess.Popen(command,
341
346
shell=True, cwd="/")
342
347
self.checker_callback_tag = gobject.child_watch_add\
343
348
(self.checker.pid,
344
349
self.checker_callback)
345
except subprocess.OSError, error:
350
except OSError, error:
346
351
logger.error(u"Failed to start subprocess: %s",
348
353
# Re-run this periodically if run by gobject.timeout_add
562
567
datetime.timedelta(1)
563
568
>>> string_to_delta(u'1w')
564
569
datetime.timedelta(7)
570
>>> string_to_delta('5m 30s')
571
datetime.timedelta(0, 330)
567
suffix=unicode(interval[-1])
568
value=int(interval[:-1])
570
delta = datetime.timedelta(value)
572
delta = datetime.timedelta(0, value)
574
delta = datetime.timedelta(0, 0, 0, 0, value)
576
delta = datetime.timedelta(0, 0, 0, 0, 0, value)
578
delta = datetime.timedelta(0, 0, 0, 0, 0, 0, value)
573
timevalue = datetime.timedelta(0)
574
for s in interval.split():
576
suffix=unicode(s[-1])
579
delta = datetime.timedelta(value)
581
delta = datetime.timedelta(0, value)
583
delta = datetime.timedelta(0, 0, 0, 0, value)
585
delta = datetime.timedelta(0, 0, 0, 0, 0, value)
587
delta = datetime.timedelta(0, 0, 0, 0, 0, 0, value)
590
except (ValueError, IndexError):
581
except (ValueError, IndexError):
586
596
def server_state_changed(state):
699
709
server_config = ConfigParser.SafeConfigParser(server_defaults)
700
710
del server_defaults
701
711
server_config.read(os.path.join(options.configdir, "mandos.conf"))
702
server_section = "server"
703
712
# Convert the SafeConfigParser object to a dict
704
server_settings = dict(server_config.items(server_section))
713
server_settings = server_config.defaults()
705
714
# Use getboolean on the boolean config option
706
715
server_settings["debug"] = server_config.getboolean\
707
(server_section, "debug")
708
717
del server_config
710
719
# Override the settings from the config file with command line
732
741
# Parse config file with clients
733
742
client_defaults = { "timeout": "1h",
734
743
"interval": "5m",
735
"checker": "fping -q -- %%(host)s",
744
"checker": "fping -q -- %(host)s",
737
747
client_config = ConfigParser.SafeConfigParser(client_defaults)
738
748
client_config.read(os.path.join(server_settings["configdir"],
772
782
logger.critical(u"No clients defined")
786
# Redirect stdin so all checkers get /dev/null
787
null = os.open(os.path.devnull, os.O_NOCTTY | os.O_RDWR)
788
os.dup2(null, sys.stdin.fileno())
776
793
logger.removeHandler(console)
794
# Close all input and output, do double fork, etc.
779
797
pidfilename = "/var/run/mandos/mandos.pid"