| 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� � @ sd d dl mZ d dlmZmZ ddlmZmZ G dd� dej�Z G dd� dej�Z
G d d
� d
e �Z d S ) � )�absolute_import)�hex�sha1nodeconstants� )� basestore� shallowutilc sj e Zd Z� fdd�Zddd�Zejjddd��Zejjdd � �Z d
d � Z
d d
� Z ddd�Z dd� Z
� ZS )�unionmetadatastorec s: t t| �j|i |�� || _|�d�| _|�dd�| _d S )N�
writestore�allowincompleteF)�superr �__init__�stores�getr r
)�self�args�kwargs�� __class__� �G/usr/lib64/python3.9/site-packages/hgext/remotefilelog/metadatastore.pyr s zunionmetadatastore.__init__Nc s� �du rt � �|�v rg S i � � �fdd�}||fg}|r�|�� \}}z.� �| j||�d�� |||�}|�|� W q6 ty� | js�� ||f||fkr�� Y q60 q6� S )��Returns as many ancestors as we're aware of.
return value: {
node: (p1, p2, linknode, copyfrom),
...
}
Nc s� | |fg}g }t � }|r�|�� \}}||f|v r2q|�||f� � �|�}|s^|�||f� q|\}} }
} |tjkr�|�vr�|�| p�| |f� | tjkr| �vr|�| | f� q|S �N)�set�pop�addr �appendr Znullid) �curname�curnodeZqueue�missing�seen�name�node�valueZp1Zp2�linknodeZcopyfrom�� ancestors�knownr r �traverse( s$
z1unionmetadatastore.getancestors.<locals>.traverse�r& )r r �update�_getpartialancestors�extend�KeyErrorr
) r r r! r& r' r r r Z
newmissingr r$ r � getancestors s*
�
z unionmetadatastore.getancestorsc C sJ | j D ].}z|j|||d�W S ty2 Y q0 qt|t|�f��d S )Nr( )r
r- r, r )r r r! r& �storer r r r* S s
z'unionmetadatastore._getpartialancestorsc C sF | j D ]*}z|�||�W S ty. Y q0 qt|t|�f��d S r )r
� getnodeinfor, r )r r r! r. r r r r/ ] s
z unionmetadatastore.getnodeinfoc C s t d��d S )Ns5 cannot add content only to remotefilelog contentstore�� RuntimeError�r r r! �datar r r r g s �zunionmetadatastore.addc C s" |}| j D ]}|r
|�|�}q
|S r )r
�
getmissing)r �keysr r. r r r r4 l s
z unionmetadatastore.getmissingc C s | j D ]}|�||� qd S r )r
�
markledger)r �ledger�optionsr. r r r r6 s s
z unionmetadatastore.markledgerc C s dd� | j D �}tj|� S )Nc S s g | ] }|� � �qS r )�
getmetrics)�.0�sr r r �
<listcomp>x � z1unionmetadatastore.getmetrics.<locals>.<listcomp>)r
r Zsumdicts)r Zmetricsr r r r9 w s z unionmetadatastore.getmetrics)N)N)N)�__name__�
__module__� __qualname__r r- r �baseunionstoreZ retriabler* r/ r r4 r6 r9 �
__classcell__r r r r r
s
:
r c @ s& e Zd Zddd�Zdd� Zdd� ZdS ) �remotefilelogmetadatastoreNc C s | � ||�}t�|�}|S )r )Z_getdatar Z ancestormap)r r r! r& r3 r% r r r r- } s
z'remotefilelogmetadatastore.getancestorsc C s | � ||�| S r �r- �r r r! r r r r/ � s z&remotefilelogmetadatastore.getnodeinfoc C s t d��d S )Ns7 cannot add metadata only to remotefilelog metadatastorer0 )r r r! �parentsr# r r r r � s �z remotefilelogmetadatastore.add)N)r> r? r@ r- r/ r r r r r rC | s
rC c @ s@ e Zd Zdd� Zddd�Zdd� Zdd � Zd
d � Zdd d
�ZdS )�remotemetadatastorec C s || _ || _d S r )� _fileservice�_shared)r ZuiZ fileserviceZsharedr r r r � s z remotemetadatastore.__init__Nc C s0 | j j|t|�fgdddd� | jj|||d�S )NTF)�forceZ fetchdataZ fetchhistoryr( )rH Zprefetchr rI r- )r r r! r& r r r r- � s �z remotemetadatastore.getancestorsc C s | � ||�| S r rD rE r r r r/ � s z remotemetadatastore.getnodeinfoc C s t d��d S )Ns cannot add to a remote storer0 r2 r r r r � s zremotemetadatastore.addc C s |S r r )r r5 r r r r4 � s z remotemetadatastore.getmissingc C s d S r r )r r7 r8 r r r r6 � s z remotemetadatastore.markledger)N)N) r> r? r@ r r- r/ r r4 r6 r r r r rG � s
rG N)
Z
__future__r Zmercurial.noder r � r r rA r rC �objectrG r r r r �<module> s
o