| 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 : /lib64/python3.9/site-packages/mercurial/revlogutils/__pycache__/ |
Upload File : |
a
�+�bQV � @ 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| ��d S )Ns unknown node: %s)r Z RevlogError)�self�x� r
�C/usr/lib64/python3.9/site-packages/mercurial/revlogutils/nodemap.py� __missing__ s 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 r dS | �� }td||j� td| |jjj� dS )zoThe stream clone might needs to remove some file if persisten nodemap
was dropped while stream cloning
N) r ZREVLOGV1_REQUIREMENTZNODEMAP_REQUIREMENTZ
unfiltered�delete_nodemapZ changelogZ manifestlogZ
_rootstoreZ_revlog)�repoZunfir
r
r �post_stream_cleanup& s r c
C s� | j du rdS | j�| j �}|s$dS d}t�|||tj � �\}|tkrNdS |tj7 }t�|||tj � �}|\}}}}} |tj7 }t|||| � �}
||7 }||
_ |||| � |
_
||
_ ||
_ t
| |
�} | jj�d�} t� zr| �| ��R}
| �r,zt�t�|
|��}W n t�y( d}Y n0 n
|
�|�}W d � n1 �sL0 Y W nH ttf�y� } z*|jtjk�r�W Y d}~dS � W Y d}~n
d}~0 0 t|�|k �r�dS |
|fS )z'read the nodemap for a revlog from diskNr � persistent-nodemap.mmap� )�
_nodemap_file�openerZtryread� 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)�revlogZpdata�offset�version�headersZuid_sizer! r# r$ Z
tip_node_sizer �filename�use_mmap�fd�data�er
r
r �persisted_data3 sJ
.r: c s\ � j r
dS � jdu rdS d� j }| �|�r0dS | �|� 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�r1 r
r �<lambda>p r z*setup_persistent_nodemap.<locals>.<lambda>c s
t | � �S �Nr< r> r@ r
r rA r r )�_inliner Z hasfinalizeZ
addpendingZ addfinalize)r? r1 � callback_idr
r@ r �setup_persistent_nodemapa s
�rE 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 rB ��
_postclose�r r
r
r �__init__x s z_NoTransaction.__init__c C s || j |< d S rB rG )r rD Z
callback_funcr
r
r � addpostclose{ s z_NoTransaction.addpostclosec O s d S rB r
�r �args�kwargsr
r
r � registertmp~ s z_NoTransaction.registertmpc O s d S rB r
rL r
r
r � addbackup� s z_NoTransaction.addbackupc O s d S rB r
rL r
r
r �add� s z_NoTransaction.addc O s d S rB r
rL r
r
r �addabort� s z_NoTransaction.addabortc G s d S rB r
)r rM r
r
r �_report� s z_NoTransaction._reportN) r r r �__doc__rJ rK rO rP rQ rR rS r
r
r
r rF u s rF c C sJ | j r
dS | jdu rdS t� }t|| � t|j�D ]}|j| d� q2dS )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)rC r rF r= �sortedrH )r1 Znotr�kr
r
r �update_persistent_nodemap� s
rW c C sN |j }t�d| �}|j�|j�}|j�|�D ]}|�|�r.|j� |� q.dS )z.Delete nodemap data on disk for a given revlogs" (^|/)%s(-[0-9a-f]+\.nd|\.n(\.a)?)$N)
�radix�re�compiler �dirnameZ
_indexfile�listdir�matchZsvfs� tryunlink)r? r r1 �prefix�pattern�dirpath�fr
r
r r � s
r Fc s6 t |dd�rt�d��|jdu r>|r0t|�|_nd}t�|��t�|jd�}|j}t�|jd�}|j j
� d�}d} |�rx|du�rx|j� � }
|j�
� \} } } |
jt| � }
|
j| }| |
kr�d} n�|
|d kr�d} n�t||
�� | �� |
j� |� � d
��b}|�|
j� |�| � |�rL|�r2|�d � |�|
�}n|�� t�t�||
��}W d � n1 �sb0 Y |
|
_||
_| du �rTt� }
t||
�� t�|jd ��r�|j�� } n
t|j�} |j j �� �fd
d�}d� }| � ||� |� � d��J}|�| � |�r*|�r | }n |�� t�t�|t| ���}W d � n1 �s@0 Y t| �|
_|� � |
_ |� |
j �|
_!|j}|�r�|d7 }| �"|� n
| �#|� |j |ddd�� }|�|
�$� � W d � n1 �s�0 Y |
|_|�r�|j�%|
|� t&||
����r2t |d|j ����fdd�}d|j }| �'||� dS )z-Write nodemap data on disk for a given revlogZ 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 rB r
r> )�datafiler^ r
r �abortck� s z persist_nodemap.<locals>.abortcks delete-%ss w+s .a� wT)Z
atomictempZ _realopenerc s � D ]}�� |� qd S rB )r^ )r? Zoldfile)�olds�realvfsr
r �cleanup s z persist_nodemap.<locals>.cleanups revlog-cleanup-nodemap-%s)(�getattrr ZProgrammingErrorr �get_nodemap_filer Z safehasattr�indexZ_nodemap_docketr r& r' �copyrc r# r0 r$ r% rQ �seek�writer+ �flushr( r) r rf �persistent_datar^ rR Ztiprevr! �noder" rO rP � serializerd �_other_rawdata_filepathrK )r? r1 r; �force�msgZcan_incrementalZ
ondisk_docketZ feed_datar6 r8 Z
target_docketZ
src_docketZdata_changed_countZ
new_lengthZ
new_unusedr7 Znew_datarh rD Z file_path�fprl r
)rg rj rk r^ r r= � s� �
�
2
6
.
r= 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_modZmake_uid�uidr! r" r# r$ )r r| r
r
r rJ : 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 rp V s zNodeMapDocket.copyc C sD | j |j k rdS | j |j kr dS | j|jk r0dS | 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 rB 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 r0 r| r! r# r$ r" r �join)r r8 r4 r
r
r rv l s � zNodeMapDocket.serialize)N) r r r rT rJ rp r� r� rv 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)rX r| )r1 r r_ r
r
r r% } s r% c C sl | j }t�d| �}t| |�}| j�|�}| j�|�}g }| j�|�D ] }|�|�rF||krF|� |� qF|S )Ns (^|/)%s-[0-9a-f]+\.nd$)
rX rY rZ r% r �basenamer[ r\ r] r� ) r1 r r_ r` Z
new_file_pathZ
new_file_namera Zothersrb r
r
r rw � s
rw c C s t | �}t|�S )zAreturn the persistent binary form for a nodemap for a given index)� _build_trie�
_persist_trie)ro �trier
r
r rt � s rt 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� )ro �rootZmax_idx�last_revZ
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 rB )�superr� rJ � ondisk_idrI �� __class__r
r rJ � s zBlock.__init__c s t � fdd�td�D ��S )Nc 3 s | ]}� � |�V qd S rB )r' )�.0�irI r
r � <genexpr>� r z!Block.__iter__.<locals>.<genexpr>r� )�iter�rangerI r
rI r �__iter__� s zBlock.__iter__)r r r rT rJ 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� r0 r �_insert_into_block)ro r� r� � current_hexr
r
r r� � s
r� c C sH d}t |d t| ��D ](}t| | d �}|t| d|||�7 }q||fS )Zconsumer r r� )r� r0 r r� )ro r� r� �changedr� r� r
r
r r� � s
r� c C s� d}|j durd|_ t|||d � �}|�|�}|du rD|||< nnt|t�rh|t| |d |||�7 }nJt| | 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� r' �
isinstance�dictr� r r� ) ro �level�blockZ current_revr� r� r� �entryZ other_hexZ other_revr} r
r
r r� � s$
�r� c C st i }|dur|d }nd}g }t | �D ]B}|jdurD|j|t|�< q&t|�| |t|�< |�t||�� q&d�|�S )zaturn a nodemap trie into persistent binary data
See `_build_trie` for nodemap trie structureNr r r )�
_walk_trier� �idr0 r� �_persist_blockr� )r� r� � block_mapZbase_idx�chunks�tnr
r
r r� s
r� c c s> t | �� �D ]&\}}t|t�r t|�D ]
}|V q&q | V dS )zcyield all the block in a trie
Children blocks are always yield before their parent block.
N)rU �itemsr� r� r� )r� �__�itemZ 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 rB )� _to_value)r� �v�r� r
r r� < r z!_persist_block.<locals>.<genexpr>)�tupler� r� )Z
block_noder� r8 r
r� r r� 6 s r� c C s. | du r t S t| t�r"|t| � S t| �S dS )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 dkr.d}t�|tjt | �f ��| s<t� dfS i }g }tdt | �tj�D ]H}t� }t |�|_|||j< | ||tj � }t�|�}|� ||f� qV|D ]H\}}t
|�D ]6\} }
|
t kr�q�q�|
dkr�||
|| < q�t |
�|| < q�q�||tj fS )z,parse parse nodemap data into a nodemap Trier s: nodemap data size is not a multiple of block size (%d): %dN)
r0 r� r r ZAbortr� r� r� r r� � enumerater� r� ) r8 ry r� Z
new_blocksr� r� Z
block_data�values�b�idxr� r
r
r �
parse_dataJ s,
r� c
C s d}| � dt|� � t|�\}}tt|��}| � dt|� � tt|��D ]�}||vrpd| }| �|� d}n
|�|� t|t || d ��} | du r�d| }| �|� d}qL| |krLd || f }| �|� d}qL|r�t
|�D ]}d
| }| �|� q�d}|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
) �statusr0 r� �set�_all_revisionsr� Z write_err�remove�
_find_noder rU )
Zuiro r8 �retr� r� Zall_revs�rry Znm_revr
r
r �
check_datah s:
��
r� c c s6 t | �D ](}|D ] }|du st|t�r(q|V qqdS )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�r2t||dd� �S |S )z.find the revision associated with a given noder r N)r' r� r� r� r� )r� ru r� r
r
r r� � s
r� c C s* | j r | jd }| j�|�r |S | jd S )Ns .n.as .n)Z _trypendingrX r �exists)r1 Z pending_pathr
r
r rn � s
rn )FF)N)3Z
__future__r r. rY �structru r � r r r r r{ r� r
r r r: rE �objectrF rW r r= r �Structr r r r% rw rt r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rn r
r
r
r �<module> sT
.
I&
"
#