관리-도구
편집 파일: _selectors2.cpython-39.pyc
a �)g�[ � @ s( d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z z ej Z W n e e fyn ejZ Y n0 dZ dZdZdZg d�Zd Zd Zd Ze� ZG d d � d e�Zdd� Zejdkr�dd� Zndd� Zedg d��Z G dd� de �Z G dd� de�Z e ed��r"G dd � d e �Z e�!d � e ed ��rHG d d � d e �Z"e�!d � e ed ��rnG d!d"� d"e �Z#e�!d"� e ed#��r�G d$d%� d%e �Z$e�!d%� e ed&��r�G d'd(� d(e �Z%e�!d(� d(e&� v �r�e%Z'nXd%e&� v �r�e$Z'nFd"e&� v �r�e#Z'n4d e&� v �re"Z'n"d e&� v �re Z'nd)d*� Z(e(Z'd+ZdS ),� N)� namedtuple)�MappingzSeth Michael Larsonz sethmichaellarson@protonmail.comz1.1.1ZMIT)� EVENT_READ� EVENT_WRITE� SelectorError� SelectorKey�DefaultSelector� � Tc s, e Zd Z� fdd�Zdd� Zdd� Z� ZS )r c s t t| ��� || _d S �N)�superr �__init__�errno)�self�errcode�� __class__� �K/usr/lib/python3.9/site-packages/ansible/module_utils/compat/_selectors2.pyr 8 s zSelectorError.__init__c C s d� | j�S )Nz<SelectorError errno={0}>)�formatr �r r r r �__repr__< s zSelectorError.__repr__c C s | � � S r )r r r r r �__str__? s zSelectorError.__str__)�__name__� __module__� __qualname__r r r � __classcell__r r r r r 7 s r c C sb t | t�r| }n8zt| �� �}W n& tttfyF td�| ���Y n0 |dk r^td�|���|S )zl Return a file descriptor from a file object. If given an integer will simply return that integer back. zInvalid file object: {0!r}r z Invalid file descriptor: {0})� isinstance�int�fileno�AttributeError� TypeError� ValueErrorr )�fileobj�fdr r r �_fileobj_to_fdC s r% )� � c O st z| |i |��W S t ttjfyn } z>d}t|d�r>|j}nt|d�rR|jd }t|��W Y d}~n d}~0 0 dS )zy This is the short-circuit version of the below logic because in Python 3.5+ all selectors restart system calls. Nr �argsr )�OSError�IOError�select�error�hasattrr r( r )�func�_r( �kwargs�er r r r �_syscall_wrapperT s r2 c O s\ |� dd�}|du r d}d}n t|�}|dk r4d}n t� | }t|�}|rZd|vrZtd��t}|tu �rXz| |i |��}W q^ tttj f�yT } z�d}t |d�r�|j }nt |d�r�|j d }|t j kp�t t d �o�|t jk} | �r.|du�r"t� } | |k�rtt j��|�r"d|v �r"|| |d< W Y d}~q^|�r>t|��n� W Y d}~q^d}~0 0 q^|S ) z� Wrapper function for syscalls that could fail due to EINTR. All functions should be retried if there is time left in the timeout in accordance with PEP 475. �timeoutNF� z4Timeout must be in args or kwargs to be recalculatedr r( r �WSAEINTR)�get�float� monotonic�listr" �_SYSCALL_SENTINELr) r* r+ r, r- r r( ZEINTRr5 Z ETIMEDOUTr ) r. Zrecalc_timeoutr( r0 r3 Zexpires�resultr1 r Z is_interruptZ current_timer r r r2 a sN � � r )r# r$ �events�datac @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) �_SelectorMappingz* Mapping of file objects to selector keys c C s || _ d S r )� _selector)r �selectorr r r r � s z_SelectorMapping.__init__c C s t | jj�S r )�lenr? � _fd_to_keyr r r r �__len__� s z_SelectorMapping.__len__c C s@ z| j �|�}| j j| W S ty: td�|���Y n0 d S )Nz{0!r} is not registered.)r? �_fileobj_lookuprB �KeyErrorr )r r# r$ r r r � __getitem__� s z _SelectorMapping.__getitem__c C s t | jj�S r )�iterr? rB r r r r �__iter__� s z_SelectorMapping.__iter__N)r r r �__doc__r rC rF rH r r r r r> � s r> c @ sv e Zd ZdZdd� Zdd� Zddd�Zd d � Zd d d �Zd d d�Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� ZdS ) � BaseSelectora/ Abstract Selector class A selector supports registering file objects to be monitored for specific I/O events. A file object is a file descriptor or any object with a `fileno()` method. An arbitrary object can be attached to the file object which can be used for example to store context info, a callback, etc. A selector can use various implementations (select(), poll(), epoll(), and kqueue()) depending on the platform. The 'DefaultSelector' class uses the most efficient implementation for the current platform. c C s i | _ t| �| _d S r )rB r> �_mapr r r r r � s zBaseSelector.__init__c C sL z t |�W S tyF | j�� D ] }|j|u r"|j Y S q"� Y n0 dS )aa Return a file descriptor from a file object. This wraps _fileobj_to_fd() to do an exhaustive search in case the object is invalid but we still have it in our map. Used by unregister() so we can unregister an object that was previously registered even if it is closed. It is also used by _SelectorMapping N)r% r" rB �valuesr# r$ �r r# �keyr r r rD � s z BaseSelector._fileobj_lookupNc C sb |r|t tB @ r td�|���t|| �|�||�}|j| jv rRtd�||j���|| j|j< |S )z8 Register a file object for a set of events to monitor. zInvalid events: {0!r}z${0!r} (FD {1}) is already registered) r r r" r r rD r$ rB rE �r r# r< r= rN r r r �register� s � zBaseSelector.registerc C s� z| j �| �|��}W n� ty6 td�|���Y np tjy� } zV|jtjkrV� n:| j � � D ] }|j |u r`| j �|j � q�q`td�|���W Y d}~n d}~0 0 |S )z0 Unregister a file object from being monitored. �{0!r} is not registeredN) rB �poprD rE r �socketr, r �EBADFrL r# r$ )r r# rN �errr r r � unregister� s $zBaseSelector.unregisterc C s� z| j | �|� }W n ty4 td�|���Y n0 ||jkrZ| �|� | �|||�}n"||jkr||j|d�}|| j |j < |S )z< Change a registered file object monitored events and data. rQ )r= ) rB rD rE r r< rV rP r= �_replacer$ rO r r r �modify� s zBaseSelector.modifyc C s t � �dS )zj Perform the actual selection until some monitored file objects are ready or the timeout expires. N)�NotImplementedError)r r3 r r r r+ s zBaseSelector.selectc C s | j �� d| _dS )zd Close the selector. This must be called to ensure that all underlying resources are freed. N)rB �clearrK r r r r �close s zBaseSelector.closec C sH | � � }|du rtd��z || W S tyB td�|���Y n0 dS )z: Return the key associated with a registered file object. NzSelector is closedrQ )�get_map� RuntimeErrorrE r )r r# �mappingr r r �get_key s zBaseSelector.get_keyc C s | j S )z3 Return a mapping of file objects to selector keys )rK r r r r r\ $ s zBaseSelector.get_mapc C s& z | j | W S ty Y dS 0 dS )z_ Return the key associated to a given file descriptor Return None if it is not found. N)rB rE )r r$ r r r � _key_from_fd( s zBaseSelector._key_from_fdc C s | S r r r r r r � __enter__0 s zBaseSelector.__enter__c G s | � � d S r )r[ )r r( r r r �__exit__3 s zBaseSelector.__exit__)N)N)N)r r r rI r rD rP rV rX r+ r[ r_ r\ r` ra rb r r r r rJ � s rJ r+ c sN e Zd ZdZ� fdd�Zd � fdd� Z� fdd�Zdd d �Zdd d �Z� Z S )�SelectSelectorz Select-based selector. c s" t t| ��� t� | _t� | _d S r )r rc r �set�_readers�_writersr r r r r ; s zSelectSelector.__init__Nc sD t t| ��|||�}|t@ r*| j�|j� |t@ r@| j�|j� |S r ) r rc rP r re �addr$ r rf rO r r r rP @ s zSelectSelector.registerc s0 t t| ��|�}| j�|j� | j�|j� |S r )r rc rV re �discardr$ rf rM r r r rV H s zSelectSelector.unregisterc C s t � ||g |�S )z? Wrapper for select.select because timeout is a positional arg )r+ )r �r�wr3 r r r �_selectN s zSelectSelector._selectc C s� t | j�st | j�sg S |d u r$d nt|d�}g }t| jd| j| j|d�\}}}t|�}t|�}||B D ]J}d}||v r�|tO }||v r�|tO }| � |�}|rh|� |||j @ f� qh|S )Nr4 T�r3 r ) rA re rf �maxr2 rk rd r r r` �appendr< ) r r3 �readyri rj r/ r$ r< rN r r r r+ R s& � zSelectSelector.select)N)N)N) r r r rI r rP rV rk r+ r r r r r rc 9 s rc �pollc sN e Zd ZdZ� fdd�Zd � fdd� Z� fdd�Zdd d �Zdd d �Z� Z S )� PollSelectorz Poll-based selector c s t t| ��� t�� | _d S r )r rq r r+ rp �_pollr r r r r o s zPollSelector.__init__Nc sP t t| ��|||�}d}|t@ r*|tjO }|t@ r<|tjO }| j�|j |� |S �Nr ) r rq rP r r+ �POLLINr �POLLOUTrr r$ )r r# r< r= rN � event_maskr r r rP s s zPollSelector.registerc s" t t| ��|�}| j�|j� |S r )r rq rV rr r$ rM r r r rV } s zPollSelector.unregisterc C s4 |dur$|dkrd}nt �|d �}| j�|�}|S �zj Wrapper function for select.poll.poll() so that _syscall_wrapper can work with only seconds. Nr � @�@)�math�ceilrr rp �r r3 r; r r r � _wrap_poll� s zPollSelector._wrap_pollc C st g }t | jd|d�}|D ]V\}}d}|tj @ r8|tO }|tj @ rL|tO }| �|�}|r|�|||j @ f� q|S �NTrl r � r2 r| r+ rt r ru r r` rn r< �r r3 ro � fd_eventsr$ rv r< rN r r r r+ � s zPollSelector.select)N)N)N) r r r rI r rP rV r| r+ r r r r r rq m s rq �epollc sX e Zd ZdZ� fdd�Zdd� Zd� fdd� Z� fd d �Zdd d �Z� fd d�Z � Z S )� EpollSelectorz Epoll-based selector c s t t| ��� t�� | _d S r )r r� r r+ r� �_epollr r r r r � s zEpollSelector.__init__c C s | j �� S r )r� r r r r r r � s zEpollSelector.filenoNc sT t t| ��|||�}d}|t@ r*|tjO }|t@ r<|tjO }t| j jd|j |� |S )Nr F) r r� rP r r+ �EPOLLINr �EPOLLOUTr2 r� r$ )r r# r< r= rN Z events_maskr r r rP � s zEpollSelector.registerc s> t t| ��|�}zt| jjd|j� W n ty8 Y n0 |S )NF)r r� rV r2 r� r$ r rM r r r rV � s zEpollSelector.unregisterc C s� |d ur2|dkrd}nt �|d �d }t|�}nd}tt| j�d�}g }t| jjd||d�}|D ]V\}}d}|t j @ r�|t O }|t j @ r�|t O }| �|�}|rb|�|||j@ f� qb|S ) Nr r4 rx g����MbP?g �r T)r3 Z maxevents)ry rz r7 rm rA rB r2 r� rp r+ r� r r� r r` rn r< ) r r3 � max_eventsro r� r$ rv r< rN r r r r+ � s, � zEpollSelector.selectc s | j �� tt| ��� d S r )r� r[ r r� r r r r r[ � s zEpollSelector.close)N)N) r r r rI r r rP rV r+ r[ r r r r r r� � s !r� �devpollc sb e Zd ZdZ� fdd�Zdd� Zd� fdd� Z� fd d �Zdd d �Zdd d�Z � fdd�Z � Z S )�DevpollSelectorzSolaris /dev/poll selector.c s t t| ��� t�� | _d S r )r r� r r+ r� �_devpollr r r r r � s zDevpollSelector.__init__c C s | j �� S r )r� r r r r r r � s zDevpollSelector.filenoNc sP t t| ��|||�}d}|t@ r*|tjO }|t@ r<|tjO }| j�|j |� |S rs ) r r� rP r r+ rt r ru r� r$ )r r# r< r= rN Z poll_eventsr r r rP � s zDevpollSelector.registerc s" t t| ��|�}| j�|j� |S r )r r� rV r� r$ rM r r r rV � s zDevpollSelector.unregisterc C s4 |dur$|dkrd}nt �|d �}| j�|�}|S rw )ry rz r� rp r{ r r r r| s zDevpollSelector._wrap_pollc C st g }t | jd|d�}|D ]V\}}d}|tj @ r8|tO }|tj @ rL|tO }| �|�}|r|�|||j @ f� q|S r} r~ r r r r r+ s zDevpollSelector.selectc s | j �� tt| ��� d S r )r� r[ r r� r r r r r[ s zDevpollSelector.close)N)N)N) r r r rI r r rP rV r| r+ r[ r r r r r r� � s r� �kqueuec s` e Zd ZdZ� fdd�Zdd� Zd� fdd� Z� fd d �Zdd d �Z� fd d�Z dd� Z � Z S )�KqueueSelectorz Kqueue / Kevent-based selector c s t t| ��� t�� | _d S r )r r� r r+ r� �_kqueuer r r r r ) s zKqueueSelector.__init__c C s | j �� S r )r� r r r r r r - s zKqueueSelector.filenoNc sx t t| ��|||�}|t@ rDt�|jtjtj�}t | j d|gdd� |t @ rtt�|jtj tj�}t | j d|gdd� |S �NFr ) r r� rP r r+ �keventr$ �KQ_FILTER_READZ KQ_EV_ADDr2 � _wrap_controlr �KQ_FILTER_WRITE)r r# r< r= rN r� r r r rP 0 s ��zKqueueSelector.registerc s� t t| ��|�}|jt@ rZt�|jtjtj �}zt | j d|gdd� W n t yX Y n0 |jt @ r�t�|jtjtj �}zt | j d|gdd� W n t y� Y n0 |S r� )r r� rV r< r r+ r� r$ r� Z KQ_EV_DELETEr2 r� r r r� )r r# rN r� r r r rV B s( � � zKqueueSelector.unregisterc C s� |d urt |d�}t| j�d }i }t| jdd ||d�}|D ]�}|j}|j}d}|tjkrb|t O }|tj krt|t O }| � |�} | r<| j |vr�| || j@ f|| j < q<|| j d } | || B | j@ f|| j < q<t|�� �S )Nr r Trl r )rm rA rB r2 r� �ident�filterr+ r� r r� r r` r$ r< r9 rL ) r r3 r� Z ready_fdsZ kevent_listr� r$ rv r< rN Z old_eventsr r r r+ W s, � zKqueueSelector.selectc s | j �� tt| ��� d S r )r� r[ r r� r r r r r[ t s zKqueueSelector.closec C s | j �|||�S r )r� Zcontrol)r Z changelistr� r3 r r r r� x s z KqueueSelector._wrap_control)N)N) r r r rI r r rP rV r+ r[ r� r r r r r r� ' s r� c C s t d��d S )Nz!Platform does not have a selector)r" )r/ r r r � no_selector� s r� F))r ry r+ rS �sys�time� collectionsr Z/ansible.module_utils.common._collections_compatr r8 r � ImportError� __author__Z __email__� __version__Z __license__�__all__r r Z HAS_SELECT�objectr: � Exceptionr r% � version_infor2 r r> rJ r- rc rn rq r� r� r� �globalsr r� r r r r �<module> sr 8 0 3 A ; T