Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
mercurial
/
revlogutils
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: nodemap.cpython-310.pyc
o �]LbQV � @ s� d dl mZ d dlZd dlZd dlZddlmZ ddlmZm Z m Z ddlm Z G dd � d e �Zd d � Zd d � Zdd� Zdd� ZG dd� de�Zdd� Zdd� ZdGdd�ZdZe�d�Ze�d �ZG d d � d e�Z d d � Z d!d"� Z d#d$� Z d%d&� Z e�d'�Z!d(Z"dZ#d)d*� Z$d+d,� Z%G d-d.� d.e �Z&d/d0� Z'd1d2� Z(d3d4� Z)dHd5d6�Z*d7d8� Z+d9d:� Z,d;d<� Z-d=d>� Z.d?d@� Z/dAdB� Z0dCdD� Z1dEdF� Z2dS )I� )�absolute_importN� )�hex)�error� requirements�util� )�docketc @ s e Zd Zdd� ZdS )�NodeMapc C s t �d| ��)Ns unknown node: %s)r � RevlogError)�self�x� r �?/usr/lib/python3/dist-packages/mercurial/revlogutils/nodemap.py� __missing__ � zNodeMap.__missing__N)�__name__� __module__� __qualname__r r r r r r s r c C s dS )zrhook point for test This let tests to have things happens between the docket reading and the data readingNr r r r r �test_race_hook_1 s r c C sL t j| j vrdS t j| j v rdS | �� }td||j� td| |jjj� dS )zoThe stream clone might needs to remove some file if persisten nodemap was dropped while stream cloning N) r �REVLOGV1_REQUIREMENT�NODEMAP_REQUIREMENT� unfiltered�delete_nodemap� changelog� manifestlog� _rootstore�_revlog)�repo�unfir r r �post_stream_cleanup& s r c C s� | j du rdS | j�| j �}|sdS d}t�|||tj � �\}|tkr'dS |tj7 }t�|||tj � �}|\}}}}} |tj7 }t|||| � �} ||7 }|| _ |||| � | _ || _ || _ t | | �} | jj�d�} t� z5| �| ��&} | r�z t�t�| |��}W n ty� d}Y nw | �|�}W d � n1 s�w Y W n ttfy� } z|jtjkr�W Y d}~dS � d}~ww t|�|k r�dS | |fS )z'read the nodemap for a revlog from diskNr � persistent-nodemap.mmap� )� _nodemap_file�opener�tryread� S_VERSION�unpack�size�ONDISK_VERSION�S_HEADER� NodeMapDocket�tip_rev�tip_node� data_length� data_unused�_rawdata_filepath�options�getr r �buffer�mmapread� ValueError�read�IOError�OSError�errno�ENOENT�len)�revlog�pdata�offset�version�headers�uid_sizer, r. r/ � tip_node_sizer �filename�use_mmap�fd�data�er r r �persisted_data3 sV � � �� �� rH c s\ � j rdS � jdu r dS d� j }| �|�rdS | �|� fdd�� | �|� fdd�� dS )z�Install whatever is needed transaction side to persist a nodemap on disk (only actually persist the nodemap if this is relevant for this revlog) Ns nm-revlog-persistent-nodemap-%sc s t | � dd�S )NT)�pending��persist_nodemap��tr�r< r r �<lambda>p s z*setup_persistent_nodemap.<locals>.<lambda>c s t | � �S �NrJ rL rN r r rO r s )�_inliner# � hasfinalize� addpending� addfinalize)rM r< � callback_idr rN r �setup_persistent_nodemapa s �rV c @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dS )�_NoTransactionzCtransaction like object to update the nodemap outside a transactionc C s i | _ d S rP �� _postclose�r r r r �__init__x s z_NoTransaction.__init__c C s || j |< d S rP rX )r rU � callback_funcr r r � addpostclose{ r z_NoTransaction.addpostclosec O � d S rP r �r �args�kwargsr r r � registertmp~ � z_NoTransaction.registertmpc O r^ rP r r_ r r r � addbackup� rc z_NoTransaction.addbackupc O r^ rP r r_ r r r �add� rc z_NoTransaction.addc O r^ rP r r_ r r r �addabort� rc z_NoTransaction.addabortc G r^ rP r )r r` r r r �_report� rc z_NoTransaction._reportN) r r r �__doc__r[ r] rb rd re rf rg r r r r rW u s rW c C sJ | j rdS | jdu r dS t� }t|| � t|j�D ] }|j| d� qdS )z�update the persistent nodemap right now To be used for updating the nodemap on disk outside of a normal transaction setup (eg, `debugupdatecache`). N)rQ r# rW rK �sortedrY )r< �notr�kr r r �update_persistent_nodemap� s �rl c C sN |j }t�d| �}|j�|j�}|j�|�D ] }|�|�r$|j� |� qdS )z.Delete nodemap data on disk for a given revlogs" (^|/)%s(-[0-9a-f]+\.nd|\.n(\.a)?)$N) �radix�re�compiler$ �dirname� _indexfile�listdir�match�svfs� tryunlink)rM r r< �prefix�pattern�dirpath�fr r r r � s ��r Fc s, t |dd�r t�d��|jdu r |rt|�|_nd}t�|��t�|jd�}|j}t�|jd�}|j j � d�}d} |r�|dur�|j� � } |j� � \} } } | jt| � } | j| }| | kr_d} nX| |d krhd} nOt|| �� | �� | j� |� � d ��/}|�| j� |�| � |r�|r�|�d � |�| �}n |�� t�t�|| ��}W d � n1 s�w Y | | _|| _| du �r#t� } t|| �� t�|jd �r�|j�� } nt|j�} |j j �� �fd d�}d� }| � ||� |� � d��$}|�| � |�r|r�| }n|�� t�t�|t| ���}W d � n 1 �sw Y t| �| _|� � | _ |� | j �| _!|j}|�r?|d7 }| �"|� n| �#|� |j |ddd��}|�| �$� � W d � n 1 �s_w Y | |_|�rq|j�%| |� t&|| ����r�t |d|j ����fdd�}d|j }| �'||� dS dS )z-Write nodemap data on disk for a given revlog� filteredrevsr z.cannot persist nodemap of a filtered changelogNz?calling persist nodemap on a revlog without the feature enabled�nodemap_data_incremental�update_nodemap_datar! � s r+r �nodemap_data_allc s �� � d S rP r rL )�datafileru r r �abortck� s z persist_nodemap.<locals>.abortcks delete-%ss w+s .a� wT)� atomictemp� _realopenerc s � D ]}�� |� qd S rP )ru )rM �oldfile)�olds�realvfsr r �cleanup s �z persist_nodemap.<locals>.cleanups revlog-cleanup-nodemap-%s)(�getattrr �ProgrammingErrorr# �get_nodemap_filer � safehasattr�index�_nodemap_docketr$ r1 r2 �copyr{ r. r; r/ r0 re �seek�writer6 �flushr3 r4 r+ r~ �persistent_dataru rf �tiprevr, �noder- rb rd � serializer| �_other_rawdata_filepathr] )rM r< rI �force�msg�can_incremental� ondisk_docket� feed_datarD rF � target_docket� src_docket�data_changed_count� new_length� new_unusedrE �new_datar� rU � file_path�fpr� r )r r� r� ru r rK � s� � � � � � � � �rK z>Bz>BQQQQc @ s: e Zd ZdZd dd�Zdd� Zdd� Zd d � Zd d � ZdS )r+ z}metadata associated with persistent nodemap data The persistent data may come from disk or be on their way to disk. Nc C s2 |d u rt �� }|| _d | _d | _d | _d| _d S )Nr )� docket_mod�make_uid�uidr, r- r. r/ )r r� r r r r[ : s zNodeMapDocket.__init__c C s0 t | jd�}| j|_| j|_| j|_| j|_|S )N)r� )r+ r� r, r- r. r/ )r �newr r r r� V s zNodeMapDocket.copyc C sD | j |j k rdS | j |j krdS | j|jk rdS | j|jkr dS dS )N���r r �r� r. �r �otherr r r �__cmp__^ s zNodeMapDocket.__cmp__c C s | j |j ko | j|jkS rP r� r� r r r �__eq__i s zNodeMapDocket.__eq__c C sf g }|� t�t�� t| j�| j| j| jt| j �f}|� t j|� � |� | j� |� | j � d� |�S )z9return serialized bytes for a docket using the passed uidr" ) �appendr& �packr) r; r� r, r. r/ r- r* �join)r rF r@ r r r r� l s � zNodeMapDocket.serializerP ) r r r rh r[ r� r� r� r� r r r r r+ 4 s r+ c C s | j }d||jf S )z9The (vfs relative) nodemap's rawdata file for a given uids %s-%s.nd)rm r� )r< r rv r r r r0 } s r0 c C sl | j }t�d| �}t| |�}| j�|�}| j�|�}g }| j�|�D ]}|�|�r3||kr3|� |� q#|S )Ns (^|/)%s-[0-9a-f]+\.nd$) rm rn ro r0 r$ �basenamerp rr rs r� ) r< r rv rw � new_file_path� new_file_namerx �othersry r r r r� � s �r� c C s t | �}t|�S )zAreturn the persistent binary form for a nodemap for a given index)� _build_trie� _persist_trie)r� �trier r r r� � s r� c C s& t | ||�\}}|tj t||d�fS )zGreturn the incremental update for persistent nodemap from a given index)� existing_idx)� _update_trie�S_BLOCKr( r� )r� �root�max_idx�last_rev� changed_blockr� r r r �update_persistent_data� s �r� z>llllllllllllllllr� c C s | t S )z�Return the number used to represent the rev in the tree. (or retrieve a rev number from such representation) Note that this is an involution, a function equal to its inverse (i.e. which gives the identity when applied to itself). )� REV_OFFSET)�revr r r �_transform_rev� s r� c C s t | d�S )z/turn an hexadecimal digit into a proper integer� )�int)� hex_digitr r r �_to_int� s r� c s( e Zd ZdZ� fdd�Zdd� Z� ZS )�BlockzOrepresent a block of the Trie contains up to 16 entry indexed from 0 to 15c s t t| ��� d | _d S rP )�superr� r[ � ondisk_idrZ �� __class__r r r[ � s zBlock.__init__c s t � fdd�td�D ��S )Nc 3 s � | ]}� � |�V qd S rP )r2 )�.0�irZ r r � <genexpr>� � � z!Block.__iter__.<locals>.<genexpr>r� )�iter�rangerZ r rZ r �__iter__� s zBlock.__iter__)r r r rh r[ r� � __classcell__r r r� r r� � s r� c C s< t � }tt| ��D ]}t| | d �}t| d|||� q |S )z�build a nodemap trie The nodemap stores revision number for each unique prefix. Each block is a dictionary with keys in `[0, 15]`. Values are either another block or a revision number. � r )r� r� r; r �_insert_into_block)r� r� r� � current_hexr r r r� � s r� c C sH d}t |d t| ��D ]}t| | d �}|t| d|||�7 }q ||fS )�consumer r r� )r� r; r r� )r� r� r� �changedr� r� r r r r� � s r� c C s� d}|j dur d|_ t|||d � �}|�|�}|du r#|||< |S t|t�r6|t| |d |||�7 }|S t| | d �}|} t� } | ||< t| |d | | |� t| |d | ||� |S )a7 insert a new revision in a block index: the index we are adding revision for level: the depth of the current block in the trie block: the block currently being considered current_rev: the revision number we are adding current_hex: the hexadecimal representation of the of that revision r Nr� )r� r� r2 � isinstance�dictr� r r� ) r� �level�block� current_revr� r� r� �entry� other_hex� other_revr� r r r r� � s( �� �r� c C st i }|dur |d }nd}g }t | �D ]!}|jdur"|j|t|�< qt|�| |t|�< |�t||�� qd�|�S )zaturn a nodemap trie into persistent binary data See `_build_trie` for nodemap trie structureNr r r" )� _walk_trier� �idr; r� �_persist_blockr� )r� r� � block_map�base_idx�chunks�tnr r r r� s r� c c s@ � t | �� �D ]\}}t|t�rt|�D ]}|V qq| V dS )zcyield all the block in a trie Children blocks are always yield before their parent block. N)ri �itemsr� r� r� )r� �__�item� sub_blockr r r r� * s � � r� c s t � fdd�| D ��}tj|� S )z�produce persistent binary data for a single block Children block are assumed to be already persisted and present in block_map. c 3 s � | ]}t |� �V qd S rP )� _to_value)r� �v�r� r r r� < r� z!_persist_block.<locals>.<genexpr>)�tupler� r� )� block_noder� rF r r� r r� 6 s r� c C s* | du rt S t| t�r|t| � S t| �S )z persist any value as an integerN)�NO_ENTRYr� r� r� r� )r� r� r r r r� @ s r� c C s� t | �tj dkrd}t�|tjt | �f ��| s t� dfS i }g }tdt | �tj�D ]$}t� }t |�|_|||j< | ||tj � }t�|�}|� ||f� q+|D ]#\}}t |�D ]\} } | t krcqZ| dkrn|| || < qZt | �|| < qZqR||tj fS )z,parse parse nodemap data into a nodemap Trier s: nodemap data size is not a multiple of block size (%d): %dN) r; r� r( r �Abortr� r� r� r' r� � enumerater� r� ) rF r� r� � new_blocksr� r� � block_data�values�b�idxr� r r r � parse_dataJ s. �r� c C s d}| � dt|� � t|�\}}tt|��}| � dt|� � tt|��D ]C}||vr8d| }| �|� d}n|�|� t|t || d ��} | du rXd| }| �|� d}q&| |krid || f }| �|� d}q&|r~t |�D ] }d | }| �|� qpd}|S ) zBverify that the provided nodemap data are valid for the given idexr s revision in index: %d s revision in nodemap: %d s$ revision missing from nodemap: %d r r� Ns/ revision node does not match any entries: %d s? revision node does not match the expected revision: %d != %d s! extra revision in nodemap: %d ) �statusr; r� �set�_all_revisionsr� � write_err�remove� _find_noder ri ) �uir� rF �retr� r� �all_revs�rr� �nm_revr r r � check_datah s< �� � r c c s8 � t | �D ]}|D ]}|du st|t�rq |V q qdS )z%return all revisions stored in a TrieN)r� r� r� )r� r� r� r r r r� � s � ��r� c C s6 | � t|dd� ��}t|t�rt||dd� �S |S )z.find the revision associated with a given noder r N)r2 r� r� r� r� )r� r� r� r r r r� � s r� c C s* | j r| jd }| j�|�r|S | jd S )Ns .n.as .n)� _trypendingrm r$ �exists)r< � pending_pathr r r r� � s r� )FFrP )3� __future__r r9 rn �structr� r � r r r r r� r� r r r rH rV �objectrW rl r rK r) �Structr& r* r+ r0 r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r� r� r� r r r r �<module> sV . I& " #
Save
Cancel