/
lib64
/
python3.9
/
site-packages
/
mercurial
/
__pycache__
/
Upload File
HOME
a �+�b�c � @ s d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZddlm Z ddl m Z m Z m Z ddlmZmZmZm Z mZ dd� ZG d d � d e�ZG d d � d e�ZeZG d d� de�ZG dd� dee�ZeZG dd� de�ZG dd� de�Z G dd� de �Z G dd� de�Z G dd� de �Z dS )� )�absolute_importN� )�_)�delattr�getattr�setattr)�encoding�error�pathutil�pycompat�utilc s0 � �fdd�}|� s,t �t ����� |� dS )z�Avoid file stat ambiguity forcibly This function causes copying ``path`` file, if it is owned by another (see issue5418 and issue5584 for detail). c s$ t j���} | �� � p"| ��� �S �N)r �filestat�frompathZisambigZ avoidambig)Znewstat��oldstat�path� �3/usr/lib64/python3.9/site-packages/mercurial/vfs.py� checkandavoid& s z"_avoidambig.<locals>.checkandavoidN)r �rename� mktempcopy)r r r r r r � _avoidambig s r c @ s� e Zd ZdZdZdd� Zdkdd�Zdd � Zd d � Zd d � Z dldd�Z e j dd� �Z dd� Zdmdd�Zdndd�Zdodd�Zd d � Zd d � Zd d!� Zd"d#� Zdpd%d&�Zd'd(� Zdqd)d*�Zdrd+d,�Zdsd-d.�Zdtd/d0�Zd1d2� Z d3d4� Z d5d6� Z dud7d8�Z dvd9d:�Z dwd;d<�Z!dxd>d?�Z"dyd@dA�Z#dBdC� Z$dzdDdE�Z%d{dHdI�Z&d|dJdK�Z'dLdM� Z(d}dNdO�Z)dPdQ� Z*d~dRdS�Z+ddTdU�Z,d�dVdW�Z-dXdY� Z.d�dZd[�Z/d�d\d]�Z0d�d^d_�Z1d�d`da�Z2d�dbdc�Z3d�ddde�Z4e5j6d�dgdh��Z7didj� Z8d$S )�� abstractvfsz+Abstract base class; cannot be instantiated� /c O s t dtt| �� ��dS )z7Prevent instantiation; don't call this from subclasses.�attempted instantiating N��NotImplementedError�str�type)�self�args�kwargsr r r �__init__= s zabstractvfs.__init__� rbc K s t �d S r �r )r r �moder" r r r �__call__A s zabstractvfs.__call__c C s t �d S r r% �r r r& r r r � _auditpathD s zabstractvfs._auditpathc G s t �d S r r% �r r �insidefr r r �joinG s zabstractvfs.joinc C sD z | � |�W S ty> } z|jtjkr*� W Y d}~n d}~0 0 dS )z3gracefully return an empty string for missing filesN� )�read�IOError�errno�ENOENT)r r �instr r r �tryreadJ s zabstractvfs.tryreadc C sH z| j ||d�W S tyB } z|jtjkr.� W Y d}~n d}~0 0 g S )z2gracefully return an empty array for missing files�r& N)� readlinesr/ r0 r1 )r r r& r2 r r r � tryreadlinesS s zabstractvfs.tryreadlinesc C s | j S )z�Open ``path`` file, which is relative to vfs root. Newly created directories are marked as "not to be indexed by the content indexing service", if ``notindexed`` is specified for "write" mode access. )r' �r r r r �open\ s zabstractvfs.openc C s6 | |d��}|� � W d � S 1 s(0 Y d S )Nr$ )r. )r r �fpr r r r. f s zabstractvfs.readc C s8 | ||d��}|� � W d � S 1 s*0 Y d S )Nr4 )r5 )r r r& r9 r r r r5 j s zabstractvfs.readlinesFc K sD | |dfd|i|���}|� |�W d � S 1 s60 Y d S )N� wb�backgroundclose��write)r r �datar; r" r9 r r r r= n s zabstractvfs.writer: c C s< | |||d��}|� |�W d � S 1 s.0 Y d S )N)r& � notindexed)� writelines)r r r> r& r? r9 r r r r@ r s zabstractvfs.writelinesc C s8 | |d��}|� |�W d � S 1 s*0 Y d S )Ns abr< )r r r> r9 r r r �appendv s zabstractvfs.appendc C s t j�|�S )z�return base element of a path (as os.path.basename would do) This exists to allow handling of strange encoding if needed.)�osr �basename�r r r r r rC z s zabstractvfs.basenamec C s t �| �|�|�S r )rB �chmodr, r( r r r rE � s zabstractvfs.chmodc C s t j�|�S )z�return dirname element of a path (as os.path.dirname would do) This exists to allow handling of strange encoding if needed.)rB r �dirnamerD r r r rF � s zabstractvfs.dirnameNc C s t j�| �|��S r )rB r �existsr, rD r r r rG � s zabstractvfs.existsc C s t �|�S r )r �fstat)r r9 r r r rH � s zabstractvfs.fstatc C s t j�| �|��S r )rB r �isdirr, rD r r r rI � s zabstractvfs.isdirc C s t j�| �|��S r )rB r �isfiler, rD r r r rJ � s zabstractvfs.isfilec C s t j�| �|��S r )rB r �islinkr, rD r r r rK � s zabstractvfs.islinkc C s> z| � |�}W n ty" Y dS 0 |j}t�|�p<t�|�S )zhreturn whether path is a regular file or a symlink Unlike isfile, this doesn't follow symlinks.F)�lstat�OSError�st_mode�stat�S_ISREG�S_ISLNK)r r �str& r r r � isfileorlink� s zabstractvfs.isfileorlinkc G s` d}t |�D ]$\}}tj�|�s,|�| j�r |}q |dkrF||d � }dd� |D �}| j�|�S )Nr c S s g | ] }|r|�qS r r )�.0�pr r r � <listcomp>� r- z%abstractvfs._join.<locals>.<listcomp>)� enumeraterB r �isabs� startswith�_dir_sepr, )r �pathsZroot_idx�idxrU r r r �_join� s zabstractvfs._joinc G s | j |� S )z�join various elements of a path together (as os.path.join would do) The vfs base is not injected so that path stay relative. This exists to allow handling of strange encoding if needed.)r] )r r[ r r r �reljoin� s zabstractvfs.reljoinc C s t j�|�S )z�split top-most element of a path (as os.path.split would do) This exists to allow handling of strange encoding if needed.)rB r �splitrD r r r r_ � s zabstractvfs.splitc C s t j�| �|��S r )rB r �lexistsr, rD r r r r` � s zabstractvfs.lexistsc C s t �| �|��S r )rB rL r, rD r r r rL � s zabstractvfs.lstatc C s t �| �|��S r )rB �listdirr, rD r r r ra � s zabstractvfs.listdirTc C s t �| �|�|�S r )r �makedirr, )r r r? r r r rb � s zabstractvfs.makedirc C s t �| �|�|�S r )r �makedirsr, r( r r r rc � s zabstractvfs.makedirsc C s t �|| �|��S r )r �makelockr, )r �infor r r r rd � s zabstractvfs.makelockc C s t �| �|��S r )rB �mkdirr, rD r r r rf � s zabstractvfs.mkdirr- � tmpc C sJ t j||| �|�d�\}}t�|�\}}|r>|tj�||�fS ||fS d S )N)�suffix�prefix�dir)r �mkstempr, r r_ rB r )r rh ri rj �fd�nameZdname�fnamer r r rk � s � zabstractvfs.mkstempc C s t �| �|�||�S r )r ra r, )r r rO �skipr r r �readdir� s zabstractvfs.readdirc C s t �| �|��S r )r �readlockr, rD r r r rq � s zabstractvfs.readlockc C s` | � |d� | �|�}| �|�}|o.tj�|�}|rT|jrTt�||�}t||� |S t�||�S )a� Rename from src to dst checkambig argument is used with util.filestat, and is useful only if destination file is guarded by any lock (e.g. repo.lock or repo.wlock). To avoid file stat ambiguity forcibly, checkambig=True involves copying ``src`` file, if it is owned by another. Therefore, use checkambig=True only in limited cases (see also issue5418 and issue5584 for detail). � w)r) r, r r r rO r r )r �src�dst� checkambigZsrcpathZdstpathr �retr r r r � s zabstractvfs.renamec C s t �| �|��S r )r �readlinkr, rD r r r rw � s zabstractvfs.readlinkc C s t �| �|��S )z7Remove a leaf directory and all empty intermediate ones)r � removedirsr, rD r r r rx � s zabstractvfs.removedirsc C s t �| �|��S )zRemove an empty directory.)rB �rmdirr, rD r r r ry � s zabstractvfs.rmdirc C s( |rdd� }nd}t j| �|�||d�S )zqRemove a directory tree recursively If ``forcibly``, this tries to remove READ-ONLY files, too. c S sP | t jur � t �|�}|jtj@ dkr(� t �|t�|j�tjB � t �|� d S )Nr )rB �removerO rN �S_IWRITErE �S_IMODE)�functionr �excinfo�sr r r �onerror s z#abstractvfs.rmtree.<locals>.onerrorN)� ignore_errorsr� )�shutil�rmtreer, )r r r� Zforciblyr� r r r r� s �zabstractvfs.rmtreec C s t �| �|�||�S r )r �setflagsr, )r r �l�xr r r r� s zabstractvfs.setflagsc C s t �| �|��S r )rB rO r, rD r r r rO s zabstractvfs.statc C s t �| �|��S r )r �unlinkr, rD r r r r� s zabstractvfs.unlinkc C s t �| �|�� dS )z7Attempt to remove a file, ignoring missing file errors.N)r � tryunlinkr, rD r r r r� s zabstractvfs.tryunlinkc C s t j| �|�||d�S )N)� ignoremissingry )r � unlinkpathr, )r r r� ry r r r r� $ s �zabstractvfs.unlinkpathc C s t �| �|�|�S r )rB �utimer, )r r �tr r r r� ) s zabstractvfs.utimec c sX t j�| �d��}tt�|��}t j| �|�|d�D ] \}}}||d� ||fV q4dS )a/ Yield (dirpath, dirs, files) tuple for each directories under path ``dirpath`` is relative one from the root of this vfs. This uses ``os.sep`` as path separator, even you specify POSIX style ``path``. "The root of this vfs" is represented as empty ``dirpath``. N)r� )rB r �normpathr, �lenr Z normasprefix�walk)r r r� �rootZ prefixlen�dirpath�dirs�filesr r r r� , s zabstractvfs.walk���c c s� t t�� tj�sdV dS t| d| �}t|dd�r@t�td���t||d��0}z||_ |V W d|_ nd|_ 0 W d � n1 s�0 Y dS )z�Allow files to be closed asynchronously. When this context manager is active, ``backgroundclose`` can be passed to ``__call__``/``open`` to result in the file possibly being closed asynchronously, on a background thread. N�vfs�_backgroundfileclosers- can only have 1 active background file closer)� expectedcount) � isinstance� threading�current_thread� _MainThreadr r �Abortr �backgroundfilecloserr� )r �uir� r� Zbfcr r r �backgroundclosing< s( � ����z abstractvfs.backgroundclosingc C s dS )z1generic hook point to lets fncache steer its stewNr rD r r r � register_file^ s zabstractvfs.register_file)r$ )r$ )r$ )F)r: F)N)N)N)N)N)N)N)N)NT)NN)N)r- rg N)NNN)F)N)N)NFF)N)N)N)NFT)NN)NN)r� )9�__name__� __module__� __qualname__�__doc__rZ r# r' r) r, r3 r6 r � propertycacher8 r. r5 r= r@ rA rC rE rF rG rH rI rJ rK rS r] r^ r_ r` rL ra rb rc rd rf rk rp rq r rw rx ry r� r� rO r� r� r� r� r� � contextlib�contextmanagerr� r� r r r r r 2 sh !r c @ s` e Zd ZdZddd�Zejdd� �Zejdd � �Zd d � Z d d � Z ddd�Z dd� Z dd� Z dS )r� ak Operate files relative to a base directory This class is used to hide the details of COW semantics and remote file access from higher level code. 'cacheaudited' should be enabled only if (a) vfs object is short-lived, or (b) the base directory is managed by hg and considered sort-of append-only. See pathutil.pathauditor() for details. TFc C sd |rt �|�}|r tj�|�}|| _|| _|rBtj| j|d�| _ n ddd�| _ d | _ d | _ i | _ d S )N)�cachedc S s dS �NTr )r r& r r r �<lambda>~ r- z vfs.__init__.<locals>.<lambda>)N) r � expandpathrB r �realpath�base�_auditr Z pathauditor�audit� createmode� _trustnlink�options)r r� r� Z cacheauditedr� r� r r r r# m s z vfs.__init__c C s t �| j�S r )r Z checklinkr� r7 r r r � _cansymlink� s zvfs._cansymlinkc C s t �| j�S r )r Z checkexecr� r7 r r r �_chmod� s z vfs._chmodc C s* | j d u s| jsd S t�|| j d@ � d S )Ni� )r� r� rB rE )r rm r r r � _fixfilemode� s zvfs._fixfilemodec C s` | j r\tj�|�r.|�| j�r.tj�|| j�}t�|�}|rNt � d||f ��| j ||d� d S )Ns %s: %rr4 ) r� rB r rX rY r� �relpathr Zcheckosfilenamer r� r� )r r r& �rr r r r) � s zvfs._auditpath� rc C s |r| � ||� | �|�} d|vr*|d7 }d} |dv�rxt�| �\} } | �rx|rx|rdt�| | j|� tj| || j|d�S z\d|v r�t�| � d} n@t�| ��& t� | �} | dk r�d} W d � n1 s�0 Y W nR t t f�y& } z4| j t j kr�� d} |�rt�| | j|� W Y d } ~ n d } ~ 0 0 | dk�rx| jd u �rT| dk�pPt�| �| _| dk�sf| j�sxt�t�| �| � t�| |�}| dk�r�| �| � |�r�|dv �r�t�td �| ��t|�}|�r�tt�� tj��r�| j�s�t�td ���t || j�}|S ) a� Open ``path`` file, which is relative to vfs root. By default, parent directories are created as needed. Newly created directories are marked as "not to be indexed by the content indexing service", if ``notindexed`` is specified for "write" mode access. Set ``makeparentdirs=False`` to not create directories implicitly. If ``backgroundclose`` is passed, the file may be closed asynchronously. It can only be used if the ``self.backgroundclosing()`` context manager is active. This should only be specified if the following criteria hold: 1. There is a potential for writing thousands of files. Unless you are writing thousands of files, the performance benefits of asynchronously closing files is not realized. 2. Files are opened exactly once for the ``backgroundclosing`` active duration and are therefore free of race conditions between closing a file on a background thread and reopening it. (If the file were opened multiple times, there could be unflushed data because the original file handle hasn't been flushed/closed yet.) ``checkambig`` argument is passed to atomictempfile (valid only for writing), and is useful only if target file is guarded by any lock (e.g. repo.lock or repo.wlock). To avoid file stat ambiguity forcibly, checkambig=True involves copying ``path`` file opened in "append" mode (e.g. for truncation), if it is owned by another. Therefore, use combination of append mode and checkambig=True only in limited cases (see also issue5418 and issue5584 for detail). � br� �r� r$ )ru rr r r � Ns> implementation error: mode %s is not valid for checkambig=TruesS backgroundclose can only be used when a backgroundclosing context manager is active) r) r, r r_ rc r� Zatomictempfiler� Z posixfileZnlinksrM r/ r0 r1 r� Z checknlinkr r r� r r� r �checkambigatclosingr� r� r� r� r� �delayclosedfile)r r r& Z atomictempr? r; ru Z auditpathZmakeparentdirs�fZnlinkrF rC �er9 r r r r' � s~ ) � & & ��������z vfs.__call__c C s� | � |� | �|�}t�|� t�tj�|�| j� | j r�zt� ||� W q� t y� } z.t |j t d�|t�|j�f |��W Y d }~q�d }~0 0 n | �||� d S )Ns could not symlink to %r: %s)r� r, r r� rc rB r rF r� r� �symlinkrM r0 r r Z strtolocal�strerrorr= )r rs rt Zlinkname�errr r r r� s �� z vfs.symlinkc G s, |r"| j |g}|�|� | j|� S | j S d S r )r� �extendr] )r r r+ �partsr r r r, # s zvfs.joinN)TFFF)r� FFFFTT)r� r� r� r� r# r r� r� r� r� r) r' r� r, r r r r r� b s, � � vr� c @ s6 e Zd Zdd� Zdd� Zedd� �Zejdd� �ZdS ) �proxyvfsc C s || _ d S r )r� �r r� r r r r# 0 s zproxyvfs.__init__c C s | j �||�S r )r� r) r( r r r r) 3 s zproxyvfs._auditpathc C s | j jS r �r� r� r7 r r r r� 6 s zproxyvfs.optionsc C s || j _d S r r� )r �valuer r r r� : s N)r� r� r� r# r) �propertyr� �setterr r r r r� / s r� c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � filtervfsz4Wrapper vfs for filtering filenames with a function.c C s t �| |� || _d S r )r� r# �_filter)r r� �filterr r r r# B s zfiltervfs.__init__c O s | j | �|�g|�R i |��S r )r� r� )r r r! r" r r r r' F s zfiltervfs.__call__c G s6 |r&| j �| �| j j|g|�R � ��S | j �|�S d S r )r� r, r� r^ r* r r r r, I s "zfiltervfs.joinN�r� r� r� r� r# r' r, r r r r r� ? s r� c @ s* e Zd ZdZdd� Zd dd�Zdd� Zd S ) � readonlyvfsz#Wrapper vfs preventing any writing.c C s t �| |� d S r )r� r# r� r r r r# V s zreadonlyvfs.__init__r� c O s0 |dvrt �td���| j||g|�R i |��S )Nr� s this vfs is read only)r r� r r� )r r r& r! �kwr r r r' Y s zreadonlyvfs.__call__c G s | j j|g|�R � S r )r� r, r* r r r r, ^ s zreadonlyvfs.joinN)r� r� r r r r r� S s r� c @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dS )� closewrapbasezaBase class of wrapper, which hooks closing Do not instantiate outside of the vfs layer. c C s t �| d|� d S )N�_origfh)�object� __setattr__�r �fhr r r r# h s zclosewrapbase.__init__c C s t | j|�S r )r r� �r �attrr r r � __getattr__k s zclosewrapbase.__getattr__c C s t | j||�S r )r r� )r r� r� r r r r� n s zclosewrapbase.__setattr__c C s t | j|�S r )r r� r� r r r � __delattr__q s zclosewrapbase.__delattr__c C s | j �� | S r )r� � __enter__r7 r r r r� t s zclosewrapbase.__enter__c C s t dtt| �� ��d S �Nr r �r �exc_type� exc_value�exc_tbr r r �__exit__x s zclosewrapbase.__exit__c C s t dtt| �� ��d S r� r r7 r r r �close{ s zclosewrapbase.closeN) r� r� r� r� r# r� r� r� r� r� r� r r r r r� b s r� c s0 e Zd ZdZ� fdd�Zdd� Zdd� Z� ZS )r� zfProxy for a file object whose close is delayed. Do not instantiate outside of the vfs layer. c s" t t| ��|� t�| d|� d S )N�_closer)�superr� r# r� r� )r r� Zcloser�� __class__r r r# � s zdelayclosedfile.__init__c C s | j �| j� d S r �r� r� r� r� r r r r� � s zdelayclosedfile.__exit__c C s | j �| j� d S r r� r7 r r r r� � s zdelayclosedfile.close)r� r� r� r� r# r� r� � __classcell__r r r� r r� s r� c @ s: e Zd ZdZddd�Zdd� Zdd� Zd d � Zd d � Zd S )r� zCCoordinates background closing of file handles on multiple threads.r� c C s� d| _ d| _g | _d | _tj}|�dd|�}|s4d S |�dd�}|dkrT||k rTd S |�dd�}|�dd�}|�d| � tj j |d �| _ d | _ t |�D ](}t j| jd d �} | j�| � | �� q�d S ) NFs workers backgroundcloses backgroundcloseminfilecountr s backgroundclosemaxqueues backgroundclosethreadcounts0 starting %d threads for background file closing )�maxsizeTZbackgroundcloser)�targetrm )�_running�_entered�_threads�_threadexceptionr Z iswindowsZ configboolZ configint�debug�queueZQueue�_queue�ranger� �Thread�_workerrA �start) r r� r� ZdefaultenabledZenabledZ minfilecountZmaxqueueZ threadcount�ir� r r r r# � s, � z backgroundfilecloser.__init__c C s d| _ | S r� )r� r7 r r r r� � s z backgroundfilecloser.__enter__c C s d| _ | jD ] }|�� q d S )NF)r� r� r, )r r� r� r� r� r r r r� � s z backgroundfilecloser.__exit__c C st zL| j jddd�}z |�� W n* tyH } z|| _W Y d}~n d}~0 0 W q tjjyl | jshY qpY q 0 q dS )z Main routine for worker thread.Tg�������?��block�timeoutN) r� �getr� � Exceptionr� r r� ZEmptyr� �r r� r� r r r r� � s z backgroundfilecloser._workerc C sR | j st�td���| jr*| j}d| _|�| js<|�� dS | jj|ddd� dS )z Schedule a file for closing.s1 can only call close() when context manager activeNTr� ) r� r r� r r� r� r� r� Zputr� r r r r� � s �zbackgroundfilecloser.closeN)r� ) r� r� r� r� r# r� r� r� r� r r r r r� � s &r� c s8 e Zd ZdZ� fdd�Zdd� Zdd� Zdd � Z� ZS ) r� a" Proxy for a file object, to avoid ambiguity of file stat See also util.filestat for detail about "ambiguity of file stat". This proxy is useful only if the target file is guarded by any lock (e.g. repo.lock or repo.wlock) Do not instantiate outside of the vfs layer. c s, t t| ��|� t�| dtj�|j�� d S )N�_oldstat) r� r� r# r� r� r r r rm r� r� r r r# � s z checkambigatclosing.__init__c C s | j }|jrt| jj|� d S r )r� rO r r� rm )r r r r r � _checkambig� s z checkambigatclosing._checkambigc C s | j �|||� | �� d S r )r� r� r� r� r r r r� s z checkambigatclosing.__exit__c C s | j �� | �� d S r )r� r� r� r7 r r r r� s zcheckambigatclosing.close) r� r� r� r� r# r� r� r� r� r r r� r r� � s r� ) Z __future__r r� r0 rB r� rO r� Zi18nr r r r r � r r r r r r� r r� �openerr� r� Z filteropenerr� r� r� r� r� r r r r �<module> s0 2 K \