← Back
Editing: selectors.cpython-310.opt-2.pyc
o 0�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 krHd 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 �r�G d d!� d!e�Zeed"�r�G d#d$� d$e�Z eed%�r�G d&d'� d'e�Z d(d)� Z e d%�r�e Z dS e d �r�eZ dS e d"�r�e Z dS e d �r�eZ dS eZ dS )*� )�ABCMeta�abstractmethod)� namedtuple)�MappingN� � c C sb t | t�r | }nzt| �� �}W n tttfy# td�| ��d �w |dk r/td�|���|S )NzInvalid file object: {!r}r zInvalid file descriptor: {})� isinstance�int�fileno�AttributeError� TypeError� ValueError�format)�fileobj�fd� r �0/opt/alt/python310/lib64/python3.10/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 Z dd� Zdd� Zdd� Zdd� Zd S ) �_SelectorMappingc C s || _ d S �N)� _selector)�self�selectorr r r �__init__@ � z_SelectorMapping.__init__c C � t | jj�S r )�lenr � _fd_to_key�r r r r �__len__C � z_SelectorMapping.__len__c C s: z | j �|�}| j j| W S ty td�|��d �w �N�{!r} is not registered)r �_fileobj_lookupr" �KeyErrorr )r r r r r r � __getitem__F s �z _SelectorMapping.__getitem__c C r r )�iterr r" r# r r r �__iter__M r% z_SelectorMapping.__iter__N)�__name__� __module__� __qualname__r r$ r* r, r r r r r = s r c @ sl e Zd Z eddd��Zedd� �Zddd�Zeddd ��Zd d � Zd d � Z edd� �Z dd� Z dd� Z dS )� BaseSelectorNc C � t �r ��NotImplementedError�r r r r r r r �register` s zBaseSelector.registerc C r1 r r2 )r r r r r � unregisterw � zBaseSelector.unregisterc C s | � |� | �|||�S r )r6 r5 r4 r r r �modify� s zBaseSelector.modifyc C r1 r r2 )r �timeoutr r r �select� r7 zBaseSelector.selectc C s d S r r r# r r r �close� s zBaseSelector.closec C sD | � � }|d u r td��z|| W S ty! td�|��d �w )NzSelector is closedr' )�get_map� RuntimeErrorr) r )r r �mappingr r r �get_key� s �zBaseSelector.get_keyc C r1 r r2 r# r r r r< � s zBaseSelector.get_mapc C s | S r r r# r r r � __enter__� s zBaseSelector.__enter__c G s | � � d S r )r; )r �argsr r r �__exit__� r% zBaseSelector.__exit__r ) r- r. r/ r r5 r6 r8 r: r; r? r< r@ rB r r r r r0 Q s r0 )� metaclassc @ sR e Zd Z dd� 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 sF zt |�W S ty" | j�� D ]}|j|u r |j Y S q� w r )r r r" �valuesr r �r r �keyr r r r( � s ��z!_BaseSelectorImpl._fileobj_lookupNc C sb |r |t tB @ rtd�|���t|| �|�||�}|j| jv r)td�||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 rH r r r r5 � s � z_BaseSelectorImpl.registerc C s8 z | j �| �|��}W |S ty td�|��d �w r& )r" �popr( r) r rG r r r r6 � s ��z _BaseSelectorImpl.unregisterc C s� z | j | �|� }W n ty td�|��d �w ||jkr-| �|� | �|||�}|S ||jkr>|j|d�}|| j |j < |S )Nr' )r ) r" r( r) r r r6 r5 r �_replacer rK r r r r8 � s � � z_BaseSelectorImpl.modifyc C s | j �� d | _d S r )r" �clearrE r# r r r r; s z_BaseSelectorImpl.closec C s | j S r )rE r# r r r r< s z_BaseSelectorImpl.get_mapc C s$ z| j | W S ty Y d S w r )r" r) )r r r r r � _key_from_fd s �z _BaseSelectorImpl._key_from_fdr ) r- r. r/ r r( r5 r6 r8 r; r< rO r r r r rD � s rD c s^ e Zd Z � fdd�Zd � fdd� Z� fdd�Zejdkr#d d d �Zne j Zd d 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 )rQ r5 rI rS �addr rJ rT rK rU r r r5 + s zSelectSelector.registerc s, t � �|�}| j�|j� | j�|j� |S r )rQ r6 rS �discardr rT rG rU r r r6 3 s zSelectSelector.unregisterZwin32c C s$ t � ||||�\}}}||| g fS r )r: )r �r�w�_r9 �xr r r �_select: s zSelectSelector._selectc C s� |d u rd nt |d�}g }z| �| j| jg |�\}}}W n ty' | Y S w t|�}t|�}||B D ]%}d}||v r@|tO }||v rH|tO }| �|�}|rY|� |||j @ f� q4|S �Nr ) �maxr] rS rT �InterruptedErrorrR rI rJ rO �appendr ) r r9 �readyrY rZ r[ r r rH r r r r: @ s( � �zSelectSelector.selectr ) r- r. r/ r r5 r6 �sys�platformr] r: � __classcell__r r rU r rP # s rP c s\ e Zd Z dZdZdZ� fdd�Zd � fdd� Z� fdd�Zd � fdd � Z d d d �Z � Z S ) �_PollLikeSelectorNc s t � �� | �� | _d S r )rQ r � _selector_clsr r# rU r r r \ � z_PollLikeSelector.__init__c sd t � �|||�}d}|t@ r|| jO }|t@ r || jO }z | j�|j|� W |S t � �|� � r^ ) rQ r5 rI � _EVENT_READrJ � _EVENT_WRITEr r r6 )r r r r rH Z poller_eventsrU r r r5 ` s � z_PollLikeSelector.registerc s6 t � �|�}z | j�|j� W |S ty Y |S w r )rQ r6 r r �OSErrorrG rU r r r6 n s ��z _PollLikeSelector.unregisterc s� z | j | �|� }W n ty t|�d��d �w d}||jkrLd}|t@ r,|| jO }|t@ r5|| jO }z | j� |j |� W n t � � |� � d}||j krSd}|rb|j||d�}|| j |j < |S )Nz is not registeredFr T)r r )r" r( r) r rI ri rJ rj r r8 r rQ r6 r rM )r r r r rH ZchangedZselector_eventsrU r r r8 x s0 � z_PollLikeSelector.modifyc C s� |d u rd }n|dkrd}nt �|d �}g }z| j�|�}W n ty* | Y S w |D ]+\}}d}|| j @ r=|tO }|| j @ rG|tO }| � |�}|rX|� |||j @ f� q-|S )Nr � @�@) �math�ceilr �pollr` ri rJ rj rI rO ra r )r r9 rb � fd_event_listr �eventr rH r r r r: � s, � �z_PollLikeSelector.selectr ) r- r. r/ rg ri rj r r5 r6 r8 r: re r r rU r rf V s rf ro c @ s e Zd Z ejZejZejZ dS )� PollSelectorN) r- r. r/ r: ro rg �POLLINri �POLLOUTrj r r r r rr � s rr �epollc sB e Zd Z ejZejZejZ dd� Z ddd�Z� fdd�Z � Z S ) � EpollSelectorc C � | j �� S r �r r r# r r r r � r zEpollSelector.filenoNc C s� |d u rd}n|dkrd}n t �|d �d }tt| j�d�}g }z | j�||�}W n ty5 | Y S w |D ]+\}}d}|tj @ rH|t O }|tj @ rR|t O }| � |�}|rc|�|||j@ f� q8|S )N���r rl g����MbP?r )rm rn r_ r! r" r ro r` r: �EPOLLINrJ �EPOLLOUTrI rO ra r ) r r9 �max_evrb rp r rq r rH r r r r: � s. � �zEpollSelector.selectc � | j �� t� �� d S r �r r; rQ r# rU r r r; � rh zEpollSelector.closer ) r- r. r/ r: ru rg rz ri r{ rj r r; re r r rU r rv � s rv �devpollc s8 e Zd Z ejZejZejZ dd� Z � fdd�Z � Z S )�DevpollSelectorc C rw r rx r# r r r r � r zDevpollSelector.filenoc r} r r~ r# rU r r r; � rh zDevpollSelector.close) r- r. r/ r: r rg rs ri rt rj r r; re r r rU r r� � s r� �kqueuec sV e Zd Z � fdd�Zdd� Zd� fdd� Z� fdd �Zdd d �Z� fd d �Z� Z S )�KqueueSelectorc s t � �� t�� | _d S r )rQ r r: r� r r# rU r r r � rh zKqueueSelector.__init__c C rw r rx r# r r r r r zKqueueSelector.filenoNc s� t � �|||�}z4|t@ r t�|jtjtj�}| j� |gdd� |t @ r:t�|jtj tj�}| j� |gdd� W |S W |S t � � |� � r^ ) rQ r5 rI r: �keventr �KQ_FILTER_READZ KQ_EV_ADDr �controlrJ �KQ_FILTER_WRITEr6 )r r r r rH �kevrU r r r5 s$ � ��� zKqueueSelector.registerc s� t � �|�}|jt@ r*t�|jtjtj�}z | j � |gdd� W n t y) Y nw |jt @ rPt�|jtj tj�}z | j � |gdd� W |S t yO Y |S w |S r^ )rQ r6 r rI r: r� r r� Z KQ_EV_DELETEr r� rk rJ r� )r r rH r� rU r r r6 s, � � � ��zKqueueSelector.unregisterc C s� |d u rd nt |d�}t t| j�d�}g }z | j�d ||�}W n ty* | Y S w |D ]-}|j}|j}d}|tj kr@|t O }|tj krI|t O }| � |�} | rZ|�| || j@ f� q-|S )Nr r )r_ r! r" r r� r` Zident�filterr: r� rI r� rJ rO ra r ) r r9 r| rb Zkev_listr� r �flagr rH r r r r: * s* � �zKqueueSelector.selectc r} r r~ r# rU r r r; C rh zKqueueSelector.closer ) r- r. r/ r r r5 r6 r: r; re r r rU r r� � s r� c C s\ t t| d �}|d u r dS z|� }| dkr |�d� W dS |�� W dS ty- Y dS w )NFro r T)�getattrr: ro r; rk )�methodr Z selector_objr r r �_can_useH s � �r� ) �abcr r � collectionsr Zcollections.abcr rm r: rc rI rJ r r �__doc__� version_infor r r r r r0 rD rP rf �hasattrrr rv r� r� r� ZDefaultSelectorr r r r �<module> sP ~T3 Z . M
Save File
Cancel