| 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
�+�bJ � @ s8 d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dl
m Z m Z d dl
mZ d dlmZmZmZmZ d dlmZ dd lmZ e�d
�ZdZd Z e Z d Z dZ d Z d
Z!dZ"ej#r�ej$s�dZ%ndZ%G dd� de&�Z'G dd� de&�Z(G dd� de&�Z)G dd� de)�Z*G dd� de)�Z+G dd � d e&�Z,dS ) � )�absolute_importN)�_)�getattr�open)�hex)�policy�pycompat�util�vfs)�hashutil� )� shallowutil�osutil� ���i g�������?s rbes rbc @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �_cachebackedpacksc C sJ t |�| _t�|�| _d | _ttt|t |����D ]}| �
|| � q2d S �N) �set�_packsr Z lrucachedict� _lrucache� _lastpack�reversed�range�min�len� _movetofront)�self�packsZ cachesize�i� r �B/usr/lib64/python3.9/site-packages/hgext/remotefilelog/basepack.py�__init__E s
z_cachebackedpacks.__init__c C s d| j |< d S )NT)r �r �packr r r r O s z _cachebackedpacks._movetofrontc C s | j d ur | �| j � d | _ d S r )r r �r r r r �_registerlastpackusageS s
z(_cachebackedpacks._registerlastpackusagec C s" | � � | �|� | j�|� d S r )r% r r �addr" r r r r& X s
z_cachebackedpacks.addc c sV | � � | jD ]}|| _|V qdd� | jD �}| j| D ]}|| _|V q:d | _d S )Nc S s h | ]}|�qS r r )�.0r# r r r � <setcomp>h � z-_cachebackedpacks.__iter__.<locals>.<setcomp>)r% r r r )r r# Z cachedpacksr r r �__iter__` s
z_cachebackedpacks.__iter__N)�__name__�
__module__� __qualname__r! r r% r& r* r r r r r D s
r c @ sb e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
ddd�Z dd� Z dd� Z
dS )�
basepackstore�d c C s� || _ || _d| _g }| �� D ]|\}}}z| �|�}W nX ty� } z@t|dd �tjkrn|� t
d�||f � W Y d }~q W Y d }~n
d }~0 0 |� |� q t || j
�| _d S )Nr �errnos unable to load pack %s: %s
)�ui�path� lastrefresh� _getavailablepackfilessorted�getpack� Exceptionr r0 �ENOENT�warnr �appendr �DEFAULTCACHESIZEr )r r1 r2 r �filepath�__r# �exr r r r! v s " zbasepackstore.__init__c
c s: t | j�}t | j�}t� }t�dd� �}t�dd� �}z�tj| jdd�D ]�\}}}d} || d� | jkrz|d| � } n"|| d� | jkr�|d| � } | rH|| |j 7 < || �
|j � | |v r�t j�
| j| �t|| �|| fV qH|�| � qHW n6 t�y4 }
z |
jtjk�r � W Y d}
~
n
d}
~
0 0 dS )z�For each pack file (a index/data file combo), yields:
(full path without extension, mtime, size)
mtime will be the mtime of the index/data file (whichever is newer)
size is the combined size of index/data file
c S s dS )Nr r r r r r �<lambda>� r) z6basepackstore._getavailablepackfiles.<locals>.<lambda>c S s g S r r r r r r r> � r) T)�statN)r � INDEXSUFFIX�
PACKSUFFIXr � collections� defaultdictr �listdirr2 �st_sizer9 �st_mtime�os�join�maxr& �OSErrorr0 r7 ) r ZindexsuffixlenZ
packsuffixlenZidsZsizesZmtimes�filename�typer? �idr= r r r �_getavailablepackfiles� s0
�z$basepackstore._getavailablepackfilesc c sT g }| � � D ]\}}}|�|||f� q t|dd�}|D ]\}}}|||fV q8dS )z�Like `_getavailablepackfiles`, but also sorts the files by mtime,
yielding newest files first.
This is desirable, since it is more likely newer packfiles have more
desirable data.
T)�reverseN)rN r9 �sorted)r �filesr2 �mtime�sizer r r r4 � s z*basepackstore._getavailablepackfilessortedc C s4 d}d}| � � D ]\}}}||7 }|d7 }q||fS )aL Returns the total disk size (in bytes) of all the pack files in
this store, and the count of pack files.
(This might be smaller than the total size of the ``self.path``
directory, since this only considers fuly-writen pack files, and not
temporary files or other detritus on the directory.)
r r )rN )r Z totalsize�countr< rS r r r �gettotalsizeandcount� s
z"basepackstore.gettotalsizeandcountc C s | � � \}}||d�S )z+Returns metrics on the state of this store.)s numpackss
totalpacksize)rU )r rS rT r r r �
getmetrics� s �zbasepackstore.getmetricsc C s
t � �d S r ��NotImplementedError)r r2 r r r r5 � s zbasepackstore.getpackc C sF |}| j D ]}|�|�}|s
| S q
|rB| �� D ]}|�|�}q2|S r )r �
getmissing�refresh)r �keys�missingr# r r r rY � s
zbasepackstore.getmissingNc C s | j D ]}|�|� qd S r )r �
markledger)r �ledger�optionsr# r r r r] � s
zbasepackstore.markledgerc C s
d| _ dS )z~Tells the store that there may be new pack files, so the next time it
has a lookup miss it should check for new files.r N)r3 r$ r r r �markforrefresh� s z basepackstore.markforrefreshc C sp t � � }g }|| jt krl|| _dd� | jD �}| �� D ]2\}}}||vr8| �|�}|�|� | j�|� q8|S )ztChecks for any new packs on disk, adds them to the main pack list,
and returns a list of just the new packs.c S s h | ]
}|j �qS r )r2 )r' �pr r r r( r) z(basepackstore.refresh.<locals>.<setcomp>)�timer3 � REFRESHRATEr r4 r5 r9 r& )r ZnowZnewpacksZpreviousr; r< Znewpackr r r rZ � s
zbasepackstore.refresh)N)r+ r, r- r: r! rN r4 rU rV r5 rY r] r` rZ r r r r r. r s '
r. c @ s e Zd ZdZdgZdd� ZdS )� versionmixinNr c C sD || j v r4| jd u r || _q@| j|kr@td| ��n td| ��d S )Ns inconsistent version: %ds unsupported version: %d)�SUPPORTED_VERSIONS�VERSION� RuntimeError)r �versionr r r �
_checkversion s
zversionmixin._checkversion)r+ r, r- rf re ri r r r r rd s rd c @ sl e Zd ZdZdgZdd� Zejdd� �Zejdd� �Z d d
� Z
d d � Z ddd�Z dd� Z
dd� Zdd� Zd
S )�basepacki @r c C s� || _ || j | _|| j | _t�| j�j| _t�| j�j| _ d | _
d | _ | � � t
�d| j d t� �d }| �|� t
�d| j
d t� �\}}| �|� d|@ r�tt|�| _n tt|�| _d S )N� !Br � !BB� )r2 rA �packpathr@ � indexpathrG r? rE Z indexsizeZdatasize�_index�_data�
freememory�struct�unpack�PACKVERSIONSIZEri �INDEXVERSIONSIZE� indexparams�LARGEFANOUTPREFIX�params�SMALLFANOUTPREFIX)r r2 rh �configr r r r! ' s
zbasepack.__init__c C sd | j }| jtt|j � }g }t�d|j�D ]2}|d }t�d|||d � �d }|� |� q,|S )Nr � � !I)
ry rp � FANOUTSTART�
fanoutsizer Zxrange� fanoutcountrs rt r9 )r ry Z rawfanout� fanouttabler �locZ fanoutentryr r r � _fanouttable> s zbasepack._fanouttablec C s. t �d| j| jjd �d }| jj|| j S )N� !Q� r )rs � unpack_fromrp ry �
indexstart�INDEXENTRYLENGTH)r Z nodecountr r r � _indexendI s ��zbasepack._indexendc C s� | j r*| j| jk rdS | j �� | j�� t| jt��(}tj|� � dtj
d�| _ W d � n1 sd0 Y t| j t��(}tj|� � dtj
d�| _W d � n1 s�0 Y d| _dS )z�Unmap and remap the memory to free it up after known expensive
operations. Return True if self._data and self._index were reloaded.
Fr )�accessNT) rp Z_pagedin�
MAXPAGEDIN�closerq r ro � PACKOPENMODE�mmap�filenoZ ACCESS_READrn )r ZindexfpZdatafpr r r rr P s
�&6zbasepack.freememoryc C s
t � �d S r rW )r r[ r r r rY g s zbasepack.getmissingNc C s
t � �d S r rW )r r^ r_ r r r r] j s zbasepack.markledgerc C s
t � �d S r rW )r r^ r r r �cleanupm s zbasepack.cleanupc C s
t � �d S r rW r$ r r r r* p s zbasepack.__iter__c C s
t � �d S r rW r$ r r r � iterentriess s zbasepack.iterentries)N)r+ r, r- r� re r! r Z
propertycacher� r� rr rY r] r� r* r� r r r r rj s
rj c @ s` e Zd Zddd�Zdd� Zdd� Zdd � Zd
d � Zdd
d�Zdd� Z dd� Z
dd� Z dd� Z d S )�mutablebasepackr c C s� | � |� d| _t�|�}d|_|| _i | _t�||� |j | j
d d�\| _ | _ |j | j
d d�\| _| _t�| j d�| _ t�| jd�| _t�� | _d| _|�|�| j �� |�|�| j�� t�d| j�}| �|� d S )Ns GZi$ s -tmp)�suffixzwb+Frk ) ri � _compressor�vfsmodr
Z
createmode�opener�entriesr
ZmkstickygroupdirZmkstemprA �packfprn r@ �idxfp�idxpathrG �fdopenr Zsha1�sha�_closedZ _fixfilemoderH rs r# rf �writeraw)r r1 Zpackdirrh r� Z
versionbufr r r r! x s*
��
zmutablebasepack.__init__c C s | S r r r$ r r r � __enter__� s zmutablebasepack.__enter__c C s |d u r| � � n| �� d S r )r� �abort)r �exc_type� exc_value� tracebackr r r �__exit__� s
zmutablebasepack.__exit__c C s | � � d S r )�_cleantemppacksr$ r r r r� � s zmutablebasepack.abortc C s | j �|� | j�|� d S r )r� �writer� �update)r �datar r r r� � s zmutablebasepack.writerawNc C s | j r
d S z�t| j�� �}| j�� | �� t| j�dkrN| � � d| _ W d S | j
� | j || j
� z| j
� | j|| j � W nR ty� } z:z| j
�|| j
� W n ty� Y n0 |�W Y d }~n
d }~0 0 W n ty� | � � � Y n0 d| _ | j
�|�}|�r|�|� |S )Nr T)r� r r� �digestr� r� �
writeindexr r� r� r� �renamern rA r� r@ r6 �unlinkrH Z
addcreated)r r^ r� r= �resultr r r r� � s6
zmutablebasepack.closec C sP z| j �| j� W n ty$ Y n0 z| j �| j� W n tyJ Y n0 d S r )r� r� rn r6 r� r$ r r r r� � s z mutablebasepack._cleantemppacksc C s2 t | j�tk}|r tt| j�}n tt| j�}tg|j }i }d}t | j�D ]N}|| j
}|||< |d7 }t � |j
|d |j� �d }|| tkrJ|||< qJd} d}
|D ](} | tkr�| n|
} | }
| t �d| �7 } q�t �dt | j��} | �|dt | � �}
| �|� | j�| � | j�| � | j�|
� | j�� d S )Nr r r) r} r� r )r r� �SMALLFANOUTCUTOFFrw rx rf rz � EMPTYFANOUTr� rP r� rs rt � fanoutstruct� fanoutprefixr# � createindex� _writeheaderr� r� r� )r Z largefanoutry r� Z locationsrT Znode�locationZ fanoutkeyZrawfanouttableZlast�offsetZrawentrieslengthZrawindexr r r r� � s>
��
zmutablebasepack.writeindexc C s
t � �d S r rW )r Z
nodelocationsr r r r� s zmutablebasepack.createindexc C s. d}|j tkrd}| j�t�d| j|�� d S )Nr rm rl )r� rx r� r� rs r# rf )r rw r{ r r r r� s
z mutablebasepack._writeheader)r )N)
r+ r, r- r! r� r� r� r� r� r� r� r� r� r r r r r� w s
"
%
+r� c @ s e Zd ZdZdd� ZdS )rw )r� r� r� r r� c C sj || _ |tkrd| _n |tkr&d| _n td| ��d|d | _| jd | _t| j | _| jd7 _d S )Nrk s !Hs invalid fanout prefix size: %sr r� r| ) r� rz r� rx �
ValueErrorr� r r~ r� )r Z
prefixsizerh r r r r! s zindexparams.__init__N)r+ r, r- � __slots__r! r r r r rw s rw )-Z
__future__r rB r0 r� rG rs rb Zmercurial.i18nr Zmercurial.pycompatr r Zmercurial.noder Z mercurialr r r r
r� Zmercurial.utilsr � r
Z importmodr ru rv r~ r� rz rx r� rc ZisposixZispy3r� �objectr r. rd rj r� rw r r r r �<module> s@
. W