ikan Uploader :
Directory : /opt/alt/python37/lib64/python3.7/__pycache__/
Upload File : |
| Current File : //opt/alt/python37/lib64/python3.7/__pycache__/selectors.cpython-37.opt-2.pyc |
B
YI~d�H � @ s� d dl mZmZ d dlmZ d dlmZ d dlZd dlZd dl Z dZ
dZ dd� Z ed d
d d d
g�Z
de
_e jdkr�de
j_de
j_de
j_de
j_G dd� de�ZG dd� ded�ZG dd� de�ZG dd � d e�ZG d d � d e�Zeed �r�G d d!� d!e�Zeed"��rG d#d$� d$e�Zeed%��r6G d&d'� d'e�Z eed(��rRG d)d*� d*e�Z d*e � k�rde Z n:d$e � k�rveZ n(d'e � k�r�e Z nd!e � k�r�eZ neZ dS )+� )�ABCMeta�abstractmethod)�
namedtuple)�MappingN� � c
C sf t | t�r| }n<yt| �� �}W n* tttfk
rJ td�| ��d �Y nX |dk rbtd�|���|S )NzInvalid file object: {!r}r zInvalid file descriptor: {})�
isinstance�int�fileno�AttributeError� TypeError�
ValueError�format)�fileobj�fd� r �./opt/alt/python37/lib64/python3.7/selectors.py�_fileobj_to_fd s
r � SelectorKeyr 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)�selfZselectorr r r �__init__? s z_SelectorMapping.__init__c C s t | jj�S )N)�lenr �
_fd_to_key)r r r r �__len__B s z_SelectorMapping.__len__c C sB y| j �|�}| j j| S tk
r< td�|��d �Y nX d S )Nz{!r} is not registered)r �_fileobj_lookupr �KeyErrorr )r r r r r r � __getitem__E s
z _SelectorMapping.__getitem__c C s t | jj�S )N)�iterr r )r r r r �__iter__L 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 )N)�NotImplementedError)r r r r r r r �register_ s zBaseSelector.registerc C s t �d S )N)r) )r r r r r �
unregisterv s zBaseSelector.unregisterc C s | � |� | �|||�S )N)r+ r* )r r r r r r r �modify� s
zBaseSelector.modifyc C s t �d S )N)r) )r �timeoutr r r �select� s zBaseSelector.selectc C s d S )Nr )r r r r �close� s zBaseSelector.closec C sJ | � � }|d krtd��y|| S tk
rD td�|��d �Y nX d S )NzSelector is closedz{!r} is not registered)�get_map� RuntimeErrorr! r )r r �mappingr r r �get_key� s zBaseSelector.get_keyc C s t �d S )N)r) )r r r r r0 � s zBaseSelector.get_mapc C s | S )Nr )r r r r � __enter__� s zBaseSelector.__enter__c G s | � � d S )N)r/ )r �argsr r r �__exit__� s zBaseSelector.__exit__)N)N)N)
r% r& r' r r* r+ r, r. r/ r3 r0 r4 r6 r r r r r( P 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 )N)r r �_map)r r r r r � s z_BaseSelectorImpl.__init__c C sH yt |�S tk
rB x"| j�� D ]}|j|kr$|jS q$W � Y nX d S )N)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| jkrRtd�||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 r; r r r r* � s z_BaseSelectorImpl.registerc C s@ y| j �| �|��}W n$ tk
r: td�|��d �Y nX |S )Nz{!r} is not registered)r �popr r! r )r r r; r r r r+ � s
z _BaseSelectorImpl.unregisterc C s� y| j | �|� }W n$ tk
r8 td�|��d �Y nX ||jkr^| �|� | �|||�}n"||jkr�|j|d�}|| j |j < |S )Nz{!r} is not registered)r )
r r r! r r r+ r* r �_replacer )r r r r r; r r r r, � s
z_BaseSelectorImpl.modifyc C s | j �� d | _d S )N)r �clearr9 )r r r r r/ s
z_BaseSelectorImpl.closec C s | j S )N)r9 )r r r r r0 s z_BaseSelectorImpl.get_mapc C s$ y
| j | S tk
r d S X d S )N)r r! )r r r r r � _key_from_fd s
z _BaseSelectorImpl._key_from_fd)N)N) r% r& r' r r r* r+ r, r/ r0 rA r r r r r8 � s
r8 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 )N)�superr �set�_readers�_writers)r )� __class__r r r % s
zSelectSelector.__init__Nc s@ t � �|||�}|t@ r&| j�|j� |t@ r<| j�|j� |S )N)rC r* r< rE �addr r= rF )r r r r r; )rG r r r* * s zSelectSelector.registerc s, t � �|�}| j�|j� | j�|j� |S )N)rC r+ rE �discardr rF )r r r; )rG r r r+ 2 s zSelectSelector.unregister�win32c C s$ t � ||||�\}}}||| g fS )N)r. )r �r�w�_r- �xr r r �_select9 s zSelectSelector._selectc C s� |d kr d nt |d�}g }y | �| j| jg |�\}}}W n tk
rL |S X t|�}t|�}xV||B D ]J}d}||kr�|tO }||kr�|tO }| �|�}|rh|� |||j
@ f� qhW |S )Nr ) �maxrO rE rF �InterruptedErrorrD r< r= rA �appendr ) r r- �readyrK rL rM r r r; r r r r. ? s$
zSelectSelector.select)N)N)N) r% r& r' r r* r+ �sys�platformrO r. �
__classcell__r r )rG r rB " s
rB c sZ e Zd ZdZdZdZ� fdd�Zd � fdd� Z� fdd�Zd
� fdd � Z dd
d �Z
� Z S )�_PollLikeSelectorNc s t � �� | �� | _d S )N)rC r �
_selector_clsr )r )rG r r r [ s
z_PollLikeSelector.__init__c sl t � �|||�}d}|t@ r&|| jO }|t@ r8|| jO }y| j�|j|� W n t � �|� � Y nX |S )Nr ) rC r* r< � _EVENT_READr= � _EVENT_WRITEr r r+ )r r r r r; Z
poller_events)rG r r r* _ s
z_PollLikeSelector.registerc s8 t � �|�}y| j�|j� W n tk
r2 Y nX |S )N)rC r+ r r �OSError)r r r; )rG r r r+ m s z _PollLikeSelector.unregisterc s� y| j | �|� }W n$ tk
r8 t|�d��d �Y nX d}||jkr�d}|t@ r^|| jO }|t@ rp|| jO }y| j� |j
|� W n t � � |� � Y nX d}||j
kr�d}|r�|j||d�}|| j |j
< |S )Nz is not registeredFr T)r r )r r r! r r< rY r= rZ r r, r rC r+ r r? )r r r r r; ZchangedZselector_events)rG r r r, w s.
z_PollLikeSelector.modifyc C s� |d krd }n |dkr d}nt �|d �}g }y| j�|�}W n tk
rR |S X x^|D ]V\}}d}|| j @ rz|tO }|| j @ r�|tO }| � |�}|rZ|�
|||j @ f� qZW |S )Nr g @�@) �math�ceilr �pollrQ rY r= rZ r< rA rR r )r r- rS �
fd_event_listr �eventr r; r r r r. � s(
z_PollLikeSelector.select)N)N)N) r% r& r' rX rY rZ r r* r+ r, r. rV r r )rG r rW U s
rW r^ c @ s e Zd ZejZejZejZ dS )� PollSelectorN)
r% r& r' r. r^ rX �POLLINrY �POLLOUTrZ r r r r ra � s ra �epollc s@ e Zd ZejZejZejZ dd� Z
ddd�Z� fdd�Z � Z S ) �
EpollSelectorc C s
| j �� S )N)r r
)r r r r r
� s zEpollSelector.filenoNc C s� |d krd}n |dkr d}nt �|d �d }tt| j�d�}g }y| j�||�}W n tk
rh |S X x^|D ]V\}}d}|tj @ r�|t
O }|tj @ r�|t O }| �
|�}|rp|�|||j@ f� qpW |S )N���r g @�@g����MbP?r )r\ r] rP r r r r^ rQ r. �EPOLLINr= �EPOLLOUTr< rA rR r ) r r- �max_evrS r_ r r` r r; r r r r. � s*
zEpollSelector.selectc s | j �� t� �� d S )N)r r/ rC )r )rG r r r/ � s
zEpollSelector.close)N)
r% r& r' r. rd rX rg rY rh rZ r
r/ rV r r )rG r re � s
re �devpollc s6 e Zd ZejZejZejZ dd� Z
� fdd�Z � Z S )�DevpollSelectorc C s
| j �� S )N)r r
)r r r r r
� s zDevpollSelector.filenoc s | j �� t� �� d S )N)r r/ rC )r )rG r r r/ � s
zDevpollSelector.close)
r% r& r' r. rj rX rb rY rc rZ r
r/ rV r r )rG r rk � s
rk �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 )N)rC r r. rl r )r )rG r r r � s
zKqueueSelector.__init__c C s
| j �� S )N)r r
)r r r r r
s zKqueueSelector.filenoNc s� t � �|||�}y`|t@ r@t�|jtjtj�}| j� |gdd� |t
@ rnt�|jtj tj�}| j� |gdd� W n t � � |� � Y nX |S )Nr )
rC r* r< r. �keventr �KQ_FILTER_READZ KQ_EV_ADDr �controlr= �KQ_FILTER_WRITEr+ )r r r r r; �kev)rG r r r* s zKqueueSelector.registerc s� t � �|�}|jt@ rVt�|jtjtj�}y| j �
|gdd� W n t k
rT Y nX |jt @ r�t�|jtj
tj�}y| j �
|gdd� W n t k
r� Y nX |S )Nr )rC r+ r r< r. rn r ro Z KQ_EV_DELETEr rp r[ r= rq )r r r; rr )rG r r r+ s
zKqueueSelector.unregisterc
C s� |d kr d nt |d�}t| j�}g }y| j�d ||�}W n tk
rL |S X xb|D ]Z}|j}|j}d}|tj krz|t
O }|tj kr�|t O }| �
|�} | rT|�| || j@ f� qTW |S )Nr )rP r r r rp rQ Zident�filterr. ro r< rq r= rA rR r )
r r- ri rS Zkev_listrr r �flagr r; r r r r. ) s&
zKqueueSelector.selectc s | j �� t� �� d S )N)r r/ rC )r )rG r r r/ ? s
zKqueueSelector.close)N)N)
r% r& r' r r
r* r+ r. r/ rV r r )rG r rm � s
rm ) �abcr r � collectionsr Zcollections.abcr r\ r. rT r< r= r r �__doc__� version_infor r r r r r( r8 rB rW �hasattrra re rk rm �globalsZDefaultSelectorr r r r �<module> sJ
~T3Z
. M
........