a
R�fPL � @ s� d dl mZmZ d dlmZ d dlmZ d dlZd dlZd dl Z dZ
dZ dd� Z ed g d
��Z
d e
_e jd kr�d
e
j_de
j_de
j_de
j_G dd� de�ZG dd� ded�ZG dd� de�ZG dd� de�ZG dd� de�Zeed �r�G d d � d e�Zeed ��rG d d!� d!e�Zeed"��r2G d#d$� d$e�Z eed%��rNG d&d'� d'e�Z d(d)� Z e d%��rfe Z n4e d ��rveZ n$e d"��r�e Z ne d ��r�eZ neZ dS )*� )�ABCMeta�abstractmethod)�
namedtuple)�MappingN� � c
C sd t | t�r| }n:zt| �� �}W n( tttfyH td�| ��d �Y n0 |dk r`td�|���|S )NzInvalid file object: {!r}r zInvalid file descriptor: {})�
isinstance�int�fileno�AttributeError� TypeError�
ValueError�format)�fileobj�fd� r �./opt/alt/python39/lib64/python3.9/selectors.py�_fileobj_to_fd s
��r � SelectorKey)r r �events�dataz�SelectorKey(fileobj, fd, events, data)
Object used to associate a file object to its backing
file descriptor, selected event mask, and attached data.
)� � zFile object registered.zUnderlying file descriptor.z3Events that must be waited for on this file object.zzOptional opaque data associated to this file object.
For example, this could be used to store a per-client session ID.c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�_SelectorMappingc C s
|| _ d S �N)� _selector)�self�selectorr r r �__init__@ s z_SelectorMapping.__init__c C s t | jj�S r )�lenr �
_fd_to_key�r r r r �__len__C s z_SelectorMapping.__len__c C sB z| j �|�}| j j| W S ty< td�|��d �Y n0 d S �N�{!r} is not registered)r �_fileobj_lookupr �KeyErrorr )r r r r r r � __getitem__F s
z _SelectorMapping.__getitem__c C s t | jj�S r )�iterr r r! r r r �__iter__M s z_SelectorMapping.__iter__N)�__name__�
__module__� __qualname__r r" r' r) r r r r r = s r c @ sj e Zd Zeddd��Zedd� �Zddd�Zeddd ��Zd
d � Zd d
� Z edd� �Z
dd� Z dd� Z dS )� BaseSelectorNc C s t �d S r ��NotImplementedError�r r r r r r r �register` s zBaseSelector.registerc C s t �d S r r. )r r r r r �
unregisterw s zBaseSelector.unregisterc C s | � |� | �|||�S r )r2 r1 r0 r r r �modify� s
zBaseSelector.modifyc C s t �d S r r. )r �timeoutr r r �select� s zBaseSelector.selectc C s d S r r r! r r r �close� s zBaseSelector.closec C sJ | � � }|d u rtd��z
|| W S tyD td�|��d �Y n0 d S )NzSelector is closedr$ )�get_map� RuntimeErrorr& r )r r �mappingr r r �get_key� s
zBaseSelector.get_keyc C s t �d S r r. r! r r r r7 � s zBaseSelector.get_mapc C s | S r r r! r r r � __enter__� s zBaseSelector.__enter__c G s | � � d S r )r6 )r �argsr r r �__exit__� s zBaseSelector.__exit__)N)N)N)
r* r+ r, r r1 r2 r3 r5 r6 r: r7 r; r= r r r r r- Q s
r- )� metaclassc @ sP e Zd Zdd� Zdd� Zddd�Zdd � Zdd
d �Zd d
� Zdd� Z dd� Z
dS )�_BaseSelectorImplc C s i | _ t| �| _d S r )r r �_mapr! r r r r � s z_BaseSelectorImpl.__init__c C sL z
t |�W S tyF | j�� D ] }|j|u r"|j Y S q"� Y n0 d S r )r r
r �valuesr r �r r �keyr r r r% � s
z!_BaseSelectorImpl._fileobj_lookupNc C sb |r|t tB @ r td�|���t|| �|�||�}|j| jv rRtd�||j���|| j|j< |S )NzInvalid events: {!r}z"{!r} (FD {}) is already registered) �
EVENT_READ� EVENT_WRITEr
r r r% r r r& �r r r r rC r r r r1 � s � z_BaseSelectorImpl.registerc C s> z| j �| �|��}W n" ty8 td�|��d �Y n0 |S r# )r �popr% r& r rB r r r r2 � s
z _BaseSelectorImpl.unregisterc C s� z| j | �|� }W n" ty6 td�|��d �Y n0 ||jkr\| �|� | �|||�}n"||jkr~|j|d�}|| j |j < |S )Nr$ )r )
r r% r& r r r2 r1 r �_replacer rF r r r r3 � s
z_BaseSelectorImpl.modifyc C s | j �� d | _d S r )r �clearr@ r! r r r r6
s
z_BaseSelectorImpl.closec C s | j S r )r@ r! r r r r7 s z_BaseSelectorImpl.get_mapc C s& z | j | W S ty Y d S 0 d S r )r r& )r r r r r � _key_from_fd s z _BaseSelectorImpl._key_from_fd)N)N) r* r+ r, r r% r1 r2 r3 r6 r7 rJ r r r r r? � s
r? c s\ e Zd Z� fdd�Zd
� fdd� Z� fdd�ZejdkrDdd d
�Zne j Zdd d �Z � Z
S )�SelectSelectorc s t � �� t� | _t� | _d S r )�superr �set�_readers�_writersr! �� __class__r r r & s
zSelectSelector.__init__Nc s@ t � �|||�}|t@ r&| j�|j� |t@ r<| j�|j� |S r )rL r1 rD rN �addr rE rO rF rP r r r1 + s zSelectSelector.registerc s, t � �|�}| j�|j� | j�|j� |S r )rL r2 rN �discardr rO rB rP r r r2 3 s zSelectSelector.unregisterZwin32c C s$ t � ||||�\}}}||| g fS r )r5 )r �r�w�_r4 �xr r r �_select: s zSelectSelector._selectc C s� |d u r d nt |d�}g }z | �| j| jg |�\}}}W n tyN | Y S 0 t|�}t|�}||B D ]J}d}||v r�|tO }||v r�|tO }| �|�}|rh|� |||j
@ f� qh|S �Nr ) �maxrX rN rO �InterruptedErrorrM rD rE rJ �appendr ) r r4 �readyrT rU rV r r rC r r r r5 @ s$
zSelectSelector.select)N)N)N) r* r+ r, r r1 r2 �sys�platformrX r5 �
__classcell__r r rP r rK # s
rK c sZ e Zd ZdZdZdZ� fdd�Zd � fdd� Z� fdd�Zd
� fdd � Z dd
d �Z
� Z S )�_PollLikeSelectorNc s t � �� | �� | _d S r )rL r �
_selector_clsr r! rP r r r \ s
z_PollLikeSelector.__init__c sl t � �|||�}d}|t@ r&|| jO }|t@ r8|| jO }z| j�|j|� W n t � �|� � Y n0 |S rY ) rL r1 rD � _EVENT_READrE � _EVENT_WRITEr r r2 )r r r r rC Z
poller_eventsrP r r r1 ` s
z_PollLikeSelector.registerc s6 t � �|�}z| j�|j� W n ty0 Y n0 |S r )rL r2 r r �OSErrorrB rP r r r2 n s z _PollLikeSelector.unregisterc s� z| j | �|� }W n" ty6 t|�d��d �Y n0 d}||jkr�d}|t@ r\|| jO }|t@ rn|| jO }z| j� |j
|� W n t � � |� � Y n0 d}||j
kr�d}|r�|j||d�}|| j |j
< |S )Nz is not registeredFr T)r r )r r% r& r rD rc rE rd r r3 r rL r2 r rH )r r r r rC ZchangedZselector_eventsrP r r r3 x s.
z_PollLikeSelector.modifyc C s� |d u rd }n |dkr d}nt �|d �}g }z| j�|�}W n tyT | Y S 0 |D ]V\}}d}|| j @ rz|tO }|| j @ r�|tO }| � |�}|rZ|�
|||j @ f� qZ|S )Nr � @�@) �math�ceilr �pollr[ rc rE rd rD rJ r\ r )r r4 r] �
fd_event_listr �eventr rC r r r r5 � s(
z_PollLikeSelector.select)N)N)N) r* r+ r, rb rc rd r r1 r2 r3 r5 r` r r rP r ra V s
ra ri c @ s e Zd ZejZejZejZ dS )� PollSelectorN)
r* r+ r, r5 ri rb �POLLINrc �POLLOUTrd r r r r rl � s rl �epollc s@ e Zd ZejZejZejZ dd� Z
ddd�Z� fdd�Z � Z S ) �
EpollSelectorc C s
| j �� S r �r r
r! r r r r
� s zEpollSelector.filenoNc C s� |d u rd}n |dkr d}nt �|d �d }tt| j�d�}g }z| j�||�}W n tyj | Y S 0 |D ]V\}}d}|tj @ r�|t
O }|tj @ r�|t O }| �
|�}|rp|�|||j@ f� qp|S )N���r rf g����MbP?r )rg rh rZ r r r ri r[ r5 �EPOLLINrE �EPOLLOUTrD rJ r\ r ) r r4 �max_evr] rj r rk r rC r r r r5 � s*
zEpollSelector.selectc s | j �� t� �� d S r �r r6 rL r! rP r r r6 � s
zEpollSelector.close)N)
r* r+ r, r5 ro rb rs rc rt rd r
r6 r` r r rP r rp � s
rp �devpollc s6 e Zd ZejZejZejZ dd� Z
� fdd�Z � Z S )�DevpollSelectorc C s
| j �� S r rq r! r r r r
� s zDevpollSelector.filenoc s | j �� t� �� d S r rv r! rP r r r6 � s
zDevpollSelector.close)
r* r+ r, r5 rw rb rm rc rn rd r
r6 r` r r rP r rx � s
rx �kqueuec sT e Zd Z� fdd�Zdd� Zd� fdd� Z� fdd �Zdd
d �Z� fd d
�Z� Z S )�KqueueSelectorc s t � �� t�� | _d S r )rL r r5 ry r r! rP r r r � s
zKqueueSelector.__init__c C s
| j �� S r rq r! r r r r
s zKqueueSelector.filenoNc s� t � �|||�}z`|t@ r@t�|jtjtj�}| j� |gdd� |t
@ rnt�|jtj tj�}| j� |gdd� W n t � � |� � Y n0 |S rY )
rL r1 rD r5 �keventr �KQ_FILTER_READZ KQ_EV_ADDr �controlrE �KQ_FILTER_WRITEr2 )r r r r rC �kevrP r r r1 s � � zKqueueSelector.registerc s� t � �|�}|jt@ rTt�|jtjtj�}z| j �
|gdd� W n t yR Y n0 |jt @ r�t�|jtj
tj�}z| j �
|gdd� W n t y� Y n0 |S rY )rL r2 r rD r5 r{ r r| Z KQ_EV_DELETEr r} re rE r~ )r r rC r rP r r r2 s$
�
� zKqueueSelector.unregisterc
C s� |d u r d nt |d�}t t| j�d�}g }z| j�d ||�}W n tyT | Y S 0 |D ]Z}|j}|j}d}|tj kr�|t
O }|tj kr�|t O }| �
|�} | rZ|�| || j@ f� qZ|S )Nr r )rZ r r r r} r[ Zident�filterr5 r| rD r~ rE rJ r\ r )
r r4 ru r] Zkev_listr r �flagr rC r r r r5 * s&
zKqueueSelector.selectc s | j �� t� �� d S r rv r! rP r r r6 C s
zKqueueSelector.close)N)N)
r* r+ r, r r
r1 r2 r5 r6 r` r r rP r rz � s
rz c C sZ t t| d �}|d u rdS z(|� }| dkr4|�d� n|�� W dS tyT Y dS 0 d S )NFri r T)�getattrr5 ri r6 re )�methodr Z selector_objr r r �_can_useH s r� ) �abcr r � collectionsr �collections.abcr rg r5 r^ rD rE r r �__doc__� version_infor r r r r r- r? rK ra �hasattrrl rp rx rz r� ZDefaultSelectorr r r r �<module> sL
~T3Z
. M