| 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
�+�b�9 � @ s� d dl mZ d dlZd dlZd dlZd dlZddlmZmZm Z m
Z
m Z ddlm Z ddd �Z
ej�d
�Zerxdd d �Z
e�e jd �Ze�d
�ZG dd� de�Zdd� Zdd� Zddd�ZdS )� )�absolute_importN� )�encoding�error�node�pycompat�util� )� constants� c C s t �t�| d ��S )z_return a new unique identifier.
The identifier is random and composed of ascii characters.r )r �hex�os�urandom)�id_size� r �B/usr/lib64/python3.9/site-packages/mercurial/revlogutils/docket.py�make_uid& s r s HGTEST_UUIDFILEc
C s^ z<t tdd�� }|�� �� }W d � n1 s00 Y W n6 tyr } z |jtjkrZ� d}W Y d }~n
d }~0 0 tjr�t |�}ndd� |D �}d}t
dd�}|D ]$}|d ? }||@ d
> } || | }q�t � � }
tjr�|
j
|d d � n
|
�
|� |
�| d
�} | dk�sJ �t�d| �} t�| �}
t td��}|�|
� W d � n1 �sP0 Y |
S )N�rb)�modes 04c s s | ]}t |�V qd S �N)�ord)�.0�cr r r � <genexpr>@ � zmake_uid.<locals>.<genexpr>r Z#11111111111111111111111111111111111r �# � r )�version� r z>L�wb)�open�stable_docket_file�read�strip�IOError�errno�ENOENTr Zispy3�iter�int�randomZRandom�seedZ getrandbits�struct�packr r �write)r �fr* �instZ iter_seedZint_seedZlow_mask�iZ high_partZlow_part�r�raw�p�newr r r r 4 s6 .
*s
BBBBBBLLLLLLcz>BLc @ s� e Zd ZdZd(dd�Zdd � Zd
d � Zd)d
d�Zdd� Zdd� Z d*dd�Z
dd� Z dd� Z d+dd�Z
edd � �Zejd d � �Zed d � �Zejd d � �Zed!d"� �Zejd#d"� �Zd,d$d%�Zd-d&d'�ZdS ).� RevlogDocketz metadata associated with revlogFNr r c C s || _ t|�| _d| _|j| _|j| _|j| _ || _
|| _ || _ || _
|| _| | _t|�t|�@ rfJ �t|�t| �@ rzJ �t|�t| �@ r�J �|
| ks�J �| |
ks�J �||ks�J �|
| _| | _| | _|
| _|| _|| _|r�| j| _| j| _| j| _n| j| _| j| _| j| _|| _d S )NF)�_version_header�bool�
_read_only�_dirty�radix�_radixZ _docket_file�_path�opener�_opener� _index_uuid�_older_index_uuids�
_data_uuid�_older_data_uuids�_sidedata_uuid�_older_sidedata_uuids�set�_initial_index_endZ_pending_index_end�_initial_data_endZ_pending_data_end�_initial_sidedata_endZ_pending_sidedata_end�
_index_end� _data_end�
_sidedata_end�default_compression_header)�self�revlog� use_pending�version_header�
index_uuid�older_index_uuids� data_uuid�older_data_uuids�
sidedata_uuid�older_sidedata_uuids� index_end�pending_index_end�data_end�pending_data_end� sidedata_end�pending_sidedata_endrL r r r �__init__s s@
zRevlogDocket.__init__c C s" | j du rt� | _ d| j| j f S )z=file path to the current index file associated to this docketN� %s-%s.idx)r? r r; �rM r r r �index_filepath� s
zRevlogDocket.index_filepathc C s* | j | jf}| j�d|� t� | _ | �� S )z\switch index file to a new UID
The previous index UID is moved to the "older" list.r )r? rI r@ �insertr r` �rM �oldr r r �new_index_file� s zRevlogDocket.new_index_fileTc c s0 | j D ]$\}}|s|dkrd| j|f V qdS )z>yield file path to older index files associated to this docketr r^ N)r@ r; �rM Z
include_emptyZuuid�sizer r r �old_index_filepaths� s z RevlogDocket.old_index_filepathsc C s" | j du rt� | _ d| j| j f S )z<file path to the current data file associated to this docketN� %s-%s.dat)rA r r; r_ r r r �
data_filepath� s
zRevlogDocket.data_filepathc C s* | j | jf}| j�d|� t� | _ | �� S )zZswitch data file to a new UID
The previous data UID is moved to the "older" list.r )rA rJ rB ra r ri rb r r r �
new_data_file� s zRevlogDocket.new_data_filec c s0 | j D ]$\}}|s|dkrd| j|f V qdS )z=yield file path to older data files associated to this docketr rh N)rB r; re r r r �old_data_filepaths� s z RevlogDocket.old_data_filepathsc C s" | j du rt� | _ d| j| j f S )z@file path to the current sidedata file associated to this docketN� %s-%s.sda)rC r r; r_ r r r �sidedata_filepath� s
z RevlogDocket.sidedata_filepathc C s* | j | jf}| j�d|� t� | _ | �� S )zbswitch sidedata file to a new UID
The previous sidedata UID is moved to the "older" list.r )rC rK rD ra r rm rb r r r �new_sidedata_file� s z RevlogDocket.new_sidedata_filec c s0 | j D ]$\}}|s|dkrd| j|f V qdS )zAyield file path to older sidedata files associated to this docketr rl N)rD r; re r r r �old_sidedata_filepaths� s z#RevlogDocket.old_sidedata_filepathsc C s | j S r )rI r_ r r r rW � s zRevlogDocket.index_endc C s || j kr|| _ d| _d S �NT)rI r9 �rM Znew_sizer r r rW � s
c C s | j S r )rJ r_ r r r rY � s zRevlogDocket.data_endc C s || j kr|| _ d| _d S rp )rJ r9 rq r r r rY � s
c C s | j S r )rK r_ r r r r[ s zRevlogDocket.sidedata_endc C s || j kr|| _ d| _d S rp )rK r9 rq r r r r[ s
c C s� | j s
dS | jr(d}|| j; }t�|��|s<|j| jdd� | j| jddd��"}|�| j|d�� W d � n1 sv0 Y || _ dS d S )
z_write the modification of disk if any
This make the new content visible to all processFs writing read-only docket: %ss store)�location� wT)r Z
atomictemp)�pendingN) r9 r8 r< r ZProgrammingErrorZ addbackupr> r- �
_serialize)rM Z transactionrt Z stripping�msgr. r r r r- s
0zRevlogDocket.writec C s� |r| j }| j}| j}n| j}| j}| j}|| jks8J �|| jksFJ �| jt| j�t| j �t| j
�t| j �t| j �t| j
�|| j|| j|| j| jf}g }|�tj|� � |�| j� | j D ] \}}|�t�t|�|�� q�| j D ]\}}|�|� q�|�| j
� | j D ] \}}|�t�t|�|�� �q| j D ]\}}|�|� �q.|�| j � | j
D ] \}}|�t�t|�|�� �qV| j
D ]\}}|�|� �q~d�|�S )Nr )rF rG rH rI rJ rK r6 �lenr? r@ rA rB rC rD rL �append�S_HEADERr, � S_OLD_UID�join) rM rt Zofficial_index_endZofficial_data_endZofficial_sidedata_end�data�s�urf r r r ru ! sT � zRevlogDocket._serialize)FNNr Nr Nr r r r r r r N)T)T)T)FF)F)�__name__�
__module__� __qualname__�__doc__r] r` rd rg ri rj rk rm rn ro �propertyrW �setterrY r[ r- ru r r r r r5 p sP �
6
r5 c C sD |d@ }|t jt jfvr dS tj| j �� }t| ||d�}d|_|S )z?given a revlog version a new docket object for the given revlogi�� N)rP rL T) r
ZREVLOGV2Z CHANGELOGV2r Z compenginesZ _compengineZ revlogheaderr5 r9 )rN rP Z
rl_version�comp�docketr r r �default_docketU s �r� c C sZ g }g }t d|�D ] }| tj�}|�t�|�� q|D ] \}}| |�}|�||f� q6|S )Nr )�rangerz rf rx �unpack) �get_data�countZ all_sizesZall_uidsr0 r2 Zuid_size� file_size�uidr r r �_parse_old_uidsd s
r� Fc s t �� dt j� �}t jg�� �fdd�}t|�}t|�}t|�}||�}t|�} t|| �}
t|�} || �} t|�}
t||
�}t|�}||�}t|�}t||�}t|�}t|�}t|�}t|�}t|�}t|�}t|�}t| ||||
| ||||||||||d�}|S )zBgiven some docket data return a docket object for the given revlogNc sf �d | t � �kr:d}|�d | t � �f; }t�|��� �d �d | � }�d | 7 < |S )z/utility closure to access the `size` next bytesr s' docket is too short, expected %d got %d)rw r ZAbort)rf rv r2 �r| �offsetr r r� x s
z parse_docket.<locals>.get_data)rO rP rQ rR rS rT rU rV rW rX rY rZ r[ r\ rL )ry r� rf r' �nextr� r5 )rN r| rO �headerr� ZiheaderrP Zindex_uuid_sizerQ Zolder_index_uuid_countrR Zdata_uuid_sizerS Zolder_data_uuid_countrT Zsidedata_uuid_sizerU Zolder_sidedata_uuid_countrV Z
index_sizeZpending_index_size� data_sizeZpending_data_sizeZ
sidedata_sizeZpending_sidedata_sizerL r� r r� r � parse_docketq sV
�r� )r )r )F)Z
__future__r r% r
r) r+ � r r r r r r
r �environ�getr! �StructZINDEX_HEADER_FMTry rz �objectr5 r� r� r� r r r r �<module> s"
6
f