OwlCyberSecurity - MANAGER
Edit File: selectors.cpython-38.opt-2.pyc
U ����e5d�H����������������������@���s���d�dl�mZmZ�d�dlmZ�d�dlmZ�d�dlZd�dlZd�dl Z dZ dZdd��Zed d ddd g�Z de _e jdkr�de 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%��r6G�d&d'��d'e�Zeed(��rRG�d)d*��d*e�Zd*e��k�rdeZn:d$e��k�rveZn(d'e��k�r�eZnd!e��k�r�eZneZdS�)+�����)�ABCMeta�abstractmethod)� namedtuple)�MappingN��������c�������������� ���C���sf���t�|�t�r|�}n<zt|�����}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����!/usr/lib64/python3.8/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�r���)�lenr���� _fd_to_key�r���r���r���r����__len__B���s����z_SelectorMapping.__len__c�����������������C���sD���z|�j��|�}|�j�j|�W�S��tk r>���td�|��d��Y�nX�d�S��N�{!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�r���)�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��Zdd ��Z edd���Z dd��Zdd��ZdS�)�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���� unregisterv���s����zBaseSelector.unregisterc�����������������C���s���|���|��|��|||�S�r���)r1���r0���r/���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���sL���|�����}|d�krtd��z ||�W�S��tk rF���td�|��d��Y�nX�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���r6�������s����zBaseSelector.get_mapc�����������������C���s���|�S�r���r���r ���r���r���r���� __enter__����s����zBaseSelector.__enter__c�����������������G���s���|������d�S�r���)r5���)r����argsr���r���r����__exit__����s����zBaseSelector.__exit__)N)N)N) r)���r*���r+���r���r0���r1���r2���r4���r5���r9���r6���r:���r<���r���r���r���r���r,���P���s��� r,���)� metaclassc�������������������@���sP���e�Zd�Zdd��Zdd��Zddd�Zdd ��Zdd d�Zdd ��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���sN���z t�|�W�S��tk rH���|�j���D�]}|j|kr$|j���Y�S�q$��Y�nX�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|�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���rB���r���r���r���r0�������s������z_BaseSelectorImpl.registerc�����������������C���s@���z|�j��|��|��}W�n$�tk r:���td�|��d��Y�nX�|S�r"���)r����popr$���r%���r���rA���r���r���r���r1�������s ����z_BaseSelectorImpl.unregisterc�����������������C���s����z|�j�|��|��}W�n$�tk r8���td�|��d��Y�nX�||jkr^|��|��|��|||�}n"||jkr�|j|d�}||�j�|j <�|S�)Nr#���)r���) r���r$���r%���r���r���r1���r0���r����_replacer���rE���r���r���r���r2�������s���� z_BaseSelectorImpl.modifyc�����������������C���s���|�j�����d�|�_d�S�r���)r����clearr?���r ���r���r���r���r5�����s���� z_BaseSelectorImpl.closec�����������������C���s���|�j�S�r���)r?���r ���r���r���r���r6�����s����z_BaseSelectorImpl.get_mapc�����������������C���s(���z|�j�|�W�S��tk r"���Y�d�S�X�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$���r0���r1���r2���r5���r6���rI���r���r���r���r���r>�������s��� r>���c�����������������������s\���e�Zd�Z��fdd�Zd ��fdd� Z��fdd�ZejdkrDdd d �Zne j Zddd�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���)rK���r0���rC���rM����addr���rD���rN���rE���rO���r���r���r0���*��s����zSelectSelector.registerc��������������������s,���t����|�}|�j�|j��|�j�|j��|S�r���)rK���r1���rM����discardr���rN���rA���rO���r���r���r1���2��s����zSelectSelector.unregisterZwin32c�����������������C���s$���t���||||�\}}}|||�g�fS�r���)r4���)r����r�w�_r3����xr���r���r����_select9��s����zSelectSelector._selectc����������� ������C���s����|d�krd�nt�|d�}g�}z|��|�j|�jg�|�\}}}W�n�tk rP���|�Y�S�X�t|�}t|�}||B�D�]J}d}||kr�|tO�}||kr�|tO�}|��|�}|rj|� |||j @�f��qj|S��Nr���)�maxrW���rM���rN����InterruptedErrorrL���rC���rD���rI����appendr���) r���r3����readyrS���rT���rU���r���r���rB���r���r���r���r4���?��s$���� zSelectSelector.select)N)N)N)r)���r*���r+���r���r0���r1����sys�platformrW���r4���� __classcell__r���r���rO���r���rJ���"��s��� rJ���c�����������������������sZ���e�Zd�ZdZdZdZ��fdd�Zd��fdd� Z��fdd�Zd ��fdd � Z dd d�Z ���ZS�)�_PollLikeSelectorNc��������������������s���t�������|����|�_d�S�r���)rK���r���� _selector_clsr���r ���rO���r���r���r���[��s���� z_PollLikeSelector.__init__c��������������������sl���t����|||�}d}|t@�r&||�jO�}|t@�r8||�jO�}z|�j�|j|��W�n���t����|����Y�nX�|S�rX���) rK���r0���rC����_EVENT_READrD����_EVENT_WRITEr���r���r1���)r���r���r���r���rB���Z poller_eventsrO���r���r���r0���_��s���� z_PollLikeSelector.registerc��������������������s8���t����|�}z|�j�|j��W�n�tk r2���Y�nX�|S�r���)rK���r1���r���r����OSErrorrA���rO���r���r���r1���m��s����z_PollLikeSelector.unregisterc��������������������s����z|�j�|��|��}W�n$�tk r8���t|�d��d��Y�nX�d}||jkr�d}|t@�r^||�jO�}|t@�rp||�jO�}z|�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���rC���rb���rD���rc���r���r2���r���rK���r1���r���rG���)r���r���r���r���rB���ZchangedZselector_eventsrO���r���r���r2���w��s.���� z_PollLikeSelector.modifyc�����������������C���s����|d�krd�}n|dkrd}nt��|d��}g�}z|�j�|�}W�n�tk rV���|�Y�S�X�|D�]V\}}d}||�j�@�r||tO�}||�j�@�r�|tO�}|�� |�}|r\|� |||j@�f��q\|S�)Nr���������@�@)�math�ceilr����pollrZ���rb���rD���rc���rC���rI���r[���r���)r���r3���r\���� fd_event_listr����eventr���rB���r���r���r���r4������s(���� z_PollLikeSelector.select)N)N)N)r)���r*���r+���ra���rb���rc���r���r0���r1���r2���r4���r_���r���r���rO���r���r`���U��s��� r`���rh���c�������������������@���s���e�Zd�ZejZejZejZ dS�)�PollSelectorN) r)���r*���r+���r4���rh���ra����POLLINrb����POLLOUTrc���r���r���r���r���rk������s���rk����epollc�����������������������s@���e�Zd�ZejZejZejZ dd��Z ddd�Z��fdd�Z���ZS�) � EpollSelectorc�����������������C���s ���|�j����S�r����r���r ���r ���r���r���r���r ������s����zEpollSelector.filenoNc����������� ������C���s����|d�krd}n |dkrd}nt��|d��d�}tt|�j�d�}g�}z|�j�||�}W�n�tk rl���|�Y�S�X�|D�]V\}}d}|tj �@�r�|t O�}|tj�@�r�|tO�}|�� |�}|rr|�|||j@�f��qr|S�)N���r���re���g����MbP?r���)rf���rg���rY���r���r���r���rh���rZ���r4����EPOLLINrD����EPOLLOUTrC���rI���r[���r���) r���r3����max_evr\���ri���r���rj���r���rB���r���r���r���r4������s*���� zEpollSelector.selectc��������������������s���|�j�����t������d�S�r����r���r5���rK���r ���rO���r���r���r5������s���� zEpollSelector.close)N) r)���r*���r+���r4���rn���ra���rr���rb���rs���rc���r ���r5���r_���r���r���rO���r���ro������s��� ro����devpollc�����������������������s6���e�Zd�ZejZejZejZ dd��Z ��fdd�Z���ZS�)�DevpollSelectorc�����������������C���s ���|�j����S�r���rp���r ���r���r���r���r ������s����zDevpollSelector.filenoc��������������������s���|�j�����t������d�S�r���ru���r ���rO���r���r���r5������s���� zDevpollSelector.close) r)���r*���r+���r4���rv���ra���rl���rb���rm���rc���r ���r5���r_���r���r���rO���r���rw������s ���rw����kqueuec�����������������������sT���e�Zd�Z��fdd�Zdd��Zd��fdd� Z��fdd �Zdd d�Z��fdd �Z���Z S�)�KqueueSelectorc��������������������s���t�������t���|�_d�S�r���)rK���r���r4���rx���r���r ���rO���r���r���r������s���� zKqueueSelector.__init__c�����������������C���s ���|�j����S�r���rp���r ���r���r���r���r �����s����zKqueueSelector.filenoNc��������������������s����t����|||�}z`|t@�r@t�|jtjtj�}|�j� |gdd��|t @�rnt�|jtjtj�}|�j� |gdd��W�n���t����|����Y�nX�|S�rX���) rK���r0���rC���r4����keventr����KQ_FILTER_READZ KQ_EV_ADDr����controlrD����KQ_FILTER_WRITEr1���)r���r���r���r���rB����kevrO���r���r���r0�����s ������zKqueueSelector.registerc��������������������s����t����|�}|jt@�rVt�|jtjtj�}z|�j � |gdd��W�n�tk rT���Y�nX�|jt@�r�t�|jtj tj�}z|�j � |gdd��W�n�tk r����Y�nX�|S�rX���)rK���r1���r���rC���r4���rz���r���r{���ZKQ_EV_DELETEr���r|���rd���rD���r}���)r���r���rB���r~���rO���r���r���r1�����s$���� � �zKqueueSelector.unregisterc����������� ������C���s����|d�krd�nt�|d�}t|�j�}g�}z|�j�d�||�}W�n�tk rP���|�Y�S�X�|D�]Z}|j}|j}d}|tj kr||t O�}|tjkr�|tO�}|�� |�} | rV|�| || j@�f��qV|S�rX���)rY���r���r���r���r|���rZ���Zident�filterr4���r{���rC���r}���rD���rI���r[���r���) r���r3���rt���r\���Zkev_listr~���r����flagr���rB���r���r���r���r4���)��s&���� zKqueueSelector.selectc��������������������s���|�j�����t������d�S�r���ru���r ���rO���r���r���r5���?��s���� zKqueueSelector.close)N)N) r)���r*���r+���r���r ���r0���r1���r4���r5���r_���r���r���rO���r���ry������s��� ry���) �abcr���r����collectionsr���Zcollections.abcr���rf���r4���r]���rC���rD���r���r����__doc__�version_infor���r���r���r���r���r,���r>���rJ���r`����hasattrrk���ro���rw���ry����globalsZDefaultSelectorr���r���r���r����<module>���sJ��� ~T3Z .M