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: docket.cpython-310.pyc
o �]Lb�9 � @ s� d dl mZ d dlZd dlZd dlZd dlZddlmZmZm Z m Z m Z ddlm Z ddd �Z ej�d �Zer<dd 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 �>/usr/lib/python3/dist-packages/mercurial/revlogutils/docket.py�make_uid& s r s HGTEST_UUIDFILEc C s\ z t tdd��}|�� �� }W d � n1 sw Y W n ty9 } z|jtjkr-� d}W Y d }~nd }~ww tjrBt |�}ndd� |D �}d}t dd�}|D ]}|d ? }||@ d > } || | }qRt � � } tjrt| j |d d � n| � |� | �| d �} | dks�J �t�d| �} t�| �} t td��}|�| � W d � | S 1 s�w Y | S )N�rb)�modes 04c s s � | ]}t |�V qd S �N)�ord)�.0�cr r r � <genexpr>@ s � zmake_uid.<locals>.<genexpr>r �#11111111111111111111111111111111111r �# � r )�version� r z>L�wb)�open�stable_docket_file�read�strip�IOError�errno�ENOENTr �ispy3�iter�int�random�Random�seed� getrandbits�struct�packr r �write)r �fr, �inst� iter_seed�int_seed�low_mask�i� high_part�low_part�r�raw�p�newr r r r 4 sD �� �� ��s BBBBBBLLLLLLcz>BLc @ s� e Zd ZdZ d(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|�@ r3J �t|�t| �@ r=J �t|�t| �@ rGJ �| | ksMJ �| | ksSJ �||ksYJ �| | _| | _| | _| | _|| _|| _|rz| j| _| j| _| j| _n | j| _| j| _| j| _|| _d S )NF)�_version_header�bool� _read_only�_dirty�radix�_radix� _docket_file�_path�opener�_opener� _index_uuid�_older_index_uuids� _data_uuid�_older_data_uuids�_sidedata_uuid�_older_sidedata_uuids�set�_initial_index_end�_pending_index_end�_initial_data_end�_pending_data_end�_initial_sidedata_end�_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_endrX r r r �__init__s s@ zRevlogDocket.__init__c C �" | j du r t� | _ d| j| j f S )z=file path to the current index file associated to this docketN� %s-%s.idx)rH r rC �rY r r r �index_filepath� � zRevlogDocket.index_filepathc C �* | 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 )rH rU rI �insertr rm �rY �oldr r r �new_index_file� � zRevlogDocket.new_index_fileTc c �2 � | j D ]\}}|s|dkrd| j|f V qdS )z>yield file path to older index files associated to this docketr rk N)rI rC �rY � include_empty�uuid�sizer r r �old_index_filepaths� � � ��z RevlogDocket.old_index_filepathsc C rj )z<file path to the current data file associated to this docketN� %s-%s.dat)rJ r rC rl r r r � data_filepath� rn zRevlogDocket.data_filepathc C ro )zZswitch data file to a new UID The previous data UID is moved to the "older" list.r )rJ rV rK rp r r} rq r r r � new_data_file� rt zRevlogDocket.new_data_filec c ru )z=yield file path to older data files associated to this docketr r| N)rK rC rv r r r �old_data_filepaths� r{ z RevlogDocket.old_data_filepathsc C rj )z@file path to the current sidedata file associated to this docketN� %s-%s.sda)rL r rC rl r r r �sidedata_filepath� rn z RevlogDocket.sidedata_filepathc C ro )zbswitch sidedata file to a new UID The previous sidedata UID is moved to the "older" list.r )rL rW rM rp r r� rq r r r �new_sidedata_file� rt z RevlogDocket.new_sidedata_filec c ru )zAyield file path to older sidedata files associated to this docketr r� N)rM rC rv r r r �old_sidedata_filepaths� r{ z#RevlogDocket.old_sidedata_filepathsc C � | j S r )rU rl r r r rc � � zRevlogDocket.index_endc C � || j kr || _ d| _d S d S �NT)rU rA �rY �new_sizer r r rc � � �c C r� r )rV rl r r r re � r� zRevlogDocket.data_endc C r� r� )rV rA r� r r r re � r� c C r� r )rW rl r r r rg r� zRevlogDocket.sidedata_endc C r� r� )rW rA r� r r r rg r� c C s� | j sdS | jrd}|| j; }t�|��|s |j| jdd� | j| jddd��}|�| j|d�� W d � n1 s;w Y || _ dS ) 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 � atomictemp)�pendingN) rA r@ rE r �ProgrammingError� addbackuprG r0 � _serialize)rY � transactionr� � stripping�msgr1 r r r r0 s �zRevlogDocket.writec C s� |r | j }| j}| j}n | j}| j}| j}|| jks J �|| jks#J �| 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 ] \}}|�|� qp|�| j � | j D ]\}}|�t�t|�|�� q�| j D ] \}}|�|� q�|�| j � | j D ]\}}|�t�t|�|�� q�| j D ] \}}|�|� q�d�|�S )N� )rO rQ rS rU rV rW r> �lenrH rI rJ rK rL rM rX �append�S_HEADERr/ � S_OLD_UID�join) rY r� �official_index_end�official_data_end�official_sidedata_end�data�s�ury r r r r� ! sT � zRevlogDocket._serialize)FNNr Nr Nr r r r r r r N)T)FF�F)�__name__� __module__� __qualname__�__doc__ri rm rs rz r} r~ r r� r� r� �propertyrc �setterre rg r0 r� r r r r r= p sR �6 r= c C sD |d@ }|t jt jfvrdS tj| j �� }t| ||d�}d|_|S )z?given a revlog version a new docket object for the given revlogi�� N)r\ rX T) r �REVLOGV2� CHANGELOGV2r � compengines� _compengine� revlogheaderr= rA )rZ r\ � rl_version�comp�docketr r r �default_docketU s �r� c C sZ g }g }t d|�D ]}| tj�}|�t�|�� q |D ]\}}| |�}|�||f� q|S )Nr )�ranger� ry r� �unpack) �get_data�count� all_sizes�all_uidsr6 r: �uid_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| f|||| | ||||||||||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)r� r �Abort)ry r� r: �r� �offsetr r r� x s z parse_docket.<locals>.get_data)r[ r\ r] r^ r_ r` ra rb rc rd re rf rg rh rX )r� r� ry r( �nextr� r= )rZ r� r[ �headerr� �iheaderr\ �index_uuid_sizer] �older_index_uuid_countr^ �data_uuid_sizer_ �older_data_uuid_countr` �sidedata_uuid_sizera �older_sidedata_uuid_countrb � index_size�pending_index_size� data_size�pending_data_size� sidedata_size�pending_sidedata_sizerX r� r r� r � parse_docketq sX ��r� )r r� )� __future__r r% r r* r. � r r r r r r r �environ�getr! �Struct�INDEX_HEADER_FMTr� r� �objectr= r� r� r� r r r r �<module> s$ 6 f
Save
Cancel