Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
mercurial
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: store.cpython-310.pyc
o �]Lbe � @ s. d dl mZ d dlZd dlZd dlZd dlZd dlZddlmZ ddl m Z ddl m Z ddl mZmZmZmZm Z mZmZ ddlmZ e�d �Zd Zd d � Zd d� Ze ede�Z dd� Z dd� Z dd� Z e � \Z Z!dd� Z"dd� Z#dd� Z$e ed d�p~e$� Z%d Z&d Z'd d � Z(d!Z)d"Z*d"e*d d# Z+d$d%� Z,d&d'� Z-d(d)� Z.e ed*e.�Z.d+d,� Z/d-d.� Z0g d/�Z1d0Z2d1Z3d2Z4e�5d3�Z6d4d5� Z7d6d7� Z8d8Z9d9Z:d:Z;d;Z<d<Z=dZ>d=Z?e9e=B Z@e9e>B ZAe:e=B ZBe:e>B ZCe;e=B ZDe;e>B ZEe<ZFG d>d?� d?eG�ZHG d@dA� dAeH�ZIG dBdC� dCeG�ZJG dDdE� dEejK�ZLG dFdG� dGeH�ZMdS )H� )�absolute_importN� )�_)�getattr)�hex)� changelog�error�manifest�policy�pycompat�util�vfs)�hashutil�parsersi@B c C sl |du rdS t | �} | �d�r || td�td� � �S | �d�r/|�| td�td� � �S t�d| ��)z�parses a fncache entry and returns whether the entry is tracking a path matched by matcher or not. If matcher is None, returns TrueNT� data/� .i� meta/s /00manifest.is cannot decode path %s)� decodedir� startswith�len�visitdirr �ProgrammingError)�path�matcher� r �1/usr/lib/python3/dist-packages/mercurial/store.py�_matchtrackedpath$ s r c C s | � dd�� dd�� dd�S )aM >>> _encodedir(b'data/foo.i') 'data/foo.i' >>> _encodedir(b'data/foo.i/bla.i') 'data/foo.i.hg/bla.i' >>> _encodedir(b'data/foo.i.hg/bla.i') 'data/foo.i.hg.hg/bla.i' >>> _encodedir(b'data/foo.i\ndata/foo.i/bla.i\ndata/foo.i.hg/bla.i\n') 'data/foo.i\ndata/foo.i.hg/bla.i\ndata/foo.i.hg.hg/bla.i\n' � .hg/� .hg.hg/� .i/� .i.hg/� .d/� .d.hg/��replace�r r r r � _encodedir7 s �r& � encodedirc C s( d| vr| S | � dd�� dd�� dd�S )z� >>> decodedir(b'data/foo.i') 'data/foo.i' >>> decodedir(b'data/foo.i.hg/bla.i') 'data/foo.i/bla.i' >>> decodedir(b'data/foo.i.hg.hg/bla.i') 'data/foo.i.hg/bla.i' r r" r! r r r r# r% r r r r L s �r c c sN � dd� dD �} t d�D ]}|V q t dd�D ]}|V q| D ]}|V q dS )z�characters that are problematic for filesystems * ascii escapes (0..31) * ascii hi (126..255) * windows specials these characters will be escaped by encodefunctions c S s g | ]}t |��qS r )�ord��.0�xr r r � <listcomp>g � z _reserved.<locals>.<listcomp>z\:*?"<>|� �~ � N)�range)� winreservedr+ r r r � _reserved^ s � �r3 c s� d} t j}tt|td���}tttd�td�d ��}dd� |D �� t� D ] }d| � ||�< q%|t| �g D ]}| ||��� � ||�< q7i �t �� �D ]\}}|�|< qM�fd d ��� fd d ��fd d �fS )a� >>> enc, dec = _buildencodefun() >>> enc(b'nothing/special.txt') 'nothing/special.txt' >>> dec(b'nothing/special.txt') 'nothing/special.txt' >>> enc(b'HELLO') '_h_e_l_l_o' >>> dec(b'_h_e_l_l_o') 'HELLO' >>> enc(b'hello:world?') 'hello~3aworld~3f' >>> dec(b'hello~3aworld~3f') 'hello:world?' >>> enc(b'the\x07quick\xADshot') 'the~07quick~adshot' >>> dec(b'the~07quick~adshot') 'the\x07quick\xadshot' � _� � A� Zr c S s i | ]}||�qS r r r) r r r � <dictcomp>� � z#_buildencodefun.<locals>.<dictcomp>� ~%02xc 3 sr � d}|t | �k r7t�dd�D ] }z� | ||| � V ||7 }W n ty, Y qw t�|t | �k s d S d S )Nr r � )r r �xrange�KeyError)�s�i�l)�dmapr r �decode� s � ��z _buildencodefun.<locals>.decodec s$ d� �� fdd�t�t� ��D ��S )N� c s g | ] }� �||d � �qS )r r �r* �c)�cmapr> r r r, � s z5_buildencodefun.<locals>.<lambda>.<locals>.<listcomp>)�joinr r< r �r> �rF rH r �<lambda>� s �z!_buildencodefun.<locals>.<lambda>c s d� t� | ���S )NrC )rG �listrH )rB r r rJ � r9 ) r �bytechrrK �mapr1 r( r3 �lower� iteritems)�e�xchr�asciistr�capitalsr+ �k�vr )rF rB rA r �_buildencodefunp s �rV c C � t t| ��S )z~ >>> encodefilename(b'foo.i/bar.d/bla.hg/hi:world?/HELLO') 'foo.i.hg/bar.d.hg/bla.hg.hg/hi~3aworld~3f/_h_e_l_l_o' )� _encodefnamer' rH r r r �encodefilename� � rY c C rW )z~ >>> decodefilename(b'foo.i.hg/bar.d.hg/bla.hg.hg/hi~3aworld~3f/_h_e_l_l_o') 'foo.i/bar.d/bla.hg/hi:world?/HELLO' )r � _decodefnamerH r r r �decodefilename� rZ r\ c sz t j��fdd�t �d�D �� t� D ] } d| � �| �< qttd�td�d �D ] } �| ��� � �| �< q(� fdd �}|S ) z� >>> f = _buildlowerencodefun() >>> f(b'nothing/special.txt') 'nothing/special.txt' >>> f(b'HELLO') 'hello' >>> f(b'hello:world?') 'hello~3aworld~3f' >>> f(b'the\x07quick\xADshot') 'the~07quick~adshot' c s i | ] }� |�� |��qS r r r) )rQ r r r8 � s z(_buildlowerencodefun.<locals>.<dictcomp>r5 r: r6 r7 r c s d� � fdd�t�| �D ��S )NrC c s g | ]}� | �qS r r rD rI r r r, � r- z=_buildlowerencodefun.<locals>.lowerencode.<locals>.<listcomp>)rG r � iterbytestrrH rI r r � lowerencode� s z)_buildlowerencodefun.<locals>.lowerencode)r rL r< r3 r1 r( rN )r+ r^ r )rF rQ r �_buildlowerencodefun� s r_ r^ )s auxs cons prns nul)s coms lptc C s( t | �D ]�\}}|s q|r(|d dv r(dt|dd� � |dd� }|| |< nQ|�d�}|dkr5t|�}|dkrA|dd� tv s]|d kry|dd � d kry|dd � d kry|dd� tv rydt|d d� � }|dd � | |dd� }|| |< |d dv r�|dd� dt|dd� � | |< q| S ) a� Encodes filenames containing names reserved by Windows or which end in period or space. Does not touch other single reserved characters c. Specifically, c in '\:*?"<>|' or ord(c) <= 31 are *not* encoded here. Additionally encodes space or period at the beginning, if dotencode is True. Parameter path is assumed to be all lowercase. A segment only needs encoding if a reserved name appears as a basename (e.g. "aux", "aux.foo"). A directory or file named "foo.aux" doesn't need encoding. >>> s = b'.foo/aux.txt/txt.aux/con/prn/nul/foo.' >>> _auxencode(s.split(b'/'), True) ['~2efoo', 'au~78.txt', 'txt.aux', 'co~6e', 'pr~6e', 'nu~6c', 'foo~2e'] >>> s = b'.com1com2/lpt9.lpt4.lpt1/conprn/com0/lpt0/foo.' >>> _auxencode(s.split(b'/'), False) ['.com1com2', 'lp~749.lpt4.lpt1', 'conprn', 'com0', 'lpt0', 'foo~2e'] >>> _auxencode([b'foo. '], True) ['foo.~20'] >>> _auxencode([b' .foo'], True) ['~20.foo'] r � . r: r N� .���� r; � 9� 1� )� enumerater( �findr �_winres3�_winres4)r � dotencoder? �nr@ �ecr r r � _auxencode� s* $�rn �x � r; c C s. t t�| ��� �}t| dd � ��d�}t||�}|d }tj� |�\}}g }d} |d d� D ]4} | d t � } | d dv rE| d d� d } | dkrNt | �} n| d t | � } | t kr\ n|� | � | } q/d�|�} t | �dkrs| d7 } d| | | }tt |� }|dkr�|d |� }d| | | | }|S ) N� � /rb r r` r4 r s dh/)r r �sha1�digestr^ �splitrn �osr �splitext� _dirprefixlenr �_maxshortdirslen�appendrG �_maxstorepathlen)r rk rt �le�parts�basename�_root�ext�sdirs�sdirslen�p�d�t�dirs�res� spaceleft�fillerr r r � _hashencode s6 r� c C s@ t | �} t| ��d�}d�t||��}t|�tkr t| |�}|S )ae encodes path with a length limit Encodes all paths that begin with 'data/', according to the following. Default encoding (reversible): Encodes all uppercase letters 'X' as '_x'. All reserved or illegal characters are encoded as '~xx', where xx is the two digit hex code of the character (see encodefilename). Relevant path components consisting of Windows reserved filenames are masked by encoding the third character ('aux' -> 'au~78', see _auxencode). Hashed encoding (not reversible): If the default-encoded path is longer than _maxstorepathlen, a non-reversible hybrid hashing of the path is done instead. This encoding uses up to _dirprefixlen characters of all directory levels of the lowerencoded path, but not more levels than can fit into _maxshortdirslen. Then follows the filler followed by the sha digest of the full path. The filler is the beginning of the basename of the lowerencoded path (the basename is everything after the last path separator). The filler is as long as possible, filling in characters from the basename until the encoded path has _maxstorepathlen characters (or all chars of the basename have been taken). The extension (e.g. '.i' or '.d') is preserved. The string 'data/' at the beginning is replaced with 'dh/', if the hashed encoding was used. rr )r' rX ru rG rn r r{ r� )r rk �efr� r r r � _hybridencode4 s r� c C sV t | �}t| �tkrt|d�S t|��d�}d�t|d��}t|�tkr)t|d�S |S )NTrr )r' r r{ r� rX ru rG rn )r �der� r� r r r � _pathencode[ s r� � pathencodec C s t | d�S �NF)r� )�fr r r �_plainhybridencodei s r� c C sH z| � � j}dtj @ d|@ krd }W |S W |S ty# d }Y |S w )Ni� )�stat�st_moder �umask�OSError)r �moder r r � _calcmodem s � ��r� ) � bookmarks� narrowspec� data� meta� 00manifest.d� 00manifest.i� 00changelog.d� 00changelog.i� phaseroots� obsstore� requires)r s i.tmpcensored)s .idxs .ds .dat� .n� .nds .sdas d.tmpcensored)r� r� s .*undo\.[^/]+\.(nd?|i)$c C s |t jkrd S t| �S �N)r� �S_IFREG� revlog_type)r� �kind�str r r � is_revlog� s r� c C s6 | � t�rtS | � t�rt}| � t�r|tO }|S d S r� )�endswith�REVLOG_FILES_MAIN_EXT�FILEFLAGS_REVLOG_MAIN�REVLOG_FILES_OTHER_EXT�FILETYPE_FILELOG_OTHER�REVLOG_FILES_VOLATILE_EXT�FILEFLAGS_VOLATILE)r� r� r r r r� � s r� i i i i rf i c @ s~ e Zd ZdZdd� Zdd� Zdd� Zd d d �Zd d � Zd d d�Z dd� Z d dd�Z dd� Z dd� Z dd� Zdd� Zdd � ZdS ) � basicstorez&base class for local repository storesc C sB ||�}|j | _t|�| _| j|_|| _t�|t�| _| j| _ d S r� ) �baser r� � createmode�rawvfs�vfsmod� filtervfsr' r �opener��selfr �vfstyper r r r �__init__� s zbasicstore.__init__c C � | j d t|� S �Nrr )r r' �r� r� r r r rG � � zbasicstore.joinc C s� | j }|r |d| 7 }t| j �d }g }| j�|�rf|g}| jj}|rf|�� }||dd�D ]6\} } } |d | } t| | | �} | durWt�| |d� �}|� | t |�| j f� q-| t j krc|rc|� | � q-|s#|�� |S )z%yields (revlog_type, unencoded, size)rr r T)r� N)r r r� �isdir�readdir�popr� r �pconvertrz r �st_sizer� �S_IFDIR�sort)r� �relpath�recurser �striplenr@ �visitr� r� r� r� r� �fp�rl_typerl r r r �_walk� s, �� zbasicstore._walkNc C s t j | j||d�S )N)� trypending�concurrencychecker)r r )r� r� r� r r r r � s �zbasicstore.changelogc C s" t �|j| j�}t �| j|||�S r� )r �manifestrevlog� nodeconstantsr � manifestlog)r� �repo�storenarrowmatch� rootstorer r r r� � s zbasicstore.manifestlogc c s> � | � dd�| � dd� }|D ] \}}}t|B ||fV qdS )a4 Like walk, but excluding the changelog and root manifest. When [undecodable] is None, revlogs names that can't be decoded cause an exception. When it is provided, it should be a list and the filenames that can't be decoded are added to it instead. This is very rarely needed.r� Tr� N)r� �FILEFLAGS_FILELOG)r� r � undecodable�filesr� �ur> r r r � datafiles� s ��zbasicstore.datafilesc c sn � t | �dd��}|D ])\}}}|�d�r t|B ||fV q |�d�r,t|B ||fV q t|B ||fV q d S )NrC Fs 00changelogs 00manifest)�reversedr� r �FILEFLAGS_CHANGELOG�FILEFLAGS_MANIFESTLOG�FILETYPE_OTHER)r� r� r� r� r> r r r �topfiles s � �zbasicstore.topfilesc c s0 � | � |�D ]}|V q| �� D ]}|V qdS )z�return file related to data storage (ie: revlogs) yields (file_type, unencoded, size) if a matcher is passed, storage files of only those tracked paths are passed with matches the matcher N)r� r� )r� r r+ r r r �walk s � �zbasicstore.walkc C s t S r� ��_data�r� r r r �copylist � zbasicstore.copylistc C � d S r� r �r� �trr r r �write# r� zbasicstore.writec C r� r� r r� r r r �invalidatecaches& r� zbasicstore.invalidatecachesc C r� r� r �r� �fnr r r � markremoved) r� zbasicstore.markremovedc C s@ d� d|f�}| j�|d �rdS |�d�s|d }| j�|�S )�!Checks if the store contains pathrr r� r T)rG r �existsr� �r� r r r r � __contains__, s zbasicstore.__contains__r� �NN)�__name__� __module__� __qualname__�__doc__r� rG r� r r� r� r� r� r� r� r� r� r� r r r r r� � s r� c s6 e Zd Zdd� Zd � fdd� Zdd� Zdd � Z� ZS ) � encodedstorec C sF ||d �}|j | _t|�| _| j|_|| _t�|t�| _| j| _ d S )N� /store) r� r r� r� r� r� r� rY r r� r� r r r r� 9 s zencodedstore.__init__Nc # s� � t t| ��� D ]5\}}}zt|�}W n ty0 |d u r)td�| }t�|��|�|� Y qw t ||�s7q|||fV qd S )Ns undecodable revlog name %s) �superr� r� r\ r= r r � StorageErrorrz r )r� r r� r� �f1�size�f2�msg�� __class__r r r� G s � � �zencodedstore.datafilesc C r� r� )r rY r� r r r rG V r� zencodedstore.joinc C s ddgdd� t D � S )Nr� r� c S � g | ]}d | �qS �s store/r �r* r� r r r r, Z r- z)encodedstore.copylist.<locals>.<listcomp>r� r� r r r r� Y s zencodedstore.copylistr� )r� r� r� r� r� rG r� � __classcell__r r r r r� 8 s r� c @ sX e Zd Zdd� Zddd�Zddd�Zdd � Zd d � Zd d � Zdd� Z dd� Z dd� Z dS )�fncachec C s || _ d | _d| _t� | _d S r� )r �entries�_dirty�set�addls)r� r r r r r� ` s zfncache.__init__Nc C s | j du r | �|� dS dS )z�read the fncache file if not already read. If the file on disk is corrupted, raise. If warn is provided, warn and keep going instead.N)r �_load)r� �warnr r r � ensureloadedg s �zfncache.ensureloadedc C s� d| _ z | jddd�}W n ty t� | _Y dS w t� | _d}tt�|jt �d�D ].}||7 }z |� d�}| j� t |d|d � �� � � ||d d� }W q+ tyY Y q+w |rrtd �}|ri||d � n tj|td �d ��| �||� |�� dS ) z&fill the entries from the fncache fileF� fncache� rb)r� NrC � r s$ fncache does not ends with a newlines3 use 'hg debugrebuildfncache' to rebuild the fncache)�hint)r r �IOErrorr r �iter� functools�partial�read�fncache_chunksize�rindex�updater � splitlines� ValueErrorr r �Abort� _checkentries�close)r� r r� �chunkrE r� r r r r r o s< � ��� z fncache._loadc C sj d| j v r1|�d� tt�|��D ]!\}}|�d�s0td�|d }|r+||d � qt�|��qdS dS )z-make sure there is no empty string in entriesrC r r s! invalid entry in fncache, line %dr N) r �seekrg r �iterfile�rstripr r r )r� r� r rl �liner� r r r r � s ��zfncache._checkentriesc C s� | j r9| jd us J �| j| jB | _t� | _|�d� | jdddd�}| jr2|�td�| j�d �� |� � d| _ | jrf|�d� | jdddd�}| jrY|�td�| j�d �� |� � d | _t� | _d S d S )Nr s wbT)r� � atomictempr Fs ab) r r r r � addbackupr r� r' rG r )r� r� r� r r r r� � s& �z fncache.writec C s0 | j d u r | �� || j vr| j�|� d S d S r� )r r r �addr� r r r r' � s �z fncache.addc C sZ | j d u r | �� || jv r| j�|� d S z | j �|� d| _W d S ty, Y d S w �NT)r r r �remover r= r� r r r r) � s �zfncache.removec C s* || j v rdS | jd u r| �� || jv S r( )r r r r� r r r r� � s zfncache.__contains__c C s" | j d u r | �� t| j | jB �S r� )r r r r r� r r r �__iter__� s zfncache.__iter__r� ) r� r� r� r� r r r r� r' r) r� r* r r r r r ] s & r c @ s. e Zd Zdd� Zd dd�Zdd� Zdd � Zd S ) � _fncachevfsc C s t j�| |� || _|| _d S r� )r� �proxyvfsr� r �encode)r� r �fncr- r r r r� � s z_fncachevfs.__init__� rc O s� | � |�}|dvr6|�d�s|�d�r6| jjd u o | j�|�}|r.d|v r.| j�|�js.d}|s6| j�|� | j||g|�R i |��S )N)r/ r r r s r+F) r- r r r r r� r� r� r' )r� r r� �args�kw�encoded�notloadr r r �__call__� s �� z_fncachevfs.__call__c C s" |r | j �| �|��S | j �|�S r� )r rG r- r� r r r rG � s z_fncachevfs.joinc C s( |� d�s |� d�r| j�|� dS dS )z1generic hook point to lets fncache steer its stewr r N)r r r' r� r r r � register_file� s �z_fncachevfs.register_fileN)r/ )r� r� r� r� r4 rG r5 r r r r r+ � s r+ c @ s^ e Zd Zdd� Zdd� Zdd� Zddd �Zd d � Zd d � Zdd� Z dd� Z dd� Z dd� Z dS )� fncachestorec C st |rt }nt}|| _||d �}|j| _| jd | _t|�| _| j|_|| _t |�}|| _ t |||�| _ | j | _ d S )Nr� rr ) r� r� r- r� r �pathsepr� r� r� r r+ r r� )r� r r� rk r- r r. r r r r� � s zfncachestore.__init__c C s | j | �|� S r� )r7 r- r� r r r rG � zfncachestore.joinc C s | j �|�jS r� )r� r� r� r� r r r �getsize s zfncachestore.getsizeNc c s� � t | j�D ]A}t||�sq| �|�}zt|�}|d us J |��|tO }||| �|�fV W q tyG } z |jtj kr=� W Y d }~qd }~ww d S r� ) �sortedr r r- r� r� r9 r� �errno�ENOENT)r� r r� r� r� r� �errr r r r� s" � ����zfncachestore.datafilesc C s d}ddgdd� |D � S )N) r� r� r� r� s dhr r� r� r� r� r� r� r� r� r� c S r r r r r r r r, . r- z)fncachestore.copylist.<locals>.<listcomp>r )r� r� r r r r� s zfncachestore.copylistc C � | j �|� d S r� )r r� r� r r r r� 0 r8 zfncachestore.writec C s d | j _t� | j _d S r� )r r r r r� r r r r� 3 s z fncachestore.invalidatecachesc C r> r� )r r) r� r r r r� 7 r8 zfncachestore.markremovedc C sP | � |�}z| �|� W dS ty' } z|jtjkr � W Y d }~dS d }~ww )NTF)r- r9 r� r; r< )r� r� r� r= r r r �_exists: s ��zfncachestore._existsc C sj d� d|f�}|d }|| jv r| �|�rdS |�d�s |d7 }| jD ]}|�|�r2| �|�r2 dS q#dS )r� rr r� r TF)rG r r? r� r )r� r rP r r r r� E s �zfncachestore.__contains__r� ) r� r� r� r� rG r9 r� r� r� r� r� r? r� r r r r r6 � s r6 )N� __future__r r; r rv �rer� �i18nr r r �noder � r r r r r r r� �utilsr � importmodr r r r& r' r r3 rV rX r[ rY r\ r_ r^ ri rj rn r{ rx ry r� r� r� r� r� r� r� r� r� �compile�EXCLUDEDr� r� r� r� r� �FILEFLAGS_OTHERr� �FILEFLAGS_REVLOG_OTHERr� �FILETYPE_CHANGELOG_MAIN�FILETYPE_CHANGELOG_OTHER�FILETYPE_MANIFESTLOG_MAIN�FILETYPE_MANIFESTLOG_OTHER�FILETYPE_FILELOG_MAINr� r� �objectr� r� r r, r+ r6 r r r r �<module> s| $ <0 ' m%x#
Save
Cancel