119
119
self.domain = domain
121
121
self.rename_count = 0
122
self.max_renames = max_renames
123
122
def rename(self):
124
123
"""Derived from the Avahi example code"""
125
124
if self.rename_count >= self.max_renames:
126
125
logger.critical(u"No suitable service name found after %i"
127
126
u" retries, exiting.", rename_count)
128
127
raise AvahiServiceError("Too many renames")
129
self.name = server.GetAlternativeServiceName(self.name)
130
logger.info(u"Changing name to %r ...", str(self.name))
128
name = server.GetAlternativeServiceName(name)
129
logger.error(u"Changing name to %r ...", name)
131
130
syslogger.setFormatter(logging.Formatter\
132
131
('Mandos (%s): %%(levelname)s:'
133
' %%(message)s' % self.name))
132
' %%(message)s' % name))
136
135
self.rename_count += 1
338
337
logger.info(u"Starting checker %r for %s",
339
338
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.)
344
339
self.checker = subprocess.Popen(command,
346
341
shell=True, cwd="/")
347
342
self.checker_callback_tag = gobject.child_watch_add\
348
343
(self.checker.pid,
349
344
self.checker_callback)
350
except OSError, error:
345
except subprocess.OSError, error:
351
346
logger.error(u"Failed to start subprocess: %s",
353
348
# Re-run this periodically if run by gobject.timeout_add
410
405
gnutls.library.functions.gnutls_openpgp_crt_import\
411
406
(crt, ctypes.byref(datum),
412
407
gnutls.library.constants.GNUTLS_OPENPGP_FMT_RAW)
413
# Verify the self signature in the key
414
crtverify = ctypes.c_uint();
415
gnutls.library.functions.gnutls_openpgp_crt_verify_self\
416
(crt, ctypes.c_uint(0), ctypes.byref(crtverify))
418
gnutls.library.functions.gnutls_openpgp_crt_deinit(crt)
419
raise gnutls.errors.CertificateSecurityError("Verify failed")
420
408
# New buffer for the fingerprint
421
409
buffer = ctypes.create_string_buffer(20)
422
410
buffer_length = ctypes.c_size_t()
574
562
datetime.timedelta(1)
575
563
>>> string_to_delta(u'1w')
576
564
datetime.timedelta(7)
577
>>> string_to_delta('5m 30s')
578
datetime.timedelta(0, 330)
580
timevalue = datetime.timedelta(0)
581
for s in interval.split():
583
suffix=unicode(s[-1])
586
delta = datetime.timedelta(value)
588
delta = datetime.timedelta(0, value)
590
delta = datetime.timedelta(0, 0, 0, 0, value)
592
delta = datetime.timedelta(0, 0, 0, 0, 0, value)
594
delta = datetime.timedelta(0, 0, 0, 0, 0, 0, value)
597
except (ValueError, IndexError):
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)
581
except (ValueError, IndexError):
603
586
def server_state_changed(state):
716
699
server_config = ConfigParser.SafeConfigParser(server_defaults)
717
700
del server_defaults
718
701
server_config.read(os.path.join(options.configdir, "mandos.conf"))
702
server_section = "server"
719
703
# Convert the SafeConfigParser object to a dict
720
server_settings = server_config.defaults()
704
server_settings = dict(server_config.items(server_section))
721
705
# Use getboolean on the boolean config option
722
706
server_settings["debug"] = server_config.getboolean\
707
(server_section, "debug")
724
708
del server_config
726
710
# Override the settings from the config file with command line
748
732
# Parse config file with clients
749
733
client_defaults = { "timeout": "1h",
750
734
"interval": "5m",
751
"checker": "fping -q -- %(host)s",
735
"checker": "fping -q -- %%(host)s",
754
737
client_config = ConfigParser.SafeConfigParser(client_defaults)
755
738
client_config.read(os.path.join(server_settings["configdir"],
789
772
logger.critical(u"No clients defined")
793
# Redirect stdin so all checkers get /dev/null
794
null = os.open(os.path.devnull, os.O_NOCTTY | os.O_RDWR)
795
os.dup2(null, sys.stdin.fileno())
800
776
logger.removeHandler(console)
801
# Close all input and output, do double fork, etc.
804
779
pidfilename = "/var/run/mandos/mandos.pid"