/mandos/release

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

« back to all changes in this revision

Viewing changes to mandos

  • Committer: Teddy Hogeborn
  • Date: 2014-06-07 21:59:20 UTC
  • mto: (237.7.272 trunk)
  • mto: This revision was merged to the branch mainline in revision 317.
  • Revision ID: teddy@recompile.se-20140607215920-r4qkj7ktnjyqmrn5
Make mandos-client use fexecve().

* plugins.d/mandos-client.d (run_network_hooks): Use fexecve().

Show diffs side-by-side

added added

removed removed

Lines of Context:
mandos
11
11
# "AvahiService" class, and some lines in "main".
12
12
# 
13
13
# Everything else is
14
 
# Copyright © 2008-2013 Teddy Hogeborn
15
 
# Copyright © 2008-2013 Björn Påhlsson
 
14
# Copyright © 2008-2014 Teddy Hogeborn
 
15
# Copyright © 2008-2014 Björn Påhlsson
16
16
# 
17
17
# This program is free software: you can redistribute it and/or modify
18
18
# it under the terms of the GNU General Public License as published by
88
88
    except ImportError:
89
89
        SO_BINDTODEVICE = None
90
90
 
91
 
version = "1.6.2"
 
91
version = "1.6.5"
92
92
stored_state_file = "clients.pickle"
93
93
 
94
94
logger = logging.getLogger()
95
 
syslogger = (logging.handlers.SysLogHandler
96
 
             (facility = logging.handlers.SysLogHandler.LOG_DAEMON,
97
 
              address = str("/dev/log")))
 
95
syslogger = None
98
96
 
99
97
try:
100
98
    if_nametoindex = (ctypes.cdll.LoadLibrary
116
114
def initlogger(debug, level=logging.WARNING):
117
115
    """init logger and add loglevel"""
118
116
    
 
117
    syslogger = (logging.handlers.SysLogHandler
 
118
                 (facility =
 
119
                  logging.handlers.SysLogHandler.LOG_DAEMON,
 
120
                  address = str("/dev/log")))
119
121
    syslogger.setFormatter(logging.Formatter
120
122
                           ('Mandos [%(process)d]: %(levelname)s:'
121
123
                            ' %(message)s'))
690
692
        # If a checker exists, make sure it is not a zombie
691
693
        try:
692
694
            pid, status = os.waitpid(self.checker.pid, os.WNOHANG)
693
 
        except (AttributeError, OSError) as error:
694
 
            if (isinstance(error, OSError)
695
 
                and error.errno != errno.ECHILD):
696
 
                raise error
 
695
        except AttributeError:
 
696
            pass
 
697
        except OSError as error:
 
698
            if error.errno != errno.ECHILD:
 
699
                raise
697
700
        else:
698
701
            if pid:
699
702
                logger.warning("Checker was a zombie")
933
936
            # The byte_arrays option is not supported yet on
934
937
            # signatures other than "ay".
935
938
            if prop._dbus_signature != "ay":
936
 
                raise ValueError
 
939
                raise ValueError("Byte arrays not supported for non-"
 
940
                                 "'ay' signature {0!r}"
 
941
                                 .format(prop._dbus_signature))
937
942
            value = dbus.ByteArray(b''.join(chr(byte)
938
943
                                            for byte in value))
939
944
        prop(value)
1347
1352
                                       *args, **kwargs)
1348
1353
    
1349
1354
    def start_checker(self, *args, **kwargs):
1350
 
        old_checker = self.checker
1351
 
        if self.checker is not None:
1352
 
            old_checker_pid = self.checker.pid
1353
 
        else:
1354
 
            old_checker_pid = None
 
1355
        old_checker_pid = getattr(self.checker, "pid", None)
1355
1356
        r = Client.start_checker(self, *args, **kwargs)
1356
1357
        # Only if new checker process was started
1357
1358
        if (self.checker is not None
1702
1703
            logger.debug("Protocol version: %r", line)
1703
1704
            try:
1704
1705
                if int(line.strip().split()[0]) > 1:
1705
 
                    raise RuntimeError
 
1706
                    raise RuntimeError(line)
1706
1707
            except (ValueError, IndexError, RuntimeError) as error:
1707
1708
                logger.error("Unknown protocol version: %s", error)
1708
1709
                return
1915
1916
    
1916
1917
    def add_pipe(self, parent_pipe, proc):
1917
1918
        """Dummy function; override as necessary"""
1918
 
        raise NotImplementedError
 
1919
        raise NotImplementedError()
1919
1920
 
1920
1921
 
1921
1922
class IPv6_TCPServer(MultiprocessingMixInWithPipe,
2258
2259
            else:
2259
2260
                raise ValueError("Unknown suffix {0!r}"
2260
2261
                                 .format(suffix))
2261
 
        except (ValueError, IndexError) as e:
 
2262
        except IndexError as e:
2262
2263
            raise ValueError(*(e.args))
2263
2264
        timevalue += delta
2264
2265
    return timevalue
2340
2341
    
2341
2342
    if options.check:
2342
2343
        import doctest
2343
 
        doctest.testmod()
2344
 
        sys.exit()
 
2344
        fail_count, test_count = doctest.testmod()
 
2345
        sys.exit(os.EX_OK if fail_count == 0 else 1)
2345
2346
    
2346
2347
    # Default values for config file for server-global settings
2347
2348
    server_defaults = { "interface": "",
2481
2482
        os.setuid(uid)
2482
2483
    except OSError as error:
2483
2484
        if error.errno != errno.EPERM:
2484
 
            raise error
 
2485
            raise
2485
2486
    
2486
2487
    if debug:
2487
2488
        # Enable all possible GnuTLS debugging
2792
2793
            else:
2793
2794
                logger.warning("Could not save persistent state:",
2794
2795
                               exc_info=e)
2795
 
                raise e
 
2796
                raise
2796
2797
        
2797
2798
        # Delete all clients, and settings from config
2798
2799
        while tcp_server.clients: