korsygfhrtzangaiide
Elepffwdsff
/
lib64
/
python2.7
/
site-packages
/
hgext
/
inotify
/
linux
/
Upload FileeE
HOME
� Hq�Qc @ s� d Z d Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d e f d � � YZ i d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d! 6d" d# 6d$ d% 6Z xj e j � D]\ \ Z Z e e d& e j � � Z d' � Z e e _ e e _ e e e e e d( e �� q� W[ d) e f d* � � YZ d+ e f d, � � YZ d- e f d. � � YZ d S(/ 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����Nt eventc B s& e Z d Z d Z d � Z d � Z RS( s Derived 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 eventt cookiet fullpatht maskt namet patht rawt wdc C so | | _ | | _ | j r2 | d | j | _ n | | _ | j | _ | j | _ | j | _ | j | _ d S( Nt /( R R R R R R R ( t selfR R ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt __init__< s c C s9 t | j � } d t | j � d | | j d � d S( Ns event(path=s , t (i ( t reprR R t find( R t r( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt __repr__I s ( s cookies fullpaths masks names paths raws wd( t __name__t __module__t __doc__t __slots__R R ( ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR s s File was accessedt accesss File was modifiedt modifys* Attribute of a directory entry was changedt attribs& File was closed after being written tot close_writes( File was closed without being written tot close_nowrites File was openedt opens* Directory entry was renamed from this namet moved_froms( Directory entry was renamed to this namet moved_tos Directory entry was createdt creates Directory entry was deletedt deletes' The watched directory entry was deletedt delete_selfs' The watched directory entry was renamedt move_selfs5 Directory was unmounted, and can no longer be watchedt unmounts+ Kernel dropped events due to queue overflowt q_overflows* Directory entry is no longer being watchedt ignoreds Event occurred on a directoryt isdirt IN_c C s | j t @S( N( R ( R ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt getterc s t doct watcherc B s� e Z d Z d Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d d � Z d � Z d � Z d � Z d � Z e j e j e j g Z d d � Z d d � Z RS( 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.t fdt _pathst _wdsc C s% t j � | _ i | _ i | _ d S( s Create a new inotify instance.N( t inotifyt initR( R) R* ( R ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR x s c C s | j S( 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.pyt fileno s c C sT t j j | � } t j | j | | � } | | f | j | <| | f | j | <| S( sN Add or modify a watch. Return the watch descriptor added or modified.( t osR t normpathR+ t add_watchR( R) R* ( R R R R ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt add� s c C s$ t j | j | � | j | � d S( s Remove the given watch.N( R+ t remove_watchR( t _remove( R R ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt remove� s c C s< | j j | d � } | d k r8 | j j | d � n d S( Ni ( R* t popt NoneR) ( R R t path_mask( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR3 � s c C s | j j | � S( sx Return a (watch descriptor, event mask) pair for the given path. If the path is not being watched, return None.( R) t get( R R ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR � s c C s | j j | � 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 � s c C s� g } x� t j | j | � D]j } | j t | | j | j d � � | j t j @ri | j | j � q | j t j @r | j � q q W| 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+ t readR( t appendR R* R R t IN_IGNOREDR3 t IN_UNMOUNTt close( R t bufsizet eventst evt( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR9 � s $c C s/ t j | j � d | _ d | _ d | _ d S( s\ Shut down this watcher. All subsequent method calls are likely to raise exceptions.N( R. R= R( R6 R) R* ( R ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR= � s c C s t | j � S( s$ Return the number of active watches.( t lenR) ( R ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt __len__� s c c s8 x1 | j j � D] \ } \ } } | | | f Vq Wd S( sX Yield a (path, watch descriptor, event mask) tuple for each entry being watched.N( R) t iteritems( R R R R ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt __iter__� s "c C s& | j d k r" t j | j � n d S( N( R( R6 R. R= ( R ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt __del__� s c c s� | t j B} y | j | | � VWn8 t k r\ } | r] | j | j k r] | | � q] n Xx� t j | d t d | �D]x \ } } } xf | D]^ } y | j | d | | � VWq� t k r� } | r� | j | j k r� | | � q� q� Xq� Wqy Wd S( 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.t topdownt onerrorR N( R+ t IN_ONLYDIRR1 t OSErrort errnot ignored_errorsR. t walkt False( R R R RG t submaskt errt roott dirst namest d( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt add_iter� s + c C s& g | j | | | � D] } | ^ q S( 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 R R RG t w( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt add_all� s ( s fds _pathss _wdsN( R R R R R R- R1 R4 R3 R R R6 R9 R= RB RD RE RJ t ENOENTt EPERMt ENOTDIRRK RT RV ( ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR' l s& 't autowatcherc B s< e Z d Z d Z d d � Z e j e j BZ d d � Z RS( sC watcher class that automatically watches newly created directories.t addfilterc C s t t | � 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( t superRZ R R[ ( R R[ ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR s c C s� t t | � j | � } x� | D]� } | j | j @| j k r | j d k s\ | j | � r� | j | j d } | t j B} y | j | j | � Wq� t k r� } | j | j k r� � q� q� Xq� q q W| S( Ni ( R\ RZ R9 R t _dir_create_maskR[ R6 R* R R+ RH RV R RI RJ RK ( R R> R? R@ t parentmaskR RO ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR9 $ s ( s addfilterN( R R R R R6 R R+ t IN_ISDIRt IN_CREATER] R9 ( ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyRZ s t thresholdc B s2 e Z d Z d Z d d � Z d � Z d � Z RS( s� Class that indicates whether a file descriptor has reached a threshold of readable bytes available. This class is not thread-safe.R( Ra t _iocbufi c C s. | | _ | | _ t j d d g � | _ d S( Nt ii ( R( Ra t arrayRb ( R R( Ra ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyR @ s c C s* t j | j t j | j t � | j d S( s< Return the number of bytes readable on this file descriptor.i ( t fcntlt ioctlR( t termiost FIONREADRb t True( R ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt readableE s c C s | j � | j k S( sX Indicate whether the number of readable bytes has met or exceeded the threshold.( Rj Ra ( R ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt __call__K s ( s fds thresholds _iocbuf( R R R R R Rj Rk ( ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyRa 4 s ( R t __author__t _inotifyR+ Rd RJ Re R. Rg t objectR t _event_propsRC t kt vt getattrt upperR R% R t setattrt propertyR' RZ Ra ( ( ( sA /usr/lib64/python2.7/site-packages/hgext/inotify/linux/watcher.pyt <module> sF . �(