- cycler = Cycler()
- listener = Listener(options.socket_filename, cycler)
- # Initialisation of Cycler delayed so we grab the socket quickly
- cycler.init(options, paths)
- try:
- asyncsched.loop()
- except KeyboardInterrupt:
- print
- cycler.finish()
- finally:
- # Make sure that the socket is cleaned up
- try:
- os.unlink(options.socket_filename)
- except:
- pass
+ sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
+ sock.connect(options.socket_filename)
+ print >>sys.stderr, "Server is already running! Sending exit command."
+ sock = sock.makefile()
+ sock.write("cmd exit\n")
+ sock.close()
+ except Exception, e:
+ pass
+
+ try:
+ os.unlink(options.socket_filename)
+ except OSError:
+ pass
+
+ cycler = Cycler()
+ listener = Listener(options.socket_filename, cycler)
+ # Initialisation of Cycler delayed so we grab the socket quickly
+ cycler.init(options, paths)
+ try:
+ asyncsched.loop()
+ except KeyboardInterrupt:
+ print
+ cycler.finish()