| 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�N � @ s d dl mZ ddlmZ ddlmZmZ ddlmZ ddl m
Z
m Z m Z m
Z
mZ ddlmZmZ ddlmZmZ d d
iZd d � Zd
d� Zdd� Zdd� Zdd� ZG dd� de �Z G dd� de �Z dd� Z ej G dd � d e ��Z!G d d � d e �Z"G d d � d ej�Z#d!S )"� )�absolute_import� )�_)�bin�hex)�attr)�encoding�error�metadata�pycompat�revlog)�dateutil�
stringutil)� constants�flagutil� branch� defaultc C s( | � dd�� dd�� dd�} | � dd�S ) aA
>>> from .pycompat import bytechr as chr
>>> d = {b'nl': chr(10), b'bs': chr(92), b'cr': chr(13), b'nul': chr(0)}
>>> s = b"ab%(nl)scd%(bs)s%(bs)sn%(nul)s12ab%(cr)scd%(bs)s%(nl)s" % d
>>> s
'ab\ncd\\\\n\x0012ab\rcd\\\n'
>>> res = _string_escape(s)
>>> s == _string_unescape(res)
True
� \� \\�
s \n�
s \r� � \0)�replace��text� r �9/usr/lib64/python3.9/site-packages/mercurial/changelog.py�_string_escape$ s
���r c C s6 d| v r,| � dd�} | � dd�} | � dd�} t�| �S )Nr r s \\
r r � )r r Z unescapestrr r r r �_string_unescape8 s
r c C s< t �� }| �d�D ]$}|rt|��dd�\}}|||< q|S )a�
>>> from .pycompat import bytechr as chr
>>> sorted(decodeextra(encodeextra({b'foo': b'bar', b'baz': chr(0) + b'2'})
... ).items())
[('baz', '\x002'), ('branch', 'default'), ('foo', 'bar')]
>>> sorted(decodeextra(encodeextra({b'foo': b'bar',
... b'baz': chr(92) + chr(0) + b'2'})
... ).items())
[('baz', '\\\x002'), ('branch', 'default'), ('foo', 'bar')]
r � :r )�
_defaultextra�copy�splitr )r �extra�l�k�vr r r � decodeextraA s
r) c s � fdd�t � �D �}d�|�S )Nc s g | ]}t d |� | f ��qS )s %s:%s)r )�.0r' ��dr r �
<listcomp>V r z encodeextra.<locals>.<listcomp>r )�sorted�join)r, �itemsr r+ r � encodeextraT s r1 c C s d� dd� | �� D ���d�S )z>strip trailing whitespace and leading and trailing empty linesr c S s g | ] }|� � �qS r )�rstrip)r* r& r r r r- \ r z stripdesc.<locals>.<listcomp>)r/ �
splitlines�strip)�descr r r � stripdescZ s r6 c @ sp e Zd ZdZdd� Zdd� Zdd� Zdd � Zed
d � �Z d d
� Z
ddd�Z d dd�Z dd� Z
dd� Zdd� ZdS ) �appenderz`the changelog index must be updated last on disk, so we use this class
to delay writes to itc C s: || _ |||�}|| _|�� | _|�|�j| _| j| _d S �N)�data�fp�tell�offset�fstat�st_size�size�_end)�selfZvfs�name�mode�bufr: r r r �__init__c s
zappender.__init__c C s | j S r8 )r@ �rA r r r �endk s z appender.endc C s | j S r8 )r< rF r r r r; n s z
appender.tellc C s d S r8 r rF r r r �flushq s zappender.flushc C s | j jS r8 )r: �closedrF r r r rI t s zappender.closedc C s | j �� d S r8 )r: �closerF r r r rJ x s zappender.closer c C s\ |dkr|| _ n.|dkr(| j |7 _ n|dkr>| �� | | _ | j | jk rX| j�| j � dS )z,virtual file offset spans real file and datar r � N)r< rG r? r: �seek)rA r< �whencer r r rL { s z
appender.seek���c C s� d}| j | jk rF| j�|�}|}| j t|�7 _ |dkrF|t|�8 }|dkr�| j | j }| j�dd�| j�� | jdd�= | jd ||| � }| j t|�7 _ ||7 }|S )z5only trick here is reads that span real file and datar r r N)r< r? r: �read�lenr9 �insertr/ )rA �count�ret�sZdoffr r r rO � s z
appender.readc C s8 | j �t|�� | jt|�7 _| jt|�7 _d S r8 )r9 �append�bytesr< rP r@ )rA rT r r r �write� s zappender.writec C s | j �� | S r8 )r: � __enter__rF r r r rX � s
zappender.__enter__c G s | j j|� S r8 )r: �__exit__)rA �argsr r r rY � s zappender.__exit__N)r )rN )�__name__�
__module__� __qualname__�__doc__rE rG r; rH �propertyrI rJ rL rO rW rX rY r r r r r7 _ s
r7 c @ s& e Zd Zdd� Zd
dd�Zdd� Zd S ) �
_divertopenerc C s || _ || _d S r8 )�_opener�_target)rA �opener�targetr r r rE � s z_divertopener.__init__� rFc K s6 || j kr | j||fi |��S | j|d |fi |��S )N� .a)rb ra )rA rB rC �
checkambig�kwargsr r r �__call__� s
z_divertopener.__call__c C s t | j|�S r8 )�getattrra )rA r r r r � __getattr__� s z_divertopener.__getattr__N)re F)r[ r\ r] rE ri rk r r r r r` � s
r` c s d� ��fdd� }|S )z?build an opener that stores chunks in 'buf' instead of 'target're Fc s( | �kr�| |fi |��S t �| |� �S r8 )r7 )rB rC rg rh �rD rc rd r r �_delay� s z _delayopener.<locals>._delay)re Fr )rc rd rD rm r rl r � _delayopener� s rn c @ s� e Zd Ze�� Ze�� Zejdd�Zejdd�Zeje� e
�d�Z ejdd�Z ejdd�Z
ejdd�Zejdd�Zejdd�Zejed dfd�ZdS )�_changelogrevisionr )�default)r r Nr F)r[ r\ r] r Zibr% �manifest�user�dateZFactory�list�files�
filesadded� filesremoved�p1copies�p2copies� descriptionr" �
branchinfor r r r ro � s ro c s� e Zd ZdZdZ� fdd�Zedd� �Zedd� �Zed d
� �Z ed d � �Z
ed
d� �Z edd� �Z edd� �Z
edd� �Zedd� �Zedd� �Zedd� �Zedd � �Zed d � �Zed d � �Z� ZS )!�changelogrevisionz�Holds results of a parsed changelog revision.
Changelog revisions consist of multiple pieces of data, including
the manifest node, user, and date. This object exposes a view into
the parsed object.
)�_offsets�_text� _sidedata�_cpsd�_changesc
s� |st t|jd�S tt| ��| �}|�d�}|�d|d �}|�d|d �}||d |d � dkrj|} n|�d|d �} |||| f|_||_||_ ||_
d |_ |S )N)r% rq r r rK �
) ro r" Znullid�superr| �__new__�indexr} r~ r r� r� )
�clsZclr �sidedataZcpsdrA Znl1Znl2Znl3Zdoublenl�� __class__r r r� � s
zchangelogrevision.__new__c C s t | jd| jd � �S )Nr )r r~ r} rF r r r rq s zchangelogrevision.manifestc C s& | j }t�| j|d d |d � �S �Nr r )r} r �tolocalr~ �rA �offr r r rr
s zchangelogrevision.userc C s4 | j }| j|d d |d � }|�dd�dd� S )Nr rK � r )r} r~ r$ )rA r� � dateextrar r r �_rawdate s zchangelogrevision._rawdatec C sD | j }| j|d d |d � }|�dd�}t|�dkr<d S |d S )Nr rK r� � )r} r~ r$ rP )rA r� r� �fieldsr r r � _rawextra s zchangelogrevision._rawextrac C sB | j }t|d �}zt|d �}W n ty8 d}Y n0 ||fS r� )r� �float�int�
ValueError)rA �raw�time�timezoner r r rs s
zchangelogrevision.datec C s | j }|d u rtS t|�S r8 )r� r" r) )rA r� r r r r% + s zchangelogrevision.extrac C s` | j d ur| j S | jr$t�| j�}n2tj| jp0d| jp8d| jp@d| j pHi | j
pPi d�}|| _ |S )Nr )�touched�added�removedZ p1_copiesZ p2_copies) r� r� r
Zdecode_files_sidedatar Z
ChangingFilesru rv rw rx ry )rA �changesr r r r� 3 s
�zchangelogrevision.changesc C sL | j rt| jj�S | j}|d |d kr,g S | j|d d |d � �d�S )NrK r� r r )r� r. r� r� r} r~ r$ r� r r r ru D s zchangelogrevision.filesc C s4 | j r| jjS | j�d�}|d u r&d S t�| j|�S )Ns
filesadded)r� r� r� r% �getr
�decodefileindicesru �rA Z
rawindicesr r r rv N s z changelogrevision.filesaddedc C s4 | j r| jjS | j�d�}|d u r&d S t�| j|�S )Ns filesremoved)r� r� r� r% r� r
r� ru r� r r r rw X s z changelogrevision.filesremovedc C s4 | j r| jjS | j�d�}|d u r&d S t�| j|�S )Ns p1copies)r� r� Zcopied_from_p1r% r� r
� decodecopiesru �rA Z rawcopiesr r r rx b s zchangelogrevision.p1copiesc C s4 | j r| jjS | j�d�}|d u r&d S t�| j|�S )Ns p2copies)r� r� Zcopied_from_p2r% r� r
r� ru r� r r r ry l s zchangelogrevision.p2copiesc C s t �| j| jd d d � �S )Nr� rK )r r� r~ r} rF r r r rz v s z changelogrevision.descriptionc C s | j }t�|�d��d|v fS )Nr s close)r% r r� r� )rA r% r r r r{ z s z changelogrevision.branchinfo)r[ r\ r] r^ � __slots__r� r_ rq rr r� r� rs r% r� ru rv rw rx ry rz r{ �
__classcell__r r r� r r| � s> &
r| c s� e Zd Zd dd�Zedd� �Zejdd� �Z� fdd �Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zd dd�Zdd� Zd d � Z� ZS ) � changelogFNc C s� t j j| |tjdfddd|j�dd�||d� | jrX| jt jkrX| j t j
M _ d| _ d| _ || _
d| _d| _d| _t� | _i | _|j�d�| _dS )aV Load a changelog revlog using an opener.
If ``trypending`` is true, we attempt to load the index from a
``00changelog.i.a`` file instead of the default ``00changelog.i``.
The ``00changelog.i.a`` file contains index (and possibly inline
revision) data for a transaction that hasn't been finalized yet.
It exists in a separate file to facilitate readers (such as
hooks processes) accessing data before a transaction is finalized.
``concurrencychecker`` will be passed to the revlog init function, see
the documentation there.
Ns 00changelogTs persistent-nodemapF)rd �radixrg ZmmaplargeindexZpersistentnodemap�concurrencychecker�
trypendings copies-storage)r rE �revlog_constantsZKIND_CHANGELOG�optionsr� Z
_initemptyZ_format_versionZREVLOGV1Z
_format_flagsZFLAG_GENERALDELTAZ
_generaldeltaZ_storedeltachains� _realopener�_delayed� _delaybuf�_divert� frozenset�
_filteredrevs�_filteredrevs_hashcache�_copiesstorage)rA rc r� r� r r r rE � s,
� zchangelog.__init__c C s | j S r8 )r� rF r r r � filteredrevs� s zchangelog.filteredrevsc C s || _ i | _d S r8 )r� r� )rA �valr r r r� � s c s | j stt| ��|� d S r8 )r� r� r� �
_write_docket�rA �trr� r r r� � s zchangelog._write_docketc C s� | j du r�| js�t| �dkrXd| _| j�| jd �rF| j�| jd � t| j| j�| _ ng | _
t | j| j| j
�| _ | j | j _ | j | j
_ d| _|�dt| � | j� |�dt| � | j� dS )z2delay visibility of index updates to other readersNr Trf s cl-%i)�_docketr� rP r� r� �exists�
_indexfile�unlinkr` rc r� rn � _segmentfile�_segmentfile_sidedataZ
addpending�id�
_writependingZ addfinalize� _finalizer� r r r � delayupdate� s �
zchangelog.delayupdatec C s� d| _ | j| _| j| j_| j| j_| jdur8| �|� nr| jrr| jd }| j� |�}|�
� | jj || jdd� n8| j r�| j| jddd�}|�
d�| j �� |�
� d| _ d| _| �|� dS )zfinalize index updatesFNrf T)rg � ar )r� r� rc r� r� r� r� r� r� �openrJ �renamer� rW r/ �_enforceinlinesize)rA r� ZtmpnameZnfiler: r r r r� � s$
zchangelog._finalizec C s� | j r| j j|dd�S | jr�| �| j�}| jd }|�|� | �|d�}|�|�� � |�d�| j�� |�� d| _d| _ t
| j| j�| _ | j | j _ | j | j
_ | j r�dS dS )zLcreate a file containing the unfinalized state for
pretxnchangegroupT)�pendingrf � wr NF)r� rW r� r� r� Z registertmprO r/ rJ r� r` rc r� r� )rA r� �fp1Zpendingfilename�fp2r r r r� � s$
zchangelog._writependingc C s | j stj�| |� d S r8 )r� r r� r� r r r r� s z changelog._enforceinlinesizec C sH | � |�}| �|�}| jdk}t| |||�}|j|j|j|j|j|j fS )a� Obtain data from a parsed changelog revision.
Returns a 6-tuple of:
- manifest node in binary
- author/user as a localstr
- date as a 2-tuple of (time, timezone)
- list of files
- commit message as a localstr
- dict of extra metadata
Unless you need to access all fields, consider calling
``changelogrevision`` instead, as it is faster for partial object
access.
� changeset-sidedata)
�
_revisiondatar� r� r| rq rr rs ru rz r% )rA � nodeorrevr, r� Zcopy_sd�cr r r rO s
zchangelog.readc C s( | � |�}| �|�}t| ||| jdk�S )z6Obtain a ``changelogrevision`` for a node or revision.r� )r� r� r| r� )rA r� r r� r r r r| s
�zchangelog.changelogrevisionc C s: | � |�}|sg S |�d�}|d|� �d�}|dd� S )zX
short version of read that only returns the files modified by the cset
r� Nr r� )Zrevisionr� r$ )rA r� r Zlastr& r r r � readfiles& s
zchangelog.readfilesc
C sJ t �|�t �|� }}|�� }|s0t�td���d|v rPt�td�t�|� ��t|�}|rldt �
|� }
n dt � � }
| r�| � d�} | dv r�| d= n| dv r�t�td�| ��t
|j�} d }
d }| jd
kr�|jr�|
tjO }
t�|�}| �r t| �} d |
| f }
t|�||
g| d |g }d�|�}| j||t| �||||
d
�}| �|�S )Ns empty usernamer s username %r contains a newlines %d %dr )r r )� .s nulls tips the name '%s' is reservedr r� s %s %sr )r� �flags)r Z fromlocalr4 r Z StorageErrorr r Zbytestrr6 r
Z parsedateZmakedater� r. r� r� Zhas_copies_infor ZREVIDX_HASCOPIESINFOr
Zencode_files_sidedatar1 r r/ Z addrevisionrP �node)rA rq ru r5 � transactionZp1Zp2rr rs r% Z
parseddate�branchZ sortedfilesr� r� r& r �revr r r �add1 sH �
�
�z
changelog.addc C s | � |�jS )z�return the branch name and open/close state of a revision
This function exists because creating a changectx object
just to access this is costly.)r| r{ )rA r� r r r r{ m s zchangelog.branchinfoc C s |j �dg �}|�|� d S )Ns
revduplicates)r� �
setdefaultrU )rA r� r� �
duplicatesr r r �_nodeduplicatecallbackt s z changelog._nodeduplicatecallback)FN)NN)r[ r\ r] rE r_ r� �setterr� r� r� r� r� rO r| r� r� r{ r� r� r r r� r r� � s$
,
�
<r� N)$Z
__future__r Zi18nr r� r r Z
thirdpartyr � r r r
r r Zutilsr
r Z revlogutilsr r� r r" r r r) r1 r6 �objectr7 r` rn rT ro r| r� r r r r �<module> s( F 1