Lokasi:
/
lib64
/
python3.9
/
__pycache__
/
Ubah: selectors.cpython-39.opt-2.pyc
a �iPL � @ 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 �!/usr/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.unregister�win32c 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 ) �maxrY rN rO �InterruptedErrorrM rD rE rJ �appendr ) r r4 �readyrU rV rW r r rC r r r r5 @ s$ zSelectSelector.select)N)N)N) r* r+ r, r r1 r2 �sys�platformrY 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 rZ ) rL r1 rD � _EVENT_READrE � _EVENT_WRITEr r r2 )r r r r rC � 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 rd rE re r r3 r rL r2 r rH )r r r r rC �changed�selector_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\ rd rE re 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, rc rd re r r1 r2 r3 r5 ra r r rP r rb V s rb rm c @ s e Zd ZejZejZejZ dS )� PollSelectorN) r* r+ r, r5 rm rc �POLLINrd �POLLOUTre r r r r rp � s rp �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 rj g����MbP?r )rk rl r[ r r r rm r\ r5 �EPOLLINrE �EPOLLOUTrD rJ r] r ) r r4 �max_evr^ rn r ro 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 rs rc rw rd rx re r r6 ra r r rP r rt � s rt �devpollc s6 e Zd ZejZejZejZ dd� Z � fdd�Z � Z S )�DevpollSelectorc C s | j �� S r ru r! r r r r � s zDevpollSelector.filenoc s | j �� t� �� d S r rz r! rP r r r6 � s zDevpollSelector.close) r* r+ r, r5 r{ rc rq rd rr re r r6 ra r r rP r r| � s r| �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 r} r r! rP r r r � s zKqueueSelector.__init__c C s | j �� S r ru 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 rZ ) 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 rZ )rL r2 r rD r5 r r r� Z KQ_EV_DELETEr r� rg 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 )r[ r r r r� r\ �ident�filterr5 r� rD r� rE rJ r] r ) r r4 ry r^ Zkev_listr� r �flagr rC r r r r5 * s& zKqueueSelector.selectc s | j �� t� �� d S r rz r! rP r r r6 C s zKqueueSelector.close)N)N) r* r+ r, r r r1 r2 r5 r6 ra r r rP r r~ � s r~ c C sZ t t| d �}|d u rdS z(|� }| dkr4|�d� n|�� W dS tyT Y dS 0 d S )NFrm r T)�getattrr5 rm r6 rg )�methodr � selector_objr r r �_can_useH s r� ) �abcr r � collectionsr �collections.abcr rk r5 r_ rD rE r r �__doc__� version_infor r r r r r- r? rK rb �hasattrrp rt r| r~ r� �DefaultSelectorr r r r �<module> sL ~T3Z . M
Batal