�
Hq�Qc@s^
dd
lm
Z

ddlmZmZmZmZ
ddlZddlZddl	Z	ddl
Z
ddlZddlZddl
Z
def
d��YZdef
d��YZd�Zd	�ZejejfZd
�Zdef
d��YZd
ef
d��YZdef
d��YZe
jjd�
rB
ddlZne�
ej Z d�Z!dS(i����(
t
_(tcmdutiltposixtosutiltutilNtAlreadyStartedExceptionc
BseZ
RS((t__name__t
__module__(((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyRs
tTimeoutExceptionc
BseZ
RS((RR(((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyRs
cCs.|r*|d
dkr||
S|d|
S|
S(Ni����t
/((t
at
b((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pytjoins





c
Cs;|jd
�
}
|
dkr%d|fS||
 ||
dfS(NR	i����ti
(
trfind(tpatht
c((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pytsplits




cs(��
�fd
���||dk�S(s,Like os.walk, but only yields regular files.c
3sC
gg}}y�t�|�}x�t
j|�
D]�\}}|tjkr�|d
krc|
s�dSq�|j|�

t||�}�
j|�
r�q/nxG�|t�D]}|V
q�Wq/|tjtj	fkr/|j|�

q/q/W|||fV
WnKt
k
r>

}	
|	jtjkr&
|||fV
q?
|	jt
kr?
�q?
n
XdS(Ns.hg(RRtlistdirtstattS_IFDIRtappendt_ignoretFalsetS_IFREGtS_IFLNKtOSErrorterrnotENOTDIRtwalk_ignored_errors(
troottreporoottfilestdirstfullpathtnametkindRtresultterr(tabsroottdirstatetwalkit(s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR),s,



















R
((R(R'R((R'R(R)s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pytwalk'st	directorycBs8eZ
dZd
d�
Zd�Zdd�
Zd�ZRS(s[

    Representing a directory

    * path is the relative path from repo root to this directory
    * files is a dict listing the files in this directory
        - keys are file names
        - values are file status
    * dirs is a dict listing the subdirectories
        - key are subdirectories names
        - values are directory objects
    R
cCs|
|_i|_
i|_dS(
N(RR R!(tselftrelpath((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt__init__Ws
	
	
cCs�|
s
|S|
jd
�
}|}xi|r�|j
d�
}y|j|}Wq"tk
r�


tt|j|��
}||j|<|}q"Xq"W|S(s�
        Returns the directory contained at the relative path relpath.
        Creates the intermediate directories if necessary.
        R	i(RtpopR!tKeyErrorR+RR(R,R-t
ltrettnextt
d((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pytdir\s



	









ccs�xC|jj
�D]2\}}||
krt|j|�|fV
qqWxU|jj�D]D}|d
k	r{|j|j�

nx|j|
�
D]}|V
q�WqVWd
S(s�
        yield (filename, status) pairs for items in the trees
        that have status in states.
        filenames are relative to the repo root
        N(	R t	iteritemsRRR!t
itervaluestNonetaddR*(R,tstatestvisitedtfiletstR5t
e((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR*os






ccs)
|d
dkr|d
 }n|jd�
}|j
�}|}y"x|D]}|j|}qHWWn"tk
r�


|j|j�

dSXyI|j|}|j|j�

x%|j|
|�D]\}	}
|	V
q�WWnTtk
r$



y/|j||
kr
|j|j�

|V
nWq%
tk
r 



q%
Xn
XdS(s�
        yield root-relative filenames that match path, and whose
        status are in states:
        * if path is a file, yield path
        * if path is a directory, yield directory files
        * if path is not tracked, yield nothing
        i����R	N(RR/R!R0R9RR*R (R,R:RR;tpathstlastttreeR5ttargetR<R=((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pytlookup~s.




















N(RRt__doc__R.R5R8R*RC(((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR+Ks

	trepowatcherc
BsweZ
dZd
Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zd
�Zd�Z
d�ZRS(
s 
    Watches inotify events
    salmr!?cCs�|
|_||_
t|d
�|_t|j�
|_t�|_i|_t	g|j
D]}|t�f^qX�
|_|j�|_
d|_dS(NR
(tuiR(Rtwprefixtlent	prefixlenR+RAt	statcachetdictt
statuskeyststatustreest
dirstate_infotds_infoR8t
last_event(R,RFR(Rt
s((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR.�s
	
	

	
.c


CsdS(
N((
R,((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pythandle_timeout�s
c
Cs]y*tj
|jd
�
}
|
j|
jfSWn,tk
rX
}
|jtjkrT�ndSXdS(Ns.hg/dirstatei(ii(tostlstatRGtst_mtimetst_inoRRtENOENT(R,R=R&((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyRN�s






c
Cs�y$|jj
|
d
 \}}}}Wntk
r=


d}n
X|dkr�|\}}}	|dkridS|r�||ks�||Ad@r�dS|t|	�
kr�dSdS|dkr�|jj|
�
r�dS|S(	Nit
?t
ni����R1i@t
mt
i(R(t_mapR0tintt
_dirignore(
R,tfnR=ttype_tmodetsizettimetst_modetst_sizeRU((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt
filestatus�s 

$








 





cCs |j|
|j
|
|��
d
S(s�
        update the file entry of an existing file.

        osstat: (mode, size, time) tuple, as returned by os.lstat(wfn)
        N(t
_updatestatusRf(R,twfntosstat((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt
updatefile�scCsW|d
krd
}n|dkr*d}nd}|j
j|
d�
|j|
|�
dS(s�
        update the entry of a file which has been deleted.

        oldstatus: char in statuskeys, status of the file before deletion
        t
rtalmnt
!N(R8RJR/Rg(R,Rht	oldstatust	newstatus((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt
deletefile�s
	

	
cCs 
t|
�
\}}|j
j|�
}|jj|�
}|jjrt||krt|jjtd
�
|
||f�

n|r�||j	kr�||kr�|j
|j|�
j|=n|dkr�|jj|d�
nH||kr
||j|<|dkr
||j
|j|�
j|<q
ndS(s�
        Update the stored status of a file.

        newstatus: - char in (statuskeys + 'ni'), new status to apply.
                   - or None, to stop tracking wfn
        sstatus: %r %s -> %s
R[RYN(NR[(
RRAR5R tgetRFt	debugflagtnoteRRLRMR8R/(R,RhRoRR_R4Rn((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyRg�s










cCs�g}xC|j|
j
|
�
D]+\}}||jkr|j|�

qqWxP|D]H}t|�
\}}|j|
j|�
j|=|jj|�
j|=qSWdS(
N(RMR*R(RRR5R RA(R,tkeytnukeRhtignoreRR_((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt
check_deleted
s
#






c

CsSd
|jj
krOt|jd
�
|jjtd�
�

|j�
|j�
ndS(NRs#rescanning due to .hgignore change
(R(t__dict__tdelattrRFRsRRRtscan(
R,((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pytupdate_hgignore 
s





cCsfy|j|
SWnPt
k
ra


y|j|
�
SWqbtk
r]
}
|jtjkr^�q^qbXn
XdS(
N(RJR0RRRRW(R,twpathR&((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pytgetstat1
s








cCsvyHtj
t|j|
��
}|j|j|jf}||j|
<|SWn'tk
rq


|jj	|
d�
�n
XdS(
N(RSRTRRGRdReRURJRR/R8(R,R|R=R2((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR;
s









(RRRDRLR.RRRNRfRjRpRgRwR{R}R(((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyRE�s
												
tsocketlistenerc
Bs2eZ
dZd
�Zd�Zd�Zd�ZRS(s@
    Listens for client queries on unix socket inotify.sock
    cs�|
|_||_
y"tj�f
d
�d�|_WnJttjfk
r�
}
|jdt	j
krzttd�
�
�
n�n
X|jj
|_
dS(Nc

stj
j�d
|�S(Ns.hg(RSRR(
t
p(
R(s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt<lambda>N
stinotifyis%cannot start: socket is already bound(RFRERtunixdomainservertsockRtsocketterrortargsRt
EADDRINUSERRtfileno(R,RFRREttimeoutR&((
Rs:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR.I
s
	
	







csH
|
j�j
d
�
��j�}|jjtd�
|�

t��
�sVd�}n��
fd�}g|d|jjd�|d|jjd�|d|jjd�|d|jjd�|d	|jjd	�d
|kr�|d
|jjd
�p

ggd|kr%
|d|jj	�p(
g�
g	D]}d
j
|�
^q/
S(
Nt
sanswering query for %r
css)x"|
j|�
D]\}}|V
qWdS(
N(
R*(R:RAR_tstate((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt	genresult`
s

c3s:x3�D]+}x"|
j||�
�D]}|V
q#WqWdS(
N(
RC(R:RAR_t
f(tnamesR;(s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR�d
s



R1RZR
RkRmRXRRY(treadRR/RFRsRtsetRERMRAR(R,tcsR:R�Rk((R�R;s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pytanswer_stat_queryW
s&
	











$
c

Csd
j|j
j��
g
S(NR�(RREtdebug(
R,((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pytanswer_dbug_queryw
s
c
	Cs�
|jj
�\}
}tj|
�
}t|jd
�
�
}|tjkr�|jjt	d�
|�

y|
j
ttj�
�

Wntj
k
r�


n
XdS|jd�
}|dkr�|j|�
}n9|dkr�|j�}n|jjt	d�
|�

dSyrzZttj�
}|
j
||tjtj|tt|��
�

|
j
dj|�
�

Wd|
jtj�

XWn2tj
k
r�

}
|jdtjkr�
�q�
n
XdS(	Ni
s3received query from incompatible client version %d
itSTATtDBUGsunrecognized query type: %s
R
i(R�taccepttcommontrecvcstordR�tversionRFtwarnRtsendalltchrR�R�R�R�tstructtpacktresphdrfmtstmapRHRtshutdowntSHUT_WRR�RtEPIPE(	R,R�taddrR�R�ttypetresultst
vR&((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pytaccept_connectionz
s8


















(RRRDR.R�R�R�(((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR~E
s

		 	tlinuxc	s\
|jd
�
��r(t
��
d�nd�dtf
��
��fd��Y}dtjkr~tj�dd�
g}ntj�tjd}�jdd	�}|d
r�|dk	r�d|kr�|j	d|�

n|�}�jdd
�}�j
ddt�}�jddj
|�
�

tj|d|jd|jd|d|d|�

dS(Ntidle_timeouti`�tservicecs)eZ
��
��fd�Zd
�ZRS(c
sIyt���
��|_Wn&t
k
rD
}

tjd
|
�
�
n
XdS(Nsinotify-server: %s(tmasterRRtAbort(R,tinst(R(RR�RF(s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pytinit�
s



c

Ss>z)y|jj
�
Wntk
r'


n
XWd|jj�
XdS(
N(R�trunRR�(
R,((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR��
s





(RRR�R�((R(RR�RF(s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR��
s
tinserves-Ri
R�tpidfiletdaemonspid-files
--pid-file=%stlogt	appendpidsstarting inotify server: %s
t
 tinitfntrunfntlogfiletrunargs(RqtfloatR8tobjecttsystargvRthgcmdtconfigRt
configboolRR�RR
R�R�R�(	RFR(RtoptsR�R�R�R�R�((R(RR�RFs:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pytstart�
s"


%

"
	


("tmercurial.i18nRt	mercurialR
RRRR�RRSR�RR�R�t	ExceptionRRRRRWtENAMETOOLONGRR*R�R+RER~tplatformt
startswithtlinuxservert_servertImportErrorR�R�(((s:/usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt<module>s,
"





			$\�]