| 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�= � @ s� d dl mZ d dlZd dlZd dlmZ d dlmZ d dlm Z m
Z
m Z m Z m
Z
d dlmZ d dlmZ dd lmZmZmZ G d
d � d e�ZG d d
� d
e�ZdS )� )�absolute_importN)�bin)�_)�ancestor�error�mdiff�pycompat�revlog)� storageutil)�flagutil� )� constants�fileserverclient� shallowutilc @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�remotefilelognodemapc C s || _ || _d S �N)� _filename�_store)�self�filename�store� r �G/usr/lib64/python3.9/site-packages/hgext/remotefilelog/remotefilelog.py�__init__! s z remotefilelognodemap.__init__c C s | j �| j|fg�}t|� S r )r Z
getmissingr �bool)r �node�missingr r r � __contains__% s z!remotefilelognodemap.__contains__c C s || vrt |��|S r )�KeyError�r r r r r �__get__) s z remotefilelognodemap.__get__N)�__name__�
__module__� __qualname__r r r r r r r r s r c @ s: e Zd ZdZejZdd� Zdd� ZdFdd�Z d d
� Z
dde j dfd d �Z
dGd
d�Zdd� Zdd� ZeZdd� Zdd� ZeZdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Z dHd(d)�Z d*d+� Z d,d-� Z d.d/� Z d0d1� Z!dId2d3�Z"d4d5� Z#d6d7� Z$d8d9� Z%d:d;� Z&d<d=� Z'd>d?� Z(d@dA� Z)dBdC� Z*dDdE� Z+dS )J�
remotefilelogTc C s8 || _ || _|| _t| j|j�| _d| _ttj �| _
d S )Nr ) �openerr �repor � contentstore�nodemap�version�dictr ZflagprocessorsZ_flagprocessors)r r% �pathr& r r r r 4 s zremotefilelog.__init__c C s4 | � |�}|�d�s|S |�dd�}||d d� S )z&returns the file contents at this nodes
� N)�revision�
startswith�index)r r �t�sr r r �read> s
zremotefilelog.readNc C s> t �||�d�|�d��}t�|||�}| j||||||d�S )N� copy� copyrev)r )r Zcreaterevlogtext�getr
�hashrevisionsha1� addrevision) r �text�meta� transaction�linknode�p1�p2Zhashtextr r r r �addF s � �zremotefilelog.addc C s� t �t|�|�}d||f } |}
d} |rDd|v rD|d } t|d �}
| d||
||| f 7 } t� } i }
g }|
| jjkr�| }| r�t| j| | j�}|
� |�
|
�� |� |
� | � |
� || jjkr�|
� | �
|�� |� |� | � |� d}|�rz|�
d�}|
| \}}}}|�p d}|d|||||f 7 }|| jjk�rP|| v�rP|� |� | � |� || jjkr�|| vr�|� |� | � |� q�| |7 } | S )Ns %s %s� r3 r4 s %s%s%s%s%s r )r Zbuildfileblobheader�lenr �setr& �nullidr$ r% �update� ancestormap�appendr> �pop)r r8 r9 �flagsr< r= r r; �header�dataZrealp1�copyfromZvisitedZ
pancestors�queueZp1flogZ ancestortext�cZpa1Zpa2ZancestorlinknodeZ
pacopyfromr r r �_createfileblobP sT
�
z remotefilelog._createfileblobc
C sV |d u rt �|||�}t �|�\}
} t�| ||�\} }
| j| ||||||||
| fd� S )N)�
_metatuple)r
r6 � parsemetar Zprocessflagswrite�addrawrevision)r r8 r: r; r< r= �
cachedeltar rG �sidedatar9 �
metaoffset�rawtextZ validatehashr r r r7 � s&
��zremotefilelog.addrevisionc
C sl | r| \}
} nt �|�\}
} |dkr(d} | r:|| d � } n|} | �| |
|||||�}
| jj�| j||
� |S )Nr )r
rO rM r& r' Zaddremotefilelognoder )r rT r: r; r< r= r rG rQ rN r9 rS ZblobtextrI r r r rP � s
�z remotefilelog.addrawrevisionc C s2 | j j�| j|�}|| \}}}}|r.||fS dS �NF�r& �
metadatastore� getancestorsr )r r � ancestorsr< r= r; rJ r r r �renamed� s
zremotefilelog.renamedc C s t | �|��S )z#return the size of a given revision)r@ r2 r r r r �size� s zremotefilelog.sizec C s" || j jkrdS | �|�}||kS )zpcompare text with a given file revision
returns True if text is different than what is stored.
T)r& rB r2 )r r r8 Znodetextr r r �cmp� s
zremotefilelog.cmpc C s dS )NTr �r r r r � __nonzero__� s zremotefilelog.__nonzero__c C s | j dv rdS td��d S )N)s .hgtagss .hgsubs .hgsubstater s len not supported)r � RuntimeErrorr] r r r �__len__� s
zremotefilelog.__len__c C s g S r r r] r r r �heads s zremotefilelog.headsc C s dS rU r r] r r r �empty s zremotefilelog.emptyc C s4 t |t�rt�d��| jj}|�| j|��t j
d�S )Ns3 remotefilelog does not accept integer rev for flagsr ) �
isinstance�intr �ProgrammingErrorr& r' �getmetar r5 r
� METAKEYFLAG)r r r r r r rG s
�zremotefilelog.flagsc C sR || j jkr | j j| j jfS | j j�| j|�}|| \}}}}|rJ| j j}||fS r )r& rB rW rX r �r r rD r< r= r; rJ r r r �parents s zremotefilelog.parentsc C s
| � |�S r )ri �r �revr r r �
parentrevs s zremotefilelog.parentrevsc C s& | j j�| j|�}|| \}}}}|S r rV rh r r r r; s zremotefilelog.linknodec C s | j �� j�| �|��S r )r& Z
unfilteredZ changelogrk r; r r r r �linkrev$ s zremotefilelog.linkrevFc c s� ~~~~~d }|D ]�} | � | �\}
} |d u r4|
} }| | krD| jj} | | jjkrbd }
| �| | �}n| �| �}
d }tj| |
| | �| �| | �| �d |
|d dd� V qd S )Nr ) r Zp1nodeZp2noder; �basenoderG Zbaserevisionsizer- �deltarR Zprotocol_flags) ri r& rB �revdiff�rawdatar Zrevlogrevisiondeltar; rG )r ZnodesZ
nodesorderZ revisiondataZassumehaveparentrevisionsZ
deltapreviousZ deltamodeZsidedata_helpersZprevnoder r< r= rn r- ro r r r �
emitrevisions' s6
�zremotefilelog.emitrevisionsc C s t �| �|�| �|��S r )r Ztextdiffrq )r Znode1Znode2r r r rp Q s zremotefilelog.revdiffc C s8 t |�dkrt|�}t |�dkr4t�|| jtd���|S )N�( � s invalid lookup input)r@ r r � LookupErrorr r r r r r �lookupT s �zremotefilelog.lookupc C s |S r r r r r r rk ^ s zremotefilelog.revc C s t |t�rt�d��|S )Ns2 remotefilelog does not convert integer rev to node)rc rd r re rj r r r r b s
�zremotefilelog.nodec C s� || j jkrdS t|�dkr0t�|| jtd���|| j jjksL|| j jj v rRtj
�| j j }|� | j|�}|rp|S |�
| j|�� tjd�}|dkr�|S t�| ||�d S )z�returns the revlog contents at this node.
this includes the meta data traditionally included in file revlogs.
this is generally only used for bundling and communicating with vanilla
hg clients.
r? rt s invalid revision inputr )r& rB r@ r ru r r Z
nodeconstantsZwdiridZwdirfilenodeidsZWdirUnsupportedr' r5 rf r
rg r Zprocessflagsread)r r �rawr rT rG r r r r- j s& � � �zremotefilelog.revisionc C s | j |dd�S )NF)rw )r- r r r r rq � s zremotefilelog.rawdatac C s� | j j}|j}t�| j j| j|�}z |�|�W S ty@ Y n0 t� | j|�}t
j � | j
|�}z t�|�W S ty~ Y n0 |�| j|fg� z |�|�W S ty� Y n0 t�|| jtd���dS )z3reads the raw file blob from disk, cache, or servers no nodeN)r& � fileservice�
localcacher Z getcachekey�namer r2 r Z getlocalkey�osr+ �join� localpathr Zreadfile�IOErrorZprefetchr ru r )r �idrx ry ZcachekeyZlocalkeyr} r r r �_read� s* � zremotefilelog._readc C s | j j�| j|�S r rV r r r r rD � s zremotefilelog.ancestormapc C sv || j jks|| j jkr | j jS | �||�\}}dd� t�|�D �}t�||| || �}|rntt|j |��S | j jS )Nc S s i | ]\}}||�qS r r ��.0�k�vr r r �
<dictcomp>� r? z*remotefilelog.ancestor.<locals>.<dictcomp>)
r& rB �_buildrevgraphr � iteritemsr rY �min�map� __getitem__�r �a�b�revmapZ
parentfuncr( Zancsr r r r � s zremotefilelog.ancestorc C sf || j jks|| j jkr | j jS | �||�\}}dd� t�|�D �}t�||| || �}t|j|�S )z@calculate all the heads of the common ancestors of nodes a and bc S s i | ]\}}||�qS r r r� r r r r� � r? z6remotefilelog.commonancestorsheads.<locals>.<dictcomp>) r& rB r� r r� r �commonancestorsheadsr� r� r� r r r r� � s z"remotefilelog.commonancestorsheadsc sR | � |�}| � |�}t�t�}t� � ||fD ]p}t�|�D ]`\}}|| } |\}
} } }
|
| jjkrz|
sz| � |
� � �
|
� | | jjkr:| � | � � �
| � q:q,t�t�}i }t� � fdd�|D ��}|�rH|� � \}}||v r�|r�|| � || � q�t
|�t
|� d }|||< |�r&|| � |� |�|�D ]}|�||f� �q0q�||jfS )z�Builds a numeric revision graph for the given two nodes.
Returns a node->rev map and a rev->[revs] parent function.
c 3 s | ]}|� vrd |fV qd S r r )r� �n�Z
allparentsr r � <genexpr>� r? z/remotefilelog._buildrevgraph.<locals>.<genexpr>r )rD � collections� defaultdict�listrA r r� r& rB rE r> �dequerF r@ r5 �
appendleftr� )r r� r� ZamapZbmapZ
parentsmap�mappingr Zpdatari r< r= r; rJ rl r� rK Zprevrev�currentZ
currentrev�parentr r� r r� � s@
� z remotefilelog._buildrevgraphc C s d S r r )r Zminlinkr: r r r �strip� s zremotefilelog.stripc C s g S r r r] r r r �files� s zremotefilelog.filesc C s dS )N)r r r r] r r r � checksize� s zremotefilelog.checksize)NN)NN)NFFFNN)F),r! r" r# Z
_generaldeltar Z RevlogErrorZ_flagserrorclassr r2 r> rM r ZREVIDX_DEFAULT_FLAGSr7 rP rZ r[ Zrawsizer\ r^ �__bool__r` ra rb rG ri rl r; rm rr rp rv rk r r- rq r� rD r r� r� r� r� r� r r r r r$ / sb
@�
+ �
,
�
*
1r$ )Z
__future__r r� r{ Zmercurial.noder Zmercurial.i18nr Z mercurialr r r r r Zmercurial.utilsr
Zmercurial.revlogutilsr � r
r r �objectr r$ r r r r �<module> s