| 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/thirdparty/__pycache__/ |
Upload File : |
a
�+�bVk � @ s d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl Z ddl
m Z ej Z ej
Z
z
e jZW n ey� e j ZY n0 dZdZdZd Zd
Zg d �Zd ZdZdae� Zee ej fZ e d
g d��Z G dd� de
�Z dd� Z!G dd� de�Z"e#ed��rPG dd� de"�Z$e�%d� e j&�rPG dd� de�Z'G dd� de$�Z(e�%d� e(Z$e#ed ��rvG d d � d e"�Z)e�%d � e#ed ��r�G d d!� d!e"�Z*e�%d!� e#ed"��r�G d#d$� d$e"�Z+e�%d$� e#ed%��r�G d&d'� d'e"�Z,e�%d'� d(d)� Z-ej.d*k�rd+d,� Z/nd-d,� Z/d.d/� Z0dS )0z. Back-ported, durable, and portable selectors � )�absolute_importN� )�pycompatzSeth Michael Larsonz sethmichaellarson@protonmail.comz2.0.0ZMITz3https://www.github.com/SethMichaelLarson/selectors2)�
EVENT_READ� EVENT_WRITE� SelectorKey�DefaultSelector� BaseSelector� r )�fileobj�fd�events�datac @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) �_SelectorMappingz* Mapping of file objects to selector keys c C s
|| _ d S �N)� _selector��self�selector� r �E/usr/lib64/python3.9/site-packages/mercurial/thirdparty/selectors2.py�__init__F s z_SelectorMapping.__init__c C s t | jj�S r )�lenr �
_fd_to_key�r r r r �__len__I s z_SelectorMapping.__len__c C s@ z| j �|�}| j j| W S ty: td�|���Y n0 d S �Nz{0!r} is not registered.)r �_fileobj_lookupr �KeyError�format)r r r r r r � __getitem__L s
z _SelectorMapping.__getitem__c C s t | jj�S r )�iterr r r r r r �__iter__S s z_SelectorMapping.__iter__N)�__name__�
__module__� __qualname__�__doc__r r r r" r r r r r C s
r c
C sb t | t�r| }n8zt| �� �}W n& tttfyF td�| ���Y n0 |dk r^td�|���|S )zl Return a file descriptor from a file object. If
given an integer will simply return that integer back. zInvalid file object: {0!r}r z Invalid file descriptor: {0})�
isinstance�int�fileno�AttributeError� TypeError�
ValueErrorr )r r r r r �_fileobj_to_fdW s
r- c @ sv e Zd ZdZdd� Zdd� Zddd�Zd d
� Zd d d �Zd d
d�Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� ZdS ) r a/ Abstract Selector class
A selector supports registering file objects to be monitored
for specific I/O events.
A file object is a file descriptor or any object with a
`fileno()` method. An arbitrary object can be attached to the
file object which can be used for example to store context info,
a callback, etc.
A selector can use various implementations (select(), poll(), epoll(),
and kqueue()) depending on the platform. The 'DefaultSelector' class uses
the most efficient implementation for the current platform.
c C s i | _ t| �| _d S r )r r �_mapr r r r r u s zBaseSelector.__init__c C sL z
t |�W S tyF | j�� D ] }|j|u r"|j Y S q"� Y n0 dS )aa Return a file descriptor from a file object.
This wraps _fileobj_to_fd() to do an exhaustive
search in case the object is invalid but we still
have it in our map. Used by unregister() so we can
unregister an object that was previously registered
even if it is closed. It is also used by _SelectorMapping
N)r- r, r �valuesr r �r r �keyr r r r | s
z BaseSelector._fileobj_lookupNc C sb |r|t tB @ r td�|���t|| �|�||�}|j| jv rRtd�||j���|| j|j< |S )z8 Register a file object for a set of events to monitor. zInvalid events: {0!r}z${0!r} (FD {1}) is already registered) r r r, r r r r r r �r r r
r r1 r r r �register� s � zBaseSelector.registerc
C s� z| j �| �|��}W n� ty6 td�|���Y np tjy� } zV|jtjkrV� n:| j � � D ] }|j
|u r`| j �|j � q�q`td�|���W Y d}~n
d}~0 0 |S )z0 Unregister a file object from being monitored. �{0!r} is not registeredN) r �popr r r �socket�error�errno�EBADFr/ r r )r r r1 �errr r r �
unregister� s
$zBaseSelector.unregisterc C s� z| j | �|� }W n ty4 td�|���Y n0 ||jkrZ| �|� | �|||�}n"||jkr||j|d�}|| j |j < |S )z< Change a registered file object monitored events and data. r4 )r )
r r r r r
r; r3 r �_replacer r2 r r r �modify� s
zBaseSelector.modifyc C s
t � �dS )zj Perform the actual selection until some monitored file objects
are ready or the timeout expires. N)�NotImplementedError)r �timeoutr r r �select� s zBaseSelector.selectc C s | j �� d| _dS )zd Close the selector. This must be called to ensure that all
underlying resources are freed. N)r �clearr. r r r r �close� s
zBaseSelector.closec C sH | � � }|du rtd��z
|| W S tyB td�|���Y n0 dS )z: Return the key associated with a registered file object. NzSelector is closedr4 )�get_map� RuntimeErrorr r )r r �mappingr r r �get_key� s
zBaseSelector.get_keyc C s | j S )z3 Return a mapping of file objects to selector keys )r. r r r r rC � s zBaseSelector.get_mapc C s& z | j | W S ty Y dS 0 dS )z_ Return the key associated to a given file descriptor
Return None if it is not found. N)r r )r r r r r � _key_from_fd� s zBaseSelector._key_from_fdc C s | S r r r r r r � __enter__� s zBaseSelector.__enter__c G s | � � d S r )rB )r �_r r r �__exit__� s zBaseSelector.__exit__)N)N)N)r# r$ r% r& r r r3 r; r= r@ rB rF rC rG rH rJ r r r r r f s
r r@ c sN e Zd ZdZ� fdd�Zd
� fdd� Z� fdd�Zdd d
�Zdd d �Z� Z S )�SelectSelectorz Select-based selector. c s" t t| ��� t� | _t� | _d S r )�superrK r �set�_readers�_writersr �� __class__r r r � s zSelectSelector.__init__Nc sD t t| ��|||�}|t@ r*| j�|j� |t@ r@| j�|j� |S r ) rL rK r3 r rN �addr r rO r2 rP r r r3 � s zSelectSelector.registerc s0 t t| ��|�}| j�|j� | j�|j� |S r )rL rK r; rN �discardr rO r0 rP r r r; � s zSelectSelector.unregisterc C s� t | j�st | j�sg S |d u r$d nt|d�}g }t| jd| j| j|�\}}}t|�}t|�}||B D ]J}d}||v r~|tO }||v r�|tO }| � |�}|rf|�
|||j @ f� qf|S )N� Tr ) r rN rO �max�_syscall_wrapper� _wrap_selectrM r r rG �appendr
) r r? �ready�r�wrI r r
r1 r r r r@ s& �
zSelectSelector.selectc C s t � ||g |�S �z? Wrapper for select.select because timeout is a positional arg )r@ �r rZ r[ r? r r r rW s zSelectSelector._wrap_select)N)N)N)
r# r$ r% r& r r3 r; r@ rW �
__classcell__r r rP r rK � s
rK c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �_JythonSelectorMappingz� This is an implementation of _SelectorMapping that is built
for use specifically with Jython, which does not provide a hashable
value from socket.socket.fileno(). c C s t |t�sJ �|| _d S r )r' �JythonSelectSelectorr r r r r r ( s z _JythonSelectorMapping.__init__c C s t | jj�S r )r r �_socketsr r r r r , s z _JythonSelectorMapping.__len__c C s4 | j jD ]\}}||u r| S qtd�|���d S r )r ra r r )r r �sockr1 r r r r / s
z"_JythonSelectorMapping.__getitem__N)r# r$ r% r& r r r r r r r r_ # s r_ c s< e Zd ZdZ� fdd�Zd dd�Zdd� Zd d d
�Z� ZS )
r` az This is an implementation of SelectSelector that is for Jython
which works around that Jython's socket.socket.fileno() does not
return an integer fd value. All SelectorKey.fd will be equal to -1
and should not be used. This instead uses object id to compare fileobj
and will only use select.select as it's the only selector that allows
directly passing in socket objects rather than registering fds.
See: http://bugs.jython.org/issue1678
https://wiki.python.org/jython/NewSocketModule#socket.fileno.28.29_does_not_return_an_integer
c s> t t| ��� g | _t| �| _g | _g | _tt dt j �| _
d S )NZcpython_compatible_select) rL r` r ra r_ r. rN rO �getattrr@ � _select_funcr rP r r r A s
z JythonSelectSelector.__init__Nc C sr | j D ] \}}||u rtd�||���qt|d||�}| j �||f� |t@ rZ| j�|� |t@ rn| j�|� |S )Nz{0!r} is already registered���) ra r r r rX r rN r rO )r r r
r rb rI r1 r r r r3 L s � z JythonSelectSelector.registerc C sj t | j�D ]\}\}}||u r
q2q
td�|���|jt@ rH| j�|� |jt@ r^| j �|� | j|= |S r )
� enumeratera r r r
r rN �remover rO )r r �irb r1 r r r r; [ s
z JythonSelectSelector.unregisterc C s | � ||g |�S r\ )rd r] r r r rW j s z!JythonSelectSelector._wrap_select)N)N) r# r$ r% r& r r3 r; rW r^ r r rP r r` 6 s
r` �pollc sN e Zd ZdZ� fdd�Zd
� fdd� Z� fdd�Zdd d
�Zdd d �Z� Z S )� PollSelectorz Poll-based selector c s t t| ��� t�� | _d S r )rL rj r r@ ri �_pollr rP r r r u s zPollSelector.__init__Nc sP t t| ��|||�}d}|t@ r*|tjO }|t@ r<|tjO }| j�|j |� |S �Nr )
rL rj r3 r r@ �POLLINr �POLLOUTrk r )r r r
r r1 �
event_maskrP r r r3 y s
zPollSelector.registerc s" t t| ��|�}| j�|j� |S r )rL rj r; rk r r0 rP r r r; � s zPollSelector.unregisterc C s4 |dur$|dkrd}nt �|d �}| j�|�}|S �zj Wrapper function for select.poll.poll() so that
_syscall_wrapper can work with only seconds. Nr �� )�math�ceilrk ri �r r? �resultr r r �
_wrap_poll� s zPollSelector._wrap_pollc C st g }t | jd|d�}|D ]V\}}d}|tj @ r8|tO }|tj @ rL|tO }| �|�}|r|�|||j @ f� q|S �NT)r? r �
rV rv r@ rm r rn r rG rX r
�r r? rY � fd_eventsr ro r
r1 r r r r@ � s
zPollSelector.select)N)N)N)
r# r$ r% r& r r3 r; rv r@ r^ r r rP r rj s s
rj �epollc sX e Zd ZdZ� fdd�Zdd� Zd� fdd� Z� fd d
�Zdd d �Z� fd
d�Z � Z
S )�
EpollSelectorz Epoll-based selector c s t t| ��� t�� | _d S r )rL r| r r@ r{ �_epollr rP r r r � s zEpollSelector.__init__c C s
| j �� S r )r} r) r r r r r) � s zEpollSelector.filenoNc sT t t| ��|||�}d}|t@ r*|tjO }|t@ r<|tjO }t| j jd|j
|� |S )Nr F) rL r| r3 r r@ �EPOLLINr �EPOLLOUTrV r} r )r r r
r r1 Z events_maskrP r r r3 � s
zEpollSelector.registerc s> t t| ��|�}zt| jjd|j� W n ty8 Y n0 |S )NF)rL r| r; rV r} r � _ERROR_TYPESr0 rP r r r; � s zEpollSelector.unregisterc C s� |d ur2|dkrd}nt �|d �d }t|�}nd}tt| j�d�}g }t| jjd||d�}|D ]V\}}d}|t j
@ r�|t O }|t j @ r�|t
O }| �|�}|rb|�|||j@ f� qb|S ) Nr rT rq g����MbP?g �r
T)r? Z maxevents)rr rs �floatrU r r rV r} ri r@ r~ r r r rG rX r
) r r? �
max_eventsrY rz r ro r
r1 r r r r@ � s,
�
zEpollSelector.selectc s | j �� tt| ��� d S r )r} rB rL r| r rP r r rB � s
zEpollSelector.close)N)N� r# r$ r% r& r r) r3 r; r@ rB r^ r r rP r r| � s
!r| �devpollc sb e Zd ZdZ� fdd�Zdd� Zd� fdd� Z� fd d
�Zdd d �Zdd
d�Z � fdd�Z
� Z S )�DevpollSelectorzSolaris /dev/poll selector.c s t t| ��� t�� | _d S r )rL r� r r@ r� �_devpollr rP r r r � s zDevpollSelector.__init__c C s
| j �� S r )r� r) r r r r r) � s zDevpollSelector.filenoNc sP t t| ��|||�}d}|t@ r*|tjO }|t@ r<|tjO }| j�|j |� |S rl )
rL r� r3 r r@ rm r rn r� r )r r r
r r1 Z poll_eventsrP r r r3 � s
zDevpollSelector.registerc s" t t| ��|�}| j�|j� |S r )rL r� r; r� r r0 rP r r r; s zDevpollSelector.unregisterc C s4 |dur$|dkrd}nt �|d �}| j�|�}|S rp )rr rs r� ri rt r r r rv s zDevpollSelector._wrap_pollc C st g }t | jd|d�}|D ]V\}}d}|tj @ r8|tO }|tj @ rL|tO }| �|�}|r|�|||j @ f� q|S rw rx ry r r r r@ s
zDevpollSelector.selectc s | j �� tt| ��� d S r )r� rB rL r� r rP r r rB % s
zDevpollSelector.close)N)N)N) r# r$ r% r& r r) r3 r; rv r@ rB r^ r r rP r r� � s
r� �kqueuec sX e Zd ZdZ� fdd�Zdd� Zd� fdd� Z� fd d
�Zdd d �Z� fd
d�Z � Z
S )�KqueueSelectorz Kqueue / Kevent-based selector c s t t| ��� t�� | _d S r )rL r� r r@ r� �_kqueuer rP r r r / s zKqueueSelector.__init__c C s
| j �� S r )r� r) r r r r r) 3 s zKqueueSelector.filenoNc s| t t| ��|||�}|t@ rFt�|jtjtj�}t | j
j d|gdd� |t @ rxt�|jtj
tj�}t | j
j d|gdd� |S �NFr )rL r� r3 r r@ �keventr �KQ_FILTER_READZ KQ_EV_ADDrV r� �controlr �KQ_FILTER_WRITE)r r r
r r1 r� rP r r r3 6 s ��zKqueueSelector.registerc s� t t| ��|�}|jt@ r\t�|jtjtj �}zt
| j j d|gdd� W n t
yZ Y n0 |jt@ r�t�|jtjtj �}zt
| j j d|gdd� W n t
y� Y n0 |S r� )rL r� r; r
r r@ r� r r� Z KQ_EV_DELETErV r� r� r� r r� )r r r1 r� rP r r r; H s(
�
� zKqueueSelector.unregisterc C s� |d urt |d�}t| j�d }i }t| jjdd ||�}|D ]�}|j}|j}d}|tj krb|t
O }|tj krt|t O }| �
|�} | r<| j|vr�| || j@ f|| j< q<|| j d }
| ||
B | j@ f|| j< q<t|�� �S )Nr r Tr
)rU r r rV r� r� �ident�filterr@ r� r r� r rG r r
�listr/ ) r r? r� Z ready_fdsZ kevent_listr� r ro r
r1 Z
old_eventsr r r r@ ] s,
�
zKqueueSelector.selectc s | j �� tt| ��� d S r )r� rB rL r� r rP r r rB z s
zKqueueSelector.close)N)Nr� r r rP r r� - s
r� c C sP z2| dkr t �� }|�d� ntt | �� �� W dS ttfyJ Y dS 0 dS )a
Checks that select structs can be allocated by the underlying
operating system, not just advertised by the select module. We don't
check select() because we'll be hopeful that most platforms that
don't have it available will not advertise it. (ie: GAE) ri r TFN)r@ ri rc rB �OSErrorr* )�struct�pr r r �
_can_allocate� s r� )� � c O s | |i |��S )zy This is the short-circuit version of the below logic
because in Python 3.5+ all selectors restart system calls. r )�funcrI �args�kwargsr r r rV � s rV c
O sN |� dd�}|du r d}d}n t|�}|dk r4d}n
t� | }t|�}|rZd|vrZtd��t}|tu �rJz| |i |��}W q^ tttj f�yF } z�d}t
|d�r�|j }nt
|d�r�|j d }|t j
kp�t
t d �o�|t jk} | �r0|du�r$t� }
|
|k�rtt jd
��|�r$d|v �r$||
|d< W Y d}~q^� W Y d}~q^d}~0 0 q^|S ) z� Wrapper function for syscalls that could fail due to EINTR.
All functions should be retried if there is time left in the timeout
in accordance with PEP 475. r? NFrT z4Timeout must be in args or kwargs to be recalculatedr8 r� r �WSAEINTRzConnection timed out)�getr� � monotonicr� r, �_SYSCALL_SENTINELr� �IOErrorr@ r7 �hasattrr8 r� ZEINTRr� Z ETIMEDOUT) r� Zrecalc_timeoutr� r� r? Zexpiresru �eZerrcodeZ is_interruptZ current_timer r r rV � sJ
�
�
c C sj t du rdtjrta nPtd�r"ta nBtd�r0ta n4td�r>ta n&td�rLta nt t
d�r\t a nt d��t � S )z� This function serves as a first call for DefaultSelector to
detect if the select module is being monkey-patched incorrectly
by eventlet, greenlet, and preserve proper behavior. Nr� r� r{ ri r@ z"Platform does not have a selector.)
�_DEFAULT_SELECTORr �isjythonr` r� r� r� r| rj r� r@ rK rD r r r r r � s
r )1r& Z
__future__r � collectionsr8 rr r@ r6 �sys�time� r �
namedtuple�Mappingr� r* �
__author__Z __email__� __version__Z __license__Z__url__�__all__r r r� �objectr� r� r� r7 r� r r r- r r� rK rX r� r_ r` rj r| r� r� r� � version_inforV r r r r r �<module> sp
0
8
3
A
;
Q
8