�
Hq�Qc@swdZd
Z
dZdZddlZddlZddlZddlZddlZddl	Z	ddl
Z
dddgZd	e�d
<dZ
dZd
ZdZdZdZdZdZddZdZdZdZd	ZdZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$d Z%d!Z&d"Z'd#Z(dZ)dZ*dZ+dZ,d Z-d$Z.d%Z/d&Z0d'Z1d(Z2d)Z3d*Z4d+Z5d,Z6d-Z7d.Z8dZ9d/Z:d0Z;d"Z<id1e"6d2e#6d3e$6d4e%6d5e&6d6e'6Z=id7e*6d8e+6d9e,6d:e-6d;e.6d<e/6d=e06d>e16d?e26d@e36dAe46dBe56dCe66dDe76dEe86dFe96dGe:6dHe;6d6e<6Z>dI�Z?dJe@f
dK��YZAdLe@f
dM��YZBdNe@f
dO��YZCdPe@f
dQ��YZDdRe@f
dS��YZEdTe@f
dU��YZFdVeFf
dW��YZGdXeHf
dY��YZIdZeIf
d[��YZJd\eIf
d]��YZKd^eKf
d_��YZLd`eKf
da��YZMdbeKf
dc��YZNddeKf
de��YZOdfeKf
dg��YZPdheHf
di��YZQdjeHf
dk��YZRdleHf
dm��YZSdnejTf
do��YZUdpeHf
dq��YZVdrejTf
ds��YZWdejTf
dt��YZXdeHf
du��YZYdeHf
dv��YZZe[dwkrsdxGeGHeZ�Z\dyGHidzd{6d|d76d}d~6Z]eYdd�ej^d��
d�d	d	e]�Z_d�GHe\j`e_�

d�GHd�GHd�Geae\jbdd���
GHd�GHd�GHd�Geae\jbdd���
GHd�GHd�GHe\jce_�

d�GHe\jd�
ndS(�s Multicast DNS Service Discovery for Python, v0.12
    Copyright (C) 2003, Paul Scott-Murphy

    This module provides a framework for the use of DNS Service Discovery
    using IP multicast.  It has been tested against the JRendezvous
    implementation from <a href="http://strangeberry.com">StrangeBerry</a>,
    and against the mDNSResponder from Mac OS X 10.3.8.

    This library is free software; you can redistribute it and/or
    modify it under the terms of the GNU Lesser General Public
    License as published by the Free Software Foundation; either
    version 2.1 of the License, or (at your option) any later version.

    This library is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
    Lesser General Public License for more details.

    You should have received a copy of the GNU Lesser General Public
    License along with this library; if not, see
    <http://www.gnu.org/licenses/>.

sPaul Scott-Murphys!paul at scott dash murphy dot coms0.12i����NtZeroconftServiceInfotServiceBrowserit_GLOBAL_DONEi}i�i�i�i�
s224.0.0.251i�i5i<i�i#i�iii
i@i ii
iiii�i�i�iiiii	i
iii
iiii!tintcstchthstnonetanyt
atnstmdtmftcnametsoatmbtmgtmrtnulltwkstptrthinfotminfotmxttxttquadatsrvcCstj�d
S(s#Current system time in millisecondsi�(
ttime(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytcurrentTimeMillis�stNonLocalNameExceptionc
BseZ
RS((t__name__t
__module__(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR�s
tNonUniqueNameExceptionc
BseZ
RS((RR (((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR!�s
tNamePartTooLongExceptionc
BseZ
RS((RR (((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR"�s
tAbstractMethodExceptionc
BseZ
RS((RR (((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR#�s
tBadTypeInNameExceptionc
BseZ
RS((RR (((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR$�s
t
BadDomainNamec
BseZ
d�ZRS(
cCstj
|d
|
�
dS(Nsat position %s(t	Exceptiont__init__(tselftpos((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR'�s
(RR R'(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR%�s
tBadDomainNameCircularc
BseZ
RS((RR (((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR*�s
tDNSEntryc
BsDeZ
dZd
�Zd�Zd�Zd�Zd�Zd�ZRS(sA DNS entrycCsHtj
|
�
|_|
|_||_|t@|_|t@d
k|_dS(Ni(	tstringtlowertkeytnamettypet_CLASS_MASKtclazzt
_CLASS_UNIQUEtunique(R(R/R0R2((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR'�s


	
	


cCsGt|
t
�rC|j|
jkoB|j|
jkoB|j|
jkSd
S(s&Equality test on name, type, and classi(t
isinstanceR+R/R0R2(R(tother((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt__eq__�s
4
cCs|j|
�
S(
sNon-equality test(
R7(R(R6((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt__ne__�scCs)yt|
SWnt
k
r$


d
|
SXdS(sClass accessors?(%s)N(t_CLASSEStKeyError(R(R2((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytgetClazz�s



cCs)yt|
SWnt
k
r$


d
|
SXdS(s
Type accessors?(%s)N(t_TYPESR:(R(R0((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytgetType�s



cCs�d
|
|j|j
�
|j|j�
f}|jrA|d7}n
|d7}||j7}|dk	ru|d|7}n
|d7}|S(s1String representation with additional informations%s[%s,%ss-unique,t
,s,%s]t
]N(R=R0R;R2R4R/tNone(R(thdrR6tresult((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyttoString�s+
	








(	RR t__doc__R'R7R8R;R=RC(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR+�s
					tDNSQuestionc
Bs)eZ
dZd
�Zd�Zd�ZRS(sA DNS question entrycCs8|
jd
�
st
|
�
�
ntj||
||�
dS(Ns.local.(tendswithRR+R'(R(R/R0R2((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR'
s


cCsC|j|
jkoB|j
|
j
ks3|j
tkoB|j|
jkS(
s6Returns true if the question is answered by the record(R2R0t	_TYPE_ANYR/(R(trec((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt
answeredBy
sc

Cstj
|d
d�S(sString representationtquestionN(R+RCR@(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt__repr__
s(RR RDR'RIRK(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRE
s
		t	DNSRecordc
BsqeZ
dZd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zd
�Zd�Z
RS(s.A DNS record - like a DNS entry, but has a TTLcCs/tj
||
||�
||_t�|_dS(
N(R+R'tttlRtcreated(R(R/R0R2RM((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR'
s

	
cCs#t|
t
�rtj||
�Sd
S(sTests equality as per DNSRecordi(R5RLR+R7(R(R6((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR7!
s

cCs+x$|
jD]}|j
|�
r
d
Sq
WdS(s^Returns true if any answer in a message can suffice for the
		information held in this record.i
i(tanswerstsuppressedByAnswer(R(tmsgtrecord((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytsuppressedBy'
s


cCs*||
kr&|
j|jd
kr&dSdS(sqReturns true if another record has same name, type and class,
		and if its TTL is at least half of this record's.ii
i(
RM(R(R6((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRP/
s"

cCs|j|
|j
d
S(sRReturns the time at which this record will have expired
		by a certain percentage.i
(RNRM(R(tpercent((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytgetExpirationTime6
scCstd
|j
d�
|
d�S(s%Returns the remaining TTL in seconds.iidi�(tmaxRU(R(tnow((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytgetRemainingTTL;
scCs|jd
�
|
k
S(s(Returns true if this record has expired.id(
RU(R(RW((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt	isExpired?
scCs|jd
�
|
k
S(s9Returns true if this record is at least half way expired.i2(
RU(R(RW((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytisStaleC
scCs|
j|_|
j
|_
d
S(sDSets this record's TTL and created time to that of
		another record.N(RNRM(R(R6((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytresetTTLG
s
c
Cs
t�
d
S(sAbstract methodN(
R#(R(tout((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytwriteM
scCs5d
|j|j
t��
|
f}tj|d|�S(s1String representation with additional informations%s/%s,%sRR(RMRXRR+RC(R(R6targ((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRCQ
s"
(RR RDR'R7RSRPRURXRYRZR[R]RC(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRL
s
										t
DNSAddressc
Bs2eZ
dZd
�Zd�Zd�Zd�ZRS(sA DNS address recordcCs&tj
||
|||�
||_dS(
N(RLR'taddress(R(R/R0R2RMR`((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR'Y
s

cCs |
j|j
t|j
�
�
d
S(s'Used in constructing an outgoing packetN(twriteStringR`tlen(R(R\((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR]]
scCs#t|
t
�r|j|
jkSd
S(sTests equality on addressi(R5R_R`(R(R6((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR7a
s

c

Cs0ytj
|j�
SWntk
r+


|jSXd
S(sString representationN(tsockett	inet_ntoaR`R&(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRKg
s



(RR RDR'R]R7RK(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR_V
s

			tDNSHinfoc
Bs2eZ
dZd
�Zd�Zd�Zd�ZRS(sA DNS host information recordcCs/tj
||
|||�
||_||_dS(
N(RLR'tcputos(R(R/R0R2RMRfRg((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR'q
s

	
cCs<|
j|j
t|j
�
�
|
j|jt|j�
�
d
S(s'Used in constructing an outgoing packetN(RaRfRbRg(R(R\((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR]v
s
cCs5t|
t
�r1|j|
jko0|j|
jkSd
S(sTests equality on cpu and osi(R5ReRfRg(R(R6((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR7{
s
"
c

Cs|jd
|j
S(sString representationt
 (RfRg(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRK�
s(RR RDR'R]R7RK(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRen
s

			t
DNSPointerc
Bs2eZ
dZd
�Zd�Zd�Zd�ZRS(sA DNS pointer recordcCs&tj
||
|||�
||_dS(
N(RLR'talias(R(R/R0R2RMRj((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR'�
s

cCs|
j|j
�

d
S(s'Used in constructing an outgoing packetN(t	writeNameRj(R(R\((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR]�
scCs#t|
t
�r|j|
jkSd
S(sTests equality on aliasi(R5RiRj(R(R6((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR7�
s

c

Cs|j|j
�
S(
sString representation(RCRj(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRK�
s(RR RDR'R]R7RK(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRi�
s

			tDNSTextc
Bs2eZ
dZd
�Zd�Zd�Zd�ZRS(sA DNS text recordcCs&tj
||
|||�
||_dS(
N(RLR'ttext(R(R/R0R2RMRm((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR'�
s

cCs |
j|j
t|j
�
�
d
S(s'Used in constructing an outgoing packetN(RaRmRb(R(R\((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR]�
scCs#t|
t
�r|j|
jkSd
S(sTests equality on texti(R5RlRm(R(R6((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR7�
s

c

CsAt|j
�
d
kr-|j|j
d d�
S|j|j
�
SdS(sString representationi
is...N(RbRmRC(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRK�
s
(RR RDR'R]R7RK(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRl�
s

			t
DNSServicec
Bs2eZ
dZd
�Zd�Zd�Zd�ZRS(sA DNS service recordc		CsAtj
||
|||�
||_||_||_||_dS(
N(RLR'tprioritytweighttporttserver(	R(R/R0R2RMRoRpRqRr((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR'�
s


	
	
	
cCsD|
j|j
�

|
j|j�

|
j|j�

|
j|j�

d
S(s'Used in constructing an outgoing packetN(t
writeShortRoRpRqRkRr(R(R\((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR]�
s


cCsYt|
t
�rU|j|
jkoT|j|
jkoT|j|
jkoT|j|
jkSd
S(s3Tests equality on priority, weight, port and serveri(R5RnRoRpRqRr(R(R6((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR7�
s
F
c

Cs|jd
|j
|jf�
S(sString representations%s:%s(RCRrRq(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRK�
s(RR RDR'R]R7RK(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRn�
s

			tDNSIncomingc
BszeZ
dZd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zd
�Zd�Z
d�ZRS(
s/Object representation of an incoming DNS packetcCsjd
|_|
|_
g|_g|_d
|_d
|_d
|_d
|_|j�
|j	�
|j
�
dS(s/Constructor from string holding bytes of packetiN(toffsettdatat	questionsROtnumQuestionst
numAnswerstnumAuthoritiestnumAdditionalst
readHeadert
readQuestionst
readOthers(R(Rv((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR'�
s	
	
	
	
	
	
	
	



c
Cs�d
}
tj
|
�
}tj|
|j|j|j|!�}|j|7_|d|_|d|_|d|_|d|_|d|_	|d|_
dS(	sReads header portion of packets!HHHHHHii
iiiiN(tstructtcalcsizetunpackRvRutidtflagsRxRyRzR{(R(tformattlengthtinfo((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR|�
s

&










c
Cs�d
}
tj
|
�
}x�td|j�D]�}|j�}tj|
|j|j|j|!�}|j|7_y.t||d|d�}|j	j
|�

Wq(tk
r�


q(Xq(WdS(s!Reads questions section of packets!HHii
N(RR�trangeRxtreadNameR�RvRuRERwtappendR(R(R�R�t
iR/R�RJ((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR}�
s



&





c
CsRd
}
tj
|
�
}tj|
|j|j|j|!�}|j|7_|dS(s Reads an integer from the packets!Ii(RR�R�RvRu(R(R�R�R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytreadInt�
s


&

c
Cs2t|j
|j�
}
|jd
7_|j|
�
S(s(Reads a character string from the packeti
(tordRvRut
readString(R(R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytreadCharacterStrings

cCs`d
t|
�
d}t
j|�
}t
j||j|j|j|!�}|j|7_|dS(s0Reads a string of a given length from the packett
!t
si(tstrRR�R�RvRu(R(RbR�R�R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR�
s


&

c
CsRd
}
tj
|
�
}tj|
|j|j|j|!�}|j|7_|dS(s'Reads an unsigned short from the packets!Hi(RR�R�RvRu(R(R�R�R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytreadUnsignedShorts


&

c
Csrd
}
tj
|
�
}|j|j|j}x?td|�D].}|j�}tj|
|j|j	|j	|!�}|j	|7_	d}|dtkr�t||d|d|d|j
d�
�}n�
|dtks�|dtkr
t||d|d|d|j��}n5
|dtkrZ
t||d|d|d|j
|d�
�}n�|dtkr�
t||d|d|d|j�|j�|j�|j��}n�|dtkr�
t||d|d|d|j�|j��}nS|dtkr8t||d|d|d|j
d�
�}n|j	|d7_	|dk	r<|jj|�

q<q<WdS(	sDReads the answers, authorities and additionals section of the packets!HHiHii
iiiiN(RR�RyRzR{R�R�R�RvRuR@t_TYPE_AR_R�t_TYPE_CNAMEt	_TYPE_PTRRit	_TYPE_TXTRlt	_TYPE_SRVRnR�t_TYPE_HINFOReR�t
_TYPE_AAAAROR�(R(R�R�t
nR�tdomainR�RH((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR~s.




&


0
 
-

4

H

6

0

c

Cs|jt
@tkS(
sReturns true if this is a query(R�t_FLAGS_QR_MASKt_FLAGS_QR_QUERY(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytisQuery?sc

Cs|jt
@tkS(
s"Returns true if this is a response(R�R�t_FLAGS_QR_RESPONSE(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt
isResponseCscCs|j|
|
|!j
d
�
S(s6Reads a UTF-8 string of a given length from the packetsutf-8(Rvtdecode(R(RuRb((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytreadUTFGsc
Cs6
d
}
|j}d}|}x�t
r
t|j|�
}|d7}|dkrQPn|d@}|dkr�d
j|
|j||�df�
}
||7}q|dkr

|dkr�|d}n|d@d>t|j|�
B}||kr�t|�
�
n|}qt|�
�
qW|dkr)
||_n	||_|
S(	s#Reads a domain name from the packetti����i
ii�t
.i?i(RutTrueR�RvtjoinR�R*R%(R(RBtofftnexttfirstRbt
t((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR�Ks2
	

	








%









	
	(RR RDR'R|R}R�R�R�R�R~R�R�R�R�(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRt�
s
								%			tDNSOutgoingcBs�eZ
dZd
d�
Zd�Zd�Zd�Zd�Zd�Zd�Z	d	�Z
d
�Zd�Zd�Z
d
�Zd�Zd�Zd�Zd�ZRS(s+Object representation of an outgoing packeti
cCsgd
|_d
|_
||_|
|_i|_g|_d|_g|_g|_g|_	g|_
dS(Nii(tfinishedR�t	multicastR�tnamesRvtsizeRwROtauthoritiestadditionals(R(R�R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR'ps
	
	
	
	
	
	
		
	
	
cCs|jj
|
�

d
S(sAdds a questionN(RwR�(R(RR((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytaddQuestion~scCs&|j|
�
s"|j
|d
�
ndS(sAdds an answeriN(RStaddAnswerAtTime(R(tinpRR((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt	addAnswer�s
cCsH|
dk	rD|d
ks(|
j
|�
rD|jj|
|f�

qDndS(s6Adds an answer if if does not expire by a certain timeiN(R@RYROR�(R(RRRW((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR��s

cCs|jj
|
�

d
S(sAdds an authoritative answerN(R�R�(R(RR((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytaddAuthoritativeAnswer�scCs|jj
|
�

d
S(sAdds an additional answerN(R�R�(R(RR((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytaddAdditionalAnswer�scCs;d
}|jj
tj|t|
�
��

|jd7_dS(s"Writes a single byte to the packets!ci
N(RvR�RtpacktchrR�(R(tvalueR�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt	writeByte�s
"
cCs8d
}|jj
|
tj||��
|jd7_dS(s=Inserts an unsigned short in a certain position in the packets!HiN(RvtinsertRR�R�(R(tindexR�R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytinsertShort�s

cCs5d
}|jj
tj||
��

|jd7_dS(s&Writes an unsigned short to the packets!HiN(RvR�RR�R�(R(R�R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRs�s

cCs;d
}|jj
tj|t|
�
��

|jd7_dS(s(Writes an unsigned integer to the packets!IiN(RvR�RR�tintR�(R(R�R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytwriteInt�s
"
cCsCd
t|�
d}|j
jtj||
��

|j|7_dS(sWrites a string to the packetR�R�N(R�RvR�RR�R�(R(R�R�R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRa�s

cCsQ|
jd
�
}t
|�
}|dkr0t�
n|j|�

|j||�
dS(s5Writes a UTF-8 string of a given length to the packetsutf-8i@N(tencodeRbR"R�Ra(R(R�tutfstrR�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytwriteUTF�s


	


cCs�y|j|
}Wnyt
k
r�


|j|j|
<|
jd
�
}|ddkr]|d }nx|D]}|j|�

qdW|jd�

dSX|j|d?dB�

|j|�

dS(s"Writes a domain name to the packetR�i����R�iNii�(R�R:R�tsplitR�R�(R(R/R�tpartstpart((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRk�s












cCs4|j|
j
�

|j|
j�

|j|
j�

d
S(sWrites a question to the packetN(RkR/RsR0R2(R(RJ((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt
writeQuestion�s

cCs�|j|
j
�

|j|
j�

|
jrI|jrI|j|
jtB�

n|j|
j�

|d
krx|j|
j	�

n|j|
j
|�
�

t|j�
}|j
d7_
|
j|�

|j
d8_
tdj|j|�
�
}|j||�
dS(sJWrites a record (answer, authoritative answer, additional) to
		the packetiiR�N(RkR/RsR0R4R�R2R3R�RMRXRbRvR�R]R�R�(R(RRRWR�R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytwriteRecord�s









c
Cs^
|jsN
d
|_x|j
D]}
|j|
�

qWx'|jD]\}}|j||�
q=Wx!|jD]}|j|d�
qgWx!|jD]}|j|d�
q�W|jdt|j�
�
|jdt|j�
�
|jdt|j�
�
|jdt|j
�
�
|jd|j	�
|j
r8
|jdd�
qN
|jd|j�
ndj|j
�
S(suReturns a string containing the packet's bytes

		No further parts should be added to the packet once this
		is done.i
iR�(R�RwR�ROR�R�R�R�RbR�R�R�R�Rv(R(RJtanswerRt	authorityt
additional((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytpacket�s&	
	












	

(RR RDR'R�R�R�R�R�R�R�RsR�RaR�RkR�R�R�(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR�ms"
															tDNSCachec
BsMeZ
dZd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	RS(sA cache of DNS entriesc

Cs
i|_dS(
N(
tcache(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR's
cCsMy|j|
j
}Wn%tk
r;


g}|j|
j
<n
X|j|
�

d
S(s
Adds an entryN(R�R.R:R�(R(tentrytlist((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytadds





cCs9y!|j|
j
}|j|
�

Wntk
r4


n
Xd
S(sRemoves an entryN(R�R.tremoveR:(R(R�R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR�s





cCsDy%|j|
j
}||j|
�
SWnttfk
r?


d
SXd
S(sHGets an entry by key.  Will return None if there is no
		matching entry.N(R�R.R�R:t
ValueErrorR@(R(R�R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytget%s




cCst|
||�}|j
|�
S(
sLGets an entry by details.  Will return None if there is
		no matching entry.(R+R�(R(R/R0R2R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytgetByDetails.s
cCs(y|j|
SWnt
k
r#


gSXd
S(s5Returns a list of entries whose key matches the name.N(R�R:(R(R/((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytentriesWithName4s



c
Cs<d
�}
yt|
|j
j��SWntk
r7


gSXdS(sReturns a list of all entriescSs||
S(
N((t
xt
y((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR�=sN(treduceR�tvaluesR&(R(R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytentries;s
	




(
RR RDR'R�R�R�R�R�R�(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR�s
							tEnginec
BsDeZ
dZd
�Zd�Zd�Zd�Zd�Zd�ZRS(sN
An engine wraps read access to sockets, allowing objects that
	need to receive data from sockets to be called back when the
	sockets are ready.

	A reader needs a handle_read() method, which is called when the socket
	it is interested in is ready for reading.

	Writers are not implemented here, because we only send short
	packets.
	cCsHtj
j|�

|
|_i|_d
|_tj�|_|j�
dS(Ni(	t	threadingtThreadR'tzeroconftreadersttimeoutt	Conditiont	conditiontstart(R(R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR'Ps

	
	
	

c
Cs�x�t�d
s�|j
�}
t|
�
dkr^|jj�
|jj|j�

|jj�
qy|tj|
gg|j�\}}}xQ|D]I}y|j	|j
�
Wq�tk
r�


t�d
s�tj
�
q�q�Xq�WWqtk
r�


qXqWdS(NRi(tglobalst
getReadersRbR�tacquiretwaitR�treleasetselectR�thandle_readR&t	tracebackt	print_exc(R(trstrrtwrterRc((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytrunXs 






$











c

Cs-|jj
�
|jj�}
|jj�
|
S(
N(R�R�R�tkeysR�(R(RB((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR�ns





cCs8|jj
�
|
|j|<|jj�
|jj�
dS(
N(R�R�R�tnotifyR�(R(treaderRc((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt	addReaderts






cCs5|jj
�
|j|
=|jj�
|jj�
dS(
N(R�R�R�R�R�(R(Rc((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt	delReaderzs






c


Cs+|jj
�
|jj�
|jj�
dS(
N(R�R�R�R�(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR��s




(	RR RDR'R�R�R�R�R�(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR�Ds
					tListenerc
Bs eZ
dZd
�Zd�ZRS(s(
A Listener is used by this module to listen on the multicast
	group to which DNS messages are sent, allowing the implementation
	to cache information as it arrives.

	It requires registration with an Engine object in order to have
	the read() method called when a socket is available for reading.cCs)|
|_|jj
j||jj�
dS(
N(R�tengineR�Rc(R(R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR'�s
	
c
Cs�|jj
jt�
\}
\}}|
|_t|
�
}|j�r�|tkrg|jj|t	t�
q�|t
kr�|jj|||�
|jj|t	t�
q�n|jj|�

dS(
N(R�Rctrecvfromt_MAX_MSG_ABSOLUTERvRtR�t
_MDNS_PORTthandleQueryt
_MDNS_ADDRt	_DNS_PORTthandleResponse(R(RvtaddrRqRQ((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR��s
!
	




(RR RDR'R�(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR��s	tReaperc
Bs eZ
dZd
�Zd�ZRS(sKA Reaper is used by this module to remove cache entries that
	have expired.cCs'tj
j|�

|
|_|j�
dS(
N(R�R�R'R�R�(R(R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR'�s

	
c
Cs�x�tr�|j
jd�

t�dr*dSt�}
xR|j
jj�D]>}|j|
�
rF|j
j|
|�
|j
jj	|�

qFqFWqWdS(Ni
i�Ri'(
R�R�R�R�RR�R�RYtupdateRecordR�(R(RWRR((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR��s
	




	



(RR RDR'R�(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR
�s	c
Bs2eZ
dZd
�Zd�Zd�Zd�ZRS(s�Used to browse for a service of a specific type.

	The listener object will have its addService() and
	removeService() methods called when this browser
	discovers changes in the services availability.cCs�tj
j|�

|
|_||_||_i|_t�|_t	|_
g|_d
|_|jj
|t|jtt��
|j�
dS(s%Creates a browser for a specific typeiN(R�R�R'R�R0tlistenertservicesRtnextTimet
_BROWSER_TIMEtdelayR�tdonetaddListenerRER�t	_CLASS_INR�(R(R�R0R
((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR'�s
	
	
	
	

	
		"
cs
�jt
kr
�j�
jkr
�j|�
}yi�
j�jj�}|s_|j��

n9�
j�jj�=��
fd
�}�
jj	|�

dSWnRt
k
r�


|s���
j�jj�<��
fd�}�
jj	|�

q�n
X�jd�
}|�
jkr
|�
_q
ndS(s|Callback invoked by Zeroconf when new information arrives.

		Updates information required by browser in the Zeroconf cache.c

s�
jj
|�
j�j�S(
N(R
t
removeServiceR0Rj(
R�(RRR((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt<lambda>�sNc

s�
jj
|�
j�j�S(
N(R
t
addServiceR0Rj(
R�(RRR((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR

�siK(
R0R�R/RYR
RjR-R[R�R�R&RUR
(R(R�RWRRtexpiredt	oldrecordtcallbacktexpires((RRR(s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR
�s$!















c

Csd
|_|j
j�
dS(Ni
(R	
R�t	notifyAll(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytcancel�s
	
c
Csv
xo
trq
d}
t�}t|j�
d
krV|j|krV|jj|j|�

nt�dsl|j	rpdSt�}|j|k
r(
t
t�
}|jt
|jtt��

x9|jj�D](}|j|�
s�|j||�
q�q�W|jj|�

||j|_td|jd�|_nt|j�
d
krR
|jjd
�
}
n|
dk	r|
|j�

qqWdS(NiRii�ii N(R�R@RRbR�R
R�R�R�R	
R�R�R�RER0R�R
R
R�RYR�tsendR
tmintpop(R(teventRWR\RR((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR��s*
	

	
$



	









(RR RDR'R
R
R�(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR�s
			cBs�eZ
dZddd
d
ddd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zd
�Zd�Z
d�Zd
�Zd�Zd�Zd�Zd�Zd�ZRS(sService informationic		Csz|j|
�
st
�
n|
|_||_||_||_||_||_|r`||_n	||_|j	|�

d
S(s�
Create a service description.

		type: fully qualified service type name
		name: fully qualified service name
		address: IP address as unsigned short, network byte order
		port: port that the service runs on
		weight: weight of the service
		priority: priority of the service
		properties: dictionary of properties (or a string holding the bytes for the text field)
		server: fully qualified name for service host (defaults to name)N(
RFR$R0R/R`RqRpRoRrt
setProperties(	R(R0R/R`RqRpRot
propertiesRr((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR's
	
	
	
	
	
	
	

	
cCs
t|
t
�r
|
|_g}d
}x�|
D]�}|
|}|dkrPd
}nEt|t�rh|}n-t|t�r�|r�d}q�d}nd
}|jdj||f�
�

q+Wx>|D]6}d
j|tj	dt
t|�
�
�|f�
}q�W||_n	|
|_dS(s7Sets properties and text of this info from a dictionaryR�ttruetfalset
=s!cN(
R5tdictR
R@R�R�R�R�RR�R�RbRm(R(R
R�RBR.R�tsuffixtitem((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR
%s(
	







	

	


		
 


4
cCsZ
|
|_y&
i}t
|
�
}d
}g}xL||krxt|
|�
}|d7}|j|
|||!�

||7}q-Wx�|D]�}|jd�
}|dkr�|}	d
}
nI|| }	||d}
|
dkr�d}
n|
dks�|
r�d
}
n|	r�|j|	�
dkr�|
||	<q�q�W||_Wn$tk
rU



t	j
�
d|_n
XdS(s+Sets properties and text given a text fieldii
R
i����R
R
N(RmRbR�R�tfindR�R@R
R&R�R�(R(RmRBtendR�tstrsR�R�teindexR.R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytsetText?s8	














	



	

	






c


Cs|jS(
s
Type accessor(
R0(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR=dsc

CsT|jdk	rM|jjd
|j�
rM|jt|j�
t|j�
d S|jS(s
Name accessorR�i
N(R0R@R/RFRb(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytgetNamehs(
%
c


Cs|jS(
sAddress accessor(
R`(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt
getAddressnsc


Cs|jS(
s
Port accessor(
Rq(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytgetPortrsc


Cs|jS(
sPriority accessor(
Ro(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytgetPriorityvsc


Cs|jS(
sWeight accessor(
Rp(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt	getWeightzsc


Cs|jS(
sProperties accessor(
R
(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt
getProperties~sc


Cs|jS(
s
Text accessor(
Rm(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytgetText�sc


Cs|jS(
sServer accessor(
Rr(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt	getServer�scCs
|d
k	r
|j
|�
r
|jtkrO|j|jkr
|j|_q
q
|jtkr�|j|jkr
|j|_|j|_|j	|_	|j
|_
|j|
||
jj
|jtt��
q
q
|jtkr
|j|jkr
|j|j�

q
q
nd
S(s-Updates service information from a DNS recordN(R@RYR0R�R/RrR`R�RqRpRoR
R�R�R
R�R%
Rm(R(R�RWRR((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR
�s







.


c	Cs�
t�}t
}||}||}d
}z�
|
j|t|jtt��
xu
|jdks{|j	dks{|j
dkr�
||k
r�d
S||k
r�
tt�
}|j
t|jtt��

|j|
jj|jtt�|�
|j
t|jtt��

|j|
jj|jtt�|�
|jdk	rx
|j
t|jtt��

|j|
jj|jtt�|�
n|
j|�

||}|d}n|
jt||�|�

t�}qNWd}Wd|
j|�

X|S(suReturns true if the service could be discovered on the
		network, and updates this object with details discovered.
		iii
N(Rt_LISTENER_TIMER

RER/RGR
RrR@R`RmR�R�R�R�R�R�R�R�R�R
R�R
tremoveListener(	R(R�R�RWR
R�tlastRBR\((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytrequest�s6	








0





%

%


(









cCs#t|
t
�r|
j|jkSd
S(sTests equality of service namei(R5R
R/(R(R6((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR7�s

cCs|j|
�
S(
sNon-equality test(
R7(R(R6((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR8�sc
Cs�d
|jt
j|j��
|jf}
|jdkrD|
d7}
n:t|j�
dkri|
|j7}
n|
|jd d7}
|
d7}
|
S(sString representationsservice[%s,%s:%s,R@iis...R?N(R/RcRdR'
RqRmR@Rb(R(RB((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRK�s(






N(RR RDR@R'R
R%
R=R&
R'
R(
R)
R*
R+
R,
R-
R
R1
R7R8RK(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR
s$
		%											#		cBs�eZ
dZdd
�
Zd�Zd�Zd�Zd�Zdd�
Z	d�Z
d	�Zed
�
Z
d�Zd�Zd
�Zd�Zd�Zd�Zd�Zd�Zeed�Zd�ZRS(s{Implementation of Zeroconf Multicast DNS Service Discovery

	Supports registration, unregistration, queries and browsing.
	cCs�
d
t�d<|
dkr4tjtj��
|_n	|
|_dtf|_tjtjtj	�|_y<|jj
tjtjd�
|jj
tjtj
d�
Wntk
r�


n
X|jj
tjtjd�
|jj
tjtjd�
y|jj|j�

Wntk
r



n
X|jj
tjtjtjt�
tjd�
�
g|_g|_i|_i|_t�|_tj�|_t|�
|_ t!|�
|_"t#|�
|_$dS(srCreates an instance of the Zeroconf class, establishing
		multicast communications, listening and reaping threads.iRR�i
i�s0.0.0.0N(%R�R@Rct
gethostbynametgethostnametintfR�tgrouptAF_INETt
SOCK_DGRAMt
setsockoptt
SOL_SOCKETtSO_REUSEADDRtSO_REUSEPORTR&tSOL_IPtIP_MULTICAST_TTLtIP_MULTICAST_LOOPtbindtIP_ADD_MEMBERSHIPt	inet_atonR�t	listenerstbrowsersR
tservicetypesR�R�R�R�R�R�R�R�R
R
treaper(R(tbindaddress((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR'�s6


	




 








2	
	
	
	

c

Cs|jj
d
�
S(Ns	127.0.0.1(R4
t
startswith(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt
isLoopbacks
c

Cs|jj
d
�
S(Ns169.254.(R4
RG
(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytisLinklocals
cCs2|jj
�
|jj|
d
�

|jj�
dS(sLCalling thread waits for a given number of milliseconds or
		until notified.i�N(R�R�R�R�(R(R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR�s


c


Cs+|jj
�
|jj�
|jj�
d
S(sNotifies all waiting threadsN(R�R�R
R�(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR
s



i�cCs)t|
|�}|j
||�r%|Sd
S(s�Returns network's service information for a particular
		name and type, or None if no service matches by the timeout,
		which defaults to 3 seconds.N(R
R1
R@(R(R0R/R�R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytgetServiceInfos


cCs-|j|�

|j
jt||
|��

d
S(s�Adds a listener for a particular service type.  This object
		will then have its updateRecord method called when information
		arrives for that type.N(tremoveServiceListenerRC
R�R(R(R0R
((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytaddServiceListener(s

cCs7x0|jD]%}|j
|
kr
|j�
~q
q
Wd
S(s<Removes a listener from the set that is currently listening.N(RC
R
R
(R(R
tbrowser((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRK
/s



c
Cs�
|j|
�

|
|j
|
jj�<|jj|
j�
rQ|j|
jcd
7<nd
|j|
j<t�}|}d}x+
|dkr�
||kr�|j||�

t�}qynt	t
tB�
}|jt
|
jtt||
j�d�
|jt|
jtt||
j|
j|
j|
j�d�
|jt|
jtt||
j�d�
|
jr
|jt|
jtt||
j�d�
n|j|�

|d
7}|t7}qyWdS(s�Registers service information to the network with a default TTL
		of 60 seconds.  Zeroconf will then respond to requests for
		information for that service.  The name of the service may be
		changed if needed to make it unique on the network.i
iiN(tcheckServiceR
R/R-RD
thas_keyR0RR�R�R�t	_FLAGS_AAR�RiR�R
RnR�RoRpRqRrRlR�RmR`R_R�R
t_REGISTER_TIME(R(R�RMRWR
R�R\((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytregisterService6s,




	





	


(
:
(
	
+




c
Cs�
yS|j|
j
j�=|j|
jd
krE|j|
jcd
8<n
|j|
j=Wntk
rf


n
Xt�}|}d}x+
|dkr�
||kr�|j||�

t�}qntt	t
B�
}|jt|
jt
td|
j
�d�
|jt|
j
ttd|
j|
j|
j|
j
�d�
|jt|
j
ttd|
j�d�
|
jr�
|jt|
jttd|
j�d�
n|j|�

|d
7}|t7}qWdS(sUnregister a service.i
iiN(R
R/R-RD
R0R:RR�R�R�RP
R�RiR�R
RnR�RoRpRqRlR�RmR`R_RrR�R
t_UNREGISTER_TIME(R(R�RWR
R�R\((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytunregisterServiceSs0






	





	


(
:
(
	
+




c
Csy
t|j
�
d
kru
t�}
|
}d
}xH
|dkrq
|
|kre|j||
�

t�}
q-ntttB�
}x�|j
j�D]�}|jt	|j
ttd
|j
�d
�
|jt|j
ttd
|j|j|j|j�d
�
|jt|j
ttd
|j�d
�
|jr�|jt|jttd
|j�d
�
q�q�W|j|�

|d7}|t7}q-WndS(s#Unregister all registered services.iii
N(RbR
RR�R�R�RP
R�R�RiR0R�R
R/RnR�RoRpRqRrRlR�RmR`R_R�R
RS
(R(RWR
R�R\R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pytunregisterAllServicesos&
	





	



(
:
(
	
/




cCs�
t�}|}d
}xg
|dkr~
x�|j
j|
j�
D]�}|jtkr:|j|�
r:|j|
jkr:|
jjd�
d
kr�|
jd|
j	d|
j
d|
j|
_|j|
�

dSt�
q:q:W||kr
|j
||�

t�}qntttB�
}||_|jt|
jtt��

|jt|
jttt|
j��

|j|�

|d7}|t7}qWdS(	shChecks the network for a unique service name, modifying the
		ServiceInfo passed in if it is not unique.iiR�s.[t
:s].Ni
(RR�R�R0R�RYRjR/R!
R`RqRN
R!R�R�R�RP
tdebugR�RER
R�Rit_DNS_TTLR
t_CHECK_TIME(R(R�RWR
R�RRR\((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyRN
�s,	




1

-







	


	

%




cCs�t�}|j
j|
�

|d
k	r}xU|jj|j�
D];}|j|�
r;|j|�
r;|
j	|||�
q;q;Wn|j
�
d
S(s�Adds a listener for a given question.  The listener will have
		its updateRecord method called when information is available to
		answer the question.N(RRB
R�R@R�R�R/RIRYR
R
(R(R
RJRWRR((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR

�s	





cCs6y|jj
|
�

|j�
Wntk
r1


n
Xd
S(sRemoves a listener.N(RB
R�R
R&(R(R
((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR/
�s





cCs5x$|jD]}|j
||
|�
q
W|j�
d
S(sHUsed to notify listeners of new information that has updated
		a record.N(RB
R
R
(R(RWRHR
((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR
�s

cCs�t�}x�|
j
D]�}|j|�
}||jj�kr�|rV|jj|�

q�|jj|�
}|d
k	r�|j|�

|}q�n|jj	|�

|j
||�
qWd
S(sfDeal with incoming response packets.  All answers
		are held in the cache, and listeners are notified.N(RRORYR�R�R�R�R@R[R�R
(R(RQRWRRR
R�((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR
�s	








cCsad}|t
krItttBd
�}x!|
jD]}|j|�

q/Wnx�|
jD]�}|jtkrN
|j	dkr�x[|j
j�D]G}|dkr�tttB�
}n|j|
t
dttt|��
q�WnxJ|jj�D]b}|j	|jkr�|dkr
tttB�
}n|j|
t
|jttt|j	��
q�q�WqSy�
|dkrp
tttB�
}n|jtks�
|jtkr�
xa|jj�D]M}|j|j	j�kr�
|j|
t|j	tttBt|j��
q�
q�
Wn|jj|j	j�d�}|swSn|jtks:|jtkr{|j|
t|j	tttBt|j|j|j|j��
n|jtks�|jtkr�|j|
t |j	tttBt|j!��
n|jtkr|j"t|jtttBt|j��

nWqSt#k
r!


t$j%�
qSXqSW|dk	r]|j&r]|
j'|_'|j(|||�
ndS(sEDeal with incoming query packets.  Provides a response if
		possible.is_services._dns-sd._udp.local.N()R@R�R�R�RP
RwR�R0R�R/RD
R�R�RiR
RX
R
R�R�RGRrR-R_R3R`R�R�RnRoRpRqR�RlRmR�R&R�R�ROR�R
(R(RQR

RqR\RJtstypetservice((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR��sL








)




2




6

A

/

0




cCs>y&|jj
|
j�d
||f�
Wntk
r9


n
XdS(sSends an outgoing packet.iN(RctsendtoR�R&(R(R\R

Rq((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR
s
&

c

Cs�t�d
dkr�dt�d
<|j
�
|jj�
|j�
|jjtjtjtj	t
�
tj	d�
�
|jj�
ndS(sXEnds the background threads, and prevent this instance from
		servicing further queries.Rii
s0.0.0.0N(R�R
R�R�RU
RcR8
R<
tIP_DROP_MEMBERSHIPRA
R�tclose(
R(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR^

s








2
N(RR RDR@R'RH
RI
R�R
RJ
RL
RK
RX
RR
RT
RU
RN
R

R/
R
R
R�R�R�R
R^
(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyR�s(
/															3
t__main__s3Multicast DNS Service Discovery for Python, versions'1. Testing registration of a service...s0.10tversions
test values
another valuet
bs_http._tcp.local.s!My Service Name._http._tcp.local.s	127.0.0.1i�s   Registering service...s   Registration done.s*2. Testing query of service information...s   Getting ZOE service:sZOE._http._tcp.local.s   Query done.s"3. Testing query of own service...s   Getting self:s/4. Testing unregister of service information...s   Unregister done.(eRDt
__author__t	__email__t__version__R,RRRcR�R�R�t__all__R�RS
RY
RQ
R.
R
R�R�R�RX
t_MAX_MSG_TYPICALR�R�R�R�RP
t	_FLAGS_TCt	_FLAGS_RDt	_FLAGS_RAt_FLAGS_Zt	_FLAGS_ADt	_FLAGS_CDR
t	_CLASS_CSt	_CLASS_CHt	_CLASS_HSt_CLASS_NONEt
_CLASS_ANYR1R3R�t_TYPE_NSt_TYPE_MDt_TYPE_MFR�t	_TYPE_SOAt_TYPE_MBt_TYPE_MGt_TYPE_MRt
_TYPE_NULLt	_TYPE_WKSR�R�t_TYPE_MINFOt_TYPE_MXR�R�R�RGR9R<RR&RR!R"R#R$R%R*tobjectR+RERLR_ReRiRlRnRtR�R�R�R�R�R
RR
RRt
rtdescRA
R�RR
R�RJ
RT
R^
(((s=/usr/lib64/python2.7/site-packages/hgext/zeroconf/Zeroconf.pyt<module>s
6












































































	0=��5AO��A
	
	


'