|
Server : Apache System : Linux iad1-shared-b8-43 6.6.49-grsec-jammy+ #10 SMP Thu Sep 12 23:23:08 UTC 2024 x86_64 User : dh_edsupp ( 6597262) PHP Version : 8.2.26 Disable Function : NONE Directory : /lib/python3/dist-packages/mercurial/__pycache__/ |
Upload File : |
o
�]Lb�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 �5/usr/lib/python3/dist-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 � 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 s z encodeextra.<locals>.<listcomp>r )�sorted�join)r- �itemsr r, r � encodeextraT s
r2 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. \ s z stripdesc.<locals>.<listcomp>)r0 �
splitlines�strip)�descr r r � stripdescZ � r7 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)�self�vfs�name�mode�bufr< r r r �__init__c s
zappender.__init__c C � | j S r: )rB �rC r r r �endk � z appender.endc C rI r: )r> rJ r r r r= n rL z
appender.tellc C s d S r: r rJ r r r �flushq s zappender.flushc C s | j jS r: )r< �closedrJ r r r rN t s zappender.closedc C s | j �� d S r: )r< �closerJ r r r rO x s zappender.closer c C s` |dkr|| _ n|dkr| j |7 _ n |dkr | �� | | _ | j | jk r.| j�| j � dS dS )z,virtual file offset spans real file and datar r � N)r> rK rA r< �seek)rC r> �whencer r r rQ { s �z
appender.seek���c C s� d}| j | jk r#| j�|�}|}| j t|�7 _ |dkr#|t|�8 }|dkrV| 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> rA r< �read�lenr; �insertr0 )rC �count�ret�s�doffr r r rT � s z
appender.readc C s8 | j �t|�� | jt|�7 _| jt|�7 _d S r: )r; �append�bytesr> rU rB )rC rY r r r �write� s zappender.writec C s | j �� | S r: )r< � __enter__rJ r r r r^ � s
zappender.__enter__c G s | j j|� S r: )r< �__exit__)rC �argsr r r r_ � � zappender.__exit__N)r )rS )�__name__�
__module__� __qualname__�__doc__rH rK r= rM �propertyrN rO rQ rT r] r^ r_ r r r r r9 _ s
r9 c @ s& e Zd Zdd� Zd
dd�Zdd� Zd S ) �
_divertopenerc C s || _ || _d S r: )�_opener�_target)rC �opener�targetr r r rH � s
z_divertopener.__init__� rFc K s6 || j kr| j||fi |��S | j|d |fi |��S )N� .a)ri rh )rC rE rF �
checkambig�kwargsr r r �__call__� s
z_divertopener.__call__c C s t | j|�S r: )�getattrrh )rC r r r r � __getattr__� ra z_divertopener.__getattr__N�rl F)rb rc rd rH rp rr r r r r rg � s
rg c s d� ��fdd� }|S )z?build an opener that stores chunks in 'buf' instead of 'target'rl Fc s0 | �kr
�| |fi |��S |rJ �t �| |� �S r: )r9 )rE rF rn ro �rG rj rk r r �_delay� s z _delayopener.<locals>._delayNrs r )rj rk rG ru r rt r � _delayopener� s rv 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)rb rc rd r �ibr& �manifest�user�date�Factory�list�files�
filesadded� filesremoved�p1copies�p2copies� descriptionr# �
branchinfor r r r rw � s rw 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� |s t t|jd�S tt| ��| �}|�d�}|�d|d �}|�d|d �}||d |d � dkr5|} n|�d|d �} |||| f|_||_||_ ||_
d |_ |S )N)r& rz r r rP �
) rw r# �nullid�superr� �__new__�indexr� r� r� r� r� )
�cls�clr �sidedata�cpsdrC �nl1�nl2�nl3�doublenl�� __class__r r r� � s
zchangelogrevision.__new__c C s t | jd| jd � �S )Nr )r r� r� rJ r r r rz s zchangelogrevision.manifestc C s& | j }t�| j|d d |d � �S �Nr r )r� r �tolocalr� �rC �offr r r r{
s zchangelogrevision.userc C s4 | j }| j|d d |d � }|�dd�dd� S )Nr rP � r )r� r� r% )rC r� � dateextrar r r �_rawdate s zchangelogrevision._rawdatec C sD | j }| j|d d |d � }|�dd�}t|�dkr d S |d S )Nr rP r� � )r� r� r% rU )rC r� r� �fieldsr r r � _rawextra s zchangelogrevision._rawextrac C sF | j }t|d �}z t|d �}W ||fS ty" d}Y ||fS w r� )r� �float�int�
ValueError)rC �raw�time�timezoner r r r| s ��zchangelogrevision.datec C s | j }|d u r tS t|�S r: )r� r# r* )rC r� r r r r& + s zchangelogrevision.extrac C s` | j d ur| j S | jrt�| j�}ntj| jpd| jp d| jp d| j p$i | j
p(i d�}|| _ |S )Nr )�touched�added�removed� p1_copies� p2_copies) r� r� r
�decode_files_sidedatar� �
ChangingFilesr r� r� r� r� )rC �changesr r r r� 3 s
�zchangelogrevision.changesc C sL | j r t| jj�S | j}|d |d krg S | j|d d |d � �d�S )NrP r� r r )r� r/ r� r� r� r� r% r� r r r r D s zchangelogrevision.filesc C �4 | j r| jjS | j�d�}|d u rd S t�| j|�S )Ns
filesadded)r� r� r� r& �getr
�decodefileindicesr �rC �
rawindicesr r r r� N � z changelogrevision.filesaddedc C r� )Ns filesremoved)r� r� r� r& r� r
r� r r� r r r r� X r� z changelogrevision.filesremovedc C r� )Ns p1copies)r� r� �copied_from_p1r& r� r
� decodecopiesr �rC � rawcopiesr r r r� b r� zchangelogrevision.p1copiesc C r� )Ns p2copies)r� r� �copied_from_p2r& r� r
r� r r� r r r r� l r� zchangelogrevision.p2copiesc C s t �| j| jd d d � �S )Nr� rP )r r� r� r� rJ r r r r� v r8 z changelogrevision.descriptionc C s | j }t�|�d��d|v fS )Nr s close)r& r r� r� )rC r& r r r r� z s z changelogrevision.branchinfo)rb rc rd re � __slots__r� rf rz r{ r� r� r| r& r� r r� r� r� r� r� 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� Z d dd�Zdd� Zd d � Z� ZS ) � changelogFNc C s� t j j| |tjdfddd|j�dd�||d� | jr,| jt jkr,| 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)rk �radixrn �mmaplargeindex�persistentnodemap�concurrencychecker�
trypendings copies-storage)r rH �revlog_constants�KIND_CHANGELOG�optionsr� �
_initempty�_format_version�REVLOGV1�
_format_flags�FLAG_GENERALDELTA�
_generaldelta�_storedeltachains� _realopener�_delayed� _delaybuf�_divert� frozenset�
_filteredrevs�_filteredrevs_hashcache�_copiesstorage)rC rj r� r� r r r rH � s,
� zchangelog.__init__c C rI r: )r� rJ r r r � filteredrevs� s zchangelog.filteredrevsc C s t |t�sJ �|| _i | _d S r: )�
isinstancer� r� r� )rC �valr r r r� � s
c s | j s
tt| ��|� d S d S r: )r� r� r� �
_write_docket�rC �trr� r r r� � s �zchangelog._write_docketc C s� | j du rC| jsCt| �dkr,d| _| j�| jd �r#| j�| jd � t| j| j�| _ n
g | _
t | j| j| j
�| _ | j | j _ | j | j
_ d| _|�dt| � | j� |�dt| � | j� dS )z2delay visibility of index updates to other readersNr Trm s cl-%i)�_docketr� rU r� r� �exists�
_indexfile�unlinkrg rj r� rv � _segmentfile�_segmentfile_sidedata�
addpending�id�
_writepending� addfinalize� _finalizer� r r r � delayupdate� s �
zchangelog.delayupdatec C s� d| _ | j| _| j| j_| j| j_| jdur | �|� n>| jr>| jr$J �| j d }| j�
|�}|� � | jj || j dd� n | jrZ| j| j ddd�}|�
d�| j�� |� � d| _d| _| �|� dS )zfinalize index updatesFNrm T)rn � ar )r� r� rj r� r� r� r� r� r� r� �openrO �renamer] r0 �_enforceinlinesize)rC r� �tmpname�nfiler< r r r r� � s&
zchangelog._finalizec C s� | j r | j j|dd�S | jrP| �| j�}| jd }|�|� | �|d�}|�|�� � |�d�| j�� |�� d| _d| _ t
| j| j�| _ | j | j _ | j | j
_ | j rUdS dS )zLcreate a file containing the unfinalized state for
pretxnchangegroupT)�pendingrm � wr NF)r� r] r� r� r� � registertmprT r0 rO r� rg rj r� r� )rC r� �fp1�pendingfilename�fp2r r r r� � s$
zchangelog._writependingc C s | j s tj�| |� d S d S r: )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� rz r{ r| r r� r& )rC � nodeorrevr- r� �copy_sd�cr r r rT s
zchangelog.readc C s( | � |�}| �|�}t| ||| jdk�S )z6Obtain a ``changelogrevision`` for a node or revision.r� )r� r� r� r� )rC r� r r� r r r r� s
�zchangelog.changelogrevisionc C s: | � |�}|s g S |�d�}|d|� �d�}|dd� S )zX
short version of read that only returns the files modified by the cset
r� Nr r� )�revisionr� r% )rC r� r �lastr' r r r � readfiles& s
zchangelog.readfilesc
C sH t �|�t �|�}}|�� }|st�td���d|v r(t�td�t�|� ��t|�}|r6dt �
|� }
ndt � � }
| rX| � d�} | dv rK| d= n
| dv rXt�td�| ��t
|j�} d }
d }| jd
krs|jrn|
tjO }
t�|�}| rt| �} 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 � fromlocalr5 r � StorageErrorr r �bytestrr7 r
� parsedate�makedater� r/ r� r� �has_copies_infor �REVIDX_HASCOPIESINFOr
�encode_files_sidedatar2 r r0 � addrevisionrU �node)rC rz r r6 � transaction�p1�p2r{ r| r& �
parseddate�branch� 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� )rC r r r r r� m s zchangelog.branchinfoc C s |j �dg �}|�|� d S )Ns
revduplicates)r� �
setdefaultr[ )rC r
r �
duplicatesr r r �_nodeduplicatecallbackt s z changelog._nodeduplicatecallback)FN)NN)rb rc rd rH rf r� �setterr� r� r� r� r� rT r� r� r r� r r� r r r� r r� � s&
,
�<r� N)$�
__future__r �i18nr r r r �
thirdpartyr � r r r
r r �utilsr
r � revlogutilsr r� r r# r r! r* r2 r7 �objectr9 rg rv rY rw r� r� r r r r �<module> s* F 1