관리-도구
편집 파일: selectors.cpython-39.opt-2.pyc
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