Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
hgext
/
narrow
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: narrowwirepeer.cpython-310.pyc
o �]LbU � @ st d dl mZ d dlmZmZmZmZmZmZm Z m Z ddl m Z dd� Z dd� Ze jd d d d �d d� �Zdd� ZdS )� )�absolute_import)�bundle2�error� extensions�hg� narrowspec�wireprototypes�wireprotov1peer�wireprotov1server� )� narrowbundle2c C s t tj_d S )N)�peernarrowwidenr �wirepeer� narrow_widen� r r �=/usr/lib/python3/dist-packages/hgext/narrow/narrowwirepeer.py�uisetup s r c s � fdd�}t j�|� d S )Nc s � fdd�}t �|d|� d S )Nc sD |dkr� j \}}d�|�|d< d�|�|d< | |g|�R i |��S )Ns unbundle� ,� includepats� excludepats)� narrowpats�join)�orig�cmd�args�kwargs�include�exclude��repor r �wrapped s z1reposetup.<locals>.wirereposetup.<locals>.wrappeds _calltwowaystream)r � wrapfunction)�ui�peerr r r r � wirereposetup s z reposetup.<locals>.wirereposetup)r �wirepeersetupfuncs�append)r r$ r r r � reposetup s r' � narrow_widensT oldincludes oldexcludes newincludes newexcludes commonheads cgversion known ellipsess pull)� permissionc C s� d} z{dd� } | |�}| |�}| |�}| |�}t �t|�� t �t|�� t �t|�� t �t|�� t�|�} t�|�}| dkrDd} nt| �} |}t�| j�} t j | j ||d�}t j | j ||d�}| sqt� | | ||| ||| � n t � | | |||| |� W n: tjy� } z-t�| j�} d|jfg}g }|jdur�|�d|jf� | �t�d ||�� d } W Y d}~nd}~ww | �� }tj|| d �S ) a� wireprotocol command to send data when a narrow clone is widen. We will be sending a changegroup here. The current set of arguments which are required: oldincludes: the old includes of the narrow copy oldexcludes: the old excludes of the narrow copy newincludes: the new includes of the narrow copy newexcludes: the new excludes of the narrow copy commonheads: list of heads which are common between the server and client cgversion(maybe): the changegroup version to produce known: list of nodes which are known on the client (used in ellipses cases) ellipses: whether to send ellipses data or not Fc S s | r| � d�S g S )Nr )�split)�datar r r � splitpathsQ s z narrow_widen.<locals>.splitpaths� 0)r r s messageNs hints error:abortT)�gen�prefer_uncompressed)r �validatepatterns�setr � decodelist�boolr �bundle20r" �match�root� widen_bundler �&generate_ellipses_bundle2_for_wideningr �Abort�message�hintr& �addpart� bundlepart� getchunks� streamres)r �proto� oldincludes� oldexcludes� newincludes� newexcludes� commonheads� cgversion�known�ellipses�preferuncompressedr, �common�bundler�newmatch�oldmatch�exc�manargs�advargs�chunksr r r r , sv " ��� �� �� �r c K sj dD ] }t �|| �||< qdD ] }d�|| �||< qdt|d � |d< | jdi |��}t�| j|�S )N)rE rG )rA rC rB rD r s %irH r( )r( )r � encodelistr r3 �_callcompressabler � getunbundlerr" )�remoter �ch�fr r r r � s r N)� __future__r � mercurialr r r r r r r r � r r r' �wireprotocommandr r r r r r �<module> s ( � ^
Save
Cancel