| 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/mercurial/utils/__pycache__/ |
Upload File : |
a
�+�b�l � @ s d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
ddl m Z ddl
mZmZ ddlmZmZmZm
Z
ddlmZ e�d�Ze
jr�dd lmZ n dd
lmZ d d � Z G d
d� dej �Z G dd� de �Z ej!�"e � dd� Z#dd� Z$G dd� de �Z%ej&�"e%� dd� Z'e
j(�r�ej)du �rDe � Z)nej)j*Z)ej+du �r`e � Z+n e'ej+j*�Z+ej,du �r�e � Z,n e'ej,j*�Z,e
j�r�e�-e+�Z+e�-e,�Z,e e+��re#e+�Z+n\ej)Z)ej+Z+ej,Z,e
j�r�e�-e+�Z+e�-e,�Z,e e+��re
j�re#e+�Z+ne�.e+�/� dd�Z+ej0Z0ej1Z2ej3Z3ej4Z4ej5Z5ej6Z6ej7Z7ej8Z8ej9Z9ej:Z:ej;Z;ej<Z<ej=Z=z
ej>Z>W n e?�y� Y n0 z
ej@Z@W n e?�y� Y n0 e
jAZBdd � ZCG d d � d e �ZDd^d!d"�ZEd#d$� ZFd%d&� ZGd_d'd(�ZHd`d)d*�ZIdad+d,�ZJd-d.� ZKd/d0� ZLeLeKd1�ZMd2d3� ZNdaOd4d5� ZPd6d7� ZQd8d9� ZRd:d;� ZSd<d=� ZTd>d?� ZUd@dA� ZVdbdBdC�ZWe
j�r|dDdE� ZXejYZZndFdE� ZXe
j[ZZdGdH� Z\dcdIdJ�Z]da^dKdL� Z_dMdN� Z`dOdP� ZadQdR� ZbejcdSdT� �Zde
j�r�dUZeeeejfB ZgdddXdY�Zhn&dedZd[�Zidfd\d]�Zje
j(�reiZhnejZhdS )g� )�absolute_importN� ��_)�getattr�open)�encoding�error�policy�pycompat)� resourceutil�osutil)�windows)�posixc C s$ z
| � � W S ty Y dS 0 d S )NF)�isatty�AttributeError)�fp� r �>/usr/lib64/python3.9/site-packages/mercurial/utils/procutil.pyr . s
r c @ s e Zd ZdZdd� Zdd� ZdS )�BadFilez3Dummy file object to simulate closed stdio behaviorc C s t tjd��d S �NzBad file descriptor��IOError�errno�EBADF��self�br r r �readinto8 s zBadFile.readintoc C s t tjd��d S r r r r r r �write; s z
BadFile.writeN)�__name__�
__module__� __qualname__�__doc__r r r r r r r 5 s r c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�LineBufferedWrapperc C s
|| _ d S �N��orig�r r' r r r �__init__@ s z LineBufferedWrapper.__init__c C s t | j|�S r% �r r' �r �attrr r r � __getattr__C s z LineBufferedWrapper.__getattr__c C s& | j }|�|�}|�d�r"|�� |S )N�
)r' r �endswith�flush)r �sr' �resr r r r F s
zLineBufferedWrapper.writeN�r r! r" r) r- r r r r r r$ ? s r$ c C s, t jrt| tj�s| S t| t�r$| S t| �S r% )r �ispy3�
isinstance�io�BufferedIOBaser$ ��streamr r r �make_line_bufferedS s
r: c C s$ t | t�r t | jt�rJ �| jS | S r% )r5 r$ r' r8 r r r �unwrap_line_buffered_ s
r; c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�WriteAllWrapperc C s
|| _ d S r% r& r( r r r r) g s zWriteAllWrapper.__init__c C s t | j|�S r% r* r+ r r r r- j s zWriteAllWrapper.__getattr__c C sF | j j}t|�}t|�}d}||k rB|||d � �}|r ||7 }q |S �Nr )r' r �
memoryview�len)r r1 Zwrite1�mZtotal_to_writeZ
total_written�cr r r r m s
zWriteAllWrapper.writeNr3 r r r r r< f s r< c C s0 t js
J �t| t�r| S t| tj�r(| S t| �S r% )r r4 r5 r< r6 r7 r8 r r r �_make_write_all~ s
rB �wb� c C s" | dkrt d�| S t d�| S )zpreturn a message describing a subprocess status
(codes from kill are negative - not os.system/wait encoding)r s exited with status %ds killed by signal %dr )�coder r r � explainexit� s rF c @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dS )�_pfilez;File-like wrapper for a stream opened by subprocess.Popen()c C s || _ || _d S r% )�_proc�_fp)r �procr r r r r) � s z_pfile.__init__c C s | j �� | j�� S r% )rI �closerH �wait�r r r r rK � s
z _pfile.closec C s
t | j�S r% )�iterrI rM r r r �__iter__� s z_pfile.__iter__c C s t | j|�S r% )r rI r+ r r r r- � s z_pfile.__getattr__c C s | S r% r rM r r r � __enter__� s z_pfile.__enter__c C s | � � d S r% )rK )r �exc_type� exc_valueZexc_tbr r r �__exit__� s z_pfile.__exit__N)
r r! r" r# r) rK rO r- rP rS r r r r rG � s rG � rb���c C s6 |dkrt | |�S |dkr$t| |�S t�d| ��d S )NrT s wbs unsupported mode: %r)� _popenreader� _popenwriterr ZProgrammingError)�cmd�mode�bufsizer r r �popen� s
r[ c C s& t jt| �d|tt jd�}t||j�S )NT)�shellrZ � close_fds�stdout)�
subprocess�Popen� tonativestr�closefds�PIPErG r^ �rX rZ �pr r r rV � s �rV c C s& t jt| �d|tt jd�}t||j�S )NT)r\ rZ r] �stdin)r_ r` ra rb rc rG rf rd r r r rW s �rW c C s0 t jt| �ddtt jt jt|�d�}|j|jfS )NTrU )r\ rZ r] rf r^ �env)r_ r` ra rb rc � tonativeenvrf r^ )rX rg re r r r �popen2 s � ri c C s t | |�\}}}}|||fS r% )�popen4)rX rg rf r^ �stderrre r r r �popen3# s rl c
C s: t jt| �d|tt jt jt jt|�d�}|j|j|j|fS )NT)r\ rZ r] rf r^ rk rg ) r_ r` ra rb rc rh rf r^ rk )rX rg rZ re r r r rj ( s �
rj c C s. t jt|�dtt jt jd�}|�| �\}}|S )z9filter string S through command CMD, returning its outputT)r\ r] rf r^ )r_ r` ra rb rc Z communicate)r1 rX re ZpoutZperrr r r �
pipefilter6 s �rm c C s� d\}}�zzt jdd�\}}t�|d�}|�| � |�� t jdd�\}}t�|� |�d|�}|�d|�}t|�}t jdkr�|d @ r�d
}|r�t �
t d �|t |�f ��t
|d ��j}|�� W d
� W z|r�t�|� W n ty� Y n0 z|�rt�|� W S t�y Y S 0 S 1 �s$0 Y W z|�rBt�|� W n t�yX Y n0 z|�rlt�|� W n t�y� Y n0 nVz|�r�t�|� W n t�y� Y n0 z|�r�t�|� W n t�y� Y n0 0 d
S )z�filter string S through a pair of temporary files with CMD.
CMD is used as a template to create the real command to be run,
with the strings INFILE and OUTFILE replaced by the real names of
the temporary files generated.)NNs
hg-filter-in-)�prefixrC s hg-filter-out-s INFILEs OUTFILE� OpenVMSrD r s command '%s' failed: %srT N)r Zmkstemp�os�fdopenr rK �replace�system� sysplatformr ZAbortr rF r �read�unlink�OSError)r1 rX ZinnameZoutname�infdr �outfdrE r r r �
tempfilterC sd
� ��rz )s tempfile:s pipe:c C sF t �t�D ]0\}}|�|�r
|| |t|�d� �� � S q
t| |�S )zMfilter a string through a command that transforms its input to its
outputN)r � iteritems� _filtertable�
startswithr? �lstriprm )r1 rX �name�fnr r r �filtern s
r� c C s� t du r�tj�d�} tjd }| r,t| � n�t�� r`t tdd�dkrTttjd � q�tt
j � nNt
j s�t
j�t |dd��d kr�tt
�|j�� n ttd
�p�t
j�t
jd �� t S ) z]return location of the 'hg' executable.
Defaults to $HG or 'hg' in the search path.
N� HG�__main__�frozen�
macosx_app� EXECUTABLEPATH�__file__� �hgs hgr )�
_hgexecutabler �environ�get�sys�modules�_sethgexecutabler �
mainfrozenr r �
sysexecutable� iswindowsrp �path�basename�fsencoder� �findexeZsysargv)r� Zmainmodr r r � hgexecutablez s$
���r� c C s | a dS )z#set location of the 'hg' executableN)r� )r� r r r r� � s r� c C s< t | dd �}z|o |� |�� kW S tjy6 Y dS 0 d S )N�filenoF)r r� r6 �UnsupportedOperation)�fZstdfr� r r r � _testfileno� s
r� c C s t | tj�S r% )r� r� � __stdin__�r� r r r �isstdin� s r� c C s t | tj�S r% )r� r� �
__stdout__r� r r r �isstdout� s r� c C s� |� � | | }}t| t�r`t�| �� �}t�tjtj�}t� || �� � t�
|� t� |d�}t|t �r�t�|�� �}t� t
�� |�� � t� |d�}||fS )a� Duplicate streams and redirect original if (uin, uout) are stdio
If uin is stdin, it's redirected to /dev/null. If uout is stdout, it's
redirected to stderr so the output is still readable.
Returns (fin, fout) which point to the original (uin, uout) fds, but
may be copy of (uin, uout). The returned streams can be considered
"owned" in that print(), exec(), etc. never reach to them.
�rbrC )r0 r� rf rp �dupr� r �devnull�O_RDONLY�dup2rK rq r^ rk )�uin�uout�fin�foutZnewfdZnullfdr r r � protectstdio� s
r� c C sJ |� � || f||ffD ],\}}||urt�|�� |�� � |�� qdS )z@Restore (uin, uout) streams from possibly duplicated (fin, fout)N)r0 rp r� r� rK )r� r� r� r� r� Zuifr r r � restorestdio� s
r� c sB dd� � t tj�}| r4|�� fdd�t�| �D �� t� |d< |S )z>return environ with optional override, useful for shelling outc S s* | du s| du rdS | du r dS t �| �S )z9convert python object into string that is useful to shellNF� 0T� 1)r Zbytestr)�valr r r �py2shell� s
z shellenviron.<locals>.py2shellc 3 s | ]\}}|� |�fV qd S r% r )�.0�k�v�r� r r � <genexpr>� � z shellenviron.<locals>.<genexpr>r� )�dictr r� �updater r{ r� )r� rg r r� r � shellenviron� s
r� c C s t �| t|��S r% )�platformZ
shelltocmdexer� �rX rg r r r �
shelltonative� s �r� c C s | S r% r r� r r r r� � s c C s t �t| �S )zHconvert the environment from bytes to strings suitable for Popen(), etc.)r �rapplyra )rg r r r rh � s rh c C s� z t �� W n ty Y n0 t|�}|du s8t|�r^tjt| �dtt |�t
� t|�d�}nXtj t| �dtt |�t
� t|�tj
tjd�}t|j jd�D ]}|�|� q�|�� |j}t
jdkr�|d@ r�d}|S ) z�enhanced shell command execution.
run with environment maybe modified, maybe in different dir.
if out is specified, it is assumed to be a file-like object that has a
write() method. stdout and stderr will be redirected to out.NT)r\ r] rg �cwd)r\ r] rg r� r^ rk r� ro rD r )r^ r0 � Exceptionr� r� r_ �callra rb rh r r� r` rc ZSTDOUTrN �readliner rL �
returncodert )rX r� r� �outrg �rcrJ �liner r r rs � s:
�
� rs c C sP t jr.dtjv rdS ttdd�r(t�� S dS n t jpJtj�d�pJtj�d�S dS )zAre we running in a GUI?s SSH_CONNECTIONF�isguiNTs DISPLAYs WAYLAND_DISPLAY) r �isdarwinr r� r r
r� r� r� r r r r �_gui s
�
�r� c C s t d u rt� a t S r% )�_is_guir� r r r r �gui2 s r� c C s2 t �� r,ttdd�dkr$tjd gS tjgS t� S )z�Return the command used to execute current hg
This is different from hgexecutable() because on Windows we want
to avoid things opening new shell windows like batch files, so we
get either the python call or current executable.
r� Nr� r� ) r r� r r� r r� r r� � _gethgcmdr r r r �hgcmd9 s
r� c
s� t � � � fdd�}d}ttdd�}|dur6t�||�}zjt| �}|� s�|� v sVt|�sx|� sxW |durtt�tj|� dS t�d� q@|W |dur�t�tj|� S n|dur�t�tj|� 0 dS )a_ Execute the argument list in a detached process.
condfn is a callable which is called repeatedly and should return
True once the child process is known to have started successfully.
At this point, the child process PID is returned. If the child
process fails to start or finishes before condfn() evaluates to
True, return -1.
c s � � t�� � d S r% )�addrp rL )Zsignum�frame�Z
terminatedr r �handler[ s z rundetached.<locals>.handlerN�SIGCHLDrU g�������?)�setr �signal�
spawndetached�testpidr� �time�sleep)�argsZcondfnr� Z prevhandlerr� �pidr r� r � rundetachedI s. � � �r� c # s� t �t j�g� g �� ��fdd�}zTzt � t j|� W n tyN � d= Y n0 dV W � rnt � t j� d � �r�t�n � r�t � t j� d � �r�t�0 dS )a Inhibit SIGINT handling on a region of code.
Note that if this is called in a non-main thread, it turns into a no-op.
Args:
warn: A callable which takes no arguments, and returns True if the
previous signal handling should be restored.
c s, �� r t � t j� d � � d= ��d� d S )Nr T)r� �SIGINT�append)r� �ZoldsiginthandlerZ
shouldbail�warnr r �disabledsiginthandler| s z.uninterruptible.<locals>.disabledsiginthandlerr N)r� � getsignalr� �
ValueError�KeyboardInterrupt)r� r� r r� r �uninterruptiblen s" �r� � FTc
C s� z|d}|dur2t �� }|�|� |�� |�d� tjt �t| �|t |�dt
|||d�} |durj|| j � W |dur�|� � n|dur�|� � 0 dS )z1Spawn a command without waiting for it to finish.Nr T)r\ rg r] Z
creationflagsrf r^ rk )
r �unnamedtempfiler r0 �seekr_ r` r� ra rh �_creationflagsrL rK )
�scriptrg r\ r^ rk � ensurestart� record_wait� stdin_bytesrf re r r r � runbgcommand� s.
�
�r� c
s� t jr t� |r| }n$t| t�r&| g} d�dd� | D ��}|du rPd| }d} nd} d}d}
z�zn|du rptj}
n$t �� }
|
� |� |
�
� |
� d� |du r�tj}|du r�tj}tj |d|d|
||| d �� W n$ t
y� |dur�|d
� � Y n0 W |du�rP|
du�rPt|
t��rJ �|
�� n.|du�rN|
du�rNt|
t��rFJ �|
�� 0 |�sztj� fd d �d
�} d| _| �� n� j} |du�r�|| � dS )� Spawn a command without waiting for it to finish.
When `record_wait` is not None, the spawned process will not be fully
detached and the `record_wait` argument will be called with a the
`Subprocess.wait` function for the spawned process. This is mostly
useful for developers that need to make sure the spawned process
finished before a certain point. (eg: writing test)� c s s | ]}t |�V qd S r% )�
shellquote)r� �xr r r r� � r� z"runbgcommandpy3.<locals>.<genexpr>Ns ( %s ) &TFr )r\ rg r] rf r^ rk �start_new_session� c s � j S r% )rL r �re r r �<lambda> r� z!runbgcommandpy3.<locals>.<lambda>��target)r r� r� r5 �bytes�joinr_ ZDEVNULLr� r r0 r� r` r� �intrK � threading�Thread�daemon�startrL )
rX rg r\ r^ rk r� r� r� r� r� rf �tr� r r� r �runbgcommandpy3� sf
�
�
r� c
s t jr t� |du r�t�� � � r�|sN� fdd�}tj|d�} d| _| �� dS t� � d�\}
} t�
| �rtt� | �} n t� | � } | dkr�| dkr�t
j} t| d| t�| �f ��dS d} d}
�z*z�|du r�t�� |du r�ttjd �}
n$t �� }
|
�|� |
�� |
�d� |du �r ttjd
�}|du �r6ttjd
�}tj| ||d|
||d �}|du�rb||j� d} W nT t�y� } z$|j
d@ } | dk�r�d} W Y d}~n d}~0 t �y� d} Y n0 W |
du�r�|
� � |du �rt� | � n(|
du�r�|
� � |du �rt� | � 0 dS ) r� Nc s t �� d� d S r= )rp �waitpidr �r� r r �_do_wait< s z!runbgcommandpy2.<locals>._do_waitr� Tr r� s error running %r: %s� r� w)r\ rg r] rf r^ rk ) r r� r� rp �forkr� r� r� r� r� � WIFEXITED� WEXITSTATUS�WTERMSIGr �EINVALrw �strerror�setsidr r� r� r r0 r� r_ r` rL �EnvironmentErrorr� rK �_exit)rX rg r\ r^ rk r� r� r� r r� Z_pid�statusr� rf re �exr r r �runbgcommandpy2 s�
��
�
�
r )rT rU )N)N)NrU )N)NNN)FNNTNN)FNNTNN)FNNTNN)kZ
__future__r �
contextlibr r6 rp r� r_ r� r� r� Zi18nr r r r r� r r r
Zutilsr Z importmodr
r� r r� r r � RawIOBaser �objectr$ r7 �registerr: r; r< �IOBaserB r4 rf �bufferr^ rk Z winstdoutrq r� r� Zgethgcmdr� Zgetuser�getpidZ
hidewindowZreadpipeZ setbinaryZsetsignalhandlerr� Z
shellsplitr� Zsshargsr� Z setprocnamer Z
unblocksignalZisposixrb rF rG r[ rV rW ri rl rj rm rz r| r� r� r� r� r� r� r� r� r� r� r� Z strfromlocalra �identityrh rs r� r� r� r� r� �contextmanagerr� ZDETACHED_PROCESSZCREATE_NEW_PROCESS_GROUPr� r� r� r r r r r �<module>
s
&�
&%
!�� � , �
W �
r