]> arthur.barton.de Git - bup.git/blob - cmd/daemon-cmd.py
cmd/daemon: pass extra options along to 'bup server'.
[bup.git] / cmd / daemon-cmd.py
1 #!/usr/bin/env python
2 import sys, getopt, socket, subprocess
3 from bup import options, path
4 from bup.helpers import *
5
6 optspec = """
7 bup daemon [options...] -- [bup-server options...]
8 --
9 l,listen  ip address to listen on, defaults to *
10 p,port    port to listen on, defaults to 1982
11 """
12 o = options.Options(optspec, optfunc=getopt.getopt)
13 (opt, flags, extra) = o.parse(sys.argv[1:])
14
15 host = opt.listen
16 port = opt.port and int(opt.port) or 1982
17
18 import socket
19 import sys
20
21 socks = []
22 e = None
23 for res in socket.getaddrinfo(host, port, socket.AF_UNSPEC,
24                               socket.SOCK_STREAM, 0, socket.AI_PASSIVE):
25     af, socktype, proto, canonname, sa = res
26     try:
27         s = socket.socket(af, socktype, proto)
28     except socket.error, e:
29         continue
30     try:
31         if af == socket.AF_INET6:
32             log("bup daemon: listening on [%s]:%s\n" % sa[:2])
33         else:
34             log("bup daemon: listening on %s:%s\n" % sa[:2])
35         s.bind(sa)
36         s.listen(1)
37     except socket.error, e:
38         s.close()
39         continue
40     socks.append(s)
41
42 if not socks:
43     log('bup daemon: listen socket: %s\n' % e.args[1])
44     sys.exit(1)
45
46 try:
47     while True:
48         [rl,wl,xl] = select.select(socks, [], [], 60)
49         for l in rl:
50             s, src = l.accept()
51             log("Socket accepted connection from %s\n" % (src,))
52             sp = subprocess.Popen([path.exe(), 'mux', '--', 'server'] + extra,
53                                   stdin=os.dup(s.fileno()), stdout=os.dup(s.fileno()))
54             s.close()
55 finally:
56     for l in socks:
57         l.shutdown(socket.SHUT_RDWR)
58         l.close()
59
60 debug1("bup daemon: done")