|
Server : Apache System : Linux cs317.bluehost.com 4.19.286-203.ELK.el7.x86_64 #1 SMP Wed Jun 14 04:33:55 CDT 2023 x86_64 User : andertr9 ( 1047) PHP Version : 8.2.18 Disable Function : NONE Directory : /lib64/python2.7/site-packages/hgext/inotify/ |
Upload File : |
�
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, " $\�]