| 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/hgext/remotefilelog/__pycache__/ |
Upload File : |
a
�+�b�3 � @ s� d dl mZ d dlZd dlmZmZ d dlmZ d dlm Z m
Z
m Z ddl m
Z
mZmZ G dd � d e�ZG d
d � d e
j�ZG d d
� d
e
j
�ZG dd� de�ZG dd� de�ZdS )� )�absolute_importN)�hex�sha1nodeconstants)�getattr)�mdiff�pycompat�revlog� )� basestore� constants� shallowutilc @ s$ e Zd ZdZdZdZdZdZdZdS )�
ChainIndiciesz>A static class for easy reference to the delta chain indicies.r r � � � N) �__name__�
__module__� __qualname__�__doc__�NAMEZNODEZBASENAME�BASENODE�DATA� r r �F/usr/lib64/python3.9/site-packages/hgext/remotefilelog/contentstore.pyr
s r
c s� e Zd Z� fdd�Zdd� Zejjdd� �Zdd� Z ejjd d
� �Z
d d � Z ejjd
d� �Z dd� Z
dd� Zdd� Zddd�Z� ZS )�unioncontentstorec s: t t| �j|i |�� || _|�d�| _|�dd�| _d S )N�
writestore�allowincompleteF)�superr �__init__�stores�getr r ��self�args�kwargs�� __class__r r r ) s zunioncontentstore.__init__c C sh | � ||�}|d tj tjkr0t|t|�f��|�� tj }|}|rd|�� tj }t �
||g�}qB|S )a Fetches the full text revision contents of the given name+node pair.
If the full text doesn't exist, throws a KeyError.
Under the hood, this uses getdeltachain() across all the stores to build
up a full chain to produce the full text.
���) �
getdeltachainr
r r �nullid�KeyErrorr �popr r Zpatches)r" �name�node�chainZfulltext�textZdeltar r r r 4 s zunioncontentstore.getc C sF | j D ]*}z|�||�W S ty. Y q0 qt|t|�f��dS )z;Return the single delta entry for the given name/node pair.N)r �getdeltar* r �r" r, r- �storer r r r0 L s
zunioncontentstore.getdeltac C sr | � ||�}|d tj tjkrn|d \}}}}}z| � ||�}|�|� W q tyj | jsb� Y qnY q 0 q |S )a
Returns the deltachain for the given name/node pair.
Returns an ordered list of:
[(name, node, deltabasename, deltabasenode, deltacontent),...]
where the chain is terminated by a full text entry with a nullid
deltabasenode.
r' )�_getpartialchainr
r r r) �extendr* r )r" r, r- r. �xZ
deltabasenameZ
deltabasenodeZ morechainr r r r( W s
z unioncontentstore.getdeltachainc C sF | j D ]*}z|�||�W S ty. Y q0 qt|t|�f��dS )z)Returns the metadata dict for given node.N)r �getmetar* r r1 r r r r6 o s
zunioncontentstore.getmetac C s dd� | j D �}tj|� S )Nc S s g | ] }|� � �qS r )�
getmetrics)�.0�sr r r �
<listcomp>z � z0unioncontentstore.getmetrics.<locals>.<listcomp>)r r Zsumdicts)r" Zmetricsr r r r7 y s z unioncontentstore.getmetricsc C sF | j D ]*}z|�||�W S ty. Y q0 qt|t|�f��dS )z�Returns a partial delta chain for the given name/node pair.
A partial chain is a chain that may not be terminated in a full-text.
N)r r( r* r r1 r r r r3 } s
z"unioncontentstore._getpartialchainc C s t d��d S �Ns5 cannot add content only to remotefilelog contentstore�� RuntimeError�r" r, r- �datar r r �add� s �zunioncontentstore.addc C s" |}| j D ]}|r
|�|�}q
|S �N)r �
getmissing)r" �keys�missingr2 r r r rC � s
z unioncontentstore.getmissingc C s$ | j r| j �|||� ntd��d S )Ns no writable store configured)r �addremotefilelognoder> r? r r r rF � s z&unioncontentstore.addremotefilelognodeNc C s | j D ]}|�||� qd S rB )r �
markledger)r" �ledger�optionsr2 r r r rG � s
z unioncontentstore.markledger)N)r r r r r r
�baseunionstoreZ retriabler0 r( r6 r7 r3 rA rC rF rG �
__classcell__r r r% r r ( s
r c sT e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
� Z S )�remotefilelogcontentstorec s$ t t| �j|i |�� t�� | _d S rB )r rL r � threading�local� _threaddatar! r% r r r � s z"remotefilelogcontentstore.__init__c C s� | � ||�}t�|�\}}}|||| � }t�|�}|| \} }
} } d }
| rVt| �}
| �|||� |tj@ rvd }
} t�|| |
�}|S rB ) �_getdatar �parsesizeflags� ancestormapr �_updatemetacacher ZREVIDX_EXTSTOREDZcreaterevlogtext)r" r, r- r@ �offset�size�flagsZcontentrR �p1�p2�linknodeZcopyfromZcopyrev�revisionr r r r � s
z remotefilelogcontentstore.getc C s" | � ||�}||tj| �||�fS rB )r r r) r6 �r" r, r- rZ r r r r0 � s
�z"remotefilelogcontentstore.getdeltac C s | � ||�}||d tj|fgS rB �r r r) r[ r r r r( � s z'remotefilelogcontentstore.getdeltachainc C sN | � � || jjd krB| �||�}t�|�\}}}| �|||� | jjd S �Nr r )�_sanitizemetacacherO � metacacherP r rQ rS )r" r, r- r@ rT rU rV r r r r6 � s z!remotefilelogcontentstore.getmetac C s t d��d S r< r= r? r r r rA � s �z remotefilelogcontentstore.addc C s" t | jdd �}|d u r d| j_d S )Nr_ )NN)r rO r_ )r" r_ r r r r^ � s z,remotefilelogcontentstore._sanitizemetacachec C s< | � � || jjd kr d S tj|tj|i}||f| j_d S )Nr )r^ rO r_ r � METAKEYFLAG� METAKEYSIZE)r" r- rU rV �metar r r rS � s
z*remotefilelogcontentstore._updatemetacache) r r r r r r0 r( r6 rA r^ rS rK r r r% r rL � s rL c @ sN e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z ddd�Z
dS )�remotecontentstorec C s || _ || _d S rB )� _fileservice�_shared)r" ZuiZ fileserviceZsharedr r r r � s zremotecontentstore.__init__c C s* | j j|t|�fgddd� | j�||�S �NT)�forceZ fetchdata)rd �prefetchr re r �r" r, r- r r r r � s �zremotecontentstore.getc C s$ | � ||�}||tj| j�||�fS rB )r r r) re r6 r[ r r r r0 � s �zremotecontentstore.getdeltac C s | � ||�}||d tj|fgS rB r\ r[ r r r r( � s z remotecontentstore.getdeltachainc C s* | j j|t|�fgddd� | j�||�S rf )rd rh r re r6 ri r r r r6 s �zremotecontentstore.getmetac C s t d��d S )Ns cannot add to a remote storer= r? r r r rA
s zremotecontentstore.addc C s |S rB r )r" rD r r r rC s z remotecontentstore.getmissingNc C s d S rB r )r" rH rI r r r rG s z remotecontentstore.markledger)N) r r r r r r0 r( r6 rA rC rG r r r r rc � s rc c @ sx e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d d
�Zdd� Z dd� Z
dd� Z dd� Z dd� Z
d dd�Zdd� Zd S ) �manifestrevlogstorec C s4 |j | _|j| _t� | _tj| jdd�| _d| _d S )Ns
00changelog.i��radixr ) r2 �_storeZsvfs�_svfs�dict�_revlogsr �_cl�_repackstartlinkrev)r" Zrepor r r r s
z manifestrevlogstore.__init__c C s | � |��|�S rB )�_revlogZrawdatari r r r r s zmanifestrevlogstore.getc C s$ | � ||�}||| jj| �||�fS rB )r rq r) r6 r[ r r r r0 " s z manifestrevlogstore.getdeltac C s | � ||�}||d | jj|fgS rB )r rq r) r[ r r r r( & s z!manifestrevlogstore.getdeltachainc C s0 | � |�}|�|�}tj|�|�tj|�|�iS rB )rs �revr r` rV ra Zrawsize)r" r, r- �rlrt r r r r6 * s
�zmanifestrevlogstore.getmetaNc C s� |d u rt � }||v rg S | �|�}i }|h}|j|�|�gdd�D ]�}|�|�}|�|� |�|�\} }
| | jjkr�| |vr�|� | � |
| jjkr�|
|vr�|� |
� | j�|�
|��} | |
| df||�|�< |sD q�qD|S )NT)Z inclusiver; ) �setrs � ancestorsrt r- �discard�parentsrq r) rA �linkrev) r" r, r- Zknownru rw rE ZancrevZancnoderW rX rY r r r � getancestors2 s(
z manifestrevlogstore.getancestorsc C sD | j }| �|�}|�|�}|�|�|��}|d |d |�|�d fS r] )rq rs ry rz rt r- )r" r, r- Zclru ry rz r r r � getnodeinfoK s
z manifestrevlogstore.getnodeinfoc G s t d��d S )Ns cannot add to a revlog storer= )r" r# r r r rA R s zmanifestrevlogstore.addc C sF | j �|�}|d u rBd}|dkr(d| }tj| j|d�}|| j |< |S )N� 00manifesttreer; s meta/%s/00manifestrk )rp r r rn )r" r, ru Z
revlognamer r r rs U s
zmanifestrevlogstore._revlogc C s8 g }|D ]*\}}| � |�}||jvr|�||f� q|S rB )rs Znodemap�append)r" rD rE r, r- Zmfrevlogr r r rC _ s
z manifestrevlogstore.getmissingc C s || _ || _d S rB )rr �_repackendlinkrev)r" ZstartrevZendrevr r r �setrepacklinkrevrangeh s z)manifestrevlogstore.setrepacklinkrevrangec
C sf |r|� tj�rd S d}tj| jdd�}| j}| j}t�t |�d dd�D ]J}|�
|�}||k rd q�||krnqJ|� |�} |� | || � |�
| || � qJ| j�� D ]�\}
} } | d d� dks�| dd � d kr�q�| dt d
� � }tj| j| d d� d �}t�t |�d dd�D ]R}|�
|�}||k �r( q�||k�r6�q |� |�} |� | || � |�
| || � �q q�d S ) Nr; r} rk r r' � s meta/���s .is /00manifest)Z indexfile)r r ZOPTION_PACKSONLYr rn rr r r Zxrange�lenrz r- Z
markdataentryZmarkhistoryentryrm Z datafiles)
r" rH rI Ztreenameru Z startlinkrevZ
endlinkrevrt rz r- �t�pathrU r r r rG l s:
z manifestrevlogstore.markledgerc C s d S rB r )r" rH r r r �cleanup� s zmanifestrevlogstore.cleanup)N)N)r r r r r r0 r( r6 r{ r| rA rs rC r� rG r� r r r r rj s
"rj )Z
__future__r rM Zmercurial.noder r Zmercurial.pycompatr Z mercurialr r r � r
r r �objectr
rJ r rL rc rj r r r r �<module> s zH-