korsygfhrtzangaiide
Elepffwdsff
/
lib64
/
python2.7
/
site-packages
/
hgext
/
inotify
/
Upload FileeE
HOME
� Hq�Qc @ s� d d l 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 e f d � � YZ d � Z d e f d � � YZ d S( i����( t _Nt QueryFailedc B s e Z RS( ( t __name__t __module__( ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/client.pyR s c s � f d � } | S( s� Decorator. Tries to call function, if it fails, try to (re)start inotify server. Raise QueryFailed if something went wrong c s y � | | � SWn�t t j f k r�} | j j d d t � } | j d t j k r� | j j t d � � t j t j j | j d d � � n | j d t j t j f k r�| r�ye y2 t j | j | j | j t d t d d � � Wn, t j k r } | j j t | � � n XWn- t k rN} | j j t d � | � q�Xy � | | � SWq�t j k r�} | j j t d � | j d � q�Xq�| j d t j t j f k r�| j j d � q�| j j t d � | j d � n X| j j � t d � � d S( Nt inotifyt autostarti s> inotify-client: found dead inotify server socket; removing it s .hgs inotify.sockt daemont daemon_pipefdst s3 inotify-client: could not start inotify server: %s s9 inotify-client: could not talk to new inotify server: %s i����s (inotify server not running) s5 inotify-client: failed to contact inotify server: %s s inotify query failed( t OSErrort sockett errort uit configboolt Truet argst errnot ECONNREFUSEDt warnR t ost unlinkt patht joint roott ENOENTt servert startt dirstatet dictt AlreadyStartedExceptiont debugt strt Exceptiont tracebackR ( t selfR t errR t inst( t function( s: /usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt decorated_function s8 %% ( ( R% R& ( ( R% s: /usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt start_server s &t clientc B sV e Z d � Z d � Z d � Z d � Z d � Z e e d � � Z e d � � Z RS( c C s: | | _ | j | _ | j | _ t j t j � | _ d S( N( R R R R t AF_UNIXt sock( R" R t repo( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt __init__A s c C s� t j j | j d d � } y | j j | � WnN t j k r } | j d d k ry t j | � } | j j | � q� � n Xd S( Ns .hgs inotify.socki s AF_UNIX path too long( R R R R R* t connectR R R t readlink( R" t sockpathR# ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt _connectG s c C s8 | j j t t j � | | � | j j t j � d S( s+ Sends protocol version number, and the dataN( R* t sendallt chrt commont versiont shutdownR t SHUT_WR( R" t typet data( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt _sendR s !c C sI t j | j � } y t | j d � � } Wn3 t k r` | j j t d � � t d � � n X| t j k r� | j j t d � | � t d � � n | j d � } | | k r� | j j t d � | | f � t d � � n t j | } t j | } y t j | | j | � � } Wn t j k r>t d � � n X| | f S( s� Read data, check version number, extract headers, and returns a tuple (data descriptor, header) Raises QueryFailed on error i s9 inotify-client: received empty answer from inotify servers server crashedsA (inotify: received response from incompatible server version %d) s incompatible server versioni s6 (inotify: received '%s' response when expecting '%s') s wrong response types) unable to retrieve query response headers( R3 t recvcsR* t ordt readt TypeErrorR R R R R4 t resphdrfmtst resphdrsizest structt unpackR ( R" R7 t csR4 t readtypet hdrfmtt hdrsizet resphdr( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt _receiveX s, c C s' | j � | j | | � | j | � S( N( R0 R9 RG ( R" R7 t req( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt query{ s c s� � � � � f d � } d j | � � } | j d | � \ � } � � f d � } t t | | d � � } � r� | d } � j | � } | r� x' | j d � D] } � j | � q� Wq� n | S( Nc 3 s` x � D] } | Vq Wd } � r1 t d � � n � rD | d 7} n � rW | d 7} n | Vd S( Ns almrx!s this is insanityt ct ?( t ValueError( t nt states( t cleant ignoredt namest unknown( s: /usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt genquery� s t t STATc s8 | r4 � j | � } | r4 t � | j d � � Sn g S( NRT ( R< t filtert split( t nbytesRQ ( RB t match( s: /usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt readnames� s i����( R RI t tuplet mapR< RW t dir( R" RQ RY RP RO RR RS RH RF RZ t resultsRX t vdirst vdir( ( RO RB RP RY RQ RR s: /usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt statusquery� s c C s> | j d d � \ } } | d } | j | � } | j d � S( Nt DBUGR i RT ( RI R< RW ( R" RB RF RX RQ ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt debugquery� s ( R R R, R0 R9 RG RI R' R Ra Rc ( ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/client.pyR( @ s # #( t mercurial.i18nR R3 R R R R R@ R R R' t objectR( ( ( ( s: /usr/lib64/python2.7/site-packages/hgext/inotify/client.pyt <module> s 0 /