| 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�K � @ s� d dl mZ d dlZd dlZd dlmZmZmZ d dlm Z m
Z
m Z m Z m
Z
ddlmZ e
jZdZG dd � d e
j�ZG d
d � d e
je�ZdS ) � )�absolute_importN)�bin�hex�nullrev)�ancestor�context�error�phases�util� )� shallowutilg �?c s� e Zd Zd)� fdd� Zdd� Zedd� �Zd*dd �Zd
d � Zed d
� �Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zd+dd �Zd d � Zd d � Zd,d!d"�Zd#d$� Z� fd%d&�Zd'd(� Z� ZS )-�
remotefilectxNc sJ |t kr|j}|r&t|�dkr&t|�}tt| ��||||||� || _d S )N�( )r �nullid�lenr �superr
�__init__� _ancestormap)�self�repo�path�changeid�fileid�filelogZ changectx� ancestormap�� __class__� �G/usr/lib64/python3.9/site-packages/hgext/remotefilelog/remotefilectx.pyr s
�zremotefilectx.__init__c C s | j �| j�S �N)�_filelog�size� _filenode�r r r r r! . s zremotefilectx.sizec C sd d| j v r| jS d| j v r$| j�� S d| j v rX| �| j| j| j| j�}| j �
� j �|�S | � � S d S )N� _changeid�
_changectx�_descendantrev)
�__dict__r$ r% �rev�_adjustlinknode�_pathr r" r& �_repo�
unfiltered� changelog�linkrev)r �linknoder r r r$ 1 s
�zremotefilectx._changeidc C s t | j| j|| j|d�S )zMopens an arbitrary revision of the file without
opening a new filelog)r r r )r
r+ r* r )r r r r r r �filectxA s �zremotefilectx.filectxc C s | j S r )�_linkrevr# r r r r. L s zremotefilectx.linkrevc
C s� | j | jjkrtS | �� }|| j \}}}}| jjj�|�}|d urH|S | j}| j }| j� � j} | jj
}
t t | �d dd�D ]F}| �
|�} | �| �} || d v r|||
| d �� �|�kr|| S q|d S )Nr r ���� )r" r+ r r r r- �indexZget_revr* r, � manifestlog�ranger �node�read�readfast�get)
r r �p1�p2r/ �copyfromr( r r �cl�mflr7 �datar r r r1 O s(
�
zremotefilectx._linkrevc C sb | � � }t| �}d|v p d|v }|s2| �� |kr6|S | j| j| j| j| �� dd�}| jj�|�S )a return the rev of the changeset which introduced this file revision
This method is different from linkrev because it take into account the
changeset the filectx was created from. It ensures the returned
revision is one of its ancestors. This prevents bugs from
'linkrev-shadowing' when a file revision is used by multiple
changesets.
r$ r% T�� inclusive) r. �varsr( r) r* r r" r+ r- )r Zlkr�attrsZnoctxr/ r r r �introrevo s �zremotefilectx.introrevc
C s� | � � }|| j \}}}}|s"dS ||f}| �� | �� kr>|S | �� }| j}| j�� D ]4} z|| �|�krrW dS W qV tj y� Y qV0 qV|S )a# check if file was actually renamed in this changeset revision
If rename logged in file revision, we report copy for changeset only
if file revisions linkrev points back to the changeset in question
or both changeset parents contain different file revisions.
N)
r r" r( r. r r% �parents�filenoder � LookupError)
r r r; r< r/ r= �renamed�name�fnode�pr r r rI � s zremotefilectx.renamedc C s | � � }|o|d S )Nr )rI )r �copyr r r �
copysource� s zremotefilectx.copysourcec C s | j s| �� �| j�| _ | j S r )r r r r" r# r r r r � s zremotefilectx.ancestormapc C s� | j }| �� }|| j \}}}}g }||jkrh|p6| j}|�|�} t|||| |d�}
| �� |
_|� |
� ||jkr�| j}|�|�} t|||| |d�} | �� | _|� | � |S )N)r r r )
r+ r r" r r* �filer
r( r& �append) r r r r; r< r/ r= �resultsr Zflog�p1ctx�p2ctxr r r rF � s*
�
�
zremotefilectx.parentsc C sH |� |�}|d |d }}||v rD||| �� �|�krD|�|�S dS )zBreturns the node for <path> in <ancrev> if content matches <fnode>r r3 N)r8 r9 r: r7 ) r �ancrevr> r? r rK ZancctxZ manifestnode�filesr r r �_nodefromancrev� s
z remotefilectx._nodefromancrevFc s2 | j }|�� j� |j}| �� }|| d } |du rPdd� | j d �� D �}
d}n|g}
| �|
| �rf| S d�� fdd�|
D ��t|�|t �
|j �t � |j �d�} |j j
d
i | �� |j} d }
� j|
|d �}|D ]`}| �|� |||�}|dur�| S |
s�| �||�tjkr�| �||||
| �}|�r(| S d}
q�| S )a� return the first ancestor of <srcrev> introducing <fnode>
If the linkrev of the file revision does not point to an ancestor of
srcrev, we'll walk down the ancestors until we find one introducing
this file revision.
:repo: a localrepository object (used to access changelog and manifest)
:path: the file path
:fnode: the nodeid of the file revision
:filelog: the filelog of this path
:srcrev: the changeset revision we search ancestors from
:inclusive: if true, the src revision will also be checked
Note: This is based on adjustlinkrev in core, but it's quite different.
adjustlinkrev depends on the fact that the linkrev is the bottom most
node, and uses that as a stopping point for the ancestor traversal. We
can't do that here because the linknode is not guaranteed to be the
bottom most one.
In our code here, we actually know what a bunch of potential ancestor
linknodes are, so instead of stopping the cheap-ancestor-traversal when
we get to a linkrev, we stop when we see any of the known linknodes.
� Nc S s g | ] }|� � �qS r )r( )�.0rL r r r �
<listcomp>� � z1remotefilectx._adjustlinknode.<locals>.<listcomp>T� c s g | ]}t � �|���qS r )r r7 )rX r( �r> r r rY � rZ )�revsrK �filepath�userZreponame� linkrevfixup� adjusting linknode
FrA )r` ra )r+ r, r- r5 r rF �_verifylinknode�joinr r Z getusername�uiZ getreponame�logZ _phasecache� ancestorsrV Zphaser Zpublic�_forceprefetch)r r r rK ZsrcrevrB r r? r r/ r] �commonlogkwargsZpcZ
seenpublicZiterancrT Zlnoder r\ r r) � sB
�
�z remotefilectx._adjustlinknodec C s� d}t � � }�zDz�|jj|t|�fgdd� d | _| �� | d }| �||�r�d}|W W t � � | } |jjd|d fd| d i|�� S d
}W W t � � | } |jjd|d fd| d i|�� d S t �y }
zFd |
}W Y d }
~
W t � � | } |jjd|d fd| d i|�� d S d }
~
0 0 W t � � | } |jjd|d fd| d i|�� n0t � � | } |jjd|d fd| d i|�� 0 d S ) NrZ T)�forcerW s# remotefilelog prefetching succeededr` �
�elapsedi� s# remotefilelog prefetching not founds% remotefilelog prefetching failed (%s))
�time� fileservice�prefetchr r r rb rd re � Exception) r r r rK r] rh Zlogmsg�startr/ rk �er r r rg s| * ���� ���� ���� ���� ���z remotefilectx._forceprefetchc sJ |sdS z&| j �� j� t� �fdd�|D ��W S tjyD Y dS 0 dS )a�
Check if a linknode is correct one for the current history.
That is, return True if the linkrev is the ancestor of any of the
passed in revs, otherwise return False.
`revs` is a list that usually has one element -- usually the wdir parent
or the user-passed rev we're looking back from. It may contain two revs
when there is a merge going on, or zero revs when a root node with no
parents is being created.
Fc 3 s | ]}� � �� �|��V qd S r )Z
isancestorr7 )rX �r�r> r/ r r � <genexpr>q rZ z0remotefilectx._verifylinknode.<locals>.<genexpr>N)r+ r, r- �anyr rH )r r] r/ r rs r rb ` s z remotefilectx._verifylinknodec
c s� g }t �| f�}t� }|rv|�� }|�� |v r0q|�|�� � |�|� |�� }d}|D ]}|sd|sn|�|� d}qXq|�d� t|ddd� d�}|D ]
} | V q�d S )NTFr c S s | � � S r )r. )�xr r r �<lambda>� rZ z)remotefilectx.ancestors.<locals>.<lambda>)�reverse�key) � collections�deque�set�poprG �addrP rF �sorted)
r Z followfirstrf �queue�seen�currentrF �firstrL r r r r rf y s&
zremotefilectx.ancestorsc
s� |� � | � � kr(| � � |v r(|| � � S | � � |v rL|� � |vrL|| � � S |� � |v rp| � � |vrp||� � S | �� � |�� �� �fdd�}| � � | �� f}|� � |�� f}t�|||�}|r�|\}}t| j||� d�} | S d S )Nc sD | \}}� � |�p�� |�}|s$g S |d p.||d f||d fgS )Nr3 r r )r: )rv �f�nrL �ZamapZbmapr r rF � s
z'remotefilectx.ancestor.<locals>.parents)r r )r r rG r Zgenericancestorr
r+ )
r Zfc2ZactxrF �a�b�resultr� r� rr r r� r r � s" zremotefilectx.ancestorc s" | }|� dd �}|rF| �� }| �� |krFt| j| j|| j| j| jd�}g }t � }t
� |f�}|� |�
� � |r�|� � } | �� | �� kr�|�| �� t| �� �f� |r�| |v r�qj| �� D ](}
|
�
� |vr�|� |
�
� � |�|
� q�qj| jj�dt|� � |�r | jj�|� tt| �j|i |��S )N� prefetchskip)r r r r s1 remotefilelog: prefetching %d files for annotate
)r} rE r( r
r+ r* r" r r r| rz r{ r~ r7 rG rP r r rF rd �debugr rm rn r �annotate) r �args�kwargsZintroctxr� rE Zfetchr� r� r� �parentr r r r� � sF � ��zremotefilectx.annotatec C s g S r r r# r r r �children� s zremotefilectx.children)NNNNN)N)F)F)�__name__�
__module__� __qualname__r r! �
propertycacher$ r0 r. r1 rE rI rN r rF rV r) rg rb rf r r� r� �
__classcell__r r r r r
s4 �
LE
" ,r
c s. e Zd Zd� fdd� Zdd� Zdd� Z� ZS ) �remoteworkingfilectxNc s d | _ tt| ��||||� d S r )r r r� r )r r r r Z
workingctxr r r r � s
�z remoteworkingfilectx.__init__c C s
t �| �S r )r
rF r# r r r rF � s z remoteworkingfilectx.parentsc
C s2 | j �s,| j}| jj}| �� }|r(|}n||d j�|| jj�f}|| jjf}t |�dkrt||d j�|| jj�f}i }|d | jjkr�| jj
|d |d d�}|� |� � �
|d �� |d | jjkr�| jj
|d |d d�}|� |� � �
|d �� d} |�r
|d } |d |d | jj| f|d < || _ | j S )Nr r )r rZ )r r* r% Z_parentsrI Z _manifestr: r+ r r r0 �updater r )
r r ZpclrI r; r< �mrR rS r= r r r r � s. z remoteworkingfilectx.ancestormap)NN)r� r� r� r rF r r� r r r r r� � s r� )Z
__future__r rz rl Zmercurial.noder r r Z mercurialr r r r r
� r r� ZFASTLOG_TIMEOUT_IN_SECSr0 r
Zworkingfilectxr� r r r r �<module> s Q