| Server IP : 80.87.202.40 / Your IP : 216.73.216.169 Web Server : Apache System : Linux rospirotorg.ru 5.14.0-539.el9.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Dec 5 22:26:13 UTC 2024 x86_64 User : bitrix ( 600) PHP Version : 8.2.27 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib64/python3.9/site-packages/hgext/fsmonitor/__pycache__/ |
Upload File : |
a
�+�b� � @ s d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl m
Z
ddl m Z ddl
mZ ddlmZmZmZmZmZmZmZmZmZmZmZ ddlmZ dd l m Z m Z d
d l m!Z!m"Z"m#Z# d Z$i Z%e�&e%�Z&e&d
ddd� e&d
ddd� e&d
ddd� e&d
de'd� e&d
ddd� e&d
dddd� e&dd dd� d d gZ(d d � Z)d!d"� Z*d#d$� Z+e!j�,� Z-e�.� �pxe�/� Z0e�1e-�e�1e0�kZ2d%d&� Z3d@d'd(�Z4dAd*d+�Z5G d,d-� d-e6�Z7d.d/� Z8d0d1� Z9d2d3� Z:d4d5� Z;G d6d7� d7e6�Z<d8d9� Z=dBd:d;�Z>d<d=� Z?d>d?� Z@dS )Cab Faster status operations with the Watchman file monitor (EXPERIMENTAL)
Integrates the file-watching program Watchman with Mercurial to produce faster
status results.
On a particular Linux system, for a real-world repository with over 400,000
files hosted on ext4, vanilla `hg status` takes 1.3 seconds. On the same
system, with fsmonitor it takes about 0.3 seconds.
fsmonitor requires no configuration -- it will tell Watchman about your
repository as necessary. You'll need to install Watchman from
https://facebook.github.io/watchman/ and make sure it is in your PATH.
fsmonitor is incompatible with the largefiles and eol extensions, and
will disable itself if any of those are active.
The following configuration options exist:
::
[fsmonitor]
mode = {off, on, paranoid}
When `mode = off`, fsmonitor will disable itself (similar to not loading the
extension at all). When `mode = on`, fsmonitor will be enabled (the default).
When `mode = paranoid`, fsmonitor will query both Watchman and the filesystem,
and ensure that the results are consistent.
::
[fsmonitor]
timeout = (float)
A value, in seconds, that determines how long fsmonitor will wait for Watchman
to return results. Defaults to `2.0`.
::
[fsmonitor]
blacklistusers = (list of userids)
A list of usernames for which fsmonitor will disable itself altogether.
::
[fsmonitor]
walk_on_invalidate = (boolean)
Whether or not to walk the whole repo ourselves when our cached state has been
invalidated, for example when Watchman has been restarted or .hgignore rules
have been changed. Walking the repo in that case can result in competing for
I/O with Watchman. For large repos it is recommended to set this value to
false. You may wish to set this to true if you have a very fast filesystem
that can outpace the IPC overhead of getting the result data for the full repo
from Watchman. Defaults to false.
::
[fsmonitor]
warn_when_unused = (boolean)
Whether to print a warning during certain operations when fsmonitor would be
beneficial to performance but isn't enabled.
::
[fsmonitor]
warn_update_file_count = (integer)
# or when mercurial is built with rust support
warn_update_file_count_rust = (integer)
If ``warn_when_unused`` is set and fsmonitor isn't enabled, a warning will
be printed during working directory updates if this many files will be
created.
� )�absolute_importN)�_)�hex)�open) �context�encoding�error�
extensions� localrepo�merge�pathutil�pycompat� registrar�scmutil�util)�match)�hashutil�
stringutil� )�
pywatchman�state�watchmanclients ships-with-hg-core� fsmonitor� modes on)�defaults walk_on_invalidateFs timeout� 2s blacklistusers� watchman_exe� watchman� verboseT)r Z experimental� experimental� fsmonitor.transaction_notifys
largefiless eolc
C s� |� dtd�| �dd�� t�� }t�| |�}d }z*|�d�}|� dtd�t� |d �� W n0 tj
y� } zt � |�}W Y d }~n
d }~0 0 |�
|d td
�|� |r�d S d S )
Ns fsmonitor-watchmans/ fsmonitor checking for watchman binary... (%s)
r r s versions fsmonitor-watchman-versions watchman binary version %s
�versions fsmonitor-watchman-errors' watchman binary missing or broken: %s
r r )�writer Z
configpath�tempfileZmkdtempr �client�commandr
Zbytestr� Unavailabler � forcebytestrZ condwrite)�uiZfm�root�c�err�v�e� r. �>/usr/lib64/python3.9/site-packages/hgext/fsmonitor/__init__.py� debuginstall� s0
�
� �r0 c C s� t |tj�rr|jr@| �dd�r@dt�|�vr@| �t�|�d � |jrN|�� | �dd�r�| �ddt�|j �� n| �ddt�|�� dS )z5Exception handler for Watchman interaction exceptionsr r s illegal_fstypes�
s Watchman unavailable: %s
s Watchman exception: %s
N)
�
isinstancer r& �warn�
configboolr r' �
invalidate�log�msg)r( r �exr. r. r/ �_handleunavailable� s"
��r9 c C s& t �� }|�t�| �� t�|�� �S )z�Calculate hash for ignore patterns and filenames
If this information changes between Mercurial invocations, we can't
rely on Watchman information anymore and have to re-scan the working
copy.
)r �sha1�updater
Zbyterepr�sysbytes� hexdigest)�ignorer: r. r. r/ � _hashignore� s r? c
C s� z| � t�}W n8 tyF } z tjt�|�dd��W Y d}~n
d}~0 0 z|�td�}W n4 t y� } z t�t�|���W Y d}~n
d}~0 0 |S )z�Fix path to match watchman and local filesystem encoding
watchman's paths encoding can differ from filesystem encoding. For example,
on Windows, it's always utf-8.
s watchman encoding error)�hintN�strict)
�decode�_watchmanencoding�UnicodeDecodeErrorr ZAbortr r' �encode� _fsencoding�UnicodeEncodeError)�pathZdecodedr- Zencodedr. r. r/ �_watchmantofsencoding s
� &rI c (
s" ��� �
��fdd�}|r"|d�S �r.|d�S �
j �� s@|d�S �
j}|�� \} }
} | sn|jrf|d�S d} g } �
j��
j��r�t��|
kr�| dkr�|jr�|d�S g } d} n tj �tj ��j
��� � } �
j �t� �d �r܈j �d
d � �
j �
� D �}
�
j j}tj}tj}tj}tj}�
j�tj�
d }d }}��� �r>d
}tj �n��� �rLd
}|�sf�
j�rf�
j� d }nd� �
����\� }}|�o�|�p�| }�fdd�|D �}|�s�|�s�|�rΈD ] }� |= �q�� d= � S zR�
j �|j d � �
j � dg d�| ddddgg d�ggt |j d �|jd��}W nF t �yf } z,t �
j!||� �
j �"� |d�W Y d}~S d}~0 0 |�#t$�%|d �� |d �r�|j�r�|�&� |d �S d
}g } � �r��
fd d �� D ��t$j'd!k}|d" D �]�} | d# } t(| t)��s�| �*t+�} t,�rt-| �} |�r| �.d!d$�} � �r6�
| �} � | d
d
�} | �| < | d% } | d& } || �}!d'| v �sd| �/d(��rp|d)� S | �s�| � v�rP| �v �rP| �s��| ��rPd� | < n�|!|k�r�| �v �rP| �sȈ| ��rPd� | < n~|!|k�s�|!|k�r.| �v �r
| �s �| ��r,| � | < n"| �s�| ��rP�| ��sP| � | < n"| �v �r�| �sH�| ��r�d� | < �qЈ �rp�� �
fd*d �| D �} ���� fd+d �| D �}"|�s�| �r�|"�0� fd,d-�|
D �� |"�0� fd.d-�|D �� n4|"�0�� fd/d-�|
D �� |"�0�� fd0d-�|D �� nx| �r:|"�0� fd1d-�t$�1��D �� |"�0� fd2d-�|D �� n:|"�0�� fd3d-�t$�1��D �� |"�0�� fd4d-�|D �� t2j3�
j4d
d5�j5� � fd6d�|"D �}#|#�6� |"�7|#�}$|$D ]}%d� |%< �q�t8|#�}&t�9�fd7d�|#D ��D ]&}'t:|&�}%|'�s�|%�v �r�|'� |%< �qވD ] }� |= �q
� d= � S )8z�Replacement for dirstate.walk, hooking into Watchman.
Whenever full is False, ignored is False, and the Watchman client is
available, use Watchman combined with saved state to possibly return only a
subset of files.c s" �j �d| � ����� dd�S )Ns' fsmonitor: fallback to core status, %s
T)�full)�_ui�debug)�reason)�ignoredr �orig�self�subrepos�unknownr. r/ �bail' s zoverridewalk.<locals>.bails full rewalk requesteds listing ignored filess client unavailables no clocks c:0:0s ignore rules changeds _mapc S s, h | ]$\}}|� � d ks$|�� dkr|�qS )� n���)Zv1_stateZv1_mtime)�.0�fr- r. r. r/ � <setcomp>P s �z overridewalk.<locals>.<setcomp>FTNc s g | ]}� |d �s|�qS )r r. )rV �d)� dirignorer. r/ �
<listcomp>s � z overridewalk.<locals>.<listcomp>� .hg皙�����?s query)r s mtimes size� exists� names nots anyofs dirname)r` r] s wholenamei� )s fieldss sinces
expressions sync_timeouts empty_on_fresh_instances exception during runs clocks is_fresh_instances fresh instancec s i | ]}� |�|�qS r. r. )rV �k)�normcaser. r/ �
<dictcomp>� r\ z overridewalk.<locals>.<dictcomp>� \s filesr` � /r r_ s /.hg/s /.hgs nested-repo-detectedc s$ h | ] }�|�� vr�|d d ��qS )Tr. �rV rW )�foldmap� normalizerb r. r/ rX � s �c s0 h | ](}|�vr�|�r|� v s(�|�s|�qS r. r. rf )�dmapr> �matchfn�resultsr. r/ rX � s �c 3 s | ]}|� vr|V qd S �Nr. rf �rk r. r/ � <genexpr>� r\ z overridewalk.<locals>.<genexpr>c 3 s | ]}|� vr|V qd S rl r. rf rm r. r/ rn � r\ c 3 s" | ]}|�vr� |�r|V qd S rl r. rf �rj rk r. r/ rn � s c 3 s" | ]}|�vr� |�r|V qd S rl r. rf ro r. r/ rn � r\ c 3 s | ]\}}|� vr|V qd S rl r. �rV rW �strm r. r/ rn � s c 3 s | ]}|� vr|V qd S rl r. rf rm r. r/ rn � r\ c 3 s& | ] \}}|�vr� |�r|V qd S rl r. rp ro r. r/ rn � s �c 3 s" | ]}|�vr� |�r|V qd S rl r. rf ro r. r/ rn r\ )�cachedc s g | ]}� |�r|�qS r. r. rf )�auditr. r/ r[ r\ c s g | ] }� |��qS r. r. rf )�joinr. r/ r[
r\ );�_watchmanclientZ available�_fsmonitorstate�get�walk_on_invalidate�_ignoreZ
_dirignorer? r �alwaysrj �_map� safehasattr�items�copymap�stat�S_IFMT�S_IFDIR�S_IFREG�S_IFLNKZ_joinrb Zisexact�prefixZ
_checkcaseZ_normalizefileZ
_walkexplicit�
settimeout�timeoutr% �int� Exceptionr9 rK �clearconnectionZ setlastclockr
r< r5 Zossepr2 �bytesrE rC � _fixencodingrI �replace�endswithr; Z iteritemsr Z pathauditor�_root�check�sort�
difference�iterZ statfiles�next)(rO rP r rQ rR rN rJ rS r �clockZ
ignorehash� notefilesZ matchalwaysZ nonnormalsetr~ ZgetkindZdirkindZregkindZlnkkindZfresh_instance�exactZ skipstep3ZworkZ dirsnotfound�s�resultr8 Zswitch_slashes�entry�fname�normedZfmodeZfexists�kindZvisitZ auditpassZ auditfailrW Znfrq r. )rs rZ ri rg r> rN rt r rj rh rb rO rk rP rQ rR r/ � overridewalk sJ
�
�� ��
����
��� ��
r� � .c s� |} |}
|} � fdd�} t |tj�r*|}
n� | }
t |tj�rD|}n� | }|�� d u }|of|
� d k}|prt�� }|o�|�� o�t |tjtjf� o�dtj v}z8� j
j r�� j �
d� n� j �
� j
jd � � j �� }W nT t�y* } z:� j �� t� j� j
|� | |||| |
| |�W Y d }~S d }~0 0 |�r8d}n| }|�rTt|�}� �|� | |||| |
||�}|\}}}}}}}| �s�g }|
�p�|jd u}� j
jdk�r�|�s�d� j_� jj} d� j_� jj� jj } } t t j d� � j_� j_ z:| |||| |
| |�} W d � j_| � j_| | � j_� j_ n$d � j_| � j_| | � j_� j_ 0 � � � �( | |||||||g| � W d � n1 �s�0 Y | \}}}}}}}t!�"|||||||�S )
Nc s� z6dt jv r"t jd }t|d�}nd}� j�|d�}W n, ttfyb � j�td�| � Y d S 0 zbt t
| |��D ]F\}\}}t |�t |�krt|� d| � |� d| � |� d| � qtW |�
� n
|�
� 0 d S )Ns FSMONITOR_LOG_FILE� wbs fsmonitorfail.logs warning: unable to write to %s
s sets at position %d are unequal
s watchman returned: %r
s stat returned: %r
)r �environr Zvfs�IOError�OSErrorr( r3 r � enumerate�zip�setr" �close)�l1�l2�fnrW �i�s1�s2�rP r. r/ �_cmpsets' s
z overridestatus.<locals>._cmpsetsr� s
HG_PENDINGr^ Ts paranoidr� F)#r2 r Z changectx�rev�matchmodrz ZworkingcommitctxZmemctxr r� rv rx ru r� r� Zgetcurrentclockr� r� r9 r( �
poststatusZaddpostdsstatusZ traversedir�mode�dirstate�_fsmonitordisable�quiet�fout�ferrr �os�devnull�wlockr �status) rO rP Znode1Znode2r rN ZcleanrR Z listsubreposZ listignoredZ listcleanZ listunknownr� Zctx1Zctx2ZworkingZ
parentworkingZ updatestate�
startclockr8 Z stateunknownZps�r�modified�added�removed�deletedrJ r� r� r� Zrv2r. r� r/ �overridestatus s�
���
�
��
�
�$�r� c @ s e Zd Zdd� Zdd� ZdS )r� c C s t �|�| _d S rl )r
r< � _startclock)rP r� r. r. r/ �__init__� s zpoststatus.__init__c C sZ |� � j�� p| j}t|� � jj�}|j|j |j |j
|j }|� � j� |||� d S rl )
�reporv Z getlastclockr� r? r� ry r� r� r� r� rR r� )rP Zwctxr� r� Z
hashignorer� r. r. r/ �__call__� s �����zpoststatus.__call__N)�__name__�
__module__� __qualname__r� r� r. r. r. r/ r� � s r� c s* G � fdd�d|j �� � |_ |�| � d S )Nc sB e Zd Zdd� Z� �fdd�Z� �fdd�Z� �fdd�Z� ZS ) z'makedirstate.<locals>.fsmonitordirstatec S s& d| _ |j| _|j| _t�|�| _d S �NF)r� rv ru �weakref�proxyZ_repo)rP r� r. r. r/ �_fsmonitorinit� s z6makedirstate.<locals>.fsmonitordirstate._fsmonitorinitc s8 t �| �j}| jr ||i |��S t|| g|�R i |��S rl )�super�walkr� r� �rP �args�kwargsrO �� __class__�fsmonitordirstater. r/ r� � s z,makedirstate.<locals>.fsmonitordirstate.walkc s | j �� t�| �j|i |��S rl )rv r5 r� �rebuild�rP r� r� r� r. r/ r� � s
z/makedirstate.<locals>.fsmonitordirstate.rebuildc s | j �� t�| �j|i |��S rl )rv r5 r� r� r� r. r/ r5 � s
z2makedirstate.<locals>.fsmonitordirstate.invalidate)r� r� r� r� r� r� r5 �
__classcell__r. �r� �r� r/ r� � s r� )r� r� )r� r� r. r� r/ � makedirstate� s r� c C s" | |�}t �|d�r t||� |S )Ns _fsmonitorstate)r r| r� )rO rP Zdsr. r. r/ � wrapdirstate� s
r� c C s6 t �tjdt� tjr$t �tdt � t �t
dt � d S )N� dirstates symlinks _update) r Z
wrapfilecacher
Zlocalrepositoryr� r
ZisdarwinZ wrapfunctionr� � wrapsymlinkr �
wrapupdate)r( r. r. r/ �extsetup� s �r� c C s� zf| ||�W zt �t j�|�d� W S ty6 Y S 0 S zt �t j�|�d� W q� tyd Y q�0 n.zt �t j�|�d� W n ty� Y n0 0 dS )zyif we create a dangling symlink, also touch the parent dir
to encourage fsevents notifications to work more correctlyN)r� �utimerH �dirnamer� )rO �sourceZ link_namer. r. r/ r� � s
� � r� c @ sF e Zd ZdZddd�Zdd� Zdd � Zd
d � Zdd d
�Zddd�Z dS )� state_updatea� This context manager is responsible for dispatching the state-enter
and state-leave signals to the watchman service. The enter and leave
methods can be invoked manually (for scenarios where context manager
semantics are not possible). If parameters oldnode and newnode are None,
they will be populated based on current working copy in enter and
leave, respectively. Similarly, if the distance is none, it will be
calculated based on the oldnode and newnode in the leave method.NFc C s8 |� � | _|| _|| _|| _|| _|| _d | _d| _d S r� ) �
unfilteredr� �name�oldnode�newnode�distance�partial�_lock�
need_leave)rP r� r� r� r� r� r� r. r. r/ r� s
zstate_update.__init__c C s | � � d S rl )�enterr� r. r. r/ � __enter__ s zstate_update.__enter__c C sh | j d u r| jd �� | _ | j�� d u rPt�| jd�rD| j�� | _n | j�� | _| � dt
| j ��| _ | S )Nr� s wlocknostateupdates state-enter) r� r� �nodeZ currentwlockr r| �wlocknostateupdater� r� �_stater r� r� r. r. r/ r� s
zstate_update.enterc C s |rdnd}| j |d� d S )NTF)�abort)�exit)rP �type_�value�tbr� r. r. r/ �__exit__* s zstate_update.__exit__c C s� zz| j rb|rdnd}| jd u r.| jd �� | _| jd u rLt| j| j| j�| _| jdt| j�|d� W d| _ | j r�| j �
� nd| _ | j r�| j �
� 0 d S )Ns failed� okr� s state-leave)r� F) r� r� r� r� r� � calcdistancer� r� r r� �release)rP r� r� r. r. r/ r� . s
� �zstate_update.exitr� c
C s� t �| jd�sdS z6| jj�|| j|| jr0| jnd|| jd�d�� W dS ty� } z"| jj �
dd||� W Y d }~dS d }~0 0 d S ) Ns _watchmanclientFr )s revs distances statuss partial)r` s metadataTr s Exception %s while running %s
) r r| r� ru r% r� r� r� r� r( r6 )rP �cmdZ
commithashr� r- r. r. r/ r� > s& ����zstate_update._state)NNNF)F)r� )
r� r� r� �__doc__r� r� r� r� r� r� r. r. r. r/ r� � s �
r� c C sF | j �||�}| | �� }t| | �� | �t| | �� | � }|S rl )Z changelog�ancestorr� �abs)r� r� r� ZancZancrevr� r. r. r/ r� \ s �r� c
K s� d}
d} |d � � } || � � }
|d u s0|�� rDd} t|�� | |
�}
t|d| |
|
| d��. | ||||||||fi | ��W d � S 1 s�0 Y d S )Nr Tr� Fs hg.update)r� r� r� r� r� )r� rz r� r� r� )rO r� r� Z branchmerge�forcer� Z
mergeancestor�labelsZmatcherr� r� r� r� r� r. r. r/ r� i s6
�� �r� c C sH | j �� D ]8}tj�tj�| j|d��r
d}| j�|| � dS q
dS )Nr] s: fsmonitor: sub-repository %r detected, fsmonitor disabled
TF) �wvfs�listdirr� rH �isdirrt r) r( rL )r� rW r7 r. r. r/ � repo_has_depth_one_nested_repo� s r c
s t �� }tD ]$}||v r ��td�| � d S q |�� �r |j�d�sT|j�d�rXd S t|�rdd S t � |�}|j
dkr|d S zt � |j
|j�}W n2 ty� } zt�||� W Y d }~d S d }~0 0 ||_||_t�|d�\}}|r�t||� G � �fdd�d|j�� � |_d S )NsU The fsmonitor extension is incompatible with the %s extension and has been disabled.
s .hgsubstates .hgsubs offr� c s< e Zd Z� �fdd�Z� �fdd�Z� ��fdd�Z� ZS )z reposetup.<locals>.fsmonitorrepoc s$ t �| �j}t|| g|�R i |��S rl )r� r� r� r� �r� �
fsmonitorrepor. r/ r� � s z'reposetup.<locals>.fsmonitorrepo.statusc s t �| �j|i |��S rl )r� r� r� r r. r/ r� � s z3reposetup.<locals>.fsmonitorrepo.wlocknostateupdatec
s� t �| �j|i |��� ��dd�s&� S � jdkr4� S � j�� �fdd�}z(d � _t| dd�� _� j�� |� _W n4 ty� } z | j �
dd |� W Y d }~n
d }~0 0 � S )
Nr r r c s$ �r
�� � j r � j �� d � _ d S rl )� stateupdater� r. ��lZ origreleaser. r/ � staterelease� s
z<reposetup.<locals>.fsmonitorrepo.wlock.<locals>.statereleases hg.transaction)r� r s Exception in state update %s
) r� r� r4 ZheldZ releasefnr r� r� r� r( r6 )rP r� r� r
r- )r� r r( r r/ r� � s& �
�z&reposetup.<locals>.fsmonitorrepo.wlock)r� r� r� r� r� r� r� r. �r r( r� r/ r � s r )r Zenabled�
_blacklistr3 r �localr �existsr r r� r r$ r( r) r� r9 rv ru r
Z isfilecachedr� r� ) r( r� Zexts�extZfsmonitorstater$ r8 r� rr r. r r/ � reposetup� s> ���
%r )T)r� NNFFFF)NFNN)Ar� Z
__future__r �codecsr� r �sysr# r� Zmercurial.i18nr Zmercurial.noder Zmercurial.pycompatr Z mercurialr r r r r
r r r
r r r r r� Zmercurial.utilsr r � r r r Z
testedwithZ configtableZ
configitem�listr r0 r9 r? Zget_local_encodingrC �getfilesystemencoding�getdefaultencodingrF �lookupr� rI r� r� �objectr� r� r� r� r� r� r� r� r r r. r. r. r/ �<module> s� f 4
�������
| �
` �
*