403Webshell
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 :
current_dir [ Writeable] document_root [ Writeable]

 

Command :


[ Back ]     

Current File : /lib64/python3.9/site-packages/hgext/remotefilelog/__pycache__/shallowrepo.cpython-39.opt-1.pyc
a

�+�b	/�@s�ddlmZddlZddlmZddlmZmZddlm	Z	m
Z
mZmZm
Z
mZmZmZddlmZddlmZmZmZmZmZmZmZmZmZmZd	d
�Zdd�Zd
d�Z dd�Z!dd�Z"dd�Z#dS)�)�absolute_importN)�_)�hex�nullrev)�encoding�error�	localrepo�match�pycompat�scmutil�sparse�util)�procutil�)
�connectionpool�	constants�contentstore�datapack�fileserverclient�historypack�
metadatastore�
remotefilectx�
remotefilelog�shallowutilcCsZtj�|jjjd�}tj�|�s*t�|�tj	|||j
dd�}tj|||j
dd�}||fS)z:In-repo stores, like .hg/store/data; can not be discarded.sdataF�Zshared)
�os�path�join�svfsZvfs�base�exists�makedirsr�remotefilelogcontentstore�namer�remotefilelogmetadatastore)�repoZ	localpath�localcontent�
localmetadata�r(�E/usr/lib64/python3.9/site-packages/hgext/remotefilelog/shallowrepo.py�makelocalstores's

�
�r*cCsZt�|j�}tj|||jdd�}tj|||jdd�}||_|j	�
|�|j�
|�||fS)z?Typically machine-wide, cache of remote data; can be discarded.Tr)rZgetcachepath�uirr"r#rr$Zsharedstore�shareddatastores�append�sharedhistorystores)r%Z	cachepath�cachecontent�
cachemetadatar(r(r)�makecachestores7s
�
�r1cCs8t�|�|_t�|j|j|�}t�|j|j|�}||fS)z-These stores fetch data from a remote server.)r�fileservicerZremotecontentstorer+rZremotemetadatastore)r%r/r0�
remotecontent�remotemetadatar(r(r)�makeremotestoresIs
�
�r5cCs\t�|tj�}t�|j|�}t�|j|�}|j	�
|�|j�
|�t�|jd||�||fS)z5Packs are more efficient (to read from) cache stores.�	filestore)
rZgetcachepackpathrZFILEPACK_CATEGORYrZ
datapackstorer+rZhistorypackstorer,r-r.�reportpackmetrics)r%Zpackpath�packcontentstore�packmetadatastorer(r(r)�makepackstoresVs
�r:cCs�g|_g|_t|�\}}t|�\}}t|�\}}t|||�\}}tj|||||d�|_tj	|||||d�|_|}	|}
|j
�|j|j|	|
�t�
|jd||�dS)zBUnion stores iterate the other stores and return the first result.)Z
writestorer6N)r,r.r:r1r*r5rZunioncontentstorerZunionmetadatastorer2Zsetstorerr7r+)r%r8r9r/r0r&r'r3r4ZfileservicedatawriteZfileservicehistorywriter(r(r)�makeunionstoresesB����
�r;cs�G��fdd�d�j����_t���_t���j�ddd��_�j�ddd��_t	�
�d�slt����_�jsx�jr�t��jdd�j�j��_dS)Ncs�eZdZejdd��Zej�fdd��Z�fdd�Z��fdd�Z��fd	d
�Z	e
jd��fd
d�	�Zd�fdd�	Z
d�fdd�	Zd�fdd�	Z��fdd�Z�ZS)z#wraprepo.<locals>.shallowrepositorycSs|j�dd�S)N�
remotefilelogsreponame)r+�config��selfr(r(r)r#�sz(wraprepo.<locals>.shallowrepository.namecs,�j�dd�j�dd��}|s(t�d��|S)Nr<sfallbackpathspathssdefaults>no remotefilelog server configured - is your .hg/hgrc trusted?)r+r=rZAbort)r?r�r%r(r)�fallbackpath�s��z0wraprepo.<locals>.shallowrepository.fallbackpathcs.|rtj�|d�}n
t���}|��r*dS|S)z�
            A wrapper that allows the remotefilelog to invoke sparsematch() if
            this is a sparse repository, or returns None if this is not a
            sparse repository.
            )�revsN)rZmatcher�always)r?rB�kwargs�retr@r(r)�maybesparsematch�s
z4wraprepo.<locals>.shallowrepository.maybesparsematchcsF|ddkr|dd�}|�|�r2t�|j||�St�|��|�SdS)Nr�/r)�shallowmatchrr�super�file)r?�f��	__class__�shallowrepositoryr(r)rJ�s

z(wraprepo.<locals>.shallowrepository.filecsF|�|�r$tj||g|�Ri|��St�|�j|g|�Ri|��SdS�N)rHrrI�filectx)r?r�argsrDrLr(r)rP�s

���z+wraprepo.<locals>.shallowrepository.filectxFNcsz|��sd|����}g}|��|��D].}|�||j�}||jkr(|�|t|�f�q(|j	�
|�t�|�j|||d�S)z{Add a new revision to current repository.
            Revision information is passed via the context argument.
            )r�origctx)
�manifestnode�p1ZmanifestZmodifiedZadded�getZnullidr-rr2�prefetchrI�	commitctx)r?�ctxrrRZm1�filesrKZfparent1rLr(r)rW�s	

�z-wraprepo.<locals>.shallowrepository.commitctxcslt��d�jdg}|r |�d�|r0|d|g7}i}�j�dd�rN�jj|d<tj|tj	fdd	i|��d
S)z0Runs prefetch in background with optional repacks-Rsprefetchs--repacks-rsdevelsremotefilelog.bg-waitZrecord_waitZensurestartFN)
rZhgexecutable�origrootr-r+Z
configbool�atexitZrunbgcommandr�environ)r?rBrZrepack�pats�opts�cmdrDr@r(r)�backgroundprefetch�s
���z6wraprepo.<locals>.shallowrepository.backgroundprefetchc	sT���jddddtd��j�� |�||||�Wd�n1sF0YdS)z|Prefetches all the necessary file revisions for the given revs
            Optionally runs repack in background
            sprefetchlockTNsprefetching in %s)�_lockrrrZ�	_prefetch)r?rBrr]r^r@r(r)rV�s�z,wraprepo.<locals>.shallowrepository.prefetchcs"|j}|rF��d|�}|durJ|tkrJt��d||��}|rJ|d}n�}�j}|�d�}	|dur�|�|����}
tt	�
|
��}nt�}|��}|��}
t�}|�t�t
|�}|jjtd�|d�}|�d�t|�D]�}�|}|r�t�|||����|��|��}|	�|�}|	�|�\}}||v�rD||v�rD||��}
n||��}
t	�
|
�}|�rr�fdd�|D�}��r��fd	d�|D�}||v�r�|
�|�n
|�|�|�|�|��q�|�|�|
�|�|��|
�r�d
d�|
D�}�jj|dd
�|�rdd�|D�}�j�|�dS)Nsoutgoing(%s)sfirst(reverse(::%s) - %ld)r�sprefetching)�totalc3s|]}�|d�r|VqdS�rNr(��.0Zpf)�mr(r)�	<genexpr>0rcz@wraprepo.<locals>.shallowrepository._prefetch.<locals>.<genexpr>c3s|]}�|d�r|VqdSrer(rf)�sparsematchr(r)ri2rccSsg|]\}}|t|�f�qSr(�r�rgrZfnoder(r(r)�
<listcomp>ArczAwraprepo.<locals>.shallowrepository._prefetch.<locals>.<listcomp>T)�forcecSsg|]\}}|t|�f�qSr(rkrlr(r(r)rmFrc)rArBr�listZmanifestlogZ
getstoragerS�read�setr
Z	iteritems�copy�add�lenr+Zmakeprogressr�update�sortedrr	rF�revZ
parentrevsZreadfastZ	increment�difference_updateZcompleter2rV)r?rBrr]r^rAZ	localrevsZ
serverbaseZmflZmfrevlogZmfdict�skiprYZserverfilesZvisitedZrevcountZprogressrwrXZmfnodeZmfrevrTZp2�diff�resultsr@)rhrjr)rb�sn��












z-wraprepo.<locals>.shallowrepository._prefetchcst�|���|j��dSrO)rI�closerr>rLr(r)r|Isz)wraprepo.<locals>.shallowrepository.close)FN)NFNN)NNN)NNN)�__name__�
__module__�__qualname__r
Z
propertycacher#rArFrJrPrZunfilteredmethodrWr`rVrbr|�
__classcell__r(�r%rN)rMr)rN�s
	�OrNr<sincludepatternsexcludepatternrrc)
rMr	rCrHr;r+Z
configlistZincludepatternZexcludepatternr
Zsafehasattrr�rootr@r(r�r)�wraprepo�s"?
���r�)$Z
__future__rrZmercurial.i18nrZmercurial.noderrZ	mercurialrrrr	r
rrr
Zmercurial.utilsr�rrrrrrrrrrr*r1r5r:r;r�r(r(r(r)�<module>s(
0
)

Youez - 2016 - github.com/yon3zu
LinuXploit