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 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 d e f d � � YZ d e f d � � YZ d � Z d � Z e j e j f Z d � Z d e f d � � YZ d e f d � � YZ d e f d � � YZ e j j d � rBd d l Z n e � e j Z d � Z! d S( i����( t _( t cmdutilt posixt osutilt utilNt AlreadyStartedExceptionc B s e Z RS( ( t __name__t __module__( ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR s t TimeoutExceptionc B s e Z RS( ( R R ( ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR s c C s. | r* | d d k r | | S| d | S| S( Ni����t /( ( t at b( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt join s c C s; | j d � } | d k r% d | f S| | | | d f S( NR i����t i ( t rfind( t patht c( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt split s c s( � � � f d � � � | | d k � S( s, Like os.walk, but only yields regular files.c 3 sC g g } } y� t � | � } x� t j | � D]� \ } } | t j k r� | d k rc | s� d Sq� | j | � t | | � } � j | � r� q/ n xG � | t � D] } | Vq� Wq/ | t j t j f k r/ | j | � q/ q/ W| | | f VWnK t k r>} | j t j k r&| | | f Vq?| j t k r?� q?n Xd S( Ns .hg( R R t listdirt statt S_IFDIRt appendt _ignoret Falset S_IFREGt S_IFLNKt OSErrort errnot ENOTDIRt walk_ignored_errors( t roott reporoott filest dirst fullpatht namet kindR t resultt err( t absroott dirstatet walkit( 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.pyt walk' s t directoryc B s8 e Z d Z d d � Z d � Z d d � Z d � Z RS( 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 c C s | | _ i | _ i | _ d S( N( R R R! ( t selft relpath( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt __init__W s c C s� | s | S| j d � } | } xi | r� | j d � } y | j | } Wq" t k r� t t | j | � � } | | j | <| } q" Xq" W| S( s� Returns the directory contained at the relative path relpath. Creates the intermediate directories if necessary. R i ( R t popR! t KeyErrorR+ R R ( R, R- t lt rett nextt d( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt dir\ s c c s� xC | j j � D]2 \ } } | | k r t | j | � | f Vq q WxU | j j � D]D } | d k r{ | j | j � n x | j | � D] } | Vq� WqV Wd 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 R R! t itervaluest Nonet addR* ( R, t statest visitedt filet stR5 t e( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR* o s c c s) | d d k r | d } n | j d � } | j � } | } y" x | D] } | j | } qH WWn" t k r� | j | j � d SXyI | j | } | j | j � x% | j | | � D] \ } } | Vq� WWnT t k r$y/ | j | | k r | j | j � | Vn Wq%t k r q%Xn Xd S( 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( R R/ R! R0 R9 R R* R ( R, R: R R; t pathst lastt treeR5 t targetR< R= ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt lookup~ s. N( R R t __doc__R. R5 R8 R* RC ( ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR+ K s t repowatcherc B sw e Z d Z d Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s Watches inotify events s almr!?c C s� | | _ | | _ t | d � | _ t | j � | _ t � | _ i | _ t g | j D] } | t � f ^ qX � | _ | j � | _ d | _ d S( NR ( t uiR( R t wprefixt lent prefixlenR+ RA t statcachet dictt statuskeyst statustreest dirstate_infot ds_infoR8 t last_event( R, RF R( R t s( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR. � s .c C s d S( N( ( R, ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt handle_timeout� s c C s] y* t j | j d � } | j | j f SWn, t k rX } | j t j k rT � n d SXd S( Ns .hg/dirstatei ( i i ( t ost lstatRG t st_mtimet st_inoR R t ENOENT( R, R= R& ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyRN � s c C s� y$ | j j | d \ } } } } Wn t k r= d } n X| d k r� | \ } } } | d k ri d S| r� | | k s� | | Ad @r� d S| t | � k r� d Sd S| d k r� | j j | � r� d S| S( Ni t ?t ni����R1 i@ t mt i( R( t _mapR0 t intt _dirignore( R, t fnR= t type_t modet sizet timet st_modet st_sizeRU ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt filestatus� s $ c C s | 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, t wfnt osstat( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt updatefile� s c C sW | d k r d } n | d k r* d } n d } | j j | d � | j | | � d S( s� update the entry of a file which has been deleted. oldstatus: char in statuskeys, status of the file before deletion t rt almnt !N( R8 RJ R/ Rg ( R, Rh t oldstatust newstatus( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt deletefile� s c C s t | � \ } } | j j | � } | j j | � } | j j rt | | k rt | j j t d � | | | f � n | r� | | j k r� | | k r� | j | j | � j | =n | d k r� | j j | d � nH | | k r | | j | <| d k r | | j | j | � j | <q n d S( s� Update the stored status of a file. newstatus: - char in (statuskeys + 'ni'), new status to apply. - or None, to stop tracking wfn s status: %r %s -> %s R[ RY N( NR[ ( R RA R5 R t getRF t debugflagt noteR RL RM R8 R/ ( R, Rh Ro R R_ R4 Rn ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyRg � s c C s� g } xC | j | j | � D]+ \ } } | | j k r | j | � q q WxP | D]H } t | � \ } } | j | j | � j | =| j j | � j | =qS Wd S( N( RM R* R( R R R5 R RA ( R, t keyt nukeRh t ignoreR R_ ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt check_deleted s # c C sS d | j j k rO t | j d � | j j t d � � | j � | j � n d S( NR s# rescanning due to .hgignore change ( R( t __dict__t delattrRF Rs R RR t scan( R, ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt update_hgignore s c C sf y | j | SWnP t k ra y | j | � SWqb t k r] } | j t j k r^ � q^ qb Xn Xd S( N( RJ R0 R R R RW ( R, t wpathR& ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt getstat1 s c C sv yH t j t | j | � � } | j | j | j f } | | j | <| SWn' t k rq | j j | d � � n Xd S( N( RS RT R RG Rd Re RU RJ R R/ R8 ( R, R| R= R2 ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR ; s ( R R RD RL R. RR RN Rf Rj Rp Rg Rw R{ R} R ( ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyRE � s t socketlistenerc B s2 e Z d Z d � Z d � Z d � Z d � Z RS( s@ Listens for client queries on unix socket inotify.sock c s� | | _ | | _ y" t j � f d � d � | _ WnJ t t j f k r� } | j d t j k rz t t d � � � n � n X| j j | _ d S( Nc s t j j � d | � S( Ns .hg( RS R R ( t p( R ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt <lambda>N s t inotifyi s% cannot start: socket is already bound( RF RE R t unixdomainservert sockR t sockett errort argsR t EADDRINUSER R t fileno( R, RF R RE t timeoutR& ( ( R s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR. I s c sH | j � j d � � � j � } | j j t d � | � t � � � sV d � } n � � f d � } g | d | j j d � | d | j j d � | d | j j d � | d | j j d � | d | j j d � d | k r� | d | j j d � pg g d | k r%| d | j j � p(g � g D] } d j | � ^ q/S( Nt s answering query for %r c s s) x" | j | � D] \ } } | Vq Wd S( N( R* ( R: RA R_ t state( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt genresult` s c 3 s: x3 � D]+ } x" | j | | � � D] } | Vq# Wq Wd S( N( RC ( R: RA R_ t f( t namesR; ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR� d s R1 RZ R Rk Rm RX R RY ( t readR R/ RF Rs R t setRE RM RA R ( R, t csR: R� Rk ( ( R� R; s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt answer_stat_queryW s& $c C s d j | j j � � g S( NR� ( R RE t debug( R, ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt answer_dbug_queryw s c C s� | j j � \ } } t j | � } t | j d � � } | t j k r� | j j t d � | � y | j t t j � � Wn t j k r� n Xd S| j d � } | d k r� | j | � } n9 | d k r� | j � } n | j j t d � | � d Syr zZ t t j � } | j | | t j t j | t t | � � � | j d j | � � Wd | j t j � XWn2 t j k r�} | j d t j k r�� q�n Xd S( Ni s3 received query from incompatible client version %d i t STATt DBUGs unrecognized query type: %s R i ( R� t acceptt commont recvcst ordR� t versionRF t warnR t sendallt chrR� R� R� R� t structt packt resphdrfmtst mapRH R t shutdownt SHUT_WRR� R t EPIPE( R, R� t addrR� R� t typet resultst vR& ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt accept_connectionz s8 ( R R RD R. R� R� R� ( ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR~ E s t linuxc s\ | j d � � � r( t � � d � n d � d t f � � � � f d � � Y} d t j k r~ t j � d d � g } n t j � t j d } � j d d � } | d r� | d k r� d | k r� | j d | � n | � } � j d d � } � j d d t � } � j d d j | � � t j | d | j d | j d | d | d | �d S( Nt idle_timeouti`� t servicec s) e Z � � � � f d � Z d � Z RS( c sI y t � � � � � | _ Wn& t k rD } t j d | � � n Xd S( Ns inotify-server: %s( t masterR R t Abort( R, t inst( R( R R� RF ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt init� s c S s> z) y | j j � Wn t k r' n XWd | j j � Xd S( N( R� t runR R� ( R, ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR� � s ( R R R� R� ( ( R( R R� RF ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyR� � s t inserves -Ri R� t pidfilet daemons pid-files --pid-file=%st logt appendpids starting inotify server: %s t t initfnt runfnt logfilet runargs( Rq t floatR8 t objectt syst argvR t hgcmdt configR t configboolR R� R R R� R� R� ( RF R( R t optsR� R� R� R� R� ( ( R( R R� RF s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt start� s" % " (" t mercurial.i18nR t mercurialR R R R R� R RS R� R R� R� t ExceptionR R R R RW t ENAMETOOLONGR R* R� R+ RE R~ t platformt startswitht linuxservert _servert ImportErrorR� R� ( ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/server.pyt <module> s, " $\�]