/mandos/trunk

# -*- mode: python; after-save-hook: (lambda () (let ((command (if (fboundp 'file-local-name) (file-local-name (buffer-file-name)) (or (file-remote-p (buffer-file-name) 'localname) (buffer-file-name))))) (if (= (progn (if (get-buffer "*Test*") (kill-buffer "*Test*")) (process-file-shell-command (format "%s --check" (shell-quote-argument command)) nil "*Test*")) 0) (let ((w (get-buffer-window "*Test*"))) (if w (delete-window w))) (progn (with-current-buffer "*Test*" (compilation-mode)) (display-buffer "*Test*" '(display-buffer-in-side-window)))))); coding: utf-8 -*-

#

# Mandos server - give out binary blobs to connecting clients.

 

if sys.version_info.major == 2:

    __metaclass__ = type

 

# Show warnings by default

if not sys.warnoptions:

            # No value found

            SO_BINDTODEVICE = None

 

if sys.version_info < (3, 2):

    configparser.Configparser = configparser.SafeConfigParser

 

stored_state_file = "clients.pickle"

 

logger = logging.getLogger()

            output = subprocess.check_output(["gpgconf"])

            for line in output.splitlines():

                name, text, path = line.split(b":")

                    self.gpg = path

                    break

        except OSError as e:

                          '--force-mdc',

                          '--quiet']

        # Only GPG version 1 has the --no-use-agent option.

            self.gnupgargs.append("--no-use-agent")

 

    def __enter__(self):

        # Read return code from connection (see call_pipe)

        returncode = connection.recv()

        connection.close()

        self.checker_callback_tag = None

        self.checker = None

 

                kwargs=popen_args)

            self.checker.start()

            self.checker_callback_tag = GLib.io_add_watch(

                self.checker_callback, pipe[0], command)

        # Re-run this periodically if run by GLib.timeout_add

        return True

                raise ValueError("Byte arrays not supported for non-"

                                 "'ay' signature {!r}"

                                 .format(prop._dbus_signature))

        prop(value)

 

    @dbus.service.method(dbus.PROPERTIES_IFACE,

    def add_pipe(self, parent_pipe, proc):

        # Call "handle_ipc" for both data and EOF events

        GLib.io_add_watch(

            functools.partial(self.handle_ipc,

                              parent_pipe=parent_pipe,

                              proc=proc))

                return False

 

            GLib.io_add_watch(

                functools.partial(self.handle_ipc,

                                  parent_pipe=parent_pipe,

                                  proc=proc,

def rfc3339_duration_to_delta(duration):

    """Parse an RFC 3339 "duration" and return a datetime.timedelta

 

    """

 

    # Parsing an RFC 3339 duration with regular expressions is not

def string_to_delta(interval):

    """Parse a string and return a datetime.timedelta

 

    """

 

    try:

                             if isinstance(s, bytes)

                             else s) for s in

                            value["client_structure"]]

                            if isinstance(value[k], bytes):

                                value[k] = value[k].decode("utf-8")

                        if "key_id" not in value:

                        for key, value in

                        bytes_old_client_settings.items()}

                    del bytes_old_client_settings

                    for value in old_client_settings.values():

            os.remove(stored_state_path)

        except IOError as e:

            if e.errno == errno.ENOENT:

                sys.exit(1)

            # End of Avahi example code

 

 

        logger.debug("Starting main loop")

        main_loop.run()