/
lib64
/
python3.9
/
site-packages
/
mercurial
/
__pycache__
/
New Directory
Upload File
HOME
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