�
Hq�Qc@s�dd
lm
Z

ddlZddlZddlZddlZddlZddlZdef
d��YZ	d�Z
def
d��YZdS(i����(
t
_NtQueryFailedc
BseZ
RS((t__name__t
__module__(((s:/usr/lib64/python2.7/site-packages/hgext/inotify/client.pyR
s
c
s�f
d
�}
|
S(s�
    Decorator.
    Tries to call function, if it fails, try to (re)start inotify server.
    Raise QueryFailed if something went wrong
    c

sy�||
�
SWn�
tt
jfk
r�

}
|jjd
dt�}|jdtjkr�|jj	t
d�
�

tjtj
j|jdd��

n|jdtjtjfkr�
|r�
yey2tj|j|j|jtdtdd	��
Wn,tjk
r

}
|jjt|�
�

n
XWn-tk
rN

}
|jj	t
d
�
|�

q�
Xy�||
�
SWq�
t
jk
r�

}
|jj	t
d�
|jd�

q�
Xq�
|jdtjtjfkr�
|jjd
�

q�
|jj	t
d�
|jd�

n
X|jj�
td�
�
dS(Ntinotifyt	autostartis>inotify-client: found dead inotify server socket; removing it
s.hgsinotify.socktdaemontdaemon_pipefdsts3inotify-client: could not start inotify server: %s
s9inotify-client: could not talk to new inotify server: %s
i����s(inotify server not running)
s5inotify-client: failed to contact inotify server: %s
sinotify query failed(tOSErrortsocketterrortuit
configbooltTruetargsterrnotECONNREFUSEDtwarnRtostunlinktpathtjointroottENOENTtservertstarttdirstatetdicttAlreadyStartedExceptiontdebugtstrt	Exceptiont	tracebackR
(tselfRterrRtinst(
tfunction(s:/usr/lib64/python2.7/site-packages/hgext/inotify/client.pytdecorated_functions8




%
%















((R%R&((
R%s:/usr/lib64/python2.7/site-packages/hgext/inotify/client.pytstart_servers&tclientcBsVeZ
d�Zd
�Zd�Zd�Zd�Zeed�
�
Z	ed��
Z
RS(cCs:|
|_|j
|_
|j|_tjtj�
|_dS(
N(RRRR
tAF_UNIXtsock(R"Rtrepo((s:/usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt__init__As
	


c
Cs�tj
j|jd
d�}
y|jj|
�

WnNtjk
r
}
|jddkrytj	|
�
}
|jj|
�

q��n
XdS(Ns.hgsinotify.sockisAF_UNIX path too long(
RRRRR*tconnectR
RRtreadlink(R"tsockpathR#((s:/usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt_connectGs






cCs8|jj
ttj�
|
|�

|jjtj�

d
S(s+Sends protocol version number, and the dataN(R*tsendalltchrtcommontversiontshutdownR
tSHUT_WR(R"ttypetdata((s:/usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt_sendRs!cCsI
tj
|j�
}yt|jd
�
�
}Wn3tk
r`


|jjtd�
�

t	d�
�
n
X|tj
kr�|jjtd�
|�

t	d�
�
n|jd�
}||
kr�|jjtd�
||
f�

t	d�
�
ntj|
}tj|
}yt
j||j|�
�}Wn t
jk
r>



t	d	�
�
n
X||fS(
s�
        Read data, check version number, extract headers,
        and returns a tuple (data descriptor, header)
        Raises QueryFailed on error
        i
s9inotify-client: received empty answer from inotify serversserver crashedsA(inotify: received response from incompatible server version %d)
sincompatible server versionis6(inotify: received '%s' response when expecting '%s')
swrong response types)unable to retrieve query response headers(R3trecvcsR*tordtreadt	TypeErrorRRRR
R4tresphdrfmtstresphdrsizeststructtunpackR(R"R7tcsR4treadtypethdrfmtthdrsizetresphdr((s:/usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt_receiveXs,

















cCs'|j�
|j
|
|�
|j|
�
S(
N(R0R9RG(R"R7treq((s:/usr/lib64/python2.7/site-packages/hgext/inotify/client.pytquery{s

cs�����fd
�}dj|��
}|j
d|�\�
}�
�fd�}	tt|	|d ��
}
�r�|d}�
j|�
}|r�x'|jd�
D]}
�j|
�

q�Wq�n|
S(Nc3s`x�D]}|V
qWd
}
�
r1td�
�
n�rD|
d7}
n�rW|
d7}
n|
V
dS(Nsalmrx!sthis is insanityt
ct
?(
t
ValueError(t
ntstates(tcleantignoredtnamestunknown(s:/usr/lib64/python2.7/site-packages/hgext/inotify/client.pytgenquery�s


	









t
tSTATc
s8|r4�j|�
}
|
r4t
�
|
jd
�
�SngS(NRT(R<tfiltertsplit(tnbytesRQ(RBtmatch(s:/usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt	readnames�s





i����(RRIttupletmapR<RWtdir(R"RQRYRPRORRRSRHRFRZtresultsRXtvdirstvdir((RORBRPRYRQRRs:/usr/lib64/python2.7/site-packages/hgext/inotify/client.pytstatusquery�s





c
Cs>|jd
d�\}
}|d}|
j
|�
}|jd�
S(NtDBUGRiRT(RIR<RW(R"RBRFRXRQ((s:/usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt
debugquery�s


(RRR,R0R9RGRIR'RRaRc(((s:/usr/lib64/python2.7/site-packages/hgext/inotify/client.pyR(@s
				#	
#(
tmercurial.i18nRR3RRRR
R@R R
R'tobjectR((((s:/usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt<module>
s


0	/