asyncore.dispatcher.__init__(self)
self.cycler = cycler
self.create_socket(socket.AF_UNIX, socket.SOCK_STREAM)
- try:
- os.unlink(socket_filename)
- except OSError:
- pass
self.bind(socket_filename)
self.listen(2) # Backlog = 2
def do_server(options, paths):
+ try:
+ sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
+ sock.connect(options.socket_filename)
+ print >>sys.stderr, "Server is already running! Will do nothing"
+ return
+ except:
+ pass
+
+ try:
+ os.unlink(options.socket_filename)
+ except OSError:
+ pass
+
try:
cycler = Cycler()
listener = Listener(options.socket_filename, cycler)
# Make sure that the socket is cleaned up
try:
os.unlink(options.socket_filename)
- except:
+ except OSError:
pass
def do_client(options, args):