/mandos/trunk

To get this branch, use:
bzr branch http://bzr.recompile.se/loggerhead/mandos/trunk

« back to all changes in this revision

Viewing changes to mandos

  • Committer: Teddy Hogeborn
  • Date: 2008-08-22 00:16:20 UTC
  • mfrom: (24.1.57 mandos)
  • Revision ID: teddy@fukt.bsnet.se-20080822001620-vxpn1evy0t0kyvj0
* clients.conf ([DEFAULT]/checker): Update to new default value.

* mandos (Client.start_checker): Bug fix: OSError, not
                                 subprocess.OSError.
  (main): Use "fping -q -- %(host)s" instead of "fping -q --
          %%(host)s" as default value for "checker".  Always redirect
          stdin to be from /dev/null, even if in debug mode.

* mandos-clients.conf.xml (DESCRIPTION): Improved wording and refer to
                                         the EXPANSION section.
  (OPTIONS): Added synopsis and improved wording for "checker",
             "fingerprint", and "secret".  Refer to the RUNTIME
             EXPANSION section for the "checker" option.
  (EXAMPLE): Update to new default value for "checker".

* mandos-keygen (trap): Split lines and add "set +e".

Show diffs side-by-side

added added

removed removed

Lines of Context:
mandos
6
6
# This program is partly derived from an example program for an Avahi
7
7
# service publisher, downloaded from
8
8
# <http://avahi.org/wiki/PythonPublishExample>.  This includes the
9
 
# following functions: "AvahiService.add", "AvahiService.remove",
10
 
# "server_state_changed", "entry_group_state_changed", and some lines
11
 
# in "main".
 
9
# methods "add" and "remove" in the "AvahiService" class, the
 
10
# "server_state_changed" and "entry_group_state_changed" functions,
 
11
# and some lines in "main".
12
12
# 
13
13
# Everything else is
14
14
# Copyright © 2007-2008 Teddy Hogeborn & Björn Påhlsson
61
61
from dbus.mainloop.glib import DBusGMainLoop
62
62
import ctypes
63
63
 
64
 
# Brief description of the operation of this program:
65
 
# 
66
 
# This server announces itself as a Zeroconf service.  Connecting
67
 
# clients use the TLS protocol, with the unusual quirk that this
68
 
# server program acts as a TLS "client" while a connecting client acts
69
 
# as a TLS "server".  The client (acting as a TLS "server") must
70
 
# supply an OpenPGP certificate, and the fingerprint of this
71
 
# certificate is used by this server to look up (in a list read from a
72
 
# file at start time) which binary blob to give the client.  No other
73
 
# authentication or authorization is done by this server.
74
 
 
 
64
version = "1.0"
75
65
 
76
66
logger = logging.Logger('mandos')
77
67
syslogger = logging.handlers.SysLogHandler\
78
 
            (facility = logging.handlers.SysLogHandler.LOG_DAEMON)
 
68
            (facility = logging.handlers.SysLogHandler.LOG_DAEMON,
 
69
             address = "/dev/log")
79
70
syslogger.setFormatter(logging.Formatter\
80
 
                        ('%(levelname)s: %(message)s'))
 
71
                        ('Mandos: %(levelname)s: %(message)s'))
81
72
logger.addHandler(syslogger)
82
 
del syslogger
83
73
 
 
74
console = logging.StreamHandler()
 
75
console.setFormatter(logging.Formatter('%(name)s: %(levelname)s:'
 
76
                                       ' %(message)s'))
 
77
logger.addHandler(console)
84
78
 
85
79
class AvahiError(Exception):
86
80
    def __init__(self, value):
96
90
 
97
91
 
98
92
class AvahiService(object):
99
 
    """
 
93
    """An Avahi (Zeroconf) service.
 
94
    Attributes:
100
95
    interface: integer; avahi.IF_UNSPEC or an interface index.
101
96
               Used to optionally bind to the specified interface.
102
 
    name = string; Example: "Mandos"
103
 
    type = string; Example: "_mandos._tcp".
104
 
                   See <http://www.dns-sd.org/ServiceTypes.html>
105
 
    port = integer; what port to announce
106
 
    TXT = list of strings; TXT record for the service
107
 
    domain = string; Domain to publish on, default to .local if empty.
108
 
    host = string; Host to publish records for, default to localhost
109
 
                   if empty.
110
 
    max_renames = integer; maximum number of renames
111
 
    rename_count = integer; counter so we only rename after collisions
112
 
                   a sensible number of times
 
97
    name: string; Example: 'Mandos'
 
98
    type: string; Example: '_mandos._tcp'.
 
99
                  See <http://www.dns-sd.org/ServiceTypes.html>
 
100
    port: integer; what port to announce
 
101
    TXT: list of strings; TXT record for the service
 
102
    domain: string; Domain to publish on, default to .local if empty.
 
103
    host: string; Host to publish records for, default is localhost
 
104
    max_renames: integer; maximum number of renames
 
105
    rename_count: integer; counter so we only rename after collisions
 
106
                  a sensible number of times
113
107
    """
114
108
    def __init__(self, interface = avahi.IF_UNSPEC, name = None,
115
109
                 type = None, port = None, TXT = None, domain = "",
116
 
                 host = "", max_renames = 12):
117
 
        """An Avahi (Zeroconf) service. """
 
110
                 host = "", max_renames = 32768):
118
111
        self.interface = interface
119
112
        self.name = name
120
113
        self.type = type
126
119
        self.domain = domain
127
120
        self.host = host
128
121
        self.rename_count = 0
 
122
        self.max_renames = max_renames
129
123
    def rename(self):
130
124
        """Derived from the Avahi example code"""
131
125
        if self.rename_count >= self.max_renames:
132
126
            logger.critical(u"No suitable service name found after %i"
133
127
                            u" retries, exiting.", rename_count)
134
128
            raise AvahiServiceError("Too many renames")
135
 
        name = server.GetAlternativeServiceName(name)
136
 
        logger.notice(u"Changing name to %r ...", name)
 
129
        self.name = server.GetAlternativeServiceName(self.name)
 
130
        logger.info(u"Changing name to %r ...", str(self.name))
 
131
        syslogger.setFormatter(logging.Formatter\
 
132
                               ('Mandos (%s): %%(levelname)s:'
 
133
                               ' %%(message)s' % self.name))
137
134
        self.remove()
138
135
        self.add()
139
136
        self.rename_count += 1
175
172
    fingerprint: string (40 or 32 hexadecimal digits); used to
176
173
                 uniquely identify the client
177
174
    secret:    bytestring; sent verbatim (over TLS) to client
178
 
    fqdn:      string (FQDN); available for use by the checker command
 
175
    host:      string; available for use by the checker command
179
176
    created:   datetime.datetime(); object creation, not client host
180
177
    last_checked_ok: datetime.datetime() or None if not yet checked OK
181
178
    timeout:   datetime.timedelta(); How long from last_checked_ok
221
218
    interval = property(lambda self: self._interval,
222
219
                        _set_interval)
223
220
    del _set_interval
224
 
    def __init__(self, name=None, stop_hook=None, fingerprint=None,
225
 
                 secret=None, secfile=None, fqdn=None, timeout=None,
226
 
                 interval=-1, checker=None):
227
 
        """Note: the 'checker' argument sets the 'checker_command'
228
 
        attribute and not the 'checker' attribute.."""
 
221
    def __init__(self, name = None, stop_hook=None, config={}):
 
222
        """Note: the 'checker' key in 'config' sets the
 
223
        'checker_command' attribute and *not* the 'checker'
 
224
        attribute."""
229
225
        self.name = name
230
226
        logger.debug(u"Creating client %r", self.name)
231
 
        # Uppercase and remove spaces from fingerprint
232
 
        # for later comparison purposes with return value of
233
 
        # the fingerprint() function
234
 
        self.fingerprint = fingerprint.upper().replace(u" ", u"")
 
227
        # Uppercase and remove spaces from fingerprint for later
 
228
        # comparison purposes with return value from the fingerprint()
 
229
        # function
 
230
        self.fingerprint = config["fingerprint"].upper()\
 
231
                           .replace(u" ", u"")
235
232
        logger.debug(u"  Fingerprint: %s", self.fingerprint)
236
 
        if secret:
237
 
            self.secret = secret.decode(u"base64")
238
 
        elif secfile:
239
 
            sf = open(secfile)
 
233
        if "secret" in config:
 
234
            self.secret = config["secret"].decode(u"base64")
 
235
        elif "secfile" in config:
 
236
            sf = open(config["secfile"])
240
237
            self.secret = sf.read()
241
238
            sf.close()
242
239
        else:
243
240
            raise TypeError(u"No secret or secfile for client %s"
244
241
                            % self.name)
245
 
        self.fqdn = fqdn
 
242
        self.host = config.get("host", "")
246
243
        self.created = datetime.datetime.now()
247
244
        self.last_checked_ok = None
248
 
        self.timeout = string_to_delta(timeout)
249
 
        self.interval = string_to_delta(interval)
 
245
        self.timeout = string_to_delta(config["timeout"])
 
246
        self.interval = string_to_delta(config["interval"])
250
247
        self.stop_hook = stop_hook
251
248
        self.checker = None
252
249
        self.checker_initiator_tag = None
253
250
        self.stop_initiator_tag = None
254
251
        self.checker_callback_tag = None
255
 
        self.check_command = checker
 
252
        self.check_command = config["checker"]
256
253
    def start(self):
257
254
        """Start this client's checker and timeout hooks"""
258
255
        # Schedule a new checker to be started an 'interval' from now,
271
268
        The possibility that a client might be restarted is left open,
272
269
        but not currently used."""
273
270
        # If this client doesn't have a secret, it is already stopped.
274
 
        if self.secret:
275
 
            logger.debug(u"Stopping client %s", self.name)
 
271
        if hasattr(self, "secret") and self.secret:
 
272
            logger.info(u"Stopping client %s", self.name)
276
273
            self.secret = None
277
274
        else:
278
275
            return False
297
294
        self.checker = None
298
295
        if os.WIFEXITED(condition) \
299
296
               and (os.WEXITSTATUS(condition) == 0):
300
 
            logger.debug(u"Checker for %(name)s succeeded",
301
 
                         vars(self))
 
297
            logger.info(u"Checker for %(name)s succeeded",
 
298
                        vars(self))
302
299
            self.last_checked_ok = now
303
300
            gobject.source_remove(self.stop_initiator_tag)
304
301
            self.stop_initiator_tag = gobject.timeout_add\
308
305
            logger.warning(u"Checker for %(name)s crashed?",
309
306
                           vars(self))
310
307
        else:
311
 
            logger.debug(u"Checker for %(name)s failed",
312
 
                         vars(self))
 
308
            logger.info(u"Checker for %(name)s failed",
 
309
                        vars(self))
313
310
    def start_checker(self):
314
311
        """Start a new checker subprocess if one is not running.
315
312
        If a checker already exists, leave it running and do
325
322
        if self.checker is None:
326
323
            try:
327
324
                # In case check_command has exactly one % operator
328
 
                command = self.check_command % self.fqdn
 
325
                command = self.check_command % self.host
329
326
            except TypeError:
330
327
                # Escape attributes for the shell
331
328
                escaped_attrs = dict((key, re.escape(str(val)))
338
335
                                 u' %s', self.check_command, error)
339
336
                    return True # Try again later
340
337
            try:
341
 
                logger.debug(u"Starting checker %r for %s",
342
 
                             command, self.name)
 
338
                logger.info(u"Starting checker %r for %s",
 
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.)
343
344
                self.checker = subprocess.Popen(command,
344
345
                                                close_fds=True,
345
346
                                                shell=True, cwd="/")
346
347
                self.checker_callback_tag = gobject.child_watch_add\
347
348
                                            (self.checker.pid,
348
349
                                             self.checker_callback)
349
 
            except subprocess.OSError, error:
 
350
            except OSError, error:
350
351
                logger.error(u"Failed to start subprocess: %s",
351
352
                             error)
352
353
        # Re-run this periodically if run by gobject.timeout_add
358
359
            self.checker_callback_tag = None
359
360
        if getattr(self, "checker", None) is None:
360
361
            return
361
 
        logger.debug("Stopping checker for %(name)s", vars(self))
 
362
        logger.debug(u"Stopping checker for %(name)s", vars(self))
362
363
        try:
363
364
            os.kill(self.checker.pid, signal.SIGTERM)
364
365
            #os.sleep(0.5)
396
397
 
397
398
def fingerprint(openpgp):
398
399
    "Convert an OpenPGP bytestring to a hexdigit fingerprint string"
399
 
    # New empty GnuTLS certificate
400
 
    crt = gnutls.library.types.gnutls_openpgp_crt_t()
401
 
    gnutls.library.functions.gnutls_openpgp_crt_init\
402
 
        (ctypes.byref(crt))
403
400
    # New GnuTLS "datum" with the OpenPGP public key
404
401
    datum = gnutls.library.types.gnutls_datum_t\
405
402
        (ctypes.cast(ctypes.c_char_p(openpgp),
406
403
                     ctypes.POINTER(ctypes.c_ubyte)),
407
404
         ctypes.c_uint(len(openpgp)))
 
405
    # New empty GnuTLS certificate
 
406
    crt = gnutls.library.types.gnutls_openpgp_crt_t()
 
407
    gnutls.library.functions.gnutls_openpgp_crt_init\
 
408
        (ctypes.byref(crt))
408
409
    # Import the OpenPGP public key into the certificate
409
 
    ret = gnutls.library.functions.gnutls_openpgp_crt_import\
410
 
        (crt,
411
 
         ctypes.byref(datum),
412
 
         gnutls.library.constants.GNUTLS_OPENPGP_FMT_RAW)
 
410
    gnutls.library.functions.gnutls_openpgp_crt_import\
 
411
                    (crt, ctypes.byref(datum),
 
412
                     gnutls.library.constants.GNUTLS_OPENPGP_FMT_RAW)
413
413
    # New buffer for the fingerprint
414
414
    buffer = ctypes.create_string_buffer(20)
415
415
    buffer_length = ctypes.c_size_t()
431
431
    Note: This will run in its own forked process."""
432
432
    
433
433
    def handle(self):
434
 
        logger.debug(u"TCP connection from: %s",
 
434
        logger.info(u"TCP connection from: %s",
435
435
                     unicode(self.client_address))
436
436
        session = gnutls.connection.ClientSession\
437
437
                  (self.request, gnutls.connection.X509Credentials())
 
438
        
 
439
        line = self.request.makefile().readline()
 
440
        logger.debug(u"Protocol version: %r", line)
 
441
        try:
 
442
            if int(line.strip().split()[0]) > 1:
 
443
                raise RuntimeError
 
444
        except (ValueError, IndexError, RuntimeError), error:
 
445
            logger.error(u"Unknown protocol version: %s", error)
 
446
            return
 
447
        
438
448
        # Note: gnutls.connection.X509Credentials is really a generic
439
449
        # GnuTLS certificate credentials object so long as no X.509
440
450
        # keys are added to it.  Therefore, we can use it here despite
453
463
        try:
454
464
            session.handshake()
455
465
        except gnutls.errors.GNUTLSError, error:
456
 
            logger.debug(u"Handshake failed: %s", error)
 
466
            logger.warning(u"Handshake failed: %s", error)
457
467
            # Do not run session.bye() here: the session is not
458
468
            # established.  Just abandon the request.
459
469
            return
460
470
        try:
461
471
            fpr = fingerprint(peer_certificate(session))
462
472
        except (TypeError, gnutls.errors.GNUTLSError), error:
463
 
            logger.debug(u"Bad certificate: %s", error)
 
473
            logger.warning(u"Bad certificate: %s", error)
464
474
            session.bye()
465
475
            return
466
476
        logger.debug(u"Fingerprint: %s", fpr)
470
480
                client = c
471
481
                break
472
482
        if not client:
473
 
            logger.debug(u"Client not found for fingerprint: %s", fpr)
 
483
            logger.warning(u"Client not found for fingerprint: %s",
 
484
                           fpr)
474
485
            session.bye()
475
486
            return
476
487
        # Have to check if client.still_valid(), since it is possible
477
488
        # that the client timed out while establishing the GnuTLS
478
489
        # session.
479
490
        if not client.still_valid():
480
 
            logger.debug(u"Client %(name)s is invalid", vars(client))
 
491
            logger.warning(u"Client %(name)s is invalid",
 
492
                           vars(client))
481
493
            session.bye()
482
494
            return
483
495
        sent_size = 0
509
521
        """This overrides the normal server_bind() function
510
522
        to bind to an interface if one was specified, and also NOT to
511
523
        bind to an address or port if they were not specified."""
512
 
        if self.settings["interface"] != avahi.IF_UNSPEC:
 
524
        if self.settings["interface"]:
513
525
            # 25 is from /usr/include/asm-i486/socket.h
514
526
            SO_BINDTODEVICE = getattr(socket, "SO_BINDTODEVICE", 25)
515
527
            try:
518
530
                                       self.settings["interface"])
519
531
            except socket.error, error:
520
532
                if error[0] == errno.EPERM:
521
 
                    logger.warning(u"No permission to"
522
 
                                   u" bind to interface %s",
523
 
                                   self.settings["interface"])
 
533
                    logger.error(u"No permission to"
 
534
                                 u" bind to interface %s",
 
535
                                 self.settings["interface"])
524
536
                else:
525
537
                    raise error
526
538
        # Only bind(2) the socket if we really need to.
529
541
                in6addr_any = "::"
530
542
                self.server_address = (in6addr_any,
531
543
                                       self.server_address[1])
532
 
            elif self.server_address[1] is None:
 
544
            elif not self.server_address[1]:
533
545
                self.server_address = (self.server_address[0],
534
546
                                       0)
 
547
#                 if self.settings["interface"]:
 
548
#                     self.server_address = (self.server_address[0],
 
549
#                                            0, # port
 
550
#                                            0, # flowinfo
 
551
#                                            if_nametoindex
 
552
#                                            (self.settings
 
553
#                                             ["interface"]))
535
554
            return super(type(self), self).server_bind()
536
555
 
537
556
 
548
567
    datetime.timedelta(1)
549
568
    >>> string_to_delta(u'1w')
550
569
    datetime.timedelta(7)
 
570
    >>> string_to_delta('5m 30s')
 
571
    datetime.timedelta(0, 330)
551
572
    """
552
 
    try:
553
 
        suffix=unicode(interval[-1])
554
 
        value=int(interval[:-1])
555
 
        if suffix == u"d":
556
 
            delta = datetime.timedelta(value)
557
 
        elif suffix == u"s":
558
 
            delta = datetime.timedelta(0, value)
559
 
        elif suffix == u"m":
560
 
            delta = datetime.timedelta(0, 0, 0, 0, value)
561
 
        elif suffix == u"h":
562
 
            delta = datetime.timedelta(0, 0, 0, 0, 0, value)
563
 
        elif suffix == u"w":
564
 
            delta = datetime.timedelta(0, 0, 0, 0, 0, 0, value)
565
 
        else:
 
573
    timevalue = datetime.timedelta(0)
 
574
    for s in interval.split():
 
575
        try:
 
576
            suffix=unicode(s[-1])
 
577
            value=int(s[:-1])
 
578
            if suffix == u"d":
 
579
                delta = datetime.timedelta(value)
 
580
            elif suffix == u"s":
 
581
                delta = datetime.timedelta(0, value)
 
582
            elif suffix == u"m":
 
583
                delta = datetime.timedelta(0, 0, 0, 0, value)
 
584
            elif suffix == u"h":
 
585
                delta = datetime.timedelta(0, 0, 0, 0, 0, value)
 
586
            elif suffix == u"w":
 
587
                delta = datetime.timedelta(0, 0, 0, 0, 0, 0, value)
 
588
            else:
 
589
                raise ValueError
 
590
        except (ValueError, IndexError):
566
591
            raise ValueError
567
 
    except (ValueError, IndexError):
568
 
        raise ValueError
569
 
    return delta
 
592
        timevalue += delta
 
593
    return timevalue
570
594
 
571
595
 
572
596
def server_state_changed(state):
573
597
    """Derived from the Avahi example code"""
574
598
    if state == avahi.SERVER_COLLISION:
575
 
        logger.warning(u"Server name collision")
 
599
        logger.error(u"Server name collision")
576
600
        service.remove()
577
601
    elif state == avahi.SERVER_RUNNING:
578
602
        service.add()
592
616
                        unicode(error))
593
617
        raise AvahiGroupError("State changed: %s", str(error))
594
618
 
595
 
def if_nametoindex(interface, _func=[None]):
 
619
def if_nametoindex(interface):
596
620
    """Call the C function if_nametoindex(), or equivalent"""
597
 
    if _func[0] is not None:
598
 
        return _func[0](interface)
 
621
    global if_nametoindex
599
622
    try:
600
623
        if "ctypes.util" not in sys.modules:
601
624
            import ctypes.util
602
 
        while True:
603
 
            try:
604
 
                libc = ctypes.cdll.LoadLibrary\
605
 
                       (ctypes.util.find_library("c"))
606
 
                func[0] = libc.if_nametoindex
607
 
                return _func[0](interface)
608
 
            except IOError, e:
609
 
                if e != errno.EINTR:
610
 
                    raise
 
625
        if_nametoindex = ctypes.cdll.LoadLibrary\
 
626
            (ctypes.util.find_library("c")).if_nametoindex
611
627
    except (OSError, AttributeError):
612
628
        if "struct" not in sys.modules:
613
629
            import struct
614
630
        if "fcntl" not in sys.modules:
615
631
            import fcntl
616
 
        def the_hard_way(interface):
 
632
        def if_nametoindex(interface):
617
633
            "Get an interface index the hard way, i.e. using fcntl()"
618
634
            SIOCGIFINDEX = 0x8933  # From /usr/include/linux/sockios.h
619
635
            s = socket.socket()
622
638
            s.close()
623
639
            interface_index = struct.unpack("I", ifreq[16:20])[0]
624
640
            return interface_index
625
 
        _func[0] = the_hard_way
626
 
        return _func[0](interface)
627
 
 
628
 
 
629
 
def daemon(nochdir, noclose):
 
641
    return if_nametoindex(interface)
 
642
 
 
643
 
 
644
def daemon(nochdir = False, noclose = False):
630
645
    """See daemon(3).  Standard BSD Unix function.
631
646
    This should really exist as os.daemon, but it doesn't (yet)."""
632
647
    if os.fork():
634
649
    os.setsid()
635
650
    if not nochdir:
636
651
        os.chdir("/")
 
652
    if os.fork():
 
653
        sys.exit()
637
654
    if not noclose:
638
655
        # Close all standard open file descriptors
639
656
        null = os.open(os.path.devnull, os.O_NOCTTY | os.O_RDWR)
651
668
    global main_loop_started
652
669
    main_loop_started = False
653
670
    
654
 
    parser = OptionParser()
 
671
    parser = OptionParser(version = "%%prog %s" % version)
655
672
    parser.add_option("-i", "--interface", type="string",
656
673
                      metavar="IF", help="Bind to interface IF")
657
674
    parser.add_option("-a", "--address", type="string",
660
677
                      help="Port number to receive requests on")
661
678
    parser.add_option("--check", action="store_true", default=False,
662
679
                      help="Run self-test")
663
 
    parser.add_option("--debug", action="store_true", default=False,
 
680
    parser.add_option("--debug", action="store_true",
664
681
                      help="Debug mode; run in foreground and log to"
665
682
                      " terminal")
666
683
    parser.add_option("--priority", type="string", help="GnuTLS"
691
708
    # Parse config file for server-global settings
692
709
    server_config = ConfigParser.SafeConfigParser(server_defaults)
693
710
    del server_defaults
694
 
    server_config.read(os.path.join(options.configdir, "server.conf"))
695
 
    server_section = "server"
 
711
    server_config.read(os.path.join(options.configdir, "mandos.conf"))
696
712
    # Convert the SafeConfigParser object to a dict
697
 
    server_settings = dict(server_config.items(server_section))
 
713
    server_settings = server_config.defaults()
698
714
    # Use getboolean on the boolean config option
699
715
    server_settings["debug"] = server_config.getboolean\
700
 
                               (server_section, "debug")
 
716
                               ("DEFAULT", "debug")
701
717
    del server_config
702
 
    if not server_settings["interface"]:
703
 
        server_settings["interface"] = avahi.IF_UNSPEC
704
718
    
705
719
    # Override the settings from the config file with command line
706
720
    # options, if set.
712
726
    del options
713
727
    # Now we have our good server settings in "server_settings"
714
728
    
 
729
    debug = server_settings["debug"]
 
730
    
 
731
    if not debug:
 
732
        syslogger.setLevel(logging.WARNING)
 
733
        console.setLevel(logging.WARNING)
 
734
    
 
735
    if server_settings["servicename"] != "Mandos":
 
736
        syslogger.setFormatter(logging.Formatter\
 
737
                               ('Mandos (%s): %%(levelname)s:'
 
738
                                ' %%(message)s'
 
739
                                % server_settings["servicename"]))
 
740
    
715
741
    # Parse config file with clients
716
742
    client_defaults = { "timeout": "1h",
717
743
                        "interval": "5m",
718
 
                        "checker": "fping -q -- %%(fqdn)s",
 
744
                        "checker": "fping -q -- %(host)s",
 
745
                        "host": "",
719
746
                        }
720
747
    client_config = ConfigParser.SafeConfigParser(client_defaults)
721
748
    client_config.read(os.path.join(server_settings["configdir"],
724
751
    global service
725
752
    service = AvahiService(name = server_settings["servicename"],
726
753
                           type = "_mandos._tcp", );
 
754
    if server_settings["interface"]:
 
755
        service.interface = if_nametoindex(server_settings["interface"])
727
756
    
728
757
    global main_loop
729
758
    global bus
737
766
            avahi.DBUS_INTERFACE_SERVER )
738
767
    # End of Avahi example code
739
768
    
740
 
    debug = server_settings["debug"]
741
 
    
742
 
    if debug:
743
 
        console = logging.StreamHandler()
744
 
        # console.setLevel(logging.DEBUG)
745
 
        console.setFormatter(logging.Formatter\
746
 
                             ('%(levelname)s: %(message)s'))
747
 
        logger.addHandler(console)
748
 
        del console
749
 
    
750
769
    clients = Set()
751
770
    def remove_from_clients(client):
752
771
        clients.remove(client)
753
772
        if not clients:
754
 
            logger.debug(u"No clients left, exiting")
 
773
            logger.critical(u"No clients left, exiting")
755
774
            sys.exit()
756
775
    
757
 
    clients.update(Set(Client(name=section,
 
776
    clients.update(Set(Client(name = section,
758
777
                              stop_hook = remove_from_clients,
759
 
                              **(dict(client_config\
760
 
                                      .items(section))))
 
778
                              config
 
779
                              = dict(client_config.items(section)))
761
780
                       for section in client_config.sections()))
762
 
    
763
 
    if not debug:
764
 
        daemon(False, False)
 
781
    if not clients:
 
782
        logger.critical(u"No clients defined")
 
783
        sys.exit(1)
 
784
    
 
785
    if debug:
 
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())
 
789
        if null > 2:
 
790
            os.close(null)
 
791
    else:
 
792
        # No console logging
 
793
        logger.removeHandler(console)
 
794
        # Close all input and output, do double fork, etc.
 
795
        daemon()
 
796
    
 
797
    pidfilename = "/var/run/mandos/mandos.pid"
 
798
    pid = os.getpid()
 
799
    try:
 
800
        pidfile = open(pidfilename, "w")
 
801
        pidfile.write(str(pid) + "\n")
 
802
        pidfile.close()
 
803
        del pidfile
 
804
    except IOError, err:
 
805
        logger.error(u"Could not write %s file with PID %d",
 
806
                     pidfilename, os.getpid())
765
807
    
766
808
    def cleanup():
767
809
        "Cleanup function; run on exit"
794
836
                                clients=clients)
795
837
    # Find out what port we got
796
838
    service.port = tcp_server.socket.getsockname()[1]
797
 
    logger.debug(u"Now listening on port %d", service.port)
 
839
    logger.info(u"Now listening on address %r, port %d, flowinfo %d,"
 
840
                u" scope_id %d" % tcp_server.socket.getsockname())
798
841
    
799
 
    if not server_settings["interface"]:
800
 
        service.interface = if_nametoindex\
801
 
                            (server_settings["interface"])
 
842
    #service.interface = tcp_server.socket.getsockname()[3]
802
843
    
803
844
    try:
804
845
        # From the Avahi example code
815
856
                             tcp_server.handle_request\
816
857
                             (*args[2:], **kwargs) or True)
817
858
        
818
 
        logger.debug("Starting main loop")
 
859
        logger.debug(u"Starting main loop")
819
860
        main_loop_started = True
820
861
        main_loop.run()
821
862
    except AvahiError, error: