Mercurial > hg
annotate hgext/zeroconf/Zeroconf.py @ 43076:2372284d9457
formatting: blacken the codebase
This is using my patch to black
(https://github.com/psf/black/pull/826) so we don't un-wrap collection
literals.
Done with:
hg files 'set:**.py - mercurial/thirdparty/** - "contrib/python-zstandard/**"' | xargs black -S
# skip-blame mass-reformatting only
# no-check-commit reformats foo_bar functions
Differential Revision: https://phab.mercurial-scm.org/D6971
author | Augie Fackler <augie@google.com> |
---|---|
date | Sun, 06 Oct 2019 09:45:02 -0400 |
parents | 8306b6c29add |
children | 687b865b95ad |
rev | line source |
---|---|
28296
a73394e7b47c
zeroconf: use absolute_import
timeless <timeless@mozdev.org>
parents:
28295
diff
changeset
|
1 from __future__ import absolute_import, print_function |
28295
01815c159856
zeroconf: use print function
timeless <timeless@mozdev.org>
parents:
28249
diff
changeset
|
2 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
3 """ Multicast DNS Service Discovery for Python, v0.12 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
4 Copyright (C) 2003, Paul Scott-Murphy |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
5 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
6 This module provides a framework for the use of DNS Service Discovery |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
7 using IP multicast. It has been tested against the JRendezvous |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
8 implementation from <a href="http://strangeberry.com">StrangeBerry</a>, |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
9 and against the mDNSResponder from Mac OS X 10.3.8. |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
10 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
11 This library is free software; you can redistribute it and/or |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
12 modify it under the terms of the GNU Lesser General Public |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
13 License as published by the Free Software Foundation; either |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
14 version 2.1 of the License, or (at your option) any later version. |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
15 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
16 This library is distributed in the hope that it will be useful, |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
17 but WITHOUT ANY WARRANTY; without even the implied warranty of |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
18 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
19 Lesser General Public License for more details. |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
20 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
21 You should have received a copy of the GNU Lesser General Public |
15782
7de7630053cb
Remove FSF mailing address from GPL headers
Martin Geisler <mg@aragost.com>
parents:
14494
diff
changeset
|
22 License along with this library; if not, see |
7de7630053cb
Remove FSF mailing address from GPL headers
Martin Geisler <mg@aragost.com>
parents:
14494
diff
changeset
|
23 <http://www.gnu.org/licenses/>. |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
24 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
25 """ |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
26 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
27 """0.12 update - allow selection of binding interface |
28298 | 28 typo fix - Thanks A. M. Kuchlingi |
29 removed all use of word 'Rendezvous' - this is an API change""" | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
30 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
31 """0.11 update - correction to comments for addListener method |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
32 support for new record types seen from OS X |
28298 | 33 - IPv6 address |
34 - hostinfo | |
35 ignore unknown DNS record types | |
36 fixes to name decoding | |
28299 | 37 works alongside other processes using port 5353 (e.g. Mac OS X) |
28298 | 38 tested against Mac OS X 10.3.2's mDNSResponder |
39 corrections to removal of list entries for service browser""" | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
40 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
41 """0.10 update - Jonathon Paisley contributed these corrections: |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
42 always multicast replies, even when query is unicast |
28298 | 43 correct a pointer encoding problem |
44 can now write records in any order | |
45 traceback shown on failure | |
46 better TXT record parsing | |
47 server is now separate from name | |
48 can cancel a service browser | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
49 |
28298 | 50 modified some unit tests to accommodate these changes""" |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
51 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
52 """0.09 update - remove all records on service unregistration |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
53 fix DOS security problem with readName""" |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
54 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
55 """0.08 update - changed licensing to LGPL""" |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
56 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
57 """0.07 update - faster shutdown on engine |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
58 pointer encoding of outgoing names |
28298 | 59 ServiceBrowser now works |
60 new unit tests""" | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
61 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
62 """0.06 update - small improvements with unit tests |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
63 added defined exception types |
28298 | 64 new style objects |
65 fixed hostname/interface problem | |
66 fixed socket timeout problem | |
67 fixed addServiceListener() typo bug | |
68 using select() for socket reads | |
69 tested on Debian unstable with Python 2.2.2""" | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
70 |
17424
e7cfe3587ea4
fix trivial spelling errors
Mads Kiilerich <mads@kiilerich.com>
parents:
15782
diff
changeset
|
71 """0.05 update - ensure case insensitivity on domain names |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
72 support for unicast DNS queries""" |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
73 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
74 """0.04 update - added some unit tests |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
75 added __ne__ adjuncts where required |
28298 | 76 ensure names end in '.local.' |
77 timeout on receiving socket for clean shutdown""" | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
78 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
79 __author__ = "Paul Scott-Murphy" |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
80 __email__ = "paul at scott dash murphy dot com" |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
81 __version__ = "0.12" |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
82 |
34447
5385b76fd1fd
zeroconf: do not crash if socket being read is closed by another thread
Jun Wu <quark@fb.com>
parents:
28504
diff
changeset
|
83 import errno |
28422
e2c6092ad422
zeroconf: replace reduce+add with itertools.chain
timeless <timeless@mozdev.org>
parents:
28421
diff
changeset
|
84 import itertools |
28296
a73394e7b47c
zeroconf: use absolute_import
timeless <timeless@mozdev.org>
parents:
28295
diff
changeset
|
85 import select |
a73394e7b47c
zeroconf: use absolute_import
timeless <timeless@mozdev.org>
parents:
28295
diff
changeset
|
86 import socket |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
87 import struct |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
88 import threading |
28296
a73394e7b47c
zeroconf: use absolute_import
timeless <timeless@mozdev.org>
parents:
28295
diff
changeset
|
89 import time |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
90 import traceback |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
91 |
42551
8306b6c29add
py3: hack around inconsistency of type of name passed to DNSQuestion
Pulkit Goyal <7895pulkit@gmail.com>
parents:
42550
diff
changeset
|
92 from mercurial import pycompat |
8306b6c29add
py3: hack around inconsistency of type of name passed to DNSQuestion
Pulkit Goyal <7895pulkit@gmail.com>
parents:
42550
diff
changeset
|
93 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
94 __all__ = ["Zeroconf", "ServiceInfo", "ServiceBrowser"] |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
95 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
96 # hook for threads |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
97 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
98 globals()['_GLOBAL_DONE'] = 0 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
99 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
100 # Some timing constants |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
101 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
102 _UNREGISTER_TIME = 125 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
103 _CHECK_TIME = 175 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
104 _REGISTER_TIME = 225 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
105 _LISTENER_TIME = 200 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
106 _BROWSER_TIME = 500 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
107 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
108 # Some DNS constants |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
109 |
41519
a36f462cf533
zeroconf: Python 3 porting of vendored library
Gregory Szorc <gregory.szorc@gmail.com>
parents:
41365
diff
changeset
|
110 _MDNS_ADDR = r'224.0.0.251' |
28297 | 111 _MDNS_PORT = 5353 |
112 _DNS_PORT = 53 | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
113 _DNS_TTL = 60 * 60 # one hour default TTL |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
114 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
115 _MAX_MSG_TYPICAL = 1460 # unused |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
116 _MAX_MSG_ABSOLUTE = 8972 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
117 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
118 _FLAGS_QR_MASK = 0x8000 # query response mask |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
119 _FLAGS_QR_QUERY = 0x0000 # query |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
120 _FLAGS_QR_RESPONSE = 0x8000 # response |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
121 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
122 _FLAGS_AA = 0x0400 # Authoritative answer |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
123 _FLAGS_TC = 0x0200 # Truncated |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
124 _FLAGS_RD = 0x0100 # Recursion desired |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
125 _FLAGS_RA = 0x8000 # Recursion available |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
126 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
127 _FLAGS_Z = 0x0040 # Zero |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
128 _FLAGS_AD = 0x0020 # Authentic data |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
129 _FLAGS_CD = 0x0010 # Checking disabled |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
130 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
131 _CLASS_IN = 1 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
132 _CLASS_CS = 2 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
133 _CLASS_CH = 3 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
134 _CLASS_HS = 4 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
135 _CLASS_NONE = 254 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
136 _CLASS_ANY = 255 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
137 _CLASS_MASK = 0x7FFF |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
138 _CLASS_UNIQUE = 0x8000 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
139 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
140 _TYPE_A = 1 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
141 _TYPE_NS = 2 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
142 _TYPE_MD = 3 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
143 _TYPE_MF = 4 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
144 _TYPE_CNAME = 5 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
145 _TYPE_SOA = 6 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
146 _TYPE_MB = 7 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
147 _TYPE_MG = 8 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
148 _TYPE_MR = 9 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
149 _TYPE_NULL = 10 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
150 _TYPE_WKS = 11 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
151 _TYPE_PTR = 12 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
152 _TYPE_HINFO = 13 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
153 _TYPE_MINFO = 14 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
154 _TYPE_MX = 15 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
155 _TYPE_TXT = 16 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
156 _TYPE_AAAA = 28 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
157 _TYPE_SRV = 33 |
27637
b502138f5faa
cleanup: remove superfluous space after space after equals (python)
timeless <timeless@mozdev.org>
parents:
17537
diff
changeset
|
158 _TYPE_ANY = 255 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
159 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
160 # Mapping constants to names |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
161 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
162 _CLASSES = { |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
163 _CLASS_IN: "in", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
164 _CLASS_CS: "cs", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
165 _CLASS_CH: "ch", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
166 _CLASS_HS: "hs", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
167 _CLASS_NONE: "none", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
168 _CLASS_ANY: "any", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
169 } |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
170 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
171 _TYPES = { |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
172 _TYPE_A: "a", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
173 _TYPE_NS: "ns", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
174 _TYPE_MD: "md", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
175 _TYPE_MF: "mf", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
176 _TYPE_CNAME: "cname", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
177 _TYPE_SOA: "soa", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
178 _TYPE_MB: "mb", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
179 _TYPE_MG: "mg", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
180 _TYPE_MR: "mr", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
181 _TYPE_NULL: "null", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
182 _TYPE_WKS: "wks", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
183 _TYPE_PTR: "ptr", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
184 _TYPE_HINFO: "hinfo", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
185 _TYPE_MINFO: "minfo", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
186 _TYPE_MX: "mx", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
187 _TYPE_TXT: "txt", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
188 _TYPE_AAAA: "quada", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
189 _TYPE_SRV: "srv", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
190 _TYPE_ANY: "any", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
191 } |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
192 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
193 # utility functions |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
194 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
195 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
196 def currentTimeMillis(): |
28298 | 197 """Current system time in milliseconds""" |
198 return time.time() * 1000 | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
199 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
200 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
201 # Exceptions |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
202 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
203 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
204 class NonLocalNameException(Exception): |
28298 | 205 pass |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
206 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
207 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
208 class NonUniqueNameException(Exception): |
28298 | 209 pass |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
210 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
211 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
212 class NamePartTooLongException(Exception): |
28298 | 213 pass |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
214 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
215 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
216 class AbstractMethodException(Exception): |
28298 | 217 pass |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
218 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
219 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
220 class BadTypeInNameException(Exception): |
28298 | 221 pass |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
222 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
223 |
11435
7c58cde598fe
zeroconf: Use BadDomainName exception instead of string exceptions
Javi Merino <cibervicho@gmail.com>
parents:
10514
diff
changeset
|
224 class BadDomainName(Exception): |
28298 | 225 def __init__(self, pos): |
226 Exception.__init__(self, "at position %s" % pos) | |
11435
7c58cde598fe
zeroconf: Use BadDomainName exception instead of string exceptions
Javi Merino <cibervicho@gmail.com>
parents:
10514
diff
changeset
|
227 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
228 |
11435
7c58cde598fe
zeroconf: Use BadDomainName exception instead of string exceptions
Javi Merino <cibervicho@gmail.com>
parents:
10514
diff
changeset
|
229 class BadDomainNameCircular(BadDomainName): |
28298 | 230 pass |
11435
7c58cde598fe
zeroconf: Use BadDomainName exception instead of string exceptions
Javi Merino <cibervicho@gmail.com>
parents:
10514
diff
changeset
|
231 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
232 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
233 # implementation classes |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
234 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
235 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
236 class DNSEntry(object): |
28298 | 237 """A DNS entry""" |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
238 |
28298 | 239 def __init__(self, name, type, clazz): |
41519
a36f462cf533
zeroconf: Python 3 porting of vendored library
Gregory Szorc <gregory.szorc@gmail.com>
parents:
41365
diff
changeset
|
240 self.key = name.lower() |
28298 | 241 self.name = name |
242 self.type = type | |
243 self.clazz = clazz & _CLASS_MASK | |
244 self.unique = (clazz & _CLASS_UNIQUE) != 0 | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
245 |
28298 | 246 def __eq__(self, other): |
247 """Equality test on name, type, and class""" | |
248 if isinstance(other, DNSEntry): | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
249 return ( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
250 self.name == other.name |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
251 and self.type == other.type |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
252 and self.clazz == other.clazz |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
253 ) |
28298 | 254 return 0 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
255 |
28298 | 256 def __ne__(self, other): |
257 """Non-equality test""" | |
258 return not self.__eq__(other) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
259 |
28298 | 260 def getClazz(self, clazz): |
261 """Class accessor""" | |
262 try: | |
263 return _CLASSES[clazz] | |
264 except KeyError: | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
265 return "?(%s)" % clazz |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
266 |
28298 | 267 def getType(self, type): |
268 """Type accessor""" | |
269 try: | |
270 return _TYPES[type] | |
271 except KeyError: | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
272 return "?(%s)" % type |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
273 |
28298 | 274 def toString(self, hdr, other): |
275 """String representation with additional information""" | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
276 result = "%s[%s,%s" % ( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
277 hdr, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
278 self.getType(self.type), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
279 self.getClazz(self.clazz), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
280 ) |
28298 | 281 if self.unique: |
282 result += "-unique," | |
283 else: | |
284 result += "," | |
285 result += self.name | |
286 if other is not None: | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
287 result += ",%s]" % other |
28298 | 288 else: |
289 result += "]" | |
290 return result | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
291 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
292 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
293 class DNSQuestion(DNSEntry): |
28298 | 294 """A DNS question entry""" |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
295 |
28298 | 296 def __init__(self, name, type, clazz): |
42551
8306b6c29add
py3: hack around inconsistency of type of name passed to DNSQuestion
Pulkit Goyal <7895pulkit@gmail.com>
parents:
42550
diff
changeset
|
297 if pycompat.ispy3 and isinstance(name, str): |
8306b6c29add
py3: hack around inconsistency of type of name passed to DNSQuestion
Pulkit Goyal <7895pulkit@gmail.com>
parents:
42550
diff
changeset
|
298 name = name.encode('ascii') |
28298 | 299 if not name.endswith(".local."): |
300 raise NonLocalNameException(name) | |
301 DNSEntry.__init__(self, name, type, clazz) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
302 |
28298 | 303 def answeredBy(self, rec): |
304 """Returns true if the question is answered by the record""" | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
305 return ( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
306 self.clazz == rec.clazz |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
307 and (self.type == rec.type or self.type == _TYPE_ANY) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
308 and self.name == rec.name |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
309 ) |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
310 |
28298 | 311 def __repr__(self): |
312 """String representation""" | |
313 return DNSEntry.toString(self, "question", None) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
314 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
315 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
316 class DNSRecord(DNSEntry): |
28298 | 317 """A DNS record - like a DNS entry, but has a TTL""" |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
318 |
28298 | 319 def __init__(self, name, type, clazz, ttl): |
320 DNSEntry.__init__(self, name, type, clazz) | |
321 self.ttl = ttl | |
322 self.created = currentTimeMillis() | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
323 |
28298 | 324 def __eq__(self, other): |
325 """Tests equality as per DNSRecord""" | |
326 if isinstance(other, DNSRecord): | |
327 return DNSEntry.__eq__(self, other) | |
328 return 0 | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
329 |
28298 | 330 def suppressedBy(self, msg): |
331 """Returns true if any answer in a message can suffice for the | |
332 information held in this record.""" | |
333 for record in msg.answers: | |
334 if self.suppressedByAnswer(record): | |
335 return 1 | |
336 return 0 | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
337 |
28298 | 338 def suppressedByAnswer(self, other): |
339 """Returns true if another record has same name, type and class, | |
340 and if its TTL is at least half of this record's.""" | |
341 if self == other and other.ttl > (self.ttl / 2): | |
342 return 1 | |
343 return 0 | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
344 |
28298 | 345 def getExpirationTime(self, percent): |
346 """Returns the time at which this record will have expired | |
347 by a certain percentage.""" | |
348 return self.created + (percent * self.ttl * 10) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
349 |
28298 | 350 def getRemainingTTL(self, now): |
351 """Returns the remaining TTL in seconds.""" | |
352 return max(0, (self.getExpirationTime(100) - now) / 1000) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
353 |
28298 | 354 def isExpired(self, now): |
355 """Returns true if this record has expired.""" | |
356 return self.getExpirationTime(100) <= now | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
357 |
28298 | 358 def isStale(self, now): |
359 """Returns true if this record is at least half way expired.""" | |
360 return self.getExpirationTime(50) <= now | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
361 |
28298 | 362 def resetTTL(self, other): |
363 """Sets this record's TTL and created time to that of | |
364 another record.""" | |
365 self.created = other.created | |
366 self.ttl = other.ttl | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
367 |
28298 | 368 def write(self, out): |
369 """Abstract method""" | |
370 raise AbstractMethodException | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
371 |
28298 | 372 def toString(self, other): |
373 """String representation with additional information""" | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
374 arg = "%s/%s,%s" % ( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
375 self.ttl, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
376 self.getRemainingTTL(currentTimeMillis()), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
377 other, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
378 ) |
28298 | 379 return DNSEntry.toString(self, "record", arg) |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
380 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
381 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
382 class DNSAddress(DNSRecord): |
28298 | 383 """A DNS address record""" |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
384 |
28298 | 385 def __init__(self, name, type, clazz, ttl, address): |
386 DNSRecord.__init__(self, name, type, clazz, ttl) | |
387 self.address = address | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
388 |
28298 | 389 def write(self, out): |
390 """Used in constructing an outgoing packet""" | |
391 out.writeString(self.address, len(self.address)) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
392 |
28298 | 393 def __eq__(self, other): |
394 """Tests equality on address""" | |
395 if isinstance(other, DNSAddress): | |
396 return self.address == other.address | |
397 return 0 | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
398 |
28298 | 399 def __repr__(self): |
400 """String representation""" | |
401 try: | |
402 return socket.inet_ntoa(self.address) | |
403 except Exception: | |
404 return self.address | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
405 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
406 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
407 class DNSHinfo(DNSRecord): |
28298 | 408 """A DNS host information record""" |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
409 |
28298 | 410 def __init__(self, name, type, clazz, ttl, cpu, os): |
411 DNSRecord.__init__(self, name, type, clazz, ttl) | |
412 self.cpu = cpu | |
413 self.os = os | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
414 |
28298 | 415 def write(self, out): |
416 """Used in constructing an outgoing packet""" | |
417 out.writeString(self.cpu, len(self.cpu)) | |
418 out.writeString(self.os, len(self.os)) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
419 |
28298 | 420 def __eq__(self, other): |
421 """Tests equality on cpu and os""" | |
422 if isinstance(other, DNSHinfo): | |
423 return self.cpu == other.cpu and self.os == other.os | |
424 return 0 | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
425 |
28298 | 426 def __repr__(self): |
427 """String representation""" | |
428 return self.cpu + " " + self.os | |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
429 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
430 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
431 class DNSPointer(DNSRecord): |
28298 | 432 """A DNS pointer record""" |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
433 |
28298 | 434 def __init__(self, name, type, clazz, ttl, alias): |
435 DNSRecord.__init__(self, name, type, clazz, ttl) | |
436 self.alias = alias | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
437 |
28298 | 438 def write(self, out): |
439 """Used in constructing an outgoing packet""" | |
440 out.writeName(self.alias) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
441 |
28298 | 442 def __eq__(self, other): |
443 """Tests equality on alias""" | |
444 if isinstance(other, DNSPointer): | |
445 return self.alias == other.alias | |
446 return 0 | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
447 |
28298 | 448 def __repr__(self): |
449 """String representation""" | |
450 return self.toString(self.alias) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
451 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
452 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
453 class DNSText(DNSRecord): |
28298 | 454 """A DNS text record""" |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
455 |
28298 | 456 def __init__(self, name, type, clazz, ttl, text): |
457 DNSRecord.__init__(self, name, type, clazz, ttl) | |
458 self.text = text | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
459 |
28298 | 460 def write(self, out): |
461 """Used in constructing an outgoing packet""" | |
462 out.writeString(self.text, len(self.text)) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
463 |
28298 | 464 def __eq__(self, other): |
465 """Tests equality on text""" | |
466 if isinstance(other, DNSText): | |
467 return self.text == other.text | |
468 return 0 | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
469 |
28298 | 470 def __repr__(self): |
471 """String representation""" | |
472 if len(self.text) > 10: | |
473 return self.toString(self.text[:7] + "...") | |
474 else: | |
475 return self.toString(self.text) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
476 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
477 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
478 class DNSService(DNSRecord): |
28298 | 479 """A DNS service record""" |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
480 |
28298 | 481 def __init__(self, name, type, clazz, ttl, priority, weight, port, server): |
482 DNSRecord.__init__(self, name, type, clazz, ttl) | |
483 self.priority = priority | |
484 self.weight = weight | |
485 self.port = port | |
486 self.server = server | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
487 |
28298 | 488 def write(self, out): |
489 """Used in constructing an outgoing packet""" | |
490 out.writeShort(self.priority) | |
491 out.writeShort(self.weight) | |
492 out.writeShort(self.port) | |
493 out.writeName(self.server) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
494 |
28298 | 495 def __eq__(self, other): |
496 """Tests equality on priority, weight, port and server""" | |
497 if isinstance(other, DNSService): | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
498 return ( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
499 self.priority == other.priority |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
500 and self.weight == other.weight |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
501 and self.port == other.port |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
502 and self.server == other.server |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
503 ) |
28298 | 504 return 0 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
505 |
28298 | 506 def __repr__(self): |
507 """String representation""" | |
508 return self.toString("%s:%s" % (self.server, self.port)) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
509 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
510 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
511 class DNSIncoming(object): |
28298 | 512 """Object representation of an incoming DNS packet""" |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
513 |
28298 | 514 def __init__(self, data): |
515 """Constructor from string holding bytes of packet""" | |
516 self.offset = 0 | |
517 self.data = data | |
518 self.questions = [] | |
519 self.answers = [] | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
520 self.numquestions = 0 |
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
521 self.numanswers = 0 |
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
522 self.numauthorities = 0 |
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
523 self.numadditionals = 0 |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
524 |
28298 | 525 self.readHeader() |
526 self.readQuestions() | |
527 self.readOthers() | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
528 |
28298 | 529 def readHeader(self): |
530 """Reads header portion of packet""" | |
531 format = '!HHHHHH' | |
532 length = struct.calcsize(format) | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
533 info = struct.unpack( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
534 format, self.data[self.offset : self.offset + length] |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
535 ) |
28298 | 536 self.offset += length |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
537 |
28298 | 538 self.id = info[0] |
539 self.flags = info[1] | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
540 self.numquestions = info[2] |
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
541 self.numanswers = info[3] |
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
542 self.numauthorities = info[4] |
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
543 self.numadditionals = info[5] |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
544 |
28298 | 545 def readQuestions(self): |
546 """Reads questions section of packet""" | |
547 format = '!HH' | |
548 length = struct.calcsize(format) | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
549 for i in range(0, self.numquestions): |
28298 | 550 name = self.readName() |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
551 info = struct.unpack( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
552 format, self.data[self.offset : self.offset + length] |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
553 ) |
28298 | 554 self.offset += length |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
555 |
28298 | 556 try: |
557 question = DNSQuestion(name, info[0], info[1]) | |
558 self.questions.append(question) | |
559 except NonLocalNameException: | |
560 pass | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
561 |
28298 | 562 def readInt(self): |
563 """Reads an integer from the packet""" | |
564 format = '!I' | |
565 length = struct.calcsize(format) | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
566 info = struct.unpack( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
567 format, self.data[self.offset : self.offset + length] |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
568 ) |
28298 | 569 self.offset += length |
570 return info[0] | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
571 |
28298 | 572 def readCharacterString(self): |
573 """Reads a character string from the packet""" | |
574 length = ord(self.data[self.offset]) | |
575 self.offset += 1 | |
576 return self.readString(length) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
577 |
28298 | 578 def readString(self, len): |
579 """Reads a string of a given length from the packet""" | |
42550
683aeef12830
py3: add r'' prefixes and do ('%d' % int) instead of str(int)
Pulkit Goyal <7895pulkit@gmail.com>
parents:
41519
diff
changeset
|
580 format = '!%ds' % len |
28298 | 581 length = struct.calcsize(format) |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
582 info = struct.unpack( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
583 format, self.data[self.offset : self.offset + length] |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
584 ) |
28298 | 585 self.offset += length |
586 return info[0] | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
587 |
28298 | 588 def readUnsignedShort(self): |
589 """Reads an unsigned short from the packet""" | |
590 format = '!H' | |
591 length = struct.calcsize(format) | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
592 info = struct.unpack( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
593 format, self.data[self.offset : self.offset + length] |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
594 ) |
28298 | 595 self.offset += length |
596 return info[0] | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
597 |
28298 | 598 def readOthers(self): |
28299 | 599 """Reads answers, authorities and additionals section of the packet""" |
28298 | 600 format = '!HHiH' |
601 length = struct.calcsize(format) | |
28504
3c90090320ad
zeroconf: remove leftover camelcase identifier
Martin von Zweigbergk <martinvonz@google.com>
parents:
28422
diff
changeset
|
602 n = self.numanswers + self.numauthorities + self.numadditionals |
28298 | 603 for i in range(0, n): |
604 domain = self.readName() | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
605 info = struct.unpack( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
606 format, self.data[self.offset : self.offset + length] |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
607 ) |
28298 | 608 self.offset += length |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
609 |
28298 | 610 rec = None |
611 if info[0] == _TYPE_A: | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
612 rec = DNSAddress( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
613 domain, info[0], info[1], info[2], self.readString(4) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
614 ) |
28298 | 615 elif info[0] == _TYPE_CNAME or info[0] == _TYPE_PTR: |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
616 rec = DNSPointer( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
617 domain, info[0], info[1], info[2], self.readName() |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
618 ) |
28298 | 619 elif info[0] == _TYPE_TXT: |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
620 rec = DNSText( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
621 domain, info[0], info[1], info[2], self.readString(info[3]) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
622 ) |
28298 | 623 elif info[0] == _TYPE_SRV: |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
624 rec = DNSService( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
625 domain, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
626 info[0], |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
627 info[1], |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
628 info[2], |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
629 self.readUnsignedShort(), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
630 self.readUnsignedShort(), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
631 self.readUnsignedShort(), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
632 self.readName(), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
633 ) |
28298 | 634 elif info[0] == _TYPE_HINFO: |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
635 rec = DNSHinfo( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
636 domain, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
637 info[0], |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
638 info[1], |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
639 info[2], |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
640 self.readCharacterString(), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
641 self.readCharacterString(), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
642 ) |
28298 | 643 elif info[0] == _TYPE_AAAA: |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
644 rec = DNSAddress( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
645 domain, info[0], info[1], info[2], self.readString(16) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
646 ) |
28298 | 647 else: |
648 # Try to ignore types we don't know about | |
649 # this may mean the rest of the name is | |
650 # unable to be parsed, and may show errors | |
651 # so this is left for debugging. New types | |
652 # encountered need to be parsed properly. | |
653 # | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
654 # print "UNKNOWN TYPE = " + str(info[0]) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
655 # raise BadTypeInNameException |
28298 | 656 self.offset += info[3] |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
657 |
28298 | 658 if rec is not None: |
659 self.answers.append(rec) | |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
660 |
28298 | 661 def isQuery(self): |
662 """Returns true if this is a query""" | |
663 return (self.flags & _FLAGS_QR_MASK) == _FLAGS_QR_QUERY | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
664 |
28298 | 665 def isResponse(self): |
666 """Returns true if this is a response""" | |
667 return (self.flags & _FLAGS_QR_MASK) == _FLAGS_QR_RESPONSE | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
668 |
28298 | 669 def readUTF(self, offset, len): |
670 """Reads a UTF-8 string of a given length from the packet""" | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
671 return self.data[offset : offset + len].decode('utf-8') |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
672 |
28298 | 673 def readName(self): |
674 """Reads a domain name from the packet""" | |
42550
683aeef12830
py3: add r'' prefixes and do ('%d' % int) instead of str(int)
Pulkit Goyal <7895pulkit@gmail.com>
parents:
41519
diff
changeset
|
675 result = r'' |
28298 | 676 off = self.offset |
677 next = -1 | |
678 first = off | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
679 |
28298 | 680 while True: |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
681 len = ord(self.data[off : off + 1]) |
28298 | 682 off += 1 |
683 if len == 0: | |
684 break | |
685 t = len & 0xC0 | |
686 if t == 0x00: | |
42550
683aeef12830
py3: add r'' prefixes and do ('%d' % int) instead of str(int)
Pulkit Goyal <7895pulkit@gmail.com>
parents:
41519
diff
changeset
|
687 result = r''.join((result, self.readUTF(off, len) + r'.')) |
28298 | 688 off += len |
689 elif t == 0xC0: | |
690 if next < 0: | |
691 next = off + 1 | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
692 off = ((len & 0x3F) << 8) | ord(self.data[off : off + 1]) |
28298 | 693 if off >= first: |
694 raise BadDomainNameCircular(off) | |
695 first = off | |
696 else: | |
697 raise BadDomainName(off) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
698 |
28298 | 699 if next >= 0: |
700 self.offset = next | |
701 else: | |
702 self.offset = off | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
703 |
28298 | 704 return result |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
705 |
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
706 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
707 class DNSOutgoing(object): |
28298 | 708 """Object representation of an outgoing packet""" |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
709 |
28302
e96a3ae025ed
zeroconf: remove whitespace around = for named parameters
timeless <timeless@mozdev.org>
parents:
28301
diff
changeset
|
710 def __init__(self, flags, multicast=1): |
28298 | 711 self.finished = 0 |
712 self.id = 0 | |
713 self.multicast = multicast | |
714 self.flags = flags | |
715 self.names = {} | |
716 self.data = [] | |
717 self.size = 12 | |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
718 |
28298 | 719 self.questions = [] |
720 self.answers = [] | |
721 self.authorities = [] | |
722 self.additionals = [] | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
723 |
28298 | 724 def addQuestion(self, record): |
725 """Adds a question""" | |
726 self.questions.append(record) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
727 |
28298 | 728 def addAnswer(self, inp, record): |
729 """Adds an answer""" | |
730 if not record.suppressedBy(inp): | |
731 self.addAnswerAtTime(record, 0) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
732 |
28298 | 733 def addAnswerAtTime(self, record, now): |
734 """Adds an answer if if does not expire by a certain time""" | |
735 if record is not None: | |
736 if now == 0 or not record.isExpired(now): | |
737 self.answers.append((record, now)) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
738 |
28298 | 739 def addAuthoritativeAnswer(self, record): |
740 """Adds an authoritative answer""" | |
741 self.authorities.append(record) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
742 |
28298 | 743 def addAdditionalAnswer(self, record): |
744 """Adds an additional answer""" | |
745 self.additionals.append(record) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
746 |
28298 | 747 def writeByte(self, value): |
748 """Writes a single byte to the packet""" | |
749 format = '!c' | |
750 self.data.append(struct.pack(format, chr(value))) | |
751 self.size += 1 | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
752 |
28298 | 753 def insertShort(self, index, value): |
754 """Inserts an unsigned short in a certain position in the packet""" | |
755 format = '!H' | |
756 self.data.insert(index, struct.pack(format, value)) | |
757 self.size += 2 | |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
758 |
28298 | 759 def writeShort(self, value): |
760 """Writes an unsigned short to the packet""" | |
761 format = '!H' | |
762 self.data.append(struct.pack(format, value)) | |
763 self.size += 2 | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
764 |
28298 | 765 def writeInt(self, value): |
766 """Writes an unsigned integer to the packet""" | |
767 format = '!I' | |
768 self.data.append(struct.pack(format, int(value))) | |
769 self.size += 4 | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
770 |
28298 | 771 def writeString(self, value, length): |
772 """Writes a string to the packet""" | |
773 format = '!' + str(length) + 's' | |
774 self.data.append(struct.pack(format, value)) | |
775 self.size += length | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
776 |
28298 | 777 def writeUTF(self, s): |
778 """Writes a UTF-8 string of a given length to the packet""" | |
779 utfstr = s.encode('utf-8') | |
780 length = len(utfstr) | |
781 if length > 64: | |
782 raise NamePartTooLongException | |
783 self.writeByte(length) | |
784 self.writeString(utfstr, length) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
785 |
28298 | 786 def writeName(self, name): |
787 """Writes a domain name to the packet""" | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
788 |
28298 | 789 try: |
790 # Find existing instance of this name in packet | |
791 # | |
792 index = self.names[name] | |
793 except KeyError: | |
794 # No record of this name already, so write it | |
795 # out as normal, recording the location of the name | |
796 # for future pointers to it. | |
797 # | |
798 self.names[name] = self.size | |
799 parts = name.split('.') | |
800 if parts[-1] == '': | |
801 parts = parts[:-1] | |
802 for part in parts: | |
803 self.writeUTF(part) | |
804 self.writeByte(0) | |
805 return | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
806 |
28298 | 807 # An index was found, so write a pointer to it |
808 # | |
809 self.writeByte((index >> 8) | 0xC0) | |
810 self.writeByte(index) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
811 |
28298 | 812 def writeQuestion(self, question): |
813 """Writes a question to the packet""" | |
814 self.writeName(question.name) | |
815 self.writeShort(question.type) | |
816 self.writeShort(question.clazz) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
817 |
28298 | 818 def writeRecord(self, record, now): |
819 """Writes a record (answer, authoritative answer, additional) to | |
820 the packet""" | |
821 self.writeName(record.name) | |
822 self.writeShort(record.type) | |
823 if record.unique and self.multicast: | |
824 self.writeShort(record.clazz | _CLASS_UNIQUE) | |
825 else: | |
826 self.writeShort(record.clazz) | |
827 if now == 0: | |
828 self.writeInt(record.ttl) | |
829 else: | |
830 self.writeInt(record.getRemainingTTL(now)) | |
831 index = len(self.data) | |
832 # Adjust size for the short we will write before this record | |
833 # | |
834 self.size += 2 | |
835 record.write(self) | |
836 self.size -= 2 | |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
837 |
28298 | 838 length = len(''.join(self.data[index:])) |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
839 self.insertShort(index, length) # Here is the short we adjusted for |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
840 |
28298 | 841 def packet(self): |
842 """Returns a string containing the packet's bytes | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
843 |
28298 | 844 No further parts should be added to the packet once this |
845 is done.""" | |
846 if not self.finished: | |
847 self.finished = 1 | |
848 for question in self.questions: | |
849 self.writeQuestion(question) | |
850 for answer, time_ in self.answers: | |
851 self.writeRecord(answer, time_) | |
852 for authority in self.authorities: | |
853 self.writeRecord(authority, 0) | |
854 for additional in self.additionals: | |
855 self.writeRecord(additional, 0) | |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
856 |
28298 | 857 self.insertShort(0, len(self.additionals)) |
858 self.insertShort(0, len(self.authorities)) | |
859 self.insertShort(0, len(self.answers)) | |
860 self.insertShort(0, len(self.questions)) | |
861 self.insertShort(0, self.flags) | |
862 if self.multicast: | |
863 self.insertShort(0, 0) | |
864 else: | |
865 self.insertShort(0, self.id) | |
866 return ''.join(self.data) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
867 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
868 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
869 class DNSCache(object): |
28298 | 870 """A cache of DNS entries""" |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
871 |
28298 | 872 def __init__(self): |
873 self.cache = {} | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
874 |
28298 | 875 def add(self, entry): |
876 """Adds an entry""" | |
877 try: | |
878 list = self.cache[entry.key] | |
879 except KeyError: | |
880 list = self.cache[entry.key] = [] | |
881 list.append(entry) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
882 |
28298 | 883 def remove(self, entry): |
884 """Removes an entry""" | |
885 try: | |
886 list = self.cache[entry.key] | |
887 list.remove(entry) | |
888 except KeyError: | |
889 pass | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
890 |
28298 | 891 def get(self, entry): |
892 """Gets an entry by key. Will return None if there is no | |
893 matching entry.""" | |
894 try: | |
895 list = self.cache[entry.key] | |
896 return list[list.index(entry)] | |
897 except (KeyError, ValueError): | |
898 return None | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
899 |
28298 | 900 def getByDetails(self, name, type, clazz): |
901 """Gets an entry by details. Will return None if there is | |
902 no matching entry.""" | |
903 entry = DNSEntry(name, type, clazz) | |
904 return self.get(entry) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
905 |
28298 | 906 def entriesWithName(self, name): |
907 """Returns a list of entries whose key matches the name.""" | |
908 try: | |
909 return self.cache[name] | |
910 except KeyError: | |
911 return [] | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
912 |
28298 | 913 def entries(self): |
914 """Returns a list of all entries""" | |
915 try: | |
28422
e2c6092ad422
zeroconf: replace reduce+add with itertools.chain
timeless <timeless@mozdev.org>
parents:
28421
diff
changeset
|
916 return list(itertools.chain.from_iterable(self.cache.values())) |
28298 | 917 except Exception: |
918 return [] | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
919 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
920 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
921 class Engine(threading.Thread): |
28298 | 922 """An engine wraps read access to sockets, allowing objects that |
923 need to receive data from sockets to be called back when the | |
924 sockets are ready. | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
925 |
28298 | 926 A reader needs a handle_read() method, which is called when the socket |
927 it is interested in is ready for reading. | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
928 |
28298 | 929 Writers are not implemented here, because we only send short |
930 packets. | |
931 """ | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
932 |
28298 | 933 def __init__(self, zeroconf): |
934 threading.Thread.__init__(self) | |
935 self.zeroconf = zeroconf | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
936 self.readers = {} # maps socket to reader |
28298 | 937 self.timeout = 5 |
938 self.condition = threading.Condition() | |
939 self.start() | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
940 |
28298 | 941 def run(self): |
942 while not globals()['_GLOBAL_DONE']: | |
943 rs = self.getReaders() | |
944 if len(rs) == 0: | |
945 # No sockets to manage, but we wait for the timeout | |
946 # or addition of a socket | |
947 # | |
948 self.condition.acquire() | |
949 self.condition.wait(self.timeout) | |
950 self.condition.release() | |
951 else: | |
952 try: | |
953 rr, wr, er = select.select(rs, [], [], self.timeout) | |
954 for sock in rr: | |
955 try: | |
956 self.readers[sock].handle_read() | |
957 except Exception: | |
958 if not globals()['_GLOBAL_DONE']: | |
959 traceback.print_exc() | |
960 except Exception: | |
961 pass | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
962 |
28298 | 963 def getReaders(self): |
964 self.condition.acquire() | |
965 result = self.readers.keys() | |
966 self.condition.release() | |
967 return result | |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
968 |
28298 | 969 def addReader(self, reader, socket): |
970 self.condition.acquire() | |
971 self.readers[socket] = reader | |
972 self.condition.notify() | |
973 self.condition.release() | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
974 |
28298 | 975 def delReader(self, socket): |
976 self.condition.acquire() | |
28301
fd8a4d2d6541
zeroconf: del is not a function
timeless <timeless@mozdev.org>
parents:
28300
diff
changeset
|
977 del self.readers[socket] |
28298 | 978 self.condition.notify() |
979 self.condition.release() | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
980 |
28298 | 981 def notify(self): |
982 self.condition.acquire() | |
983 self.condition.notify() | |
984 self.condition.release() | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
985 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
986 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
987 class Listener(object): |
28298 | 988 """A Listener is used by this module to listen on the multicast |
989 group to which DNS messages are sent, allowing the implementation | |
990 to cache information as it arrives. | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
991 |
28298 | 992 It requires registration with an Engine object in order to have |
993 the read() method called when a socket is available for reading.""" | |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
994 |
28298 | 995 def __init__(self, zeroconf): |
996 self.zeroconf = zeroconf | |
997 self.zeroconf.engine.addReader(self, self.zeroconf.socket) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
998 |
28298 | 999 def handle_read(self): |
34447
5385b76fd1fd
zeroconf: do not crash if socket being read is closed by another thread
Jun Wu <quark@fb.com>
parents:
28504
diff
changeset
|
1000 sock = self.zeroconf.socket |
5385b76fd1fd
zeroconf: do not crash if socket being read is closed by another thread
Jun Wu <quark@fb.com>
parents:
28504
diff
changeset
|
1001 try: |
5385b76fd1fd
zeroconf: do not crash if socket being read is closed by another thread
Jun Wu <quark@fb.com>
parents:
28504
diff
changeset
|
1002 data, (addr, port) = sock.recvfrom(_MAX_MSG_ABSOLUTE) |
5385b76fd1fd
zeroconf: do not crash if socket being read is closed by another thread
Jun Wu <quark@fb.com>
parents:
28504
diff
changeset
|
1003 except socket.error as e: |
5385b76fd1fd
zeroconf: do not crash if socket being read is closed by another thread
Jun Wu <quark@fb.com>
parents:
28504
diff
changeset
|
1004 if e.errno == errno.EBADF: |
5385b76fd1fd
zeroconf: do not crash if socket being read is closed by another thread
Jun Wu <quark@fb.com>
parents:
28504
diff
changeset
|
1005 # some other thread may close the socket |
5385b76fd1fd
zeroconf: do not crash if socket being read is closed by another thread
Jun Wu <quark@fb.com>
parents:
28504
diff
changeset
|
1006 return |
5385b76fd1fd
zeroconf: do not crash if socket being read is closed by another thread
Jun Wu <quark@fb.com>
parents:
28504
diff
changeset
|
1007 else: |
5385b76fd1fd
zeroconf: do not crash if socket being read is closed by another thread
Jun Wu <quark@fb.com>
parents:
28504
diff
changeset
|
1008 raise |
28298 | 1009 self.data = data |
1010 msg = DNSIncoming(data) | |
1011 if msg.isQuery(): | |
1012 # Always multicast responses | |
1013 # | |
1014 if port == _MDNS_PORT: | |
1015 self.zeroconf.handleQuery(msg, _MDNS_ADDR, _MDNS_PORT) | |
1016 # If it's not a multicast query, reply via unicast | |
1017 # and multicast | |
1018 # | |
1019 elif port == _DNS_PORT: | |
1020 self.zeroconf.handleQuery(msg, addr, port) | |
1021 self.zeroconf.handleQuery(msg, _MDNS_ADDR, _MDNS_PORT) | |
1022 else: | |
1023 self.zeroconf.handleResponse(msg) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1024 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1025 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1026 class Reaper(threading.Thread): |
28298 | 1027 """A Reaper is used by this module to remove cache entries that |
1028 have expired.""" | |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
1029 |
28298 | 1030 def __init__(self, zeroconf): |
1031 threading.Thread.__init__(self) | |
1032 self.zeroconf = zeroconf | |
1033 self.start() | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1034 |
28298 | 1035 def run(self): |
1036 while True: | |
1037 self.zeroconf.wait(10 * 1000) | |
1038 if globals()['_GLOBAL_DONE']: | |
1039 return | |
1040 now = currentTimeMillis() | |
1041 for record in self.zeroconf.cache.entries(): | |
1042 if record.isExpired(now): | |
1043 self.zeroconf.updateRecord(now, record) | |
1044 self.zeroconf.cache.remove(record) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1045 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1046 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1047 class ServiceBrowser(threading.Thread): |
28298 | 1048 """Used to browse for a service of a specific type. |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1049 |
28298 | 1050 The listener object will have its addService() and |
1051 removeService() methods called when this browser | |
1052 discovers changes in the services availability.""" | |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
1053 |
28298 | 1054 def __init__(self, zeroconf, type, listener): |
1055 """Creates a browser for a specific type""" | |
1056 threading.Thread.__init__(self) | |
1057 self.zeroconf = zeroconf | |
1058 self.type = type | |
1059 self.listener = listener | |
1060 self.services = {} | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1061 self.nexttime = currentTimeMillis() |
28298 | 1062 self.delay = _BROWSER_TIME |
1063 self.list = [] | |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
1064 |
28298 | 1065 self.done = 0 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1066 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1067 self.zeroconf.addListener( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1068 self, DNSQuestion(self.type, _TYPE_PTR, _CLASS_IN) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1069 ) |
28298 | 1070 self.start() |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1071 |
28298 | 1072 def updateRecord(self, zeroconf, now, record): |
1073 """Callback invoked by Zeroconf when new information arrives. | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1074 |
28298 | 1075 Updates information required by browser in the Zeroconf cache.""" |
1076 if record.type == _TYPE_PTR and record.name == self.type: | |
1077 expired = record.isExpired(now) | |
1078 try: | |
1079 oldrecord = self.services[record.alias.lower()] | |
1080 if not expired: | |
1081 oldrecord.resetTTL(record) | |
1082 else: | |
28301
fd8a4d2d6541
zeroconf: del is not a function
timeless <timeless@mozdev.org>
parents:
28300
diff
changeset
|
1083 del self.services[record.alias.lower()] |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1084 callback = lambda x: self.listener.removeService( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1085 x, self.type, record.alias |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1086 ) |
28298 | 1087 self.list.append(callback) |
1088 return | |
1089 except Exception: | |
1090 if not expired: | |
1091 self.services[record.alias.lower()] = record | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1092 callback = lambda x: self.listener.addService( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1093 x, self.type, record.alias |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1094 ) |
28298 | 1095 self.list.append(callback) |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1096 |
28298 | 1097 expires = record.getExpirationTime(75) |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1098 if expires < self.nexttime: |
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1099 self.nexttime = expires |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1100 |
28298 | 1101 def cancel(self): |
1102 self.done = 1 | |
1103 self.zeroconf.notifyAll() | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1104 |
28298 | 1105 def run(self): |
1106 while True: | |
1107 event = None | |
1108 now = currentTimeMillis() | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1109 if len(self.list) == 0 and self.nexttime > now: |
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1110 self.zeroconf.wait(self.nexttime - now) |
28298 | 1111 if globals()['_GLOBAL_DONE'] or self.done: |
1112 return | |
1113 now = currentTimeMillis() | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1114 |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1115 if self.nexttime <= now: |
28298 | 1116 out = DNSOutgoing(_FLAGS_QR_QUERY) |
1117 out.addQuestion(DNSQuestion(self.type, _TYPE_PTR, _CLASS_IN)) | |
1118 for record in self.services.values(): | |
1119 if not record.isExpired(now): | |
1120 out.addAnswerAtTime(record, now) | |
1121 self.zeroconf.send(out) | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1122 self.nexttime = now + self.delay |
28298 | 1123 self.delay = min(20 * 1000, self.delay * 2) |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1124 |
28298 | 1125 if len(self.list) > 0: |
1126 event = self.list.pop(0) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1127 |
28298 | 1128 if event is not None: |
1129 event(self.zeroconf) | |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
1130 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1131 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1132 class ServiceInfo(object): |
28298 | 1133 """Service information""" |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
1134 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1135 def __init__( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1136 self, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1137 type, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1138 name, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1139 address=None, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1140 port=None, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1141 weight=0, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1142 priority=0, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1143 properties=None, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1144 server=None, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1145 ): |
28298 | 1146 """Create a service description. |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1147 |
28298 | 1148 type: fully qualified service type name |
1149 name: fully qualified service name | |
1150 address: IP address as unsigned short, network byte order | |
1151 port: port that the service runs on | |
1152 weight: weight of the service | |
1153 priority: priority of the service | |
28299 | 1154 properties: dictionary of properties (or a string holding the bytes for |
1155 the text field) | |
28298 | 1156 server: fully qualified name for service host (defaults to name)""" |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1157 |
28298 | 1158 if not name.endswith(type): |
1159 raise BadTypeInNameException | |
1160 self.type = type | |
1161 self.name = name | |
1162 self.address = address | |
1163 self.port = port | |
1164 self.weight = weight | |
1165 self.priority = priority | |
1166 if server: | |
1167 self.server = server | |
1168 else: | |
1169 self.server = name | |
1170 self.setProperties(properties) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1171 |
28298 | 1172 def setProperties(self, properties): |
1173 """Sets properties and text of this info from a dictionary""" | |
1174 if isinstance(properties, dict): | |
1175 self.properties = properties | |
1176 list = [] | |
1177 result = '' | |
1178 for key in properties: | |
1179 value = properties[key] | |
1180 if value is None: | |
1181 suffix = '' | |
1182 elif isinstance(value, str): | |
1183 suffix = value | |
1184 elif isinstance(value, int): | |
1185 if value: | |
1186 suffix = 'true' | |
1187 else: | |
1188 suffix = 'false' | |
1189 else: | |
1190 suffix = '' | |
1191 list.append('='.join((key, suffix))) | |
1192 for item in list: | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1193 result = ''.join( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1194 (result, struct.pack('!c', chr(len(item))), item) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1195 ) |
28298 | 1196 self.text = result |
1197 else: | |
1198 self.text = properties | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1199 |
28298 | 1200 def setText(self, text): |
1201 """Sets properties and text given a text field""" | |
1202 self.text = text | |
1203 try: | |
1204 result = {} | |
1205 end = len(text) | |
1206 index = 0 | |
1207 strs = [] | |
1208 while index < end: | |
1209 length = ord(text[index]) | |
1210 index += 1 | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1211 strs.append(text[index : index + length]) |
28298 | 1212 index += length |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
1213 |
28298 | 1214 for s in strs: |
1215 eindex = s.find('=') | |
1216 if eindex == -1: | |
1217 # No equals sign at all | |
1218 key = s | |
1219 value = 0 | |
1220 else: | |
1221 key = s[:eindex] | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1222 value = s[eindex + 1 :] |
28298 | 1223 if value == 'true': |
1224 value = 1 | |
1225 elif value == 'false' or not value: | |
1226 value = 0 | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1227 |
28298 | 1228 # Only update non-existent properties |
28420
d03b7800672c
zeroconf: compare singleton using is
timeless <timeless@mozdev.org>
parents:
28419
diff
changeset
|
1229 if key and result.get(key) is None: |
28298 | 1230 result[key] = value |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1231 |
28298 | 1232 self.properties = result |
1233 except Exception: | |
1234 traceback.print_exc() | |
1235 self.properties = None | |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
1236 |
28298 | 1237 def getType(self): |
1238 """Type accessor""" | |
1239 return self.type | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1240 |
28298 | 1241 def getName(self): |
1242 """Name accessor""" | |
1243 if self.type is not None and self.name.endswith("." + self.type): | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1244 return self.name[: len(self.name) - len(self.type) - 1] |
28298 | 1245 return self.name |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1246 |
28298 | 1247 def getAddress(self): |
1248 """Address accessor""" | |
1249 return self.address | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1250 |
28298 | 1251 def getPort(self): |
1252 """Port accessor""" | |
1253 return self.port | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1254 |
28298 | 1255 def getPriority(self): |
1256 """Priority accessor""" | |
1257 return self.priority | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1258 |
28298 | 1259 def getWeight(self): |
1260 """Weight accessor""" | |
1261 return self.weight | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1262 |
28298 | 1263 def getProperties(self): |
1264 """Properties accessor""" | |
1265 return self.properties | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1266 |
28298 | 1267 def getText(self): |
1268 """Text accessor""" | |
1269 return self.text | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1270 |
28298 | 1271 def getServer(self): |
1272 """Server accessor""" | |
1273 return self.server | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1274 |
28298 | 1275 def updateRecord(self, zeroconf, now, record): |
1276 """Updates service information from a DNS record""" | |
1277 if record is not None and not record.isExpired(now): | |
1278 if record.type == _TYPE_A: | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1279 # if record.name == self.name: |
28298 | 1280 if record.name == self.server: |
1281 self.address = record.address | |
1282 elif record.type == _TYPE_SRV: | |
1283 if record.name == self.name: | |
1284 self.server = record.server | |
1285 self.port = record.port | |
1286 self.weight = record.weight | |
1287 self.priority = record.priority | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1288 # self.address = None |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1289 self.updateRecord( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1290 zeroconf, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1291 now, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1292 zeroconf.cache.getByDetails( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1293 self.server, _TYPE_A, _CLASS_IN |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1294 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1295 ) |
28298 | 1296 elif record.type == _TYPE_TXT: |
1297 if record.name == self.name: | |
1298 self.setText(record.text) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1299 |
28298 | 1300 def request(self, zeroconf, timeout): |
1301 """Returns true if the service could be discovered on the | |
1302 network, and updates this object with details discovered. | |
1303 """ | |
1304 now = currentTimeMillis() | |
1305 delay = _LISTENER_TIME | |
1306 next = now + delay | |
1307 last = now + timeout | |
1308 try: | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1309 zeroconf.addListener( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1310 self, DNSQuestion(self.name, _TYPE_ANY, _CLASS_IN) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1311 ) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1312 while ( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1313 self.server is None or self.address is None or self.text is None |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1314 ): |
28298 | 1315 if last <= now: |
1316 return 0 | |
1317 if next <= now: | |
1318 out = DNSOutgoing(_FLAGS_QR_QUERY) | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1319 out.addQuestion( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1320 DNSQuestion(self.name, _TYPE_SRV, _CLASS_IN) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1321 ) |
28299 | 1322 out.addAnswerAtTime( |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1323 zeroconf.cache.getByDetails( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1324 self.name, _TYPE_SRV, _CLASS_IN |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1325 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1326 now, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1327 ) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1328 out.addQuestion( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1329 DNSQuestion(self.name, _TYPE_TXT, _CLASS_IN) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1330 ) |
28299 | 1331 out.addAnswerAtTime( |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1332 zeroconf.cache.getByDetails( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1333 self.name, _TYPE_TXT, _CLASS_IN |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1334 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1335 now, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1336 ) |
28298 | 1337 if self.server is not None: |
28299 | 1338 out.addQuestion( |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1339 DNSQuestion(self.server, _TYPE_A, _CLASS_IN) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1340 ) |
28299 | 1341 out.addAnswerAtTime( |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1342 zeroconf.cache.getByDetails( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1343 self.server, _TYPE_A, _CLASS_IN |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1344 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1345 now, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1346 ) |
28298 | 1347 zeroconf.send(out) |
1348 next = now + delay | |
1349 delay = delay * 2 | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1350 |
28298 | 1351 zeroconf.wait(min(next, last) - now) |
1352 now = currentTimeMillis() | |
1353 result = 1 | |
1354 finally: | |
1355 zeroconf.removeListener(self) | |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
1356 |
28298 | 1357 return result |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1358 |
28298 | 1359 def __eq__(self, other): |
1360 """Tests equality of service name""" | |
1361 if isinstance(other, ServiceInfo): | |
1362 return other.name == self.name | |
1363 return 0 | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1364 |
28298 | 1365 def __ne__(self, other): |
1366 """Non-equality test""" | |
1367 return not self.__eq__(other) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1368 |
28298 | 1369 def __repr__(self): |
1370 """String representation""" | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1371 result = "service[%s,%s:%s," % ( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1372 self.name, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1373 socket.inet_ntoa(self.getAddress()), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1374 self.port, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1375 ) |
28298 | 1376 if self.text is None: |
1377 result += "None" | |
1378 else: | |
1379 if len(self.text) < 20: | |
1380 result += self.text | |
1381 else: | |
1382 result += self.text[:17] + "..." | |
1383 result += "]" | |
1384 return result | |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
1385 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1386 |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1387 class Zeroconf(object): |
28298 | 1388 """Implementation of Zeroconf Multicast DNS Service Discovery |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1389 |
28298 | 1390 Supports registration, unregistration, queries and browsing. |
1391 """ | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1392 |
28298 | 1393 def __init__(self, bindaddress=None): |
1394 """Creates an instance of the Zeroconf class, establishing | |
1395 multicast communications, listening and reaping threads.""" | |
1396 globals()['_GLOBAL_DONE'] = 0 | |
1397 if bindaddress is None: | |
1398 self.intf = socket.gethostbyname(socket.gethostname()) | |
1399 else: | |
1400 self.intf = bindaddress | |
1401 self.group = ('', _MDNS_PORT) | |
1402 self.socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) | |
1403 try: | |
1404 self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) | |
1405 self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1) | |
1406 except Exception: | |
1407 # SO_REUSEADDR should be equivalent to SO_REUSEPORT for | |
1408 # multicast UDP sockets (p 731, "TCP/IP Illustrated, | |
1409 # Volume 2"), but some BSD-derived systems require | |
1410 # SO_REUSEPORT to be specified explicitly. Also, not all | |
1411 # versions of Python have SO_REUSEPORT available. So | |
1412 # if you're on a BSD-based system, and haven't upgraded | |
1413 # to Python 2.3 yet, you may find this library doesn't | |
1414 # work as expected. | |
1415 # | |
1416 pass | |
1417 self.socket.setsockopt(socket.SOL_IP, socket.IP_MULTICAST_TTL, "\xff") | |
1418 self.socket.setsockopt(socket.SOL_IP, socket.IP_MULTICAST_LOOP, "\x01") | |
1419 try: | |
1420 self.socket.bind(self.group) | |
1421 except Exception: | |
1422 # Some versions of linux raise an exception even though | |
1423 # SO_REUSEADDR and SO_REUSEPORT have been set, so ignore it | |
1424 pass | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1425 self.socket.setsockopt( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1426 socket.SOL_IP, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1427 socket.IP_ADD_MEMBERSHIP, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1428 socket.inet_aton(_MDNS_ADDR) + socket.inet_aton(r'0.0.0.0'), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1429 ) |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1430 |
28298 | 1431 self.listeners = [] |
1432 self.browsers = [] | |
1433 self.services = {} | |
1434 self.servicetypes = {} | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1435 |
28298 | 1436 self.cache = DNSCache() |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1437 |
28298 | 1438 self.condition = threading.Condition() |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
1439 |
28298 | 1440 self.engine = Engine(self) |
1441 self.listener = Listener(self) | |
1442 self.reaper = Reaper(self) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1443 |
28298 | 1444 def isLoopback(self): |
1445 return self.intf.startswith("127.0.0.1") | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1446 |
28298 | 1447 def isLinklocal(self): |
1448 return self.intf.startswith("169.254.") | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1449 |
28298 | 1450 def wait(self, timeout): |
1451 """Calling thread waits for a given number of milliseconds or | |
1452 until notified.""" | |
1453 self.condition.acquire() | |
28300
15c5f50e7e13
zeroconf: add whitespace around operator
timeless <timeless@mozdev.org>
parents:
28299
diff
changeset
|
1454 self.condition.wait(timeout / 1000) |
28298 | 1455 self.condition.release() |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1456 |
28298 | 1457 def notifyAll(self): |
1458 """Notifies all waiting threads""" | |
1459 self.condition.acquire() | |
1460 self.condition.notifyAll() | |
1461 self.condition.release() | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1462 |
28298 | 1463 def getServiceInfo(self, type, name, timeout=3000): |
1464 """Returns network's service information for a particular | |
1465 name and type, or None if no service matches by the timeout, | |
1466 which defaults to 3 seconds.""" | |
1467 info = ServiceInfo(type, name) | |
1468 if info.request(self, timeout): | |
1469 return info | |
1470 return None | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1471 |
28298 | 1472 def addServiceListener(self, type, listener): |
1473 """Adds a listener for a particular service type. This object | |
1474 will then have its updateRecord method called when information | |
1475 arrives for that type.""" | |
1476 self.removeServiceListener(listener) | |
1477 self.browsers.append(ServiceBrowser(self, type, listener)) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1478 |
28298 | 1479 def removeServiceListener(self, listener): |
1480 """Removes a listener from the set that is currently listening.""" | |
1481 for browser in self.browsers: | |
1482 if browser.listener == listener: | |
1483 browser.cancel() | |
28301
fd8a4d2d6541
zeroconf: del is not a function
timeless <timeless@mozdev.org>
parents:
28300
diff
changeset
|
1484 del browser |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1485 |
28298 | 1486 def registerService(self, info, ttl=_DNS_TTL): |
1487 """Registers service information to the network with a default TTL | |
1488 of 60 seconds. Zeroconf will then respond to requests for | |
1489 information for that service. The name of the service may be | |
1490 changed if needed to make it unique on the network.""" | |
1491 self.checkService(info) | |
1492 self.services[info.name.lower()] = info | |
28421
6d72cc613fc4
zeroconf: replace has_key with in
timeless <timeless@mozdev.org>
parents:
28420
diff
changeset
|
1493 if info.type in self.servicetypes: |
28300
15c5f50e7e13
zeroconf: add whitespace around operator
timeless <timeless@mozdev.org>
parents:
28299
diff
changeset
|
1494 self.servicetypes[info.type] += 1 |
28298 | 1495 else: |
28300
15c5f50e7e13
zeroconf: add whitespace around operator
timeless <timeless@mozdev.org>
parents:
28299
diff
changeset
|
1496 self.servicetypes[info.type] = 1 |
28298 | 1497 now = currentTimeMillis() |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1498 nexttime = now |
28298 | 1499 i = 0 |
1500 while i < 3: | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1501 if now < nexttime: |
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1502 self.wait(nexttime - now) |
28298 | 1503 now = currentTimeMillis() |
1504 continue | |
1505 out = DNSOutgoing(_FLAGS_QR_RESPONSE | _FLAGS_AA) | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1506 out.addAnswerAtTime( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1507 DNSPointer(info.type, _TYPE_PTR, _CLASS_IN, ttl, info.name), 0 |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1508 ) |
28299 | 1509 out.addAnswerAtTime( |
1510 DNSService( | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1511 info.name, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1512 _TYPE_SRV, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1513 _CLASS_IN, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1514 ttl, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1515 info.priority, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1516 info.weight, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1517 info.port, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1518 info.server, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1519 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1520 0, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1521 ) |
28299 | 1522 out.addAnswerAtTime( |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1523 DNSText(info.name, _TYPE_TXT, _CLASS_IN, ttl, info.text), 0 |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1524 ) |
28298 | 1525 if info.address: |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1526 out.addAnswerAtTime( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1527 DNSAddress( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1528 info.server, _TYPE_A, _CLASS_IN, ttl, info.address |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1529 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1530 0, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1531 ) |
28298 | 1532 self.send(out) |
1533 i += 1 | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1534 nexttime += _REGISTER_TIME |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1535 |
28298 | 1536 def unregisterService(self, info): |
1537 """Unregister a service.""" | |
1538 try: | |
28301
fd8a4d2d6541
zeroconf: del is not a function
timeless <timeless@mozdev.org>
parents:
28300
diff
changeset
|
1539 del self.services[info.name.lower()] |
28300
15c5f50e7e13
zeroconf: add whitespace around operator
timeless <timeless@mozdev.org>
parents:
28299
diff
changeset
|
1540 if self.servicetypes[info.type] > 1: |
15c5f50e7e13
zeroconf: add whitespace around operator
timeless <timeless@mozdev.org>
parents:
28299
diff
changeset
|
1541 self.servicetypes[info.type] -= 1 |
28298 | 1542 else: |
1543 del self.servicetypes[info.type] | |
1544 except KeyError: | |
1545 pass | |
1546 now = currentTimeMillis() | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1547 nexttime = now |
28298 | 1548 i = 0 |
1549 while i < 3: | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1550 if now < nexttime: |
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1551 self.wait(nexttime - now) |
28298 | 1552 now = currentTimeMillis() |
1553 continue | |
1554 out = DNSOutgoing(_FLAGS_QR_RESPONSE | _FLAGS_AA) | |
28299 | 1555 out.addAnswerAtTime( |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1556 DNSPointer(info.type, _TYPE_PTR, _CLASS_IN, 0, info.name), 0 |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1557 ) |
28299 | 1558 out.addAnswerAtTime( |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1559 DNSService( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1560 info.name, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1561 _TYPE_SRV, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1562 _CLASS_IN, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1563 0, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1564 info.priority, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1565 info.weight, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1566 info.port, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1567 info.name, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1568 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1569 0, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1570 ) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1571 out.addAnswerAtTime( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1572 DNSText(info.name, _TYPE_TXT, _CLASS_IN, 0, info.text), 0 |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1573 ) |
28298 | 1574 if info.address: |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1575 out.addAnswerAtTime( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1576 DNSAddress( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1577 info.server, _TYPE_A, _CLASS_IN, 0, info.address |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1578 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1579 0, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1580 ) |
28298 | 1581 self.send(out) |
1582 i += 1 | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1583 nexttime += _UNREGISTER_TIME |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1584 |
28298 | 1585 def unregisterAllServices(self): |
1586 """Unregister all registered services.""" | |
1587 if len(self.services) > 0: | |
1588 now = currentTimeMillis() | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1589 nexttime = now |
28298 | 1590 i = 0 |
1591 while i < 3: | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1592 if now < nexttime: |
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1593 self.wait(nexttime - now) |
28298 | 1594 now = currentTimeMillis() |
1595 continue | |
1596 out = DNSOutgoing(_FLAGS_QR_RESPONSE | _FLAGS_AA) | |
1597 for info in self.services.values(): | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1598 out.addAnswerAtTime( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1599 DNSPointer( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1600 info.type, _TYPE_PTR, _CLASS_IN, 0, info.name |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1601 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1602 0, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1603 ) |
28299 | 1604 out.addAnswerAtTime( |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1605 DNSService( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1606 info.name, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1607 _TYPE_SRV, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1608 _CLASS_IN, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1609 0, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1610 info.priority, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1611 info.weight, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1612 info.port, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1613 info.server, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1614 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1615 0, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1616 ) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1617 out.addAnswerAtTime( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1618 DNSText(info.name, _TYPE_TXT, _CLASS_IN, 0, info.text), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1619 0, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1620 ) |
28298 | 1621 if info.address: |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1622 out.addAnswerAtTime( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1623 DNSAddress( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1624 info.server, _TYPE_A, _CLASS_IN, 0, info.address |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1625 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1626 0, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1627 ) |
28298 | 1628 self.send(out) |
1629 i += 1 | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1630 nexttime += _UNREGISTER_TIME |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1631 |
28298 | 1632 def checkService(self, info): |
1633 """Checks the network for a unique service name, modifying the | |
1634 ServiceInfo passed in if it is not unique.""" | |
1635 now = currentTimeMillis() | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1636 nexttime = now |
28298 | 1637 i = 0 |
1638 while i < 3: | |
1639 for record in self.cache.entriesWithName(info.type): | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1640 if ( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1641 record.type == _TYPE_PTR |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1642 and not record.isExpired(now) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1643 and record.alias == info.name |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1644 ): |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1645 if info.name.find('.') < 0: |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1646 info.name = "%w.[%s:%d].%s" % ( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1647 info.name, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1648 info.address, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1649 info.port, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1650 info.type, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1651 ) |
28298 | 1652 self.checkService(info) |
1653 return | |
1654 raise NonUniqueNameException | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1655 if now < nexttime: |
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1656 self.wait(nexttime - now) |
28298 | 1657 now = currentTimeMillis() |
1658 continue | |
1659 out = DNSOutgoing(_FLAGS_QR_QUERY | _FLAGS_AA) | |
1660 self.debug = out | |
1661 out.addQuestion(DNSQuestion(info.type, _TYPE_PTR, _CLASS_IN)) | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1662 out.addAuthoritativeAnswer( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1663 DNSPointer(info.type, _TYPE_PTR, _CLASS_IN, _DNS_TTL, info.name) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1664 ) |
28298 | 1665 self.send(out) |
1666 i += 1 | |
28419
eb9d0e828c30
zeroconf: remove camelcase in identifiers
timeless <timeless@mozdev.org>
parents:
28302
diff
changeset
|
1667 nexttime += _CHECK_TIME |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1668 |
28298 | 1669 def addListener(self, listener, question): |
1670 """Adds a listener for a given question. The listener will have | |
1671 its updateRecord method called when information is available to | |
1672 answer the question.""" | |
1673 now = currentTimeMillis() | |
1674 self.listeners.append(listener) | |
1675 if question is not None: | |
1676 for record in self.cache.entriesWithName(question.name): | |
1677 if question.answeredBy(record) and not record.isExpired(now): | |
1678 listener.updateRecord(self, now, record) | |
1679 self.notifyAll() | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1680 |
28298 | 1681 def removeListener(self, listener): |
1682 """Removes a listener.""" | |
1683 try: | |
1684 self.listeners.remove(listener) | |
1685 self.notifyAll() | |
1686 except Exception: | |
1687 pass | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1688 |
28298 | 1689 def updateRecord(self, now, rec): |
1690 """Used to notify listeners of new information that has updated | |
1691 a record.""" | |
1692 for listener in self.listeners: | |
1693 listener.updateRecord(self, now, rec) | |
1694 self.notifyAll() | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1695 |
28298 | 1696 def handleResponse(self, msg): |
1697 """Deal with incoming response packets. All answers | |
1698 are held in the cache, and listeners are notified.""" | |
1699 now = currentTimeMillis() | |
1700 for record in msg.answers: | |
1701 expired = record.isExpired(now) | |
1702 if record in self.cache.entries(): | |
1703 if expired: | |
1704 self.cache.remove(record) | |
1705 else: | |
1706 entry = self.cache.get(record) | |
1707 if entry is not None: | |
1708 entry.resetTTL(record) | |
1709 record = entry | |
1710 else: | |
1711 self.cache.add(record) | |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
1712 |
28298 | 1713 self.updateRecord(now, record) |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1714 |
28298 | 1715 def handleQuery(self, msg, addr, port): |
1716 """Deal with incoming query packets. Provides a response if | |
1717 possible.""" | |
1718 out = None | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1719 |
28298 | 1720 # Support unicast client responses |
1721 # | |
1722 if port != _MDNS_PORT: | |
1723 out = DNSOutgoing(_FLAGS_QR_RESPONSE | _FLAGS_AA, 0) | |
1724 for question in msg.questions: | |
1725 out.addQuestion(question) | |
7874
d812029cda85
cleanup: drop variables for unused return values
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7071
diff
changeset
|
1726 |
28298 | 1727 for question in msg.questions: |
1728 if question.type == _TYPE_PTR: | |
1729 if question.name == "_services._dns-sd._udp.local.": | |
1730 for stype in self.servicetypes.keys(): | |
1731 if out is None: | |
1732 out = DNSOutgoing(_FLAGS_QR_RESPONSE | _FLAGS_AA) | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1733 out.addAnswer( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1734 msg, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1735 DNSPointer( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1736 "_services._dns-sd._udp.local.", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1737 _TYPE_PTR, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1738 _CLASS_IN, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1739 _DNS_TTL, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1740 stype, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1741 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1742 ) |
28298 | 1743 for service in self.services.values(): |
1744 if question.name == service.type: | |
1745 if out is None: | |
1746 out = DNSOutgoing(_FLAGS_QR_RESPONSE | _FLAGS_AA) | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1747 out.addAnswer( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1748 msg, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1749 DNSPointer( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1750 service.type, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1751 _TYPE_PTR, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1752 _CLASS_IN, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1753 _DNS_TTL, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1754 service.name, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1755 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1756 ) |
28298 | 1757 else: |
1758 try: | |
1759 if out is None: | |
1760 out = DNSOutgoing(_FLAGS_QR_RESPONSE | _FLAGS_AA) | |
7874
d812029cda85
cleanup: drop variables for unused return values
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7071
diff
changeset
|
1761 |
28298 | 1762 # Answer A record queries for any service addresses we know |
1763 if question.type == _TYPE_A or question.type == _TYPE_ANY: | |
1764 for service in self.services.values(): | |
1765 if service.server == question.name.lower(): | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1766 out.addAnswer( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1767 msg, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1768 DNSAddress( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1769 question.name, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1770 _TYPE_A, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1771 _CLASS_IN | _CLASS_UNIQUE, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1772 _DNS_TTL, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1773 service.address, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1774 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1775 ) |
7874
d812029cda85
cleanup: drop variables for unused return values
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7071
diff
changeset
|
1776 |
28298 | 1777 service = self.services.get(question.name.lower(), None) |
35629
31451f3f4b56
style: remove multiple statement on a single line in zeroconf
Boris Feld <boris.feld@octobus.net>
parents:
34447
diff
changeset
|
1778 if not service: |
31451f3f4b56
style: remove multiple statement on a single line in zeroconf
Boris Feld <boris.feld@octobus.net>
parents:
34447
diff
changeset
|
1779 continue |
7874
d812029cda85
cleanup: drop variables for unused return values
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7071
diff
changeset
|
1780 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1781 if question.type == _TYPE_SRV or question.type == _TYPE_ANY: |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1782 out.addAnswer( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1783 msg, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1784 DNSService( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1785 question.name, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1786 _TYPE_SRV, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1787 _CLASS_IN | _CLASS_UNIQUE, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1788 _DNS_TTL, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1789 service.priority, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1790 service.weight, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1791 service.port, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1792 service.server, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1793 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1794 ) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1795 if question.type == _TYPE_TXT or question.type == _TYPE_ANY: |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1796 out.addAnswer( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1797 msg, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1798 DNSText( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1799 question.name, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1800 _TYPE_TXT, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1801 _CLASS_IN | _CLASS_UNIQUE, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1802 _DNS_TTL, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1803 service.text, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1804 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1805 ) |
28298 | 1806 if question.type == _TYPE_SRV: |
28299 | 1807 out.addAdditionalAnswer( |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1808 DNSAddress( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1809 service.server, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1810 _TYPE_A, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1811 _CLASS_IN | _CLASS_UNIQUE, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1812 _DNS_TTL, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1813 service.address, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1814 ) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1815 ) |
28298 | 1816 except Exception: |
1817 traceback.print_exc() | |
7874
d812029cda85
cleanup: drop variables for unused return values
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7071
diff
changeset
|
1818 |
28298 | 1819 if out is not None and out.answers: |
1820 out.id = msg.id | |
1821 self.send(out, addr, port) | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1822 |
28302
e96a3ae025ed
zeroconf: remove whitespace around = for named parameters
timeless <timeless@mozdev.org>
parents:
28301
diff
changeset
|
1823 def send(self, out, addr=_MDNS_ADDR, port=_MDNS_PORT): |
28298 | 1824 """Sends an outgoing packet.""" |
1825 # This is a quick test to see if we can parse the packets we generate | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1826 # temp = DNSIncoming(out.packet()) |
28298 | 1827 try: |
1828 self.socket.sendto(out.packet(), 0, (addr, port)) | |
1829 except Exception: | |
1830 # Ignore this, it may be a temporary loss of network connection | |
1831 pass | |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1832 |
28298 | 1833 def close(self): |
1834 """Ends the background threads, and prevent this instance from | |
1835 servicing further queries.""" | |
1836 if globals()['_GLOBAL_DONE'] == 0: | |
1837 globals()['_GLOBAL_DONE'] = 1 | |
1838 self.notifyAll() | |
1839 self.engine.notify() | |
1840 self.unregisterAllServices() | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1841 self.socket.setsockopt( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1842 socket.SOL_IP, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1843 socket.IP_DROP_MEMBERSHIP, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1844 socket.inet_aton(_MDNS_ADDR) + socket.inet_aton(r'0.0.0.0'), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1845 ) |
28298 | 1846 self.socket.close() |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
1847 |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1848 |
7071
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1849 # Test a few module features, including service registration, service |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1850 # query (for Zoe), and service unregistration. |
643c751e60b2
zeroconf: initial implementation
Matt Mackall <mpm@selenic.com>
parents:
diff
changeset
|
1851 |
7877
eba7f12b0c51
cleanup: whitespace cleanup
Peter Arrenbrecht <peter.arrenbrecht@gmail.com>
parents:
7874
diff
changeset
|
1852 if __name__ == '__main__': |
28298 | 1853 print("Multicast DNS Service Discovery for Python, version", __version__) |
1854 r = Zeroconf() | |
1855 print("1. Testing registration of a service...") | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1856 desc = {'version': '0.10', 'a': 'test value', 'b': 'another value'} |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1857 info = ServiceInfo( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1858 "_http._tcp.local.", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1859 "My Service Name._http._tcp.local.", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1860 socket.inet_aton("127.0.0.1"), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1861 1234, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1862 0, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1863 0, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1864 desc, |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1865 ) |
28298 | 1866 print(" Registering service...") |
1867 r.registerService(info) | |
1868 print(" Registration done.") | |
1869 print("2. Testing query of service information...") | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1870 print( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1871 " Getting ZOE service:", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1872 str(r.getServiceInfo("_http._tcp.local.", "ZOE._http._tcp.local.")), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1873 ) |
28298 | 1874 print(" Query done.") |
1875 print("3. Testing query of own service...") | |
43076
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1876 print( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1877 " Getting self:", |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1878 str( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1879 r.getServiceInfo( |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1880 "_http._tcp.local.", "My Service Name._http._tcp.local." |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1881 ) |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1882 ), |
2372284d9457
formatting: blacken the codebase
Augie Fackler <augie@google.com>
parents:
42551
diff
changeset
|
1883 ) |
28298 | 1884 print(" Query done.") |
1885 print("4. Testing unregister of service information...") | |
1886 r.unregisterService(info) | |
1887 print(" Unregister done.") | |
1888 r.close() |