Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
mercurial
/
utils
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: storageutil.cpython-310.pyc
o �]Lb�C � @ s d dl mZ d dlZd dlZddlmZ ddlmZmZm Z ddl m Z m Z m Z mZ ddlmZ ddlmZ dd lmZ e�e j�Zd Zd d � Ze�d �Z dd� Z dd� Z dd� Z dd� Z dd� Z!dd� Z"d%dd�Z#d d � Z$d d � Z%dddddej&d d df d!d"�Z'd#d$� Z(dS )&� )�absolute_importN� )�_)�bin�nullrev�sha1nodeconstants)�dagop�error�mdiff�pycompat)� repository)�sidedata)�hashutil� c C s^ |t jkrt�� }|�|� n||k r|}|}n|}|}t�|�}|�|� |�| � |�� S )z�Compute the SHA-1 for revision data and its parents. This hash combines both the current file contents and its history in a manner that makes it easy to distinguish nodes with the same content in the revision graph. )r �nullid� _nullhash�copy�updater �sha1�digest)�text�p1�p2�s�a�b� r �=/usr/lib/python3/dist-packages/mercurial/utils/storageutil.py�hashrevisionsha1$ s r � c C sf | dd� dkr dS t �| d��� }| d|� }i }|�� D ]}|�dd�\}}|||< q ||d fS )z�Parse metadata header from revision data. Returns a 2-tuple of (metadata, offset), where both can be None if there is no metadata. Nr r )NNs : r )� METADATA_RE�search�start� splitlines�split)r r �mtext�meta�l�k�vr r r � parsemetaA s r* c s, t � �}d�� fdd�|D ��}d||f S )z2Add metadata to fulltext to produce revision text.� c 3 s � | ] }d |� | f V qdS )s %s: %s Nr )�.0r( �r& r r � <genexpr>V s � zpackmeta.<locals>.<genexpr>s %s %s)�sorted�join)r& r �keys�metatextr r- r �packmetaS s r3 c C s t | �d }|o d|v S )Nr s censored)r* )r r& r r r �iscensoredtextZ s r4 c C s* | � d�s| S | �dd�}| |d d� S )z�Extract just the revision data from source text. Returns ``text`` unless it has a metadata header, in which case we return a new buffer without hte metadata. r r N)� startswith�index)r �offsetr r r �filtermetadata_ s r8 c C sV | � |�d tjkr dS t| �|��d }|r)d|v r)d|v r)|d t|d �fS dS )z�Resolve file revision copy metadata. Returns ``False`` if the file has no copy metadata. Otherwise a 2-tuple of the source filename and node. r Fs copys copyrev)�parentsr r r* �revisionr )�store�noder& r r r �filerevisioncopiedl s r= c C sr |� d�r d| }n|}| �|�\}}t|||�}||kr dS | �| �|��r+|dkS | �|�r7| �|�|kS dS )ah Determines whether file data is equivalent to a stored node. Returns True if the passed file data would hash to the same value as a stored revision and False otherwise. When a stored revision is censored, filedata must be empty to have equivalence. When a stored revision has copy metadata, it is ignored as part of the compare. r s Tr+ F)r5 r9 r � iscensored�rev�renamed�read)r; r< �filedata� revisiontextr r � computednoder r r �filedataequivalent� s rE c C s@ d}|dur||kr d}||7 }|| kr| }n| }t �|||�S )z)Iterate over revision numbers in a store.r N���)r �xrange)�storelenr" �stop�stepr r r �iterrevs� s �rK c C s t |t�r z| �|�W S ty t�d| |td���w t|�dv r7z| �|� |W S tjy6 Y nw t|�dv rSz t |�}| �|� |W S t yR Y nw z!t|�}d| |kr`t �z| �|�W W S tt fyr Y nw W n t t fy Y nw t�||td���)a� Resolve the file node for a value. ``store`` is an object implementing the ``ifileindex`` interface. ``fileid`` can be: * A 20 or 32 byte binary node. * An integer revision number * A 40 or 64 byte hex node. * A bytes that can be parsed as an integer representing a revision number. ``identifier`` is used to populate ``error.LookupError`` with an identifier for the store. Raises ``error.LookupError`` on failure. s %ds no match found)� � )�( �@ ) � isinstance�intr< � IndexErrorr � LookupErrorr �lenr? r � TypeError� ValueError� OverflowError)r; �fileid� identifier�rawnoder? r r r � fileidlookup� sJ �� � � ��r[ c C s� t � }|d }i }t � }|D ]} || �} | || < | | kr!|�| � q|rZ|d8 }|�|�} | | k r7|�|� n|�| � ||�D ]} | tkrW|| �} | || < | | krW|�| � q@|s$||fS )a� Resolve information needed to strip revisions. Finds the minimum revision number that must be stripped in order to strip ``minlinkrev``. Returns a 2-tuple of the minimum revision number to do that and a set of all revision numbers that have linkrevs that would be broken by that strip. ``tiprev`` is the current tip-most revision. It is ``len(store) - 1``. ``headrevs`` is an iterable of head revisions. ``linkrevfn`` is a callable that receives a revision and returns a linked revision. ``parentrevsfn`` is a callable that receives a revision number and returns an iterable of its parent revision numbers. r )�set�add�pop�remover )� minlinkrev�tiprev�headrevs� linkrevfn� parentrevsfn� brokenrevs� strippoint�heads�futurelargelinkrevs�head� headlinkrev�linkrev�p�plinkrevr r r �resolvestripinfo� s2 � ��rn Fc ! # s � | j } | j� |dkr� fdd�|D �}n |dkr*� fdd�|D �}t�|| j�}n t� fdd�|D ��}d }| tjks>| rG| �|d �d }t� }|D �]@}|t krTqL| |�}| �|�\}}|rf||�}nt }| tjkrp|}n9| tj krxt }n1| tj kr�|}n)|t kr�||v r�|}n | r�|||fv r�|}n|d ur�|}n t }n |d ur�|}nt }|t kr�|r�|||�s�t }d }d }d }| �r*| � |�s�| � |�r�z| � |�}W n tjy� } z |j}W Y d }~nd }~ww |t kr�|r�||�}n8t| � |��}n0|t k�r| tjk�r| � |�}|�|� n|�r|||�}n t�| � |�| � |��}|�|� d }d } | �rYz| �|�} W n tj�yE i } Y n w tj| | | |d �\} } | �rYt�| �}|�r`||�nd } d } |�rv| tO } | | d | d @ B } ||| |�| |�| |�| ||||| d� V |}qLd S )a Generic implementation of ifiledata.emitrevisions(). Emitting revision data is subtly complex. This function attempts to encapsulate all the logic for doing so in a backend-agnostic way. ``store`` Object conforming to ``ifilestorage`` interface. ``nodes`` List of revision nodes whose data to emit. ``resultcls`` A type implementing the ``irevisiondelta`` interface that will be constructed and returned. ``deltaparentfn`` (optional) Callable receiving a revision number and returning the revision number of a revision that the internal delta is stored against. This delta will be preferred over computing a new arbitrary delta. If not defined, a delta will always be computed from raw revision data. ``candeltafn`` (optional) Callable receiving a pair of revision numbers that returns a bool indicating whether a delta between them can be produced. If not defined, it is assumed that any two revisions can delta with each other. ``rawsizefn`` (optional) Callable receiving a revision number and returning the length of the ``store.rawdata(rev)``. If not defined, ``len(store.rawdata(rev))`` will be called. ``revdifffn`` (optional) Callable receiving a pair of revision numbers that returns a delta between them. If not defined, a delta will be computed by invoking mdiff code on ``store.revision()`` results. Defining this function allows a precomputed or stored delta to be used without having to compute on. ``flagsfn`` (optional) Callable receiving a revision number and returns the integer flags value for it. If not defined, flags value will be 0. ``deltamode`` constaint on delta to be sent: * CG_DELTAMODE_STD - normal mode, try to reuse storage deltas, * CG_DELTAMODE_PREV - only delta against "prev", * CG_DELTAMODE_FULL - only issue full snapshot. Whether to send fulltext revisions instead of deltas, if allowed. ``nodesorder`` ``revisiondata`` ``assumehaveparentrevisions`` ``sidedata_helpers`` (optional) If not None, means that sidedata should be included. See `revlogutil.sidedata.get_sidedata_helpers`. s nodesc s g | ]}� |��qS r r �r, �n��frevr r � <listcomp>} � z!emitrevisions.<locals>.<listcomp>s linearc s h | ]}� |��qS r r ro rq r r � <setcomp> rt z emitrevisions.<locals>.<setcomp>c 3 s � | ]}� |�V qd S )Nr ro rq r r r. � s � z emitrevisions.<locals>.<genexpr>Nr )r r )r; �sidedata_helpersr r? r ) r< �p1node�p2node�basenode�flags�baserevisionsizer: �deltar �protocol_flags)r< r? r � linearize� parentrevsr/ r �CG_DELTAMODE_PREVr\ r �CG_DELTAMODE_FULL�CG_DELTAMODE_P1r> �rawdatar �CensoredNodeError� tombstonerT r] r �textdiffr � sidedatamod�run_sidedata_helpers�serialize_sidedata�CG_FLAG_SIDEDATA)!r; �nodes� nodesorder� resultcls� deltaparentfn� candeltafn� rawsizefn� revdifffn�flagsfn� deltamode� revisiondata�assumehaveparentrevisionsrv �fnode�revs�prevrev� availabler? r< �p1rev�p2rev�deltaparentrev�baserevr: r| r{ �e�serialized_sidedata�sidedata_flags� old_sidedatar rz r} r rq r � emitrevisions( s� �Q �� � � � � � ��r� c C sr t �d�}t| �|kr dS ||�}t| �| }| d|� t�||�kr%dS d}t|�}||ko8| ||| � |kS )aR Determine if a delta represents censored revision data. ``baserev`` is the base revision this delta is encoded against. ``baselenfn`` is a callable receiving a revision number that resolves the length of the revision fulltext. Returns a bool indicating if the result of the delta represents a censored revision. s >lllFNs censored:)�struct�calcsizerT r �replacediffheader)r| r� � baselenfn�hlen�oldlen�newlenr] �addlenr r r �deltaiscensored s r� )r N))� __future__r �rer� �i18nr r< r r r � r r r r � interfacesr � revlogutilsr r� �utilsr r r r r� r �compiler r* r3 r4 r8 r= rE rK r[ rn �CG_DELTAMODE_STDr� r� r r r r �<module> sD %89 � k
Save
Cancel