| 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 : /usr/lib64/python3.9/site-packages/mercurial/__pycache__/ |
Upload File : |
a
�+�b�| � @ s� d Z ddlmZmZ ddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
Z
ddlZddlZddlZddlZddlZddlZddlZddlZddlmZ ddlmZ ddl m Z m Z m Z m Z ddlmZ ddl!m"Z" dd l#m$Z$m%Z%m&Z&m'Z'm Z m(Z( dd
l)m*Z*m+Z+m,Z,m-Z- e j.�rDdd l/m0Z0m1Z1m2Z2m3Z3 e'�4d �Z5e'�4d
�Z6e5j7Z7e5j8Z8e j9Z9e j:Z:e j;Z;e j<Z<e j=Z=e j>Z>e>Z?e j@Z@e(jAZAe(jBZBe(jCZCe jDZEe jF�r�ddl#mGZ n ddl#mHZ e&jIZIejJZJejKZKejLZLejMZMejNZNejOZOejPZPejQZQejRZRejSZSejTZTejUZUejVZVejWZWe6jXZXejYZYejZZZej[Z[ej\Z\ej]Z]ej^Z^ej_Z_ej`Z`ejaZaejbZbejcZcejdZdejeZeejfZfejgZgejhZhejiZiejjZjejkZkejlZlejmZmejnZne e6dejo�ZoejpZpejqZqejrarejsZsejtZtdd� Zue*jvZve*jwZwe*jxZxz
e6jyZyW n ez�y Y n0 e{� Z|dd� Z}e~e$j��d��Z�e��rje��dde�d� e��dde�d� e��dde�d� e��r�e j��r�e��dd e�d� e��dd e�d� e��dd e�d� d�d d �Z�e j�e+j�e j�d!�Z�g d"�Z�e�D ]Z��q�G d#d$� d$e{�Z�G d%d&� d&e{�Z�ze�Z�W n e��y d�d'd(�Z�Y n0 d)Z�G d*d+� d+e{�Z�d�d,d-�Z�G d.d/� d/e{�Z�G d0d1� d1e��Z�h d2�Z�G d3d4� d4e{�Z�G d5d6� d6e{�Z�G d7d8� d8e��Z��d d;d<�Z�G d=d>� d>e��Z��dd?d@�Z�dAdB� Z��ddDdE�Z�dFdG� Z�G dHdI� dIe{�Z�G dJdK� dKej��Z�G dLdM� dMe�e��Z�G dNdO� dOe�e��Z�G dPdQ� dQe{�Z�ej��ddRdS��Z�ej��ddTdU��Z�G dVdW� dWe{�Z�G dXdY� dYe{�Z�dZd[� Z�G d\d]� d]e{�Z�d^d_� Z��ddbdc�Z�ddde� Z�dfdg� Z�dhdi� Z�e j��r�djdk� Z�dldm� Z��ddndo�Z�h dp�Z��ddqdr�Z��ddsdt�Z�h du�Z�dvZ�dwdx� Z�e edyd�Z�e jF�r6e�Z�e��sHej�Z�nej�Z�e��sHejZ�dzd{� Z�d|d}� Z�d~d� Z�d�d�� Z�d�dk� a�zddl�Z�da�W n eŐy� d:a�Y n0 G d�d�� d�e{�Z�eƃ Zi Z�d�d�� Z�d�d�� Z�d�d�� Z�d�d�� Zːd d�d��Z�G d�d�� d�e{�Z�G d�d�� d�e{�Zΐd
d�d��Z�d�d�� ZАd d�d��Z�d�d�� Z�d�d�� Z�d�d�� Z�G d�d�� d�e{�ZՐd d�d��Z�G d�d�� d�e{�Z�d�d�� Z�d�d�� Z�e�d�d�eId��fd�d�eId��fdd�eId��fd�d�eId��fd�d�eId��fdd�eId��fd�d`eId��fd�d`eId��fdd`eId��fddeId��f�
Z�G d�d�� d�e{�Z�e��d��Z�d�d�� Z�d�d�� Z�d�d�� Z�e j�d�k�r>e�Z�e�Z�e�Z�ne j�Z�e j�Z�e j�Z�e�� d�k�rtej�d�k �rtd�dń Z�nd�dń Z�d�dȄ Z�d�dʄ Z�d
d�d̄Z�e�dd�eIdfd�deIdσfd�deIdЃfddeIdуfd�d�eIdӃfd�d�eIdԃfdd�eIdՃfd�d�eId׃fd�d�eIdfdd�eIdكfd�d�eIdۃfd�d�eId܃fdd�eId݃f�
Z�ej�G d�d߄ d�e{��Z�ej�d�d� �Z�de�_�d�d� Z�d�Z�d�d� Z�G d�d� d�e{�Z�dd�d�Z�d�de,j�e,j�dd�fd�d�Z�e�Z��dd�d�Z�d�d� Z�d�d�� Z�d�d�� Z�ej�d�d�� �Z�d�d�� Z�dS ( z�Mercurial utility functions and platform specific implementations.
This contains helper routines that are independent of the SCM core and
hide platform-specific details from the core.
� )�absolute_import�print_functionN� )�hex)�attr)�delattr�getattr�open�setattr)�tracing)�encoding�error�i18n�policy�pycompat� urllibcompat)� compression�hashutil�procutil�
stringutil)�Iterator�List�Optional�Tuple�base85�osutil)�windows)�posix� statfilesc C s& t jr
dS t�| � | d@ t_adS )z%updates the umask. used by chg serverNi� )r � iswindows�os�umask�platform)�val� r$ �4/usr/lib64/python3.9/site-packages/mercurial/util.py�setumask� s
r& c C s d}| D ] }||O }q|S �Nr r$ )� container�bits�bitr$ r$ r% �bitsfrom� s
r+ s HGEMITWARNINGS�default� Z mercurialZhgextZhgext3rd�ignorez
bad escapezinvalid escape sequencez the imp module is deprecatedc C s6 t r2| d| 7 } t�t�| �t|d � tj�� dS )zxIssue an python native deprecation warning
This is a noop outside of tests, use 'ui.deprecwarn' when possible.
sF
(compatibility will be dropped after Mercurial-%s, update your code.)r N) �_dowarn�warnings�warnr �sysstr�DeprecationWarning�sys�stderr�flush)�msg�version�
stacklevelr$ r$ r% �nouideprecwarn� s �r: )� md5� sha1� sha512)r= r< r; c @ s> e Zd ZdZddd�Zdd� Zdd� Zd d
� Zed d � �Z d
S )�digestera� helper to compute digests.
This helper can be used to compute one or more digests given their name.
>>> d = digester([b'md5', b'sha1'])
>>> d.update(b'foo')
>>> [k for k in sorted(d)]
['md5', 'sha1']
>>> d[b'md5']
'acbd18db4cc2f85cedef654fccc4a4d8'
>>> d[b'sha1']
'0beec7b5ea3f0fdbc95d0dd47f3c5bc275da8a33'
>>> digester.preferred([b'md5', b'sha1'])
'sha1'
� c C sL i | _ |D ].}|tvr(t�td�| ��t| � | j |< q
|rH| �|� d S �Ns unknown digest type: %s)�_hashes�DIGESTSr
�Abort�_�update)�self�digests�s�kr$ r$ r% �__init__� s zdigester.__init__c C s | j �� D ]}|�|� q
d S �N)rA �valuesrE )rF �data�hr$ r$ r% rE s zdigester.updatec C s, |t vrt�td�t ��t| j| �� �S r@ )rB r
rC rD rI r rA �digest)rF �keyr$ r$ r% � __getitem__
s zdigester.__getitem__c C s
t | j�S rK )�iterrA �rF r$ r$ r% �__iter__ s zdigester.__iter__c C s t D ]}|| v r| S qdS )z@returns the strongest digest type in both supported and DIGESTS.N)�DIGESTS_BY_STRENGTH)Z supportedrI r$ r$ r% � preferred s
zdigester.preferredN)r? )
�__name__�
__module__� __qualname__�__doc__rJ rE rQ rT � staticmethodrV r$ r$ r$ r% r> � s
r> c @ s* e Zd ZdZdd� Zd
dd�Zdd� Zd S ) �
digestcheckerz�file handle wrapper that additionally checks content against a given
size and digests.
d = digestchecker(fh, size, {'md5': '...'})
When multiple digests are given, all of them are validated.
c C s0 || _ || _d| _t|�| _t| j�� �| _d S r' )�_fh�_size�_got�dict�_digestsr> �keys� _digester)rF �fh�sizerG r$ r$ r% rJ % s
zdigestchecker.__init__���c C s. | j �|�}| j�|� | jt|�7 _|S rK )r] �readrc rE r_ �len)rF �lengthZcontentr$ r$ r% rg , s zdigestchecker.readc C sj | j | jkr&t�td�| j | jf ��| j�� D ]4\}}|| j| kr0t�td�||| j| f ��q0d S )Ns" size mismatch: expected %d, got %ds %s mismatch: expected %s, got %s)r^ r_ r
rC rD ra �itemsrc �rF rI �vr$ r$ r% �validate2 s
����zdigestchecker.validateN)rf )rW rX rY rZ rJ rg rm r$ r$ r$ r% r\ s
r\ c C s, |d ur t | �||| � S t | �|d � S rK )�
memoryview)Z sliceable�offsetri r$ r$ r% �bufferE s rp i c s| e Zd ZdZ� fdd�Zdd� Zedd� �Zedd � �Zd
d � Z d d
� Z
dd� Z dd� Z dd� Z
dd� Zefdd�Z� ZS )�bufferedinputpipeaW a manually buffered input pipe
Python will not let us use buffered IO and lazy reading with 'polling' at
the same time. We cannot probe the buffer state and select will not detect
that data are ready to read if they are already buffered.
This class let us work around that by implementing its own buffering
(allowing efficient readline) while offering a way to know if the buffer is
empty from the output (allowing collaboration of the buffer with polling).
This class lives in the 'util' module because it makes use of the 'os'
module from the python stdlib.
c s t |t�rt} tt| ��| �S rK )�
isinstance�fileobjectproxy�observedbufferedinputpipe�superrq �__new__)�clsrd �� __class__r$ r% rv ] s
zbufferedinputpipe.__new__c C s || _ g | _d| _d| _d S )NFr )�_input�_buffer�_eof�_lenbuf)rF �inputr$ r$ r% rJ e s zbufferedinputpipe.__init__c C s
t | j�S )z�True is any data is currently buffered
This will be used externally a pre-step for polling IO. If there is
already data then no polling should be set in place.)�boolr{ rS r$ r$ r% � hasbufferk s zbufferedinputpipe.hasbufferc C s | j jS rK )rz �closedrS r$ r$ r% r� s s zbufferedinputpipe.closedc C s
| j �� S rK )rz �filenorS r$ r$ r% r� w s zbufferedinputpipe.filenoc C s
| j �� S rK )rz �closerS r$ r$ r% r� z s zbufferedinputpipe.closec C s$ | j s| j|k r| �� q | �|�S rK )r| r} � _fillbuffer� _frombuffer�rF re r$ r$ r% rg } s
zbufferedinputpipe.readc C s2 | j s | jdkr | �t|t�� | �t| j|��S r' )r| r} r� �max�
_chunksizer� �minr� r$ r$ r% �unbufferedread� s z bufferedinputpipe.unbufferedreadc O s� t | j�dkr.d�| j�g| _t | jd �| _d}| jrH| jd �d�}| jsv|dk rv| �� | jrH| jd �d�}qH|d }|dk r�| j}n&t | j�dkr�|| jt | jd � 7 }| �|�S )Nr r? r rf �
)rh r{ �joinr} �findr| r� r� )rF �args�kwargsZlfire r$ r$ r% �readline� s zbufferedinputpipe.readlinec C sz |dks| j sdS | j d }t| j �dkr6d�| j �}|d|� }|t|�d� }|rj|g| _ t|�| _n g | _ d| _|S )zYreturn at most 'size' data from the buffer
The data are removed from the buffer.r r? r N)r{ rh r� r} )rF re �bufrM r$ r$ r% r� � s
z bufferedinputpipe._frombufferc C s@ t �| j�� |�}|s d| _n | jt|�7 _| j�|� |S )zread data to the bufferT) r rg rz r� r| r} rh r{ �append)rF re rM r$ r$ r% r� � s z bufferedinputpipe._fillbuffer)rW rX rY rZ rv rJ �propertyr� r� r� r� rg r� r� r� r� r� �
__classcell__r$ r$ rx r% rq N s
rq c sr |dkr dS |d u rd}t � d� fdd��� }ztj||tjd�W S tyl t�|�jdkrfY dS � Y n0 d S )Nr r? r� c s � S rK r$ r$ ��fpr$ r% �<lambda>� r? zmmapread.<locals>.<lambda>)�access)r �mmapZ ACCESS_READ�
ValueErrorr �fstat�st_size)r� re �fdr$ r� r% �mmapread� s r� c @ s� e Zd ZdZdZdd� Zdd� Zdd� ZeZd d
� Z d d � Z
d
d� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Z d1d2� Z d3d4� Z d5d6� Z d7S )8rs z�A proxy around file objects that tells a watcher when events occur.
This type is intended to only be used for testing purposes. Think hard
before using it in important code.
��_orig� _observerc C s t �| d|� t �| d|� d S �Nr� r� ��object� __setattr__)rF rd �observerr$ r$ r% rJ � s zfileobjectproxy.__init__c C s. h d�}||v r t �| |�S tt �| d�|�S )N> �seek�readallr� �tell�readintorg r� �write�read1�readabler� �isatty�truncater� �detach�seekable�writable�
writelinesr6 � readlinesr� �r� �__getattribute__r )rF �nameZoursr$ r$ r% r� � s z fileobjectproxy.__getattribute__c C s t t�| d��S �Nr� �r r� r� rS r$ r$ r% � __nonzero__ s zfileobjectproxy.__nonzero__c C s t t�| d�|�S r� �r r� r� �rF r� r$ r$ r% � __delattr__ s zfileobjectproxy.__delattr__c C s t t�| d�||�S r� �r
r� r� �rF r� �valuer$ r$ r% r� s zfileobjectproxy.__setattr__c C s t �| d��� S r� )r� r� rT rS r$ r$ r% rT s zfileobjectproxy.__iter__c O sV t �| d�}t||�|i |��}t �| d�}t||d �}|rR||g|�R i |�� |S r� r� �rF r� r� r� Zorig�resr� �fnr$ r$ r% �
_observedcall s z fileobjectproxy._observedcallc O s t �| d�dg|�R i |��S )Nr� r� �r� r� �rF r� r� r$ r$ r% r� s
���zfileobjectproxy.closec O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� % s
���zfileobjectproxy.filenoc O s t �| d�dg|�R i |��S )Nr� r6 r� r� r$ r$ r% r6 * s
���zfileobjectproxy.flushc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� / s
���zfileobjectproxy.isattyc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� 4 s
���zfileobjectproxy.readablec O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� 9 s
���zfileobjectproxy.readlinec O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� > s
���zfileobjectproxy.readlinesc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� C s
���zfileobjectproxy.seekc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� H s
���zfileobjectproxy.seekablec O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� M s
���zfileobjectproxy.tellc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� R s
���zfileobjectproxy.truncatec O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� W s
���zfileobjectproxy.writablec O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� \ s
���zfileobjectproxy.writelinesc O s t �| d�dg|�R i |��S )Nr� rg r� r� r$ r$ r% rg a s
���zfileobjectproxy.readc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� f s
���zfileobjectproxy.readallc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� k s
���zfileobjectproxy.readintoc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� p s
���zfileobjectproxy.writec O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� u s
���zfileobjectproxy.detachc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� z s
���zfileobjectproxy.read1N) rW rX rY rZ � __slots__rJ r� r� �__bool__r� r� rT r� r� r� r6 r� r� r� r� r� r� r� r� r� r� rg r� r� r� r� r� r$ r$ r$ r% rs � s: &rs c s8 e Zd ZdZ� fdd�Z� fdd�Z� fdd�Z� ZS )rt a� A variation of bufferedinputpipe that is aware of fileobjectproxy.
``bufferedinputpipe`` makes low-level calls to ``os.read()`` that
bypass ``fileobjectproxy``. Because of this, we need to make
``bufferedinputpipe`` aware of these operations.
This variation of ``bufferedinputpipe`` can notify observers about
``os.read()`` events. It also re-publishes other events, such as
``read()`` and ``readline()``.
c s0 t t| ��� }t| jjdd �}|r,||t� |S )NZosread)ru rt r� r rz r� r� )rF r� r� rx r$ r% r� � s
z%observedbufferedinputpipe._fillbufferc s2 t t| ��|�}t| jjdd �}|r.|||� |S )N� bufferedread)ru rt rg r rz r� )rF re r� r� rx r$ r% rg � s
z observedbufferedinputpipe.readc s6 t t| �j|i |��}t| jjdd �}|r2||� |S )N�bufferedreadline)ru rt r� r rz r� )rF r� r� r� r� rx r$ r% r� � s
z"observedbufferedinputpipe.readline)rW rX rY rZ r� rg r� r� r$ r$ rx r% rt � s rt > � recv_into�recvfrom�sendall�recv�
setsockopt� setblocking�
recvfrom_into�
settimeout�
gettimeout�send�makefile�sendtoc @ s� e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Zd d � Z e Z
d
d� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'S )(� socketproxyz�A proxy around a socket that tells a watcher when events occur.
This is like ``fileobjectproxy`` except for sockets.
This type is intended to only be used for testing purposes. Think hard
before using it in important code.
r� c C s t �| d|� t �| d|� d S r� r� )rF Zsockr� r$ r$ r% rJ � s zsocketproxy.__init__c C s& |t v rt�| |�S tt�| d�|�S r� )�PROXIED_SOCKET_METHODSr� r� r r� r$ r$ r% r� � s z socketproxy.__getattribute__c C s t t�| d�|�S r� r� r� r$ r$ r% r� � s zsocketproxy.__delattr__c C s t t�| d�||�S r� r� r� r$ r$ r% r� � s zsocketproxy.__setattr__c C s t t�| d��S r� r� rS r$ r$ r% r� � s zsocketproxy.__nonzero__c O sV t �| d�}t||�|i |��}t �| d�}t||d �}|rR||g|�R i |�� |S r� r� r� r$ r$ r% r� � s zsocketproxy._observedcallc O sL t �| d�dg|�R i |��}t �| d�}t|j||j|j|j|j|jd�S )Nr� r� r� ��reads�writes�logdata� logdataapis) r� r� �makeloggingfileobjectrd r� r� r� r� r� )rF r� r� r� r� r$ r$ r% r� � s"
��� �zsocketproxy.makefilec O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� � s
���zsocketproxy.recvc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� s
���zsocketproxy.recvfromc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� s
���zsocketproxy.recvfrom_intoc O s t �| d�dg|�R i |��S )Nr� Z recv_infor� r� r$ r$ r% r� s
���zsocketproxy.recv_intoc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� s
���zsocketproxy.sendc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� s
���zsocketproxy.sendallc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� s
���zsocketproxy.sendtoc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� s
���zsocketproxy.setblockingc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� % s
���zsocketproxy.settimeoutc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� * s
���zsocketproxy.gettimeoutc O s t �| d�dg|�R i |��S )Nr� r� r� r� r$ r$ r% r� / s
���zsocketproxy.setsockoptN)rW rX rY rZ r� rJ r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r$ r$ r$ r% r� � s* r� c @ s e Zd Zdd� Zdd� ZdS )�baseproxyobserverc C s || _ || _|| _|| _d S rK )rd r� r� r� )rF rd r� r� r� r$ r$ r% rJ 6 s zbaseproxyobserver.__init__c C s� | j s&| jr"| j�d� | j�� d S d|vrv| jrL| j�dt�|� � n | j�d| jt�|�f � | j�� d S | jr�| j�d� |�d�}|D ] }| j�d| jt�|�f � q�| j�� d S )Nr� s : %s
s %s> %s
s :
T) r� r� rd r� r6 r � escapestrr� �
splitlines)rF rM �lines�liner$ r$ r% �
_writedata< s*
�
�z baseproxyobserver._writedataN)rW rX rY rJ r� r$ r$ r$ r% r� 5 s r� c s^ e Zd ZdZd� fdd� Zddd�Zdd d
�Zd d � Zd
d� Zdd� Z dd� Z
dd� Z � Z S )�fileobjectobserverzLogs file object activity.TFc s& t t| ��||||� || _|| _d S rK )ru r� rJ r� r� )rF rd r� r� r� r� r� rx r$ r% rJ ] s zfileobjectobserver.__init__rf c C sZ | j s
d S |d u rd}|dkr*|dkr*d S | jrL| j�d| j|t|�f � | �|� d S )Nr? rf s %s> read(%d) -> %d�r� r� rd r� r� rh r� �rF r� re r$ r$ r% rg d s zfileobjectobserver.readc C s8 | j s
d S | jr*| j�d| jt|�f � | �|� d S )Ns %s> readline() -> %dr� )rF r� �limitr$ r$ r% r� w s
zfileobjectobserver.readlinec C sd | j s
d S | jr,| j�d| jt|�|f � |d ur@|d|� nd}t|t�rV|�� }| � |� d S )Ns %s> readinto(%d) -> %rr r? )
r� r� rd r� r� rh rr rn �tobytesr� )rF r� �destrM r$ r$ r% r� � s �
zfileobjectobserver.readintoc C sN | j s
d S |d u r |r t|�}| jr@| j�d| jt|�|f � | �|� d S )Ns %s> write(%d) -> %r)r� rh r� rd r� r� r� )rF r� rM r$ r$ r% r� � s zfileobjectobserver.writec C s$ | j s
d S | j�d| j|f � d S )Ns %s> flush() -> %r
)r� rd r� r� �rF r� r$ r$ r% r6 � s zfileobjectobserver.flushc C s: | j s
d S | jr,| j�d| j|t|�f � | �|� d S )Ns %s> bufferedread(%d) -> %dr� r� r$ r$ r% r� � s �z fileobjectobserver.bufferedreadc C s8 | j s
d S | jr*| j�d| jt|�f � | �|� d S )Ns %s> bufferedreadline() -> %dr� r� r$ r$ r% r� � s �z#fileobjectobserver.bufferedreadline)TTFT)rf )rf )
rW rX rY rZ rJ rg r� r� r� r6 r� r� r� r$ r$ rx r% r� Z s �
r� TFc C s t | |||||d�}t||�S )z.Turn a file object into a logging file object.r� )r� rs )�loghrd r� r� r� r� r� r� r$ r$ r% r� � s �r� c s� e Zd ZdZd � fdd� Zd!dd�Zd"d
d �Zd#d d
�Zd$dd�Zd%dd�Z d&dd�Z
d'dd�Z d(dd�Z dd� Z
dd� Zd d � Zd d � Z� ZS ))�socketobserverzLogs socket activity.TFc s, t t| ��||||� || _|| _|| _d S rK )ru r� rJ r� r� �states)rF rd r� r� r� r� r� r� rx r$ r% rJ � s
zsocketobserver.__init__Nc C s& | j s
d S | j�d| j||f � d S )Ns %s> makefile(%r, %r)
�r� rd r� r� )rF r� �mode�bufsizer$ r$ r% r� � s zsocketobserver.makefiler c C s< | j s
d S | jr.| j�d| j||t|�f � | �|� d S )Ns %s> recv(%d, %d) -> %dr� �rF r� re �flagsr$ r$ r% r� � s �zsocketobserver.recvc C sD | j s
d S | jr2| j�d| j||t|d �f � | �|d � d S )Ns %s> recvfrom(%d, %d) -> %dr r� r� r$ r$ r% r� � s ��zsocketobserver.recvfromc C sH | j s
d S | jr.| j�d| j|||d f � | �|d|d � � d S )Ns %s> recvfrom_into(%d, %d) -> %dr �r� r� rd r� r� r� �rF r� r� re r� r$ r$ r% r� � s ��z socketobserver.recvfrom_intoc C s@ | j s
d S | jr*| j�d| j|||f � | �|d|� � d S )Ns %s> recv_into(%d, %d) -> %dr r� r� r$ r$ r% r� s �zsocketobserver.recv_intoc C s: | j s
d S | j�d| jt|�|t|�f � | �|� d S )Ns %s> send(%d, %d) -> %d)r� rd r� r� rh r� �rF r� rM r� r$ r$ r% r� s �zsocketobserver.sendc C s: | j s
d S | jr,| j�d| jt|�|f � | �|� d S )Ns %s> sendall(%d, %d)�r� r� rd r� r� rh r� r� r$ r$ r% r� s �zsocketobserver.sendallc C sL | j s
d S |r|}nd}| jr>| j�d| jt|�|||f � | �|� d S )Nr s %s> sendto(%d, %d, %r) -> %dr� )rF r� rM ZflagsoraddressZaddressr� r$ r$ r% r� ( s ��zsocketobserver.sendtoc C s$ | j s
d S | j�d| j|f � d S )Ns %s> setblocking(%r)
r� )rF r� �flagr$ r$ r% r� 9 s zsocketobserver.setblockingc C s$ | j s
d S | j�d| j|f � d S )Ns %s> settimeout(%r)
r� )rF r� r� r$ r$ r% r� ? s zsocketobserver.settimeoutc C s$ | j s
d S | j�d| j|f � d S )Ns %s> gettimeout() -> %f
r� r� r$ r$ r% r� E s zsocketobserver.gettimeoutc C s* | j s
d S | j�d| j||||f � d S )Ns! %s> setsockopt(%r, %r, %r) -> %r
r� )rF r� �levelZoptnamer� r$ r$ r% r� K s ��zsocketobserver.setsockopt)TTTFT)NN)r )r )r )r r )r )r )N)rW rX rY rZ rJ r� r� r� r� r� r� r� r� r� r� r� r� r� r$ r$ rx r% r� � s& �
r� c C s t | ||||||d�}t||�S )z$Turn a socket into a logging socket.)r� r� r� r� r� )r� r� ) r� rd r� r� r� r� r� r� r� r$ r$ r% �makeloggingsocketU s � r� c C s. zddl m} | jW S ty( Y dS 0 dS )z(Return version information if available.r �� __version__s unknownN)r- r� r8 � ImportErrorr� r$ r$ r% r8 m s
r8 � c C s | s
t � } t�d| �}|s&d| }}n(|�d�r>|�� \}}n|�d�d }}g }|�d�D ]0}z|�t|�� W q\ ty� Y q�Y q\0 q\t |�dk r�|�d� q�|dkr�|d |d fS |dkr�|d |d |d fS |d k� r�|d |d |d |fS t
� d
| ��dS ) az Parses a Mercurial version string into an N-tuple.
The version string to be parsed is specified with the ``v`` argument.
If it isn't defined, the current Mercurial version string will be parsed.
``n`` can be 2, 3, or 4. Here is how some version strings map to
returned values:
>>> v = b'3.6.1+190-df9b73d2d444'
>>> versiontuple(v, 2)
(3, 6)
>>> versiontuple(v, 3)
(3, 6, 1)
>>> versiontuple(v, 4)
(3, 6, 1, '190-df9b73d2d444')
>>> versiontuple(b'3.6.1+190-df9b73d2d444+20151118')
(3, 6, 1, '190-df9b73d2d444+20151118')
>>> v = b'3.6'
>>> versiontuple(v, 2)
(3, 6)
>>> versiontuple(v, 3)
(3, 6, None)
>>> versiontuple(v, 4)
(3, 6, None, None)
>>> v = b'3.9-rc'
>>> versiontuple(v, 2)
(3, 9)
>>> versiontuple(v, 3)
(3, 9, None)
>>> versiontuple(v, 4)
(3, 9, None, 'rc')
>>> v = b'3.9-rc+2-02a8fea4289b'
>>> versiontuple(v, 2)
(3, 9)
>>> versiontuple(v, 3)
(3, 9, None)
>>> versiontuple(v, 4)
(3, 9, None, 'rc+2-02a8fea4289b')
>>> versiontuple(b'4.6rc0')
(4, 6, None, 'rc0')
>>> versiontuple(b'4.6rc0+12-425d55e54f98')
(4, 6, None, 'rc0+12-425d55e54f98')
>>> versiontuple(b'.1.2.3')
(None, None, None, '.1.2.3')
>>> versiontuple(b'12.34..5')
(12, 34, None, '..5')
>>> versiontuple(b'1.2.3.4.5.6')
(1, 2, 3, '.4.5.6')
s (\d+(?:\.\d+){,2})[+-]?(.*)r? � r N� .� r r� s invalid version part request: %d) r8 �remod�match�group�groups�splitr� �intr� rh r
�ProgrammingError)rl �n�mZvpartsZextraZvints�ir$ r$ r% � versiontuplew s. 7
r c sT �j jdkr"g ���fdd�}|S i � �j jdkrB� �fdd�}n� �fdd�}|S )z"cache the result of function callsr c s t ��dkr��� � � �d S r' )rh r� r$ )�func� listcacher$ r% �f� s zcachefunc.<locals>.fr c s | � vr�| �� | < � | S rK r$ ��arg��cacher
r$ r% r � s c s | � vr�| � � | < � | S rK r$ �r� r r$ r% r � s )�__code__� co_argcount�r
r r$ )r r
r r% � cachefunc� s r c @ s e Zd ZdZdd� Zdd� ZdS )�cowz^helper class to make copy-on-write easier
Call preparewrite before doing any writes.
c C s( t | dd�r$| jd8 _| �| �S | S )z;call this before writes, return self or a copied new object�_copiedr r )r r ry rS r$ r$ r% � preparewrite� s
zcow.preparewritec C s t | dd�d | _| S )zalways do a cheap copyr r r )r r rS r$ r$ r% �copy� s zcow.copyN)rW rX rY rZ r r r$ r$ r$ r% r � s r c s6 e Zd ZdZ� fdd�Zejr&dd� Zdd� Z� Z S )�sortdicta[ a simple sorted dictionary
>>> d1 = sortdict([(b'a', 0), (b'b', 1)])
>>> d2 = d1.copy()
>>> d2
sortdict([('a', 0), ('b', 1)])
>>> d2.update([(b'a', 2)])
>>> list(d2.keys()) # should still be in last-set order
['b', 'a']
>>> d1.insert(1, b'a.5', 0.5)
>>> d1
sortdict([('a', 0), ('a.5', 0.5), ('b', 1)])
c s$ || v r| |= t t| ��||� d S rK )ru r � __setitem__)rF rP r� rx r$ r% r s zsortdict.__setitem__c K sD t |t�rt�|�}|D ]\}}|| |< q|D ]}|| | |< q.d S rK )rr r` r Z iteritems)rF �srcr rI rl r$ r$ r% rE s
zsortdict.updatec C sH t t| �� ��D ]2\}\}}||kr,|| |< ||kr| |= || |< qd S rK )� enumerate�listrj )rF ZpositionrP r� r rI rl r$ r$ r% �insert s zsortdict.insert)
rW rX rY rZ r r �ispypyrE r" r� r$ r$ rx r% r s
r c @ s e Zd ZdZdS )�cowdicta� copy-on-write dict
Be sure to call d = d.preparewrite() before writing to d.
>>> a = cowdict()
>>> a is a.preparewrite()
True
>>> b = a.copy()
>>> b is a
True
>>> c = b.copy()
>>> c is a
True
>>> a = a.preparewrite()
>>> b is a
False
>>> a is a.preparewrite()
True
>>> c = c.preparewrite()
>>> b is c
False
>>> b is b.preparewrite()
True
N�rW rX rY rZ r$ r$ r$ r% r$ ( s r$ c @ s e Zd ZdZdS )� cowsortdictzZcopy-on-write sortdict
Be sure to call d = d.preparewrite() before writing to d.
Nr% r$ r$ r$ r% r& C s r& c @ sB e Zd ZdZejZejdd� �Zejdd� �Z dd� Z
dd � Z d
S ) �
transactionalzBBase class for making a transactional type into a context manager.c C s dS )z$Successfully closes the transaction.Nr$ rS r$ r$ r% r� O s ztransactional.closec C s dS )zoMarks the end of the transaction.
If the transaction has not been closed, it will be aborted.
Nr$ rS r$ r$ r% �releaseS s ztransactional.releasec C s | S rK r$ rS r$ r$ r% � __enter__Z s ztransactional.__enter__c C s, z |d u r| � � W | �� n
| �� 0 d S rK )r� r( )rF �exc_typeZexc_valZexc_tbr$ r$ r% �__exit__] s
ztransactional.__exit__N) rW rX rY rZ �abc�ABCMetaZ
__metaclass__�abstractmethodr� r( r) r+ r$ r$ r$ r% r' J s
r' c c s\ | sdV dS z>zdV | � � W n tjy@ | � � � Y n0 W | �� n
| �� 0 dS )z�A context manager that closes the transaction on InterventionRequired
If no transaction was provided, this simply runs the body and returns
N)r� r
ZInterventionRequiredr( )�trr$ r$ r% �acceptinterventione s
r0 c c s
| V d S rK r$ )� enter_resultr$ r$ r% �nullcontextmanagerx s r2 c @ s$ e Zd ZdZdZdd� Zdd� ZdS )�
_lrucachenodez�A node in a doubly linked list.
Holds a reference to nodes on either side as well as a key-value
pair for the dictionary entry.
)�next�prevrP r� �costc C s" | | _ | | _t| _d | _d| _d S r' )r4 r5 �_notsetrP r� r6 rS r$ r$ r% rJ � s
z_lrucachenode.__init__c C s t | _d| _d| _dS )zMark the node as emptied.Nr )r7 rP r� r6 rS r$ r$ r% � markempty� s z_lrucachenode.markemptyN)rW rX rY rZ r� rJ r8 r$ r$ r$ r% r3 } s r3 c @ s� e Zd ZdZd&dd�Zdd� Zdd� Zd d
� Zd d � Zd'd
d�Z dd� Z
dd� Z e fdd�Z
d(dd�Ze fdd�Zdd� Zd)d d �Zd d � Zd d!� Zd"d#� Zd$d%� ZdS )*� lrucachedicta Dict that caches most recent accesses and sets.
The dict consists of an actual backing dict - indexed by original
key - and a doubly linked circular list defining the order of entries in
the cache.
The head node is the newest entry in the cache. If the cache is full,
we recycle head.prev and make it the new head. Cache accesses result in
the node being moved to before the existing head and being marked as the
new head node.
Items in the cache can be inserted with an optional "cost" value. This is
simply an integer that is specified by the caller. The cache can be queried
for the total cost of all items presently in the cache.
The cache can also define a maximum cost. If a cache insertion would
cause the total cost of the cache to go beyond the maximum cost limit,
nodes will be evicted to make room for the new code. This can be used
to e.g. set a max memory limit and associate an estimated bytes size
cost to each item in the cache. By default, no maximum cost is enforced.
r c C s* i | _ t� | _d| _|| _d| _|| _d S )Nr r )�_cacher3 �_headr^ �capacity� totalcost�maxcost)rF r� r> r$ r$ r% rJ � s zlrucachedict.__init__c C s
t | j�S rK )rh r: rS r$ r$ r% �__len__� s zlrucachedict.__len__c C s
|| j v S rK )r: �rF rI r$ r$ r% � __contains__� s zlrucachedict.__contains__c c s, | j }tt| j��D ]}|jV |j}qd S rK )r; �rangerh r: rP r4 )rF r r r$ r$ r% rT � s zlrucachedict.__iter__c C s | j | }| �|� |jS rK )r: � _movetoheadr� )rF rI �noder$ r$ r% rQ � s
zlrucachedict.__getitem__c C s� | j �|�}|durZ| j|j8 _||_||_| j|7 _| �|� | jrV| �� dS | j| j k rp| �
� }n| j j }|j
tur�| j|j8 _| j |j
= ||_
||_||_| j|7 _|| j |< || _ | jr�| �� dS )z8Insert a new item in the cache with optional cost value.N)r: �getr= r6 r� rC r> �_enforcecostlimitr^ r< � _addcapacityr; r5 rP r7 )rF rI rl r6 rD r$ r$ r% r" � s0
zlrucachedict.insertc C s | � ||� d S rK )r" rk r$ r$ r% r � s zlrucachedict.__setitem__c C s | � |� d S rK )�popr@ r$ r$ r% � __delitem__� s zlrucachedict.__delitem__c C sf z| j �|�}W n ty0 |tu r(� | Y S 0 |j}| j|j8 _|�� | �|� |j | _
|S rK ) r: rH �KeyErrorr7 r� r= r6 r8 rC r4 r; )rF rI r, rD r� r$ r$ r% rH � s
zlrucachedict.popNc C s( z | � |�W S ty" | Y S 0 d S rK )rQ rJ )rF rI r, r$ r$ r% rE
s zlrucachedict.getc C s8 z| j | }|jW S ty2 |tu r*� | Y S 0 dS )z�Get the specified item without moving it to the head
Unlike get(), this doesn't mutate the internal state. But be aware
that it doesn't mean peek() is thread safe.
N)r: r� rJ r7 )rF rI r, rD r$ r$ r% �peek s
zlrucachedict.peekc C s> | j }|jtur0| j|j8 _|�� |j}q| j�� d S rK ) r; rP r7 r= r6 r8 r4 r: �clear)rF r r$ r$ r% rL s
zlrucachedict.clearc C sx |p| j }|p| j}t||d�}| jj}|jtu rD|| jurD|j}q(tt| j ��D ] }|j
|j|j |j d� |j}qR|S )a8 Create a new cache as a copy of the current one.
By default, the new cache has the same capacity as the existing one.
But, the cache capacity can be changed as part of performing the
copy.
Items in the copy have an insertion/access order matching this
instance.
)r> )r6 )
r< r> r9 r; r5 rP r7 rB rh r: r" r� r6 )rF r< r> �resultr r r$ r$ r% r ( s
zlrucachedict.copyc C s\ | j s
dS | jj}|jtu r$|j}q|j|j }}| j |j= | j|j8 _|�� ||fS )zuRemove the oldest item from the cache.
Returns the (key, value) describing the removed cache entry.
N) r: r; r5 rP r7 r� r= r6 r8 )rF r rP r� r$ r$ r% � popoldestG s
zlrucachedict.popoldestc C sF | j }|j|j_|j|j_|j|_|jj|_||j_||j_|| _ dS )aq Mark a node as the newest, making it the new head.
When a node is accessed, it becomes the freshest entry in the LRU
list, which is denoted by self._head.
Visually, let's make ``N`` the new head node (* denotes head):
previous/oldest <-> head <-> next/next newest
----<->--- A* ---<->-----
| |
E <-> D <-> N <-> C <-> B
To:
----<->--- N* ---<->-----
| |
E <-> D <-> C <-> B <-> A
This requires the following moves:
C.next = D (node.prev.next = node.next)
D.prev = C (node.next.prev = node.prev)
E.next = N (head.prev.next = node)
N.prev = E (node.prev = head.prev)
N.next = A (node.next = head)
A.prev = N (head.prev = node)
N)r; r4 r5 )rF rD �headr$ r$ r% rC c s
zlrucachedict._movetoheadc C s: | j }t� }||j_|j|_||_||_| jd7 _|S )zhAdd a node to the circular linked list.
The new node is inserted before the head node.
r )r; r3 r5 r4 r^ )rF rO rD r$ r$ r% rG � s zlrucachedict._addcapacityc C s� t | �dks| j| jkr d S t| jd �}| jj}|jtu rD|j}q2t | �dkr�| j|kr�| j|j= | j|j 8 _|�
� |j}qDd S )Nr g �?) rh r= r> r r; r5 rP r7 r: r6 r8 )rF Z
targetcostr r$ r$ r% rF � s
z lrucachedict._enforcecostlimit)r )r )N)Nr )rW rX rY rZ rJ r? rA rT rQ r" r rI r7 rH rE rK rL r rN rC rG rF r$ r$ r$ r% r9 � s$
'
/r9 c s> i � t �� ��jjdkr*� ��fdd�}n� ��fdd�}|S )z+cache most recent results of function callsr c sH | � vr,t � �dkr � ��� = �| �� | < n
��| � ��| � � | S �N� �rh �popleft�remover� r �r r
�orderr$ r% r � s
zlrucachefunc.<locals>.fc sH | � vr,t � �dkr � ��� = �| � � | < n
��| � ��| � � | S rP rR r rU r$ r% r � s
)� collections�dequer r r r$ rU r% � lrucachefunc� s
rY c @ s& e Zd Zdd� Zddd�Zdd� ZdS ) �
propertycachec C s || _ |j| _d S rK )r
rW r� )rF r
r$ r$ r% rJ � s zpropertycache.__init__Nc C s | � |�}| �||� |S rK )r
�
cachevalue)rF �obj�typerM r$ r$ r% �__get__� s
zpropertycache.__get__c C s ||j | j< d S rK )�__dict__r� )rF r\ r� r$ r$ r% r[ � s zpropertycache.cachevalue)N)rW rX rY rJ r^ r[ r$ r$ r$ r% rZ � s
rZ c C s t �|�}|| jv r | j|= dS )z2clear a cached property value, if one has been setN)r r2 r_ )r\ Zpropr$ r$ r% �clearcachedproperty� s
r` � � c c s� dd� }g }d}| D ]j}|� |� |t|�7 }||kr||k rj|d> }d||�> }||kr^|}||krj|}d�|�V d}g }q|r�d�|�V dS )zrreturn no less than min bytes per chunk while data remains,
doubling min after each chunk until it reaches maxc S s* | sdS d}| r"| dL } |d7 }q |d S )Nr r r$ )�xr r$ r$ r% �log2� s
z increasingchunks.<locals>.log2r r r? N)r� rh r� )�sourcer� r� rd r� Zblen�chunkZnminr$ r$ r% �increasingchunks� s&
rg c C s dS )NTr$ �r� r$ r$ r% �always s ri c C s dS �NFr$ rh r$ r$ r% �never s rk c s � fdd�}|S )a
disable garbage collector
Python's garbage collector triggers a GC each time a certain number of
container objects (the number being defined by gc.get_threshold()) are
allocated even when marked not to be tracked by the collector. Tracking has
no effect on when GCs are triggered, only on what objects the GC looks
into. As a workaround, disable GC while building complex (huge)
containers.
This garbage collector issue have been fixed in 2.7. But it still affect
CPython's performance.
c sB t �� }t �� z � | i |��W |r,t �� S n|r<t �� 0 d S rK )�gc� isenabled�disable�enable)r� r� Z gcenabled�r
r$ r% �wrapper- s � �znogc.<locals>.wrapperr$ �r
rq r$ rp r% �nogc s rs c C s | S rK r$ �rc r$ r$ r% r� ; r? r� c C s� |s t |�S tj�|�r\tj�| �d tj�|�d krJtj�| t |��S d�t| �|f�}t|�|�d� }}|� � |� � |r�|r�|d |d kr�|�
� |�
� q�|� � t j �dgt
|� | �p�dS )aa return the relative path from one place to another.
root should use os.sep to separate directories
n1 should use os.sep to separate directories
n2 should use "/" to separate directories
returns an os.sep-separated path.
If n1 is a relative path, it's assumed it's
relative to root.
n2 should always be relative to root.
r � /rf � ..r )� localpathr �path�isabs�
splitdriver� �pconvert� splitpathr �reverserH r �osseprh )�rootZn1Zn2�a�br$ r$ r% �pathto> s
r� c s � �fdd�}|S )z5wrap a function with code to check for calling errorsc sJ z�| i |��W S t yD tt�t�� d ��� kr>tj�� Y n0 d S )Nr� )� TypeErrorrh � traceback�
extract_tbr4 �exc_infor
ZSignatureError)r� r� ��depthr
r$ r% �check] s z checksignature.<locals>.checkr$ )r
r� r� r$ r� r% �checksignatureZ s r� >
s ext2s tmpfss NTFSs ext4s ufss ext3s xfss hfss reiserfss jfss zfss apfss btrfsc
C s d}t j�|�r*|r"|o t�|�}t|� |rx|rxztt j�|��} W n ty\ d} Y n0 | t vrx|durt|� d}|r�z&t
| |� |dur�d}
t � |
��W dS t
tfy� } z&| jtjkr�|dur�|� W Y d} ~ n
d} ~ 0 0 t j�| ��r t �t �| �|� |du�rd}
t � |
��n�z�t�| |� |�rBt�| |� nTt�| |� |�r�|j�r�t�|�} | �|��r�|jtj d d@ }
t �||
|
f� |du�r�t|dd��}|� |� W d � n1 �s�0 Y W n8 tj �y } z t � t � |���W Y d}~n
d}~0 0 dS ) af copy a file, preserving mode and optionally other stat info like
atime/mtime
checkambig argument is used with filestat, and is useful only if
destination file is guarded by any lock (e.g. repo.lock or
repo.wlock).
copystat and checkambig should be exclusive.
nb_bytes: if set only copy the first `nb_bytes` of the source file.
NFz7the `nb_bytes` argument is incompatible with `hardlink`z"cannot use `nb_bytes` on a symlinkr ��zr+)r� )!r rx �lexists�filestat�frompath�unlink� getfstype�dirname�OSError�_hardlinkfswhitelist�oslinkr
r �IOError�errno�EEXIST�islink�symlink�readlink�shutil�copyfile�copystat�copymode�stat�isambig�ST_MTIME�utimer r� �ErrorrC r Z forcebytestr)r r� �hardlinkr� �
checkambigZnb_bytesZno_hardlink_cbZcheck_fs_hardlink�oldstatZfstyper
�exc�newstat�advancedr �instr$ r$ r% r� z s\
�
.r� c
s` d}� �fdd�}t j�| �r�� du rFt �| �jt �t j�|��jk� |� t �|� t| �D ]>\}}t j�| |�}t j�||�} t || � ��\� }
||
7 }q^n�� du r�t �t j�| ��jt �t j�|��jk� |� � �r6zt
| |� W nH t t f�y2 } z*| j
t
jk�rd� t�| |� W Y d} ~ n
d} ~ 0 0 n t�| |� |d7 }��rX��� � |fS )z2Copy a directory tree using hardlinks if possible.r c s �r� rt d�nt d��_d S )Ns linkings copying)rD Ztopicr$ �r� �progressr$ r% �settopic� s zcopyfiles.<locals>.settopicNFr )r rx �isdirr� �st_devr� �mkdir�listdirr� � copyfilesr� r� r� r� r� r� r Z increment) r �dstr� r� Znumr� r� �kind�srcname�dstnamer r� r$ r� r% r� � s> �
��$ r� > s nuls com4s com7s com6s auxs lpt4s com2s lpt3s prns com5s com9s lpt6s cons com8s lpt5s com1s lpt2s lpt1s lpt8s lpt7s lpt9s com3s :*?"<>|c C s� | � d�rtd�S d| v r"td�S | �dd��d�D ]�}|s>q4t|�D ]F}|tv rftd�| S t|�dkrFtd�t�|� S qF|�d �d
}|r�|� � t
v r�td�| S |d d � }|d
v r4|dvr4td�| S q4d S )aU Check that the base-relative path is a valid filename on Windows.
Returns None if the path is ok, or a UI string describing the problem.
>>> checkwinfilename(b"just/a/normal/path")
>>> checkwinfilename(b"foo/bar/con.xml")
"filename contains 'con', which is reserved on Windows"
>>> checkwinfilename(b"foo/con.xml/bar")
"filename contains 'con', which is reserved on Windows"
>>> checkwinfilename(b"foo/bar/xml.con")
>>> checkwinfilename(b"foo/bar/AUX/bla.txt")
"filename contains 'AUX', which is reserved on Windows"
>>> checkwinfilename(b"foo/bar/bla:.txt")
"filename contains ':', which is reserved on Windows"
>>> checkwinfilename(b"foo/bar/b\07la.txt")
"filename contains '\\x07', which is invalid on Windows"
>>> checkwinfilename(b"foo/bar/bla ")
"filename ends with ' ', which is not allowed on Windows"
>>> checkwinfilename(b"../bar")
>>> checkwinfilename(b"foo\\")
"filename ends with '\\', which is invalid on Windows"
>>> checkwinfilename(b"foo\\/bar")
"directory name ends with '\\', which is invalid on Windows"
� \s3 filename ends with '\', which is invalid on Windowss \/s9 directory name ends with '\', which is invalid on Windowsru s4 filename contains '%s', which is reserved on Windows� s3 filename contains '%s', which is invalid on Windowsr r rf Ns . rv s8 filename ends with '%s', which is not allowed on Windows) �endswithrD �replacer �_filenamebytestr�_winreservedchars�ordr r� �lower�_winreservednames)rx r �c�base�tr$ r$ r% �checkwinfilename sF
���
���� ���r� � perf_counterc
C s� zt �| |�W S ty@ } z|jtjkr,� W Y d}~nd}~0 tyP Y n0 t jt jB t jB t t dd�B }t �
||�}t � || � t � |� dS )z�Create a lock file atomically if possible
This may leave a stale lock file if symlink isn't supported and signal
interrupt is enabled.
NZO_BINARYr )
r r� r� r� r� �AttributeError�O_CREAT�O_WRONLY�O_EXCLr r r� r� )�info�pathname�whyr� Zldr$ r$ r% �makelock] s r� c
C s� z
t | �W S tyB } z |jtjtjfvr.� W Y d }~nd }~0 tyR Y n0 t| d��}|�� W d � S 1 s|0 Y d S �N� rb)r� r� r� �EINVALZENOSYSr� � posixfilerg )r� r� r� r$ r$ r% �readlockq s
r� c C s4 zt �| �� �W S ty. t �| j� Y S 0 dS )z1stat file object that may not have fileno method.N)r r� r� r� r� r� r� r$ r$ r% r� ~ s r� c C s� t �| �}t j�| �\}}|�� }||kr>|�� }||kr>dS t j�||�}z t �|�}||krfW dS W dS ty~ Y dS 0 dS )z�
Return true if the given path is on a case-sensitive filesystem
Requires a path (like /foo/.hg) ending with a foldable final
directory component.
TFN)r �lstatrx r �upperr� r� r� )rx �s1�dr� �b2Zp2�s2r$ r$ r% �fscasesensitive� s
r� c C s | S rK r$ rt r$ r$ r% r� � r? c @ s* e Zd Zdd� Zd dd�Zedd� �ZdS )
�_rec C sr d}d}zt t�||��aW nP ty2 daY n< tyl t�|�}t�|�}t t�||��atjaY n0 d S )Ns \[([^\[]+)\]s [ui]F) r �re2r �_re2r� r� r r2 �
_re2_input)rF Z
check_patternZ check_inputr$ r$ r% � _checkre2� s
z
_re._checkre2r c C s� t du r| �� t rt|tjtjB @ dkrt|tj@ r<d| }|tj@ rNd| }zt�t|��W S tjyr Y n0 t�||�S )z�Compile a regular expression, using re2 if possible
For best performance, use only re2-compatible regexp features. The
only flags from the re module that are re2-compatible are
IGNORECASE and MULTILINE.Nr s (?i)s (?m)) r� r� r �
IGNORECASE� MULTILINEr� �compiler� r
)rF �patr� r$ r$ r% r� � s
z _re.compilec C s$ t du r| �� t rtjS tjS dS )z�Return the version of escape corresponding to self.compile.
This is imperfect because whether re2 or re is used for a particular
function depends on the flags, etc, but it's the best we can do.
N)r� r� r� �escaper rS r$ r$ r% r� � s
z
_re.escapeN)r )rW rX rY r� r� rZ r� r$ r$ r$ r% r� � s
r� c C s� dd� }t j}t jr |t j }|�dd� t�d||f �}tj�|�}g }|� | �D ]x\}}|rn|�
|� qV|t vr�||�t |< t | } | � |�}
|
s�||� t |< } | � |�}
|�
|
p�|� tj�
||�}qVd�
|�S )a4 Get name in the case stored in the filesystem
The name should be relative to root, and be normcase-ed for efficiency.
Note that this function is unnecessary, and should not be
called, for case-sensitive filesystems (simply because it's expensive).
The root should be normcase-ed, too.
c S s dd� t �| �D �S )Nc S s i | ]}t |�|�qS r$ )�normcase)�.0r r$ r$ r% �
<dictcomp>� r? z9fspath.<locals>._makefspathcacheentry.<locals>.<dictcomp>)r r� )�dirr$ r$ r% �_makefspathcacheentry� s z%fspath.<locals>._makefspathcacheentryr� s \\s ([^%s]+)|([%s]+)r? )r r~ �osaltsepr� r r� r rx �normpath�findallr� � _fspathcacherE r� ) r� r r� �seps�patternr� rM �part�sep�contents�foundr$ r$ r% �fspath� s,
r� c C s� d\}}}�zfz�t jdtj�| � dtj�| �d�\}}t�|� d|dd� }t||� t|�}t |�dkW W |dur�|�� ||fD ].}z|dur�t�
|� W q� t y� Y q�0 q�S t �y Y W |dur�|�� ||fD ]2}z|du�r t�
|� W q� t �y Y q�0 q�d S 0 W |du�r4|�� ||fD ]4}z|du�rVt�
|� W n t �yl Y n0 �q<nR|du�r�|�� ||fD ]4}z|du�r�t�
|� W n t �y� Y n0 �q�0 dS )
z5check whether hardlink count reporting works properly)NNN� .%s-s 1~��prefix�suffixr� s %s2~N���r F) r �mkstempr rx �basenamer� r� r� r� �nlinksr� r� )Ztestfile�f1�f2r� r� r r$ r$ r% �
checknlink s`
�
�
�
�
r� c C s" t | �tj�p tjo | �tj��S )z)Check path ends with os.sep or os.altsep.)r r� r r~ r� �rx r$ r$ r% � endswithsep6 s
�r� c C s | � tj�S )z�Split path by os.sep.
Note that this function does not use os.altsep because this is
an alternative of simple "xxx.split(os.sep)".
It is recommended to use os.path.normpath() before using this
function if need.)r r r~ r� r$ r$ r% r| @ s r| c C s t j�| �\}}tjd| d|d�\}}t �|� t| |||� |rH|S z�zt| d�}W nV ty� } z>| j t j
kr�|W Y d} ~ W S t | dd�s�| | _ � W Y d} ~ n
d} ~ 0 0 t|d�}
t
|�D ]} |
�| � q�|�� |
�� W n2 zt �|� W n t�y Y n0 � Y n0 |S )a Create a temporary file with the same contents from name
The permission bits are copied from the original file.
If the temporary file is going to be truncated immediately, you
can use emptyok=True as an optimization.
Returns the name of the temporary file.
r� � ~r� r� N�filename� wb)r rx r r r� r� r� r� r� r� �ENOENTr r �
filechunkiterr� r� r� ) r� �emptyok�
createmode�enforcewritabler� r� r� ZtempZifpr� Zofprf r$ r$ r% �
mktempcopyJ s6
r c @ sV e Zd ZdZdd� Zedd� �Zedd� �Zej Z dd � Z
d
d � Z d d
� Z dd� Z
dS )r� z�help to exactly detect change of a file
'stat' attribute is result of 'os.stat()' if specified 'path'
exists. Otherwise, it is None. This can avoid preparative
'exists()' examination on client side of this class.
c C s
|| _ d S rK )r� )rF r� r$ r$ r% rJ } s zfilestat.__init__c
C sN zt �|�}W n6 tyD } z |jtjkr,� d }W Y d }~n
d }~0 0 | |�S rK )r r� r� r� r )rw rx r� �errr$ r$ r% r� � s zfilestat.frompathc C s t �|�� �}| |�S rK )r r� r� )rw r� r� r$ r$ r% �fromfp� s zfilestat.fromfpc C s� zB| j j|j jko@| j t j |j t j ko@| j t j |j t j kW S tyT Y n0 z| j d u oj|j d u W S ty� Y dS 0 d S rj )r� r� �ST_CTIMEr� r� �rF �oldr$ r$ r% �__eq__� s �� zfilestat.__eq__c C s4 z| j t j |j t j kW S ty. Y dS 0 dS )a Examine whether new (= self) stat is ambiguous against old one
"S[N]" below means stat of a file at N-th change:
- S[n-1].ctime < S[n].ctime: can detect change of a file
- S[n-1].ctime == S[n].ctime
- S[n-1].ctime < S[n].mtime: means natural advancing (*1)
- S[n-1].ctime == S[n].mtime: is ambiguous (*2)
- S[n-1].ctime > S[n].mtime: never occurs naturally (don't care)
- S[n-1].ctime > S[n].ctime: never occurs naturally (don't care)
Case (*2) above means that a file was changed twice or more at
same time in sec (= S[n-1].ctime), and comparison of timestamp
is ambiguous.
Base idea to avoid such ambiguity is "advance mtime 1 sec, if
timestamp is ambiguous".
But advancing mtime only in case (*2) doesn't work as
expected, because naturally advanced S[n].mtime in case (*1)
might be equal to manually advanced S[n-1 or earlier].mtime.
Therefore, all "S[n-1].ctime == S[n].ctime" cases should be
treated as ambiguous regardless of mtime, to avoid overlooking
by confliction between such mtime.
Advancing mtime "if isambig(oldstat)" ensures "S[n-1].mtime !=
S[n].mtime", even if size of a file isn't changed.
FN)r� r r� r r$ r$ r% r� � s zfilestat.isambigc
C sn |j t j d d@ }zt�|||f� W n@ tyh } z(|jtjkrRW Y d}~dS � W Y d}~n
d}~0 0 dS )aL Change file stat of specified path to avoid ambiguity
'old' should be previous filestat of 'path'.
This skips avoiding ambiguity, if a process doesn't have
appropriate privileges for 'path'. This returns False in this
case.
Otherwise, this returns True, as "ambiguity is avoided".
r r� NFT)r� r� r r� r� r� �EPERM)rF rx r
r� r� r$ r$ r% �
avoidambig� s zfilestat.avoidambigc C s
| |k S rK r$ )rF �otherr$ r$ r% �__ne__� s zfilestat.__ne__N)rW rX rY rZ rJ � classmethodr� r
r� �__hash__r r� r r r$ r$ r$ r% r� u s
#r� c @ sB e Zd ZdZddd�Zdd� Zd d
� Zd d � Zd
d� Zdd� Z dS )�atomictempfilea writable file object that atomically updates a file
All writes will go to a temporary copy of the original file. Call
close() when you are done writing, and atomictempfile will rename
the temporary copy to the original name, making the changes
visible. If the object is destroyed without being closed, all your
writes are discarded.
checkambig argument of constructor is used with filestat, and is
useful only if target file is guarded by any lock (e.g. repo.lock
or repo.wlock).
� w+bNFc C sj || _ t|d|v |d|v d�| _t| j|�| _|| _| jj| _| jj| _| jj| _| jj | _ | jj
| _
d S )N� w)r r r ) �_atomictempfile__namer � _tempnamer� �_fp� _checkambigrg r� r� r� r� )rF r� r� r r� r$ r$ r% rJ � s �
zatomictempfile.__init__c C s� | j js�| j �� t| j�}| jo*t�|�}|r||jr|t | j
|� t�|�}|� |�r�|jtj d d@ }t
�|||f� n t | j
|� d S )Nr r� )r r� r� rw r r r� r� r� �renamer r� r� r r� )rF r r� r� r� r$ r$ r% r�
s
zatomictempfile.closec C s: | j js6zt�| j� W n ty* Y n0 | j �� d S rK )r r� r r� r r� r� rS r$ r$ r% �discard
s zatomictempfile.discardc C s t | d�r| �� d S )Nr )� safehasattrr rS r$ r$ r% �__del__
s
zatomictempfile.__del__c C s | S rK r$ rS r$ r$ r% r)
s zatomictempfile.__enter__c C s |d ur| � � n| �� d S rK )r r� )rF �exctypeZexcvaluer� r$ r$ r% r+
s
zatomictempfile.__exit__)r NF)
rW rX rY rZ rJ r� r r r) r+ r$ r$ r$ r% r � s
r c C sF |rt | � nt| � |rBzttj�| �� W n ty@ Y n0 dS )z.unlink and remove the directory if it is emptyN)� tryunlinkr� �
removedirsr rx r� r� )r Z
ignoremissing�rmdirr$ r$ r% �
unlinkpath%
s
r$ c
C sD z t | � W n2 ty> } z|jtjkr*� W Y d}~n
d}~0 0 dS )z1Attempt to remove a file, ignoring ENOENT errors.N)r� r� r� r )r �er$ r$ r% r! 4
s
r! c
C s� zt | |� W n� ty� } z�|jtjkr8W Y d}~dS |jtjksH| sJ� tj�t| ��}|| krd� t |||� zt | |� W nJ ty� } z2|jtjkr�W Y d}~W Y d}~dS � W Y d}~n
d}~0 0 W Y d}~n
d}~0 0 |dur�t�
| |� dS )z�recursive directory creation with parent mode inheritance
Newly created directories are marked as "not to be indexed by
the content indexing service", if ``notindexed`` is specified
for "write" mode access.
N) �makedirr� r� r� r r rx r� �abspath�makedirs�chmod)r� r� Z
notindexedr �parentr$ r$ r% r( >
s& .r( c C s6 t | d��}|�� W d � S 1 s(0 Y d S r� )r rg )rx r� r$ r$ r% �readfile\
s r+ c C s8 t | d��}|�|� W d � n1 s*0 Y d S )Nr �r r� �rx �textr� r$ r$ r% � writefileb
s r/ c C s8 t | d��}|�|� W d � n1 s*0 Y d S )Ns abr, r- r$ r$ r% �
appendfileh
s r0 c @ s" e Zd ZdZdd� Zddd�ZdS )� chunkbufferzoAllow arbitrary sized chunks of data to be efficiently read from an
iterator over chunks of arbitrary size.c C s& dd� }||�| _ t�� | _d| _dS )z?in_iter is the iterator that's iterating over the input chunks.c s sN | D ]D}t |�dkrBd}|t |�k rH|d }|||� V |}qq|V qd S )N� r � �rh )�chunksrf �pos�endr$ r$ r% �splitbigu
s z&chunkbuffer.__init__.<locals>.splitbigr N)rR rW rX �_queue� _chunkoffset)rF Zin_iterr8 r$ r$ r% rJ r
s
zchunkbuffer.__init__Nc
C s |du rd� | j�S |}g }| j}|dk�r|sjd}| jD ]&}|�|� |t|�8 }|dkr: qbq:|sj�q|d }t|�}| j}|dkr�||kr�||8 }|�� |�|� q"|| } || kr�|| 8 }|�� |�||d� � d| _q"|�|||| � � | j|7 _|| 8 }q"d� |�S )z�Read L bytes of data from the iterator of chunks of data.
Returns less than L bytes if the iterator runs dry.
If size parameter is omitted, read everythingNr? r r3 )r� rR r9 r� rh r: rS )
rF �l�leftr� Zqueue�targetrf Zchunklro Zchunkremainingr$ r$ r% rg �
sB
zchunkbuffer.read)N)rW rX rY rZ rJ rg r$ r$ r$ r% r1 n
s r1 � c c sH |du r|}n
t ||�}|o$| �|�}|s,qD|r<|t|�8 }|V q dS )aY Create a generator that produces the data in the file size
(default 131072) bytes at a time, up to optional limit (default is
to read all data). Chunks may be less than size bytes if the
chunk is the last chunk in the file, or the file is a socket or
some other type of file that sometimes reads less data than is
requested.N)r� rg rh )r re r� �nbytesrH r$ r$ r% r �
s
r c @ s* e Zd ZdZdd� Zd
dd�Zdd� Zd S ) � cappedreadera� A file object proxy that allows reading up to N bytes.
Given a source file object, instances of this type allow reading up to
N bytes from that source file object. Attempts to read past the allowed
limit are treated as EOF.
It is assumed that I/O is not performed on the original file object
in addition to I/O that is performed by this instance. If there is,
state tracking will get out of sync and unexpected results will ensue.
c C s || _ || _dS )z,Allow reading up to <limit> bytes from <fh>.N)r] �_left)rF rd r� r$ r$ r% rJ �
s zcappedreader.__init__rf c C sB | j s
dS |dk r| j }| j�t|| j ��}| j t|�8 _ |S )Nr? r )rA r] rg r� rh )rF r rM r$ r$ r% rg �
s zcappedreader.readc C s2 | � t|��}|d u rd S ||dt|��< t|�S r' )rg rh )rF r� r� r$ r$ r% r� �
s
zcappedreader.readintoN)rf )rW rX rY rZ rJ rg r� r$ r$ r$ r% r@ �
s
r@ c s � fdd�}|S )z@return a function that renders a readable count of some quantityc sD � D ].\}}}t | �|| kr|| t|� S q� d d | S )Nrf r� )�abs�float)�countZ
multiplierZdivisor�format�� unittabler$ r% �go s zunitcountfn.<locals>.gor$ )rG rH r$ rF r% � unitcountfn�
s rI c C s< || dk rt �td���| dk r0t �td���| d |fS )a� Check that linerange <fromline>:<toline> makes sense and return a
0-based range.
>>> processlinerange(10, 20)
(9, 20)
>>> processlinerange(2, 1)
Traceback (most recent call last):
...
ParseError: line range must be positive
>>> processlinerange(0, 5)
Traceback (most recent call last):
...
ParseError: fromline must be strictly positive
r s line range must be positiver s" fromline must be strictly positive)r
�
ParseErrorrD )ZfromlineZtoliner$ r$ r% �processlinerange
s
rK �d � @s %.0f GB�
s %.1f GBs %.2f GBr2 s %.0f MBs %.1f MBs %.2f MBs %.0f KBs %.1f KBs %.2f KBs
%.0f bytesc @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) �transformingwriterz3Writable file wrapper to transform data by functionc C s || _ || _d S rK )r �_encode)rF r� �encoder$ r$ r% rJ 2 s ztransformingwriter.__init__c C s | j �� d S rK )r r� rS r$ r$ r% r� 6 s ztransformingwriter.closec C s | j �� d S rK )r r6 rS r$ r$ r% r6 9 s ztransformingwriter.flushc C s | j �| �|��S rK )r r� rP )rF rM r$ r$ r% r� < s ztransformingwriter.writeN)rW rX rY rZ rJ r� r6 r� r$ r$ r$ r% rO / s
rO s \r*\nc C s t �d| �S )Nr� ��_eolre�sub�rH r$ r$ r% �tolfF s rV c C s t �d| �S )N�
rR rU r$ r$ r% �tocrlfK s rX c C s
t | t�S rK )rO rX r� r$ r$ r% � _crlfwriterP s rY rW s CPython)r r c C s> d}t | �tu r&t�t�| �� �j�}|r.| S t| j d�S d S )NTr? )
r] �filer� �S_ISREGr r� r� �st_moderR r� )r� Zfastpathr$ r$ r% �iterfilez s r] c C s | S rK r$ r� r$ r$ r% r] � s c c s" | D ]}|� � D ]
}|V qqd S rK )r� )�iteratorrf r� r$ r$ r% � iterlines� s r_ c C s t j�t j�| ��S rK )r rx �
expanduser�
expandvarsr� r$ r$ r% �
expandpath� s rb c sx � p
dd� � d� ��� �}|rP|d| 7 }t| �dkrD| dd� }n| }|�|< t�d| |f �}|�� �fdd�|�S )a� Return the result of interpolating items in the mapping into string s.
prefix is a single character string, or a two character string with
a backslash as the first character if the prefix needs to be escaped in
a regular expression.
fn is an optional function that will be applied to the replacement text
just before replacement.
escape_prefix is an optional flag that allows using doubled prefix for
its escaping.
c S s | S rK r$ rU r$ r$ r% r� � r? z interpolate.<locals>.<lambda>� |r Ns %s(%s)c s � �| � � dd � �S )Nr )r rt �r� �mappingr$ r% r� � r? )r� rb rh r r� rT )r� re rH r� Z
escape_prefix�patternsZ prefix_char�rr$ rd r% � interpolate� s
rh g @�@s %.0f ss %.1f ss %.2f ss %.3f sg����MbP?s %.1f mss %.2f mss %.3f msg���ư>s %.1f uss %.2f uss %.3f usg��&� .>s %.1f nss %.2f nss %.3f nsc @ sP e Zd ZdZeje�dd� �d�Zejdd�Zejdd�Z dd� Z
e � e
�Z
d S )
� timedcmstatszFStats information produced by the timedcm context manager on entering.c C s t � S rK )�timerr$ r$ r$ r% r� � r? ztimedcmstats.<lambda>)r, r r c C s | j rt| j �S dS )Ns <unknown>)�elapsed� timecountrS r$ r$ r% � __bytes__� s ztimedcmstats.__bytes__N)rW rX rY rZ r ZibZFactory�startrk r� rm r Z strmethod�__str__r$ r$ r$ r% ri � s ri c g s� t jd7 _tt jd�}zXtj| g|�R � � |V W d � n1 sJ0 Y W t� |j |_t jd8 _n t� |j |_t jd8 _0 dS )z�A context manager that produces timing information for a given context.
On entering a timedcmstats instance is produced.
This context manager is reentrant.
r )r� N)�timedcm�_nestedri r �logrj rn rk )Z whencefmtZ
whenceargsZ timing_statsr$ r$ r% rp � s
&�rp c s � fdd�}|S )z�Report the execution time of a function call to stderr.
During development, use as a decorator when you need to measure
the cost of a function, e.g. as follows:
@util.timed
def foo(a, b, c):
pass
c sn t t�� j��� }� | i |��}W d � n1 s40 Y tj}|�dd|j d t�� j�|f � |S )Ns %s%s: %s
� r� )rp r �bytestrrW r r5 r� r� )r� r� Z
time_statsrM r5 rp r$ r% rq � s ,
���ztimed.<locals>.wrapperr$ rr r$ rp r% �timed� s ru ))� mr2 )� kra )� grM )s kbra )s mbr2 )s gbrM )� br c C s| | � � �� }zFtD ]6\}}|�|�rtt|dt|� � �| � W S qt|�W S tyv t� t
d�| ��Y n0 dS )z�Convert a space specifier to a byte count.
>>> sizetoint(b'30')
30
>>> sizetoint(b'2.2kb')
2252
>>> sizetoint(b'6M')
6291456
Ns couldn't parse size: %s) �stripr� �
_sizeunitsr� r rC rh r� r
rJ rD )rH r� rI �ur$ r$ r% � sizetoint s
&
r} c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �hooksz�A collection of hook functions that can be used to extend a
function's behavior. Hooks are called in lexicographic order,
based on the names of their sources.c C s
g | _ d S rK )�_hooksrS r$ r$ r% rJ - s zhooks.__init__c C s | j �||f� d S rK )r r� )rF re �hookr$ r$ r% �add0 s z hooks.addc G s8 | j jdd� d� g }| j D ]\}}|�||� � q |S )Nc S s | d S r' r$ rt r$ r$ r% r� 4 r? z hooks.__call__.<locals>.<lambda>)rP )r �sortr� )rF r� �resultsre r� r$ r$ r% �__call__3 s
zhooks.__call__N)rW rX rY rZ rJ r� r� r$ r$ r$ r% r~ ( s r~ � %-*s in %s
� %s:%dc # s| � fdd�t �� d| d � D �| d� }|rxtdd� |D ��}|D ].\}}|du rf|||fV qH||||f V qHdS )a� Yields lines for a nicely formatted stacktrace.
Skips the 'skip' last entries, then return the last 'depth' entries.
Each file+linenumber is formatted according to fileline.
Each line is formatted according to line.
If line is None, it yields:
length of longest filepath+line number,
filepath+linenumber,
function
Not be used in production code but very convenient while developing.
c s0 g | ](\}}}}� t �|�|f t �|�f�qS r$ )r Zsysbytes)r� r� Zlnr
Z_text��fileliner$ r% �
<listcomp>G s
�z"getstackframes.<locals>.<listcomp>Nr c s s | ]}t |d �V qdS )r Nr4 )r� �entryr$ r$ r% � <genexpr>L r? z!getstackframes.<locals>.<genexpr>)r� �
extract_stackr� )�skipr� r� r� �entriesZfnmaxZfnlnr
r$ r� r% �getstackframes; s
�� r� s
stacktracer? c C sR |r |� � |�d|| �� f � t|d |d�D ]}|�|| � q2|� � dS )aW Writes a message to f (stderr) with a nicely formatted stacktrace.
Skips the 'skip' entries closest to the call, then show 'depth' entries.
By default it will flush stdout first.
It can be used everywhere and intentionally does not require an ui object.
Not be used in production code but very convenient while developing.
s %s%s at:
r )r� N)r6 r� �rstripr� )r7 r� r Zotherfr� r� r� r$ r$ r% �debugstacktraceT s r� c C sh |du rt � }d| |f }||vr.||vr.|S t�d�D ]*}d| ||f }||vr8||vr8| S q8dS )a�
Generate a name that it is safe to rename f to in the given context.
f: filename to rename
tag: a string tag that will be included in the new name
ctx: a context, in which the new name must not exist
others: a set of other filenames that the new name must not be in
Returns a file name of the form oldname~tag[~number] which does not exist
in the provided context and is not in the set of other names.
Ns %s~%sr s %s~%s~%s)�set� itertoolsrD )r �tag�ctxZothersr� r r$ r$ r% �safenamen s r� c C s4 | � |�}t|�|k r0t�td�t|�|f ��|S )z=read n bytes from stream.read and abort if less was availables5 stream ended unexpectedly (got %d bytes, expected %d))rg rh r
rC rD )�streamr rH r$ r$ r% � readexactly� s
��r� c C sn | dk rt �d| ��| d@ }| dL } g }| rT|�t�d|B �� | d@ }| dL } q*|�t�|�� d�|�S )ai Encode an unsigned integer value to a varint.
A varint is a variable length integer of 1 or more bytes. Each byte
except the last has the most significant bit set. The lower 7 bits of
each byte store the 2's complement representation, least significant group
first.
>>> uvarintencode(0)
'\x00'
>>> uvarintencode(1)
'\x01'
>>> uvarintencode(127)
'\x7f'
>>> uvarintencode(1337)
'\xb9\n'
>>> uvarintencode(65536)
'\x80\x80\x04'
>>> uvarintencode(-1)
Traceback (most recent call last):
...
ProgrammingError: negative value for uvarint: -1
r s negative value for uvarint: %d� � � r? )r
r r� r Zbytechrr� )r� r) �bytesr$ r$ r% �
uvarintencode� s
r� c C s@ d}d}t t| d��}||d@ |> O }|d@ s2|S |d7 }qdS )a� Decode an unsigned variable length integer from a stream.
The passed argument is anything that has a ``.read(N)`` method.
>>> try:
... from StringIO import StringIO as BytesIO
... except ImportError:
... from io import BytesIO
>>> uvarintdecodestream(BytesIO(b'\x00'))
0
>>> uvarintdecodestream(BytesIO(b'\x01'))
1
>>> uvarintdecodestream(BytesIO(b'\x7f'))
127
>>> uvarintdecodestream(BytesIO(b'\xb9\n'))
1337
>>> uvarintdecodestream(BytesIO(b'\x80\x80\x04'))
65536
>>> uvarintdecodestream(BytesIO(b'\x80'))
Traceback (most recent call last):
...
Abort: stream ended unexpectedly (got 0 bytes, expected 1)
r r r� r� r� N)r� r� )rd rM �shiftZbyter$ r$ r% �uvarintdecodestream� s r� c
c st t �t jd �} | dkrjz@zt �t jd� W n t jy> Y n0 d V W t �t j| � qpt �t j| � 0 nd V d S )N�Cr- )�locale� setlocale�LC_CTYPEr� )�oldlocr$ r$ r% �
with_lc_ctype� s "r� c s� t j�d�rpddlm� m� ddlm} m}m }m
} G � �fdd�d| �}|� }||�|_ |j �
||�� |jS z*t�tjd �}t�tjd �}|| W S ty� Y n ty� Y n0 d S )
z�Provide an estimate for the available system memory in Bytes.
If no estimate can be provided on the platform, returns None.
s winr )�c_long� c_ulonglong)� Structure�byref�sizeof�windllc
sF e Zd Zd� fd� fd�fd�fd�fd�fd�fd�fd �fg Zd
S ) z'_estimatememory.<locals>.MEMORYSTATUSEX�dwLengthZ dwMemoryLoadZ ullTotalPhys� ullAvailPhysZullTotalPageFileZullAvailPageFileZullTotalVirtualZullAvailVirtualZullExtendedVirtualN)rW rX rY Z_fields_r$ �ZDWORDZ DWORDLONGr$ r% �MEMORYSTATUSEX
s �r� � SC_PAGE_SIZE�
SC_PHYS_PAGESN)r Z sysplatform�
startswithZctypesr� r� Zctypes.wintypesr� r� r� r� r� Zkernel32ZGlobalMemoryStatusExr� r �sysconf�
sysconf_namesr� rJ )r� r� r� r� r� rc ZpagesizeZpagesr$ r� r% �_estimatememory� s
r� )r )r N)N)TTFT)TTTFT)Nr� )N)N)ra rb )r )FFFNNT)NN)FNF)FT)NF)r> N)NF)r r� r� r )N( rZ Z
__future__r r r, rW �
contextlibr� rl Zhashlibr� r� r� r r" Z
pyplatform�rer r� r� r4 �timer� r0 rD r Z
thirdpartyr r r r r r
Zhgdemandimportr r- r r
r r r Zutilsr r r r �
TYPE_CHECKING�typingr r r r Z importmodr r Z b85decodeZ b85encodeZ cookielibZhttplib�pickler Z socketserverZbytesioZstringioZ xmlrpclibZ
httpserverZurlerrZurlreqrt r� r r r rD r' ZbindunixsocketZ cachestatZ checkexecZ checklinkr� Z expandglobsZgetfsmountpointr� Z get_passwordZ groupmembersZ groupnameZisexecZisownerr� rw Z lookupregr& r� r� r� Z normcasespecZnormcasefallbackZ
openhardlinksr� Zparsepatchoutputr{ Zpollr� r� r r" Z
samedevice�samefile�samestatZsetflagsr r Z
statisexecZ
statislinkr! r� �usernamer& Z compenginesZ
SERVERROLEZ
CLIENTROLEZrecvfdsr� r� r7 r+ r �environrE r/ �filterwarningsr3 Zispy3r: Zmd5Zsha1Zsha512rB rU rI r> r\ rp � NameErrorr� rq r� rs rt r� r� r� r� r� r� r� r8 r r r � OrderedDictr r` r$ r& r' �contextmanagerr0 r2 r3 r9 rY rZ r` rg ri rk rs r# r� r� r� r� r� r� r� r� rj ZcheckosfilenameZclockr� r� r� r� r� r� r� r� r� r� r� r� r� r| r r� r r$ r! r( r+ r/ r0 r1 r r@ rI rK Z bytecountrO r� rS rV rX rY Z oslinesepZ tonativeeolZ
fromnativeeolZnativeeolwriter�identityZpython_implementation� version_infor] r_ rb rh rl rH ri rp rq ru r{ r} r~ r� r5 �stdoutr� r� r� r� r� r� r� r� r$ r$ r$ r% �<module>
sZ
���
�0%n
3*{%e�
�
W ' . ! �
P ->
7-"
+jF
S ' �
�
�
%-