ruạṛ
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
cải xoăn