1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
|
#!/usr/bin/python
# coding: utf-8
#
# pkgdistcache daemon v0.3.1
# by Alessio Bianchi <venator85@gmail.com>
#
import http.server
import os
import os.path
import signal
import socket
import sys
import avahi
import dbus
import dbus.glib
avahi_service = None
def terminate(signum, frame):
avahi_service.unpublish()
sys.exit(0)
class AvahiPublisher:
# Based on http://avahi.org/wiki/PythonPublishExample
def __init__(self, name, stype, host, port):
self.name = name
self.stype = stype
self.domain = 'local'
self.host = host
self.port = port
self.systemBus = dbus.SystemBus()
self.server = dbus.Interface(
self.systemBus.get_object(
avahi.DBUS_NAME, avahi.DBUS_PATH_SERVER),
avahi.DBUS_INTERFACE_SERVER)
def publish(self):
self.group = dbus.Interface(
self.systemBus.get_object(
avahi.DBUS_NAME, self.server.EntryGroupNew()),
avahi.DBUS_INTERFACE_ENTRY_GROUP)
self.group.AddService(
avahi.IF_UNSPEC, # interface
avahi.PROTO_UNSPEC, # protocol
dbus.UInt32(0), # flags
self.name, self.stype,
self.domain, self.host,
dbus.UInt16(self.port),
avahi.string_array_to_txt_array([]))
self.group.Commit()
def unpublish(self):
self.group.Reset()
class HTTPServerV6(http.server.HTTPServer):
address_family = socket.AF_INET6
def main(args):
# load configuration file
conf_file = '/etc/pkgdistcache.conf'
if os.path.isfile(conf_file):
config = eval(open(conf_file).read())
else:
printerr("Config file " + conf_file + " not found")
return 2
port = config['port']
hostname = socket.gethostname()
global avahi_service
avahi_service = AvahiPublisher(hostname, '_pkgdistcache._tcp', '', port)
avahi_service.publish()
os.chdir('/var/cache/pacman/pkg')
handler = http.server.SimpleHTTPRequestHandler
httpd = HTTPServerV6(('', port), handler)
try:
# Disable useless polling since we never call shutdown
httpd.serve_forever(poll_interval=None)
except KeyboardInterrupt:
avahi_service.unpublish()
return 0
if __name__ == '__main__':
signal.signal(signal.SIGTERM, terminate)
main(sys.argv)
|