Attachment 314394 Details for Bug 459276 – Temporary workaround (python dbus listener)

Temporary workaround (python dbus listener)

dbus_set_ntp_servers (text/plain), 2.90 KB, created by Anders Blomdell on 2008-08-15 16:20:24 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Anders Blomdell

Created: 2008-08-15 16:20:24 UTC

Size: 2.90 KB

patch

obsolete

>#!/usr/bin/python
>
>import dbus
>import dbus.glib
>import dbus.service
>import gobject
>import re
>import os
>import sys
>import syslog
>
>class LogDevice:
>    def __init__(self, facility):
>        self.line = ''
>        self.facility = facility
>        
>    def write(self, s):
>        self.line += s
>        if '\n' in self.line:
>            syslog.syslog(self.facility, self.line)
>            self.line = ''
>
>
>def daemonize():
>    try:
>        pid = os.fork()
>    except OSError, e:
>        raise Exception, "%s [%d]" % (e.strerror, e.errno)
>    
>    if (pid != 0):
>        os._exit(0) # Exit parent
>
>    # When we get here we are first child
>    os.setsid()
>
>    try:
>        pid = os.fork()        # Fork a second child.
>    except OSError, e:
>        raise Exception, "%s [%d]" % (e.strerror, e.errno)
>
>    if (pid != 0):
>        os._exit(0)            # Exit first child
>
>    # When we qet here we are second child
>    os.chdir("/")
>
>    #maxfd = resource.getrlimit(resource.RLIMIT_NOFILE)[1]
>    #if (maxfd == resource.RLIM_INFINITY):
>    #    maxfd = MAXFD
>  
>    # Iterate through and close all file descriptors.
>    # for fd in range(0, maxfd):
>    #   try:
>    #      os.close(fd)
>    #   except OSError:   # ERROR, fd wasn't open to begin with (ignored)
>    #      pass
>
>    dev_null = os.open("/dev/null", os.O_RDWR)
>    os.dup2(dev_null, 0)
>    os.dup2(dev_null, 1)
>    os.dup2(dev_null, 2)
>    os.close(dev_null)
>
>    sys.stdout = LogDevice(syslog.LOG_DAEMON | syslog.LOG_WARNING)
>    sys.stderr = LogDevice(syslog.LOG_DAEMON | syslog.LOG_ERR)
>    return 0
>
>def set_ntp_servers(arg):
>    # Transform byte array to strings
>    dict = {}
>    for key in arg:
>        value = "".join(map(lambda x: str(x), arg[key]))
>        dict[key] = value
>
>    # Handle message
>    if dict.has_key("new_ntp_servers"):
>        old_servers = []
>        new_servers = dict["new_ntp_servers"].split(" ")
>        new_servers.sort()
>        old = open("/etc/ntp.conf")
>        new = open("/etc/ntp.conf.new", "w")
>        for l in old:
>            m = re.match("^\s*server\s+(\S+)", l)
>            if m:
>                old_servers.append(m.group(1))
>            else:
>                new.write(l)
>        for s in new_servers:
>            new.write("server %s\n" % s)
>        new.close()
>        old.close()
>
>        old_servers.sort()
>        if new_servers == old_servers:
>            os.unlink("/etc/ntp.conf")
>            os.link("/etc/ntp.conf.new", "/etc/ntp.conf")
>            os.unlink("/etc/ntp.conf.new")
>            os.system("/sbin/service ntpd condrestart")
>        
>    
>if __name__ == "__main__":
>    daemonize()
>    bus = dbus.SystemBus()
>    bus.add_signal_receiver(set_ntp_servers,
>                            path="/",
>                            bus_name="org.freedesktop.nm_dhcp_client",
>                            dbus_interface="org.freedesktop.nm_dhcp_client",
>                            signal_name="Event")
>
>    loop = gobject.MainLoop()
>    loop.run()

Actions: View

Attachments on bug 459276: 314394 | 314469 | 314470 | 354878 | 357182