| 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�8 � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZ d dl m
Z
m Z d dl m
Z
d dlmZmZmZmZmZmZmZmZmZmZmZmZmZm Z ddl m Z m Z ej Z!d d
� Z"d a#d d
� Z$dd� Z%dd� Z&dd� Z'dd� Z(dd� Z)dd� Z*dS )� )�absolute_importN)�_)�bin�hex)�open)� changegroup� changelog�context�error�
extensions�match�pycompat�scmutil�store� streamclone�util�wireprotoserver�wireprototypes�wireprotov1server� )� constants� shallowutilc s( t | � � fdd�}t�tjd|� dS )zGSets up a normal Mercurial repo so it can serve files to shallow repos.c s� |j pg }tj|v r�d } d }
|j p$g D ]F} | �d�rL| td�d � �d�} q&| �d�r&| td�d � �d�}
q&t�� � | s~|
r�t��jdd | |
�� t � fdd�|D ��}| |||||g|�R i |��S )Ns includepattern=� s excludepattern=� c s g | ]}� |�s|�qS � r ��.0�f��mr �M/usr/lib64/python3.9/site-packages/hgext/remotefilelog/remotefilelogserver.py�
<listcomp>C r z6setupserver.<locals>.generatefiles.<locals>.<listcomp>)
Z _bundlecapsr ZBUNDLE2_CAPABLITY�
startswith�len�splitr �always�root�list) �orig�selfZ changedfilesZ linknodesZ
commonrevs�source�args�kwargs�caps�includepattern�excludepatternZcap��repor r �
generatefiles/ s,
�
���z"setupserver.<locals>.generatefiless
generatefilesN)� onetimesetupr � wrapfunctionr Zcgpacker)�uir1 r2 r r0 r � setupserver* s
�r6 Fc s� t rdS da tjdddd�t� tjdddd�t� tjd d
dd�t� G d d � d t�}|� � � fd
d�}|dftjd< d � fdd� }t� t
d|� �fdd�}t� td|� dd� }t� t j d|� dd� }t� t
d |� dS ) z9Configures the wireprotocol for both clients and servers.NT� x_rfl_getflogheadss paths pull)Z
permission� x_rfl_getfilesr �
x_rfl_getfiles file nodec @ s e Zd ZdZdZdZdS )z!onetimesetup.<locals>.streamstateNF)�__name__�
__module__� __qualname__r �
shallowremote�noflatmfr r r r � streamstateb s r? c
s� d }d }|� d�}|r |�d�}|� d�}|r8|�d�}�j}�j}�j}z�d�_t�� �_|� d�dk�_|st|r�t�| jdd ||��_t�| |��t �j
�� t �j
��� ��fdd �} t � | � �W |�_|�_|�_S |�_|�_|�_0 d S )
Ns includepatternr s excludepatternTs noflatmanifests Truer c 3 s" � V �V �j D ]
} | V qd S �N)�gen)�value��first�second� streamresr r rA � s
z5onetimesetup.<locals>.stream_out_shallow.<locals>.gen)
�getr$ r= r r> r% r& r �stream�nextrA r rF )
r1 �proto�otherr. r/ �rawZ
oldshallowZoldmatchZ oldnoflatmfrA ��staterC r �stream_out_shallowi sD
�
� �z(onetimesetup.<locals>.stream_out_shallow� *s stream_out_shallowc 3 s� � j �r�t�|�r�t|jj�d }|jjj}tj� |jjd�g}|r�|�
� }||dd�D ]x\}}} |d | }
|t j kr�|
�
d�s�|
�
d�s�t�|
|d � �} t�| �} tj}
|
| | jfV |t jkrX|�|
� qXq@t�|��r"|j�� D ]6\}
}}|�d�r�|�
d��s|�
d�r�|
||fV q� j}|�rt|�� �st|j�� D ]0\}
}}|d d
� }� �|��sB|
||fV �qB|j�� D ].}� j �r�|d d d � d k�r��q~|V �q~n4t�|��r�t � t d
���n| ||�D ] }|V �q�d S )Nr s dataT)�stat� /s .is .ds meta/� ���� s 00manifest.s0 Cannot clone from a shallow repo to a full repo.) r= r � isenabledr# r �pathZrawvfs�readdir�os�join�poprQ �S_IFREG�endswithr ZpconvertZ decodedirZFILETYPE_OTHER�st_size�S_IFDIR�appendr ZistreemanifestZ datafilesr" r r% Ztopfilesr> r
�Abortr )r( r1 ZmatcherZstriplenrX Zvisit�pr �kind�st�fp�n�d�t�u�sr �xrM r r �_walkstreamfiles� sV
�
�� �z&onetimesetup.<locals>._walkstreamfiless _walkstreamfilesc sN | ||�}t �|�s � �dd�rJt|t�r6|�tj� |�d� |�d� |S )N�
remotefilelog� serverr7 r9 )r rV �
configbool�
isinstance� _sshv1serverr` r Z NETWORK_CAP_LEGACY_SSH_GETFILES)r( r1 rJ r- )r5 r r �
_capabilities� s
�
z#onetimesetup.<locals>._capabilitiess
_capabilitiesc _ sD |j }t�|d�r.|jr.|j�|j�|j��S | |g|�R i |��S )Ns forcelinkrev)�_repor Z safehasattr� forcelinkrevZ_filelogZlinkrevZrevZ _filenode)r( r) r+ r, r1 r r r �_adjustlinkrev� s z$onetimesetup.<locals>._adjustlinkrevs _adjustlinkrevc S s |dkr dS | |�S )Nr8 Fr )r( �cmdr r r �_iscmd� s z onetimesetup.<locals>._iscmds iscmd)N)�onetimer Zwireprotocommand� getflogheads�getfiles�getfile�objectZcommandsr r4 r r Z basefilectxr )r5 r? rO rl rr ru rw r )rN r5 r r3 P sD ������ )�
5 �r3 c
C s� t j�||t|��}t j�|�r2t j�|�dk�rZ| j||d�}|�� | jkrjt � | j
�| _ | j||d�}t |�}t �
|�}t �d�}z�t j�|�}t j�|�s�zt �|� W n2 ty� } z| jtjkr̂ W Y d } ~ n
d } ~ 0 0 d }
zFzt�|d�}
|
�|� W n ttf�y Y n0 W |
�r>|
�� n|
�r<|
�� 0 W t �|� n t �|� 0 n4t|d��}
|
�� }W d � n1 �s�0 Y |S )Nr )Zfileid� s wbs rb)rY rW rZ r �exists�getsize�filectx�node�nullidr Zsvfs�createfileblob�zlib�compress�umask�dirname�makedirs�OSError�errnoZEEXISTr Zatomictempfile�write�IOError�closer �read) r1 � cachepathrW r� �
filecachepathr� �textZoldumaskr� �exr r r r �
_loadfileblob� s>
� (r� c s* � � |�}|�� }d�� fdd�|D ��S )z-A server api for requesting a filelog's heads�
c 3 s | ]}|� j krt|�V qd S r@ )r� r )r �headr0 r r � <genexpr> r z getflogheads.<locals>.<genexpr>)�file�headsrZ )r1 rJ rW �flogr� r r0 r ry s
ry c C sd t �| �rdtd� S | j�dd�}|s8tj�| jd�}t|� � �}|| j
krRdS dt | |||� S )af A server api for requesting a particular version of a file. Can be used
in batches to request many files at once. The return protocol is:
<errorcode> <data/errormsg> where <errorcode> is 0 for success or
non-zero for an error.
data is a compressed blob with revlog flag and ancestors information. See
createfileblob for its content.
s 1 �+ cannot fetch remote files from shallow reporm � servercachepath� remotefilelogcaches 0 ) r rV r r5 �configrY rW rZ r �stripr� r� )r1 rJ r� r� r� r r r r{ " s
r{ c sJ t ���rt�td���t� t�s0t�td���� �fdd�}t�|� �S )zDA server api for requesting particular versions of particular files.r� s/ cannot fetch remote files over non-ssh protocolc 3 s� � j } �j�dd�}|s(tj��jd�}| �� d d� }|s>q�t|d d� �}|�jkr`dV q(|dd � }t �|||�}dt
|�|f V � j � � q(d S )Nrm r� r� ����( s 0
s %d
%s)
Z_finr5 r� rY rW rZ �readliner r� r� r# Z_fout�flush)Zfinr� Zrequestr� rW r� �rJ r1 r r �streamer= s
zgetfiles.<locals>.streamer) r rV r
ra r rp rq r rF )r1 rJ r� r r� r rz 6 s
rz c C s | � � }| �� }|j�|�}|dkr.| �� }n
|�|�}| j}| g}z�d|_|�dd� | � � D �� d}|D ]�}|�
� } |j }
|j } t | �dkr�| d �
� }
t | �dkr�| d �
� } d} |�� }
|
r�|
d } |�� }|d|�
� |
| || f 7 }qlW d|_nd|_0 t�t |�|�}d |||f S )
a�
format:
v0:
str(len(rawtext)) + ' ' + rawtext + ancestortext
v1:
'v1' + '
' + metalist + ' ' + rawtext + ancestortext
metalist := metalist + '
' + meta | meta
meta := sizemeta | flagmeta
sizemeta := METAKEYSIZE + str(len(rawtext))
flagmeta := METAKEYFLAG + str(flag)
note: sizemeta must exist. METAKEYFLAG and METAKEYSIZE must have a
length of 1.
r Tc S s g | ]}|�qS r r r r r r r! z r z"createfileblob.<locals>.<listcomp>r r s %s%s%s%s%s Fs %s %s%s)ZfilelogZfilerevZ_revlog�flags�dataZrawdatars rt �extend� ancestors�parentsr� r# �filenodeZrenamedr� r Zbuildfileblobheader)r� r� ZfrevZ revlogflagsr� r1 r� Z ancestortextZ ancestorctxr� Zp1Zp2Zcopyname�renameZlinknode�headerr r r r� [ sF
� r� c C s" |j �dd�sd S t� }|�d�}|j�d�}|D ]B}|| �� }t�|�D ]&\}}t j
�||t |��} |� | � qLq2|j �
dd�}
t�� |
d d d } | jtd�d d
�} | �d � t �|�D ]R\}
}}|D ]B}t j
�|
|�}| �� ||v r�q�t �|�}|j| k r�t �|� q�q�| �� d S ) Nrm rn s heads(tip~25000:) - nullr� s serverexpiration� �< s removing old server caches files)Zunitr )r5 ro �setZrevsZvfsrZ Zmanifestr
Z iteritemsrY rW r �addZ configint�timeZ makeprogressr �update�walkZ incrementrQ �st_mtime�removeZcomplete)r5 r1 Z neededfilesr� r� r� Zmf�filenamer� r� ZdaysZ
expirationZprogressr& �dirs�filesr� �filepathrQ r r r �gcserver� s0
r� )+Z
__future__r r� rY rQ r� r� Zmercurial.i18nr Zmercurial.noder r Zmercurial.pycompatr Z mercurialr r r r
r r r
r r r r r r r � r r Zsshv1protocolhandlerrq r6 rx r3 r� ry r{ rz r� r� r r r r �<module> s* @# "*%?