korsygfhrtzangaiide
Elepffwdsff
/
lib64
/
python2.7
/
site-packages
/
hgext
/
inotify
/
Upload FileeE
HOME
� Hq�Qc @ s: d d l m Z d d l m Z m Z m 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 d l Z y d d l Z d d l m Z Wn e k r� � n Xd � Z d � Z d e f d � � YZ d � Z d e j e f d � � YZ d e j e f d � � YZ d e f d � � YZ d S( i����( t _( t osutilt utilt errorN( t watcherc s" � � � f d � � � d t � S( sp Iterate over all subdirectories of this repo. Exclude the .hg directory, any nested repos, and ignored dirs.c 3 s� t j � | � } y� x� t j | � D]} \ } } | t j k r% | d k rY | s� d Sq� t j | | � } � j | � r� q% n x � | t � D] } | Vq� Wq% q% WWn+ t k r� } | j t j k r� � q� n X| Vd S( Ns .hg( t servert joinR t listdirt statt S_IFDIRt _ignoret Falset OSErrort errnot walk_ignored_errors( t dirnamet topt fullpatht namet kindt dt subdirt err( t absroott dirstatet walkit( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR s t ( t True( R R ( ( R R R s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt walkrepodirs s c C s\ d } y t t j | � � } Wn@ t k ra } | j t j k rI � n t j t d � � � n X| j t d � | � | j t d � � | j t d � � t t t | | � � � } | j t d � | � t | d � } x" | | | d k r| d 9} q� W| j t d � | | f � | j t d � | | f � t j t d � | � � d S( Ns% /proc/sys/fs/inotify/max_user_watchess, this system does not seem to support inotifysF *** the current per-user limit on the number of inotify watches is %s sF *** this limit is too low to watch every directory in this repository s *** counting directories: s found %d i g�������?i s4 *** to raise the limit from %d to %d (run as root): s *** echo %d > %s s3 cannot watch %s until inotify watch limit is raised( t intR t readfilet IOErrorR t ENOENTt AbortR t warnt lent listR t min( t uiR t rootabst patht limitR t ndirst newlimit( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt _explain_watch_limit, s* t pollablec B sn e Z d Z e j Z i Z e j � Z d � Z d � Z d � Z d � Z d � Z d � Z e d � � Z RS( s Interface to support polling. The file descriptor returned by fileno() is registered to a polling object. Usage: Every tick, check if an event has happened since the last tick: * If yes, call handle_events * If no, call handle_timeout c C s t � d S( N( t NotImplementedError( t self( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt filenoS s c C s t � d S( N( R. ( R/ t events( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt handle_eventsV s c C s t � d S( N( R. ( R/ ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt handle_timeoutY s c C s t � d S( N( R. ( R/ ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt shutdown\ s c C sE | j � } t j j | t j � | t j | <t | _ | | _ d S( N( R0 R- t pollt registert poll_eventst instancesR t registeredt timeout( R/ R: t fd( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR6 _ s c C s t j j | � t | _ d S( N( R- R5 t unregisterR R9 ( R/ ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR< h s c C sE x>t r@d } d } xT | j j � D]C } | j d k r% | d k sU | j | k r% | j | } } q% q% Wy | j j | � } Wn5 t j k r� } | j d t j k r� q n � n X| r*i } x- | D]% \ } } | j | g � j | � q� WxD | j � D] \ } } | j | j | � qWq | r | j � q q Wd S( Ni ( R t NoneR8 t itervaluesR: R5 t selectR t argsR t EINTRt setdefaultt appendt iteritemst handle_polleventsR3 ( t clsR: t timeobjt objR1 R t by_fdR; t event( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt runl s* ( t __name__t __module__t __doc__R? t POLLINR7 R8 R5 R0 R2 R3 R4 R6 R< t classmethodRK ( ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR- E s c s � f d � } | S( s8 Decorator to help handle events in repowatcher c s" � � f d � } � j | _ | S( Nc sY � d k r2 | | j k r2 | j | d k r2 d S� | j | <d | _ � | | � d S( Nt mt cmi� ( t lasteventR: ( R/ t wpath( t codet f( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt wrapper� s ( t func_name( RV RW ( RU ( RV s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt decorator� s ( ( RU RY ( ( RU s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt eventaction� s t repowatcherc B s e Z d Z e j e j Be j Be j Be j Be j Be j Be j Be j Be j Bd BZ d � Z d � Z d � Z d � Z d d � Z e d � d � � Z e d � d � � Z e d � d � � Z d � Z d � Z d � Z d � Z d � Z d d � Z d � Z d � Z d � Z! RS( s Watches inotify events i c C s� t j j | | | | � i | _ t | _ y t j � | _ Wn/ t k ro } t j t d � | j � � n Xt j | j � | _ | j j | _ | j d d � | j � | j � d S( Ns! inotify service not available: %sR: ( R R[ t __init__RS R t dirtyR R R R! R t strerrort thresholdR0 R6 R= R3 t scan( R/ R& R t rootR ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR\ � s c C sh | j } t j � } | | _ | d k r. d S| | } | d k rL d | S| d k r` d | Sd | S( Nt starti s +%.3fi2 s +%.2fs +%.1f( t last_eventt timeR= ( R/ t lastt nowt delta( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt event_time� s c C s� | s d S| j j | � d k r� | j j rR | j j t d � | | j � n y | j j | | � Wq� t k r� } | j t j t j f k r� d S| j t j k r� � n t | j | j | j � q� Xn d S( Ns watching %r ( R R( R= R& t debugflagt noteR t prefixlent addR R R t ENOTDIRt ENOSPCR, R t wprefix( R/ R( t maskR ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt add_watch� s $c C s; | j j t d � | j � | j | j d t j � d S( Ns watching directories under %r s .hg( R& Rj R Ro Rq t inotifyt IN_DELETE( R/ ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt setup� s R c C s� | j j j � } | j t j | j | � | j � x� t j | j | j | � D]� \ } } } x- | D]% } | j t j | | � | j � qf W| | j } xI | D]A } t j | | � } | j | | j | � � | j | d � q� WqP W| } | r| d d k r| d 7} n x� | j � D]r \ } } | j | � sCq"n y | j | � } Wn+ t k r�| d } | j | | � q"X| j | | � q"W| j d � | j d � d S( Ni����t /i t !t r( R t _mapt copyRq R R Ro Rp t walkRk t updatefilet getstatt popR= RD t startswithR R t deletefilet check_deleted( R/ t topdirt dsRa t dirst filesR t wroott fnt wfnt wtopdirt statet stt status( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR` � s2 " # t cc C s} | d k r | j � n yL | j | � } t j | d � sQ t j | d � rd | j | | � n Wn t k rx n Xd S( Ns .hgignorei ( t update_hgignoreR t S_ISREGt S_ISLNKR{ R ( R/ RT R� ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt created� s & RQ c C s� | d k r | j � n yO | j | � } t j | d � rg | j | d k rg | j | | � qg n Wn t k r{ n Xd S( Ns .hgignorei t lmn( R� R R� R R{ R ( R/ RT R� ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt modified s R c C sG | d k r | j � n | j d � r, d S| j | | j | � d S( Ns .hgignores .hg/( R� R~ R R ( R/ RT ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt deleted s c C sf | j j r5 | j j t d � | j � | f � n | j t j @rU | j | � n | j | � d S( Ns %s event: created %s ( R& Ri Rj R Rh Rp Rr t IN_ISDIRR` R� ( R/ RT t evt( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt process_create s c C s� | j j r5 | j j t d � | j � | f � n | j t j @r� | j j | � } g | j d � D] \ } } | ^ qg } x | D] } | j | d � q� W| j | � n | j | � d S( Ns %s event: deleted %s t ?( R& Ri Rj R Rh Rp Rr R� t treet dirRz R R` R� ( R/ RT R� R� R� t ignoret todeleteR� ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt process_delete! s ( c C sY | j j r5 | j j t d � | j � | f � n | j t j @sU | j | � n d S( Ns %s event: modified %s ( R& Ri Rj R Rh Rp Rr R� R� ( R/ RT R� ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt process_modify/ s c C s. | j j t d � | j � t j d � d S( Ns' filesystem containing %s was unmounted i ( R& R" R R t syst exit( R/ R� ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt process_unmount7 s c C s� | j j r> | j j t d � | j � | j j � f � n | j � s� | j r� | j j r� | j j t d � | j � � n | j � d | _ q� n | j � d S( Ns %s readable: %d bytes s %s below threshold - unhooking i� ( R& Ri Rj R Rh R_ t readableR9 R< R: t read_events( R/ R1 ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyRE < s c C s� | j j | � } | j j rM | j j t d � | j � t | � f � n xt| D]l} | j | j d k rv qT n | j | j } | j d � r� | j t j @r� qT n | d k r | j t j @r� | j j � t | _ | j � q�| j t j @r�t | _ q�qT | j rqT n | j t j @r;| j | | � qT | j t j t j B@re| j | | � qT | j t j t j Bt j B@r�| j | | � qT | j t j t j B@rT | j | | � qT qT W| j! j" � d S( Ns %s reading %d events i����s .hg/s .hg/wlock(# R t readR& Ri Rj R Rh R# R Ro Rk R~ Rp Rr R� Rs R t invalidateR R] R` t IN_CREATER t IN_UNMOUNTR� t IN_MODIFYt IN_ATTRIBR� t IN_DELETE_SELFt IN_MOVED_FROMR� t IN_MOVED_TOR� RS t clear( R/ t bufsizeR1 R� RT ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR� J s: c C st | j sg | j j rG | j j t d � | j � | j j � f � n | j d � | j d d � n d | _ d S( Ns* %s hooking back up with %d bytes readable i R: ( R9 R& Ri Rj R Rh R_ R� R� R6 R= R: ( R/ ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR3 s s c C s | j j � d S( N( R t close( R/ ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR4 } s c s t � f d � � j D� � S( sm Returns a sorted list of relatives paths currently watched, for debugging purposes. c 3 s | ] } | d � j Vq d S( i N( Rk ( t .0t tuple( R/ ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pys <genexpr>� s ( t sortedR ( R/ ( ( R/ s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt debug� s N(" RL RM RN Rr R� R� Rs R� R� R� R� t IN_MOVE_SELFt IN_ONLYDIRR� Rp R\ Rh Rq Rt R` RZ R� R� R� R� R� R� R� RE R= R� R3 R4 R� ( ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR[ � s( E ) t socketlistenerc B s; e Z d Z d � Z d � Z d � Z d � Z d � Z RS( s@ Listens for client queries on unix socket inotify.sock c C s0 t j j | | | | | � | j d | � d S( NR: ( R R� R\ R6 ( R/ R& Ra R[ R: ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR\ � s c C s t j � d S( N( R t TimeoutException( R/ ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR3 � s c C s x | D] } | j � q Wd S( N( t accept_connection( R/ R1 t e( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyRE � s c C s | j j � | j j � d S( N( t sockR� t cleanup( R/ ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR4 � s c C s/ | j j r | j j � n t j j | | � S( N( R[ R: R3 R R� t answer_stat_query( R/ t cs( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR� � s ( RL RM RN R\ R3 RE R4 R� ( ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR� � s t masterc B s& e Z d d � Z d � Z d � Z RS( c C s= | | _ t | | | � | _ t | | | j | � | _ d S( N( R& R[ R� ( R/ R& R Ra R: ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR\ � s c C sC x< t j j � D]+ } y | j � Wq t j k r: q Xq Wd S( N( R- R8 R> R4 R t SignalInterrupt( R/ RH ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR4 � s c C sP | j j � | j j t d � � t j d � rB t j d � n t j � d S( Ns finished setup t TIME_STARTUPi ( R[ Rt R& Rj R t ost getenvR� R� R- RK ( R/ ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyRK � s N( RL RM R= R\ R4 RK ( ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyR� � s ( t mercurial.i18nR t mercurialR R R R R R� R? R R� Rd t linuxRr R t ImportErrorR R, t objectR- RZ R[ R� R� ( ( ( s? /usr/lib64/python2.7/site-packages/hgext/inotify/linuxserver.pyt <module> s H A �