�
Hq�Qc@s�
dZd
Z
ddlZddlZddlZddlZddlZddlZde	f
d��YZ
idd6dd	6d
d6dd
6dd6dd6dd6dd6dd6dd6dd6dd6dd6d d!6d"d#6d$d%6Zxjej�D]\\Z
Zeed&e
j��Zd'�Ze
e_ee_ee
e
eed(e�

�
q�W[d)e	f
d*��YZd+ef
d,��YZd-e	f
d.��YZdS(/s�
High-level interfaces to the Linux inotify subsystem.

The inotify subsystem provides an efficient mechanism for file status
monitoring and change notification.

The watcher class hides the low-level details of the inotify
interface, and provides a Pythonic wrapper around it.  It generates
events that provide somewhat more information than raw inotify makes
available.

The autowatcher class is more useful, as it automatically watches
newly-created directories on your behalf.s%Bryan O'Sullivan <bos@serpentine.com>i����NteventcBs&eZ
dZd
Zd�Zd	�ZRS(sDerived inotify event class.

    The following fields are available:

        mask: event mask, indicating what kind of event this is

        cookie: rename cookie, if a rename-related event

        path: path of the directory in which the event occurred

        name: name of the directory entry to which the event occurred
        (may be None if the event happened to a watched directory)

        fullpath: complete path at which the event occurred

        wd: watch descriptor that triggered this eventtcookietfullpathtmasktnametpathtrawtwdcCso||_|
|_
|
jr2|d
|
j|_n	||_|
j|_|
j|_|
j|_|
j|_dS(Nt
/(RRRRRRR
(tselfRR((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt__init__<s
	
	
	
	


c
Cs9t|j
�
}
d
t|j�
d|
|
jd�
dS(Nsevent(path=s, t
(i
(treprRRtfind(R	t
r((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt__repr__Is

(scookiesfullpathsmasksnamespathsrawswd(t__name__t
__module__t__doc__t	__slots__R
R(((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR s





	
sFile was accessedtaccesssFile was modifiedtmodifys*Attribute of a directory entry was changedtattribs&File was closed after being written totclose_writes(File was closed without being written tot
close_nowritesFile was openedtopens*Directory entry was renamed from this namet
moved_froms(Directory entry was renamed to this nametmoved_tosDirectory entry was createdtcreatesDirectory entry was deletedtdeletes'The watched directory entry was deletedtdelete_selfs'The watched directory entry was renamedt	move_selfs5Directory was unmounted, and can no longer be watchedtunmounts+Kernel dropped events due to queue overflowt
q_overflows*Directory entry is no longer being watchedtignoredsEvent occurred on a directorytisdirtIN_c

Cs|jt@S(
N(
R(
R	((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pytgettercs
tdoctwatchercBs�eZ
dZdZd�Zd�Zd�Zd�Zd�Zd	�Z	d
�Z
dd�
Zd�Z
d
�Zd�Zd�ZejejejgZdd�
Zdd�
ZRS(s�Provide a Pythonic interface to the low-level inotify API.

    Also adds derived information to each event that is not available
    through the normal inotify API, such as directory name.tfdt_pathst_wdsc

Cs%tj
�|_i|_i|_d
S(sCreate a new inotify instance.N(tinotifytinitR(R)R*(
R	((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR
xs
	
c


Cs|jS(
s]Return the file descriptor this watcher uses.

        Useful for passing to select and poll.(
R((
R	((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pytfilenoscCsTtj
j|
�
}
tj|j|
|�}||f|j|
<|
|f|j|<|S(
sNAdd or modify a watch.

        Return the watch descriptor added or modified.(tosRtnormpathR+t	add_watchR(R)R*(R	RRR((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pytadd�s




cCs$tj
|j|
�
|j|
�

d
S(sRemove the given watch.N(R+tremove_watchR(t_remove(R	R((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pytremove�s
cCs<|jj
|
d�}|dk	r8|jj
|d
�

ndS(Ni(R*tpoptNoneR)(R	Rt	path_mask((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR3�s


cCs|jj
|
�
S(
sxReturn a (watch descriptor, event mask) pair for the given path.

        If the path is not being watched, return None.(R)tget(R	R((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR�scCs|jj
|
�
S(
s�Return a (path, event mask) pair for the given watch descriptor.

        If the watch descriptor is not valid or not associated with
        this watcher, return None.(R*R8(R	R((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR�scCs�g}x�tj
|j|
�D]j}|jt||j|jd
��

|jtj@ri|j	|j�

q|jtj
@r|j�
qqW|S(s�Read a list of queued inotify events.

        If bufsize is zero, only return those events that can be read
        immediately without blocking.  Otherwise, block until events are
        available.i(R+treadR(tappendRR*RRt
IN_IGNOREDR3t
IN_UNMOUNTtclose(R	tbufsizeteventstevt((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR9�s

$




c

Cs/tj
|j�

d
|_d
|_d
|_d
S(s\Shut down this watcher.

        All subsequent method calls are likely to raise exceptions.N(R.R=R(R6R)R*(
R	((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR=�s
	
	
c

Cs
t|j
�
S(
s$Return the number of active watches.(tlenR)(
R	((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt__len__�sc
cs8x1|jj
�D] \}
\}}|
||fV
qWd
S(sXYield a (path, watch descriptor, event mask) tuple for each
        entry being watched.N(R)t	iteritems(R	RRR((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt__iter__�s"
c

Cs&|jdk	r"tj|j�

ndS(
N(R(R6R.R=(
R	((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt__del__�s

c
cs�|tj
B}y|j|
|�V
Wn8tk
r\
}
|r]|j|jkr]||�

q]n
Xx�tj|
d
td|�
D]x\}}}xf|D]^}	y|j|d|	|�V
Wq�tk
r�
}
|r�|j|jkr�||�

q�q�Xq�WqyWdS(s}Add or modify watches over path and its subdirectories.

        Yield each added or modified watch descriptor.

        To ensure that this method runs to completion, you must
        iterate over all of its results, even if you do not care what
        they are.  For example:

            for wd in w.add_iter(path, mask):
                pass

        By default, errors are ignored.  If optional arg "onerror" is
        specified, it should be a function; it will be called with one
        argument, an OSError instance.  It can report the error to
        continue with the walk, or raise the exception to abort the
        walk.ttopdowntonerrorRN(	R+t
IN_ONLYDIRR1tOSErrorterrnotignored_errorsR.twalktFalse(
R	RRRGtsubmaskterrtroottdirstnamest
d((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pytadd_iter�s





+






cCs&g|j|
||�D]}|^qS(
s�
Add or modify watches over path and its subdirectories.

        Return a list of added or modified watch descriptors.

        By default, errors are ignored.  If optional arg "onerror" is
        specified, it should be a function; it will be called with one
        argument, an OSError instance.  It can report the error to
        continue with the walk, or raise the exception to abort the
        walk.(
RT(R	RRRGt
w((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pytadd_all�s(sfds_pathss_wdsN(RRRRR
R-R1R4R3RRR6R9R=RBRDRERJtENOENTtEPERMtENOTDIRRKRTRV(((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR'ls&

								
			'tautowatchercBs<eZ
dZdZdd�
ZejejBZ	dd�
Z
RS(sCwatcher class that automatically watches newly created directories.t	addfiltercCs tt
|�j�
|
|_d
S(s�
Create a new inotify instance.

        This instance will automatically watch newly created
        directories.

        If the optional addfilter parameter is not None, it must be a
        callable that takes one parameter.  It will be called each time
        a directory is about to be automatically watched.  If it returns
        True, the directory will be watched if it still exists,
        otherwise, it will be skipped.N(tsuperRZR
R[(R	R[((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR

s
cCs�tt
|�j|
�
}x�|D]�}|j|j@|jkr|jdks\|j|�
r�|j|jd
}|t	j
B}y|j|j|�
Wq�t
k
r�
}
|j|jkr��q�q�Xq�qqW|S(Ni
(R\RZR9Rt_dir_create_maskR[R6R*RR+RHRVRRIRJRK(R	R>R?R@t
parentmaskRRO((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR9$
s












(
s	addfilterN(RRRRR6R
R+tIN_ISDIRt	IN_CREATER]R9(((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyRZ
s

t	thresholdcBs2eZ
dZdZdd�
Zd�Zd�ZRS(	s�Class that indicates whether a file descriptor has reached a
    threshold of readable bytes available.

    This class is not thread-safe.R(Rat_iocbuficCs.|
|_||_
tjd
dg
�|_dS(Nt
ii(R(RatarrayRb(R	R(Ra((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR
@
s
	
	
c

Cs*tj
|jtj|jt�
|jd
S(s<Return the number of bytes readable on this file descriptor.i(tfcntltioctlR(ttermiostFIONREADRbtTrue(
R	((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pytreadableE
s
c

Cs|j�|j
kS(
sXIndicate whether the number of readable bytes has met or
        exceeded the threshold.(RjRa(
R	((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt__call__K
s(sfds	thresholds_iocbuf(RRRRR
RjRk(((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyRa4
s

	(Rt
__author__t_inotifyR+RdRJReR.RgtobjectRt_event_propsRCt
kt
vtgetattrtupperRR%RtsetattrtpropertyR'RZRa(((sA/usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt<module>sF




.


















		
	
 �(