관리-도구
편집 파일: selectors.cpython-35.opt-2.pyc
���\ I � @ s� d d l m Z m Z d d l m Z m Z d d l Z d d l Z d d l Z d! Z d" Z d d � Z e d d d d d g � Z Gd d � d e � Z Gd d � d d e �Z Gd d � d e � Z Gd d � d e � Z e e d � rGd d � d e � Z e e d � r(Gd d � d e � Z e e d � rMGd d � d e � Z e e d � rrGd d � d e � Z d e � k r�e Z nN d e � k r�e Z n6 d e � k r�e Z n d e � k r�e Z n e Z d S)#� )�ABCMeta�abstractmethod)� namedtuple�MappingN� c C s� t | t � r | } nL y t | j � � } Wn3 t t t f k rc t d j | � � d � Yn X| d k r� t d j | � � � | S)NzInvalid file object: {!r}r zInvalid file descriptor: {})� isinstance�int�fileno�AttributeError� TypeError� ValueError�format)�fileobj�fd� r �9/opt/rh/rh-python35/root/usr/lib64/python3.5/selectors.py�_fileobj_to_fd s r � SelectorKeyr r �events�datac @ s@ e Z d Z d d � Z d d � Z d d � Z d d � Z d S) �_SelectorMappingc C s | | _ d S)N)� _selector)�selfZselectorr r r �__init__5 s z_SelectorMapping.__init__c C s t | j j � S)N)�lenr � _fd_to_key)r r r r �__len__8 s z_SelectorMapping.__len__c C sU y$ | j j | � } | j j | SWn* t k rP t d j | � � d � Yn Xd S)Nz{!r} is not registered)r �_fileobj_lookupr �KeyErrorr )r r r r r r � __getitem__; s z _SelectorMapping.__getitem__c C s t | j j � S)N)�iterr r )r r r r �__iter__B s z_SelectorMapping.__iter__N)�__name__� __module__� __qualname__r r r r! r r r r r 2 s r c @ s� e Z d Z e d d d � � Z e d d � � Z d d d � Z e d d d � � Z d d � Z d d � Z e d d � � Z d d � Z d d � Z d S)� BaseSelectorNc C s t � d S)N)�NotImplementedError)r r r r r r r �registerU s zBaseSelector.registerc C s t � d S)N)r& )r r r r r � unregisterl s zBaseSelector.unregisterc C s | j | � | j | | | � S)N)r( r' )r r r r r r r �modify s zBaseSelector.modifyc C s t � d S)N)r& )r �timeoutr r r �select� s zBaseSelector.selectc C s d S)Nr )r r r r �close� s zBaseSelector.closec C sa | j � } | d k r$ t d � � y | | SWn* t k r\ t d j | � � d � Yn Xd S)NzSelector is closedz{!r} is not registered)�get_map� RuntimeErrorr r )r r �mappingr r r �get_key� s zBaseSelector.get_keyc C s t � d S)N)r& )r r r r r- � s zBaseSelector.get_mapc C s | S)Nr )r r r r � __enter__� s zBaseSelector.__enter__c G s | j � d S)N)r, )r �argsr r r �__exit__� s zBaseSelector.__exit__) r" r# r$ r r' r( r) r+ r, r0 r- r1 r3 r r r r r% F s r% � metaclassc @ sv e Z d Z d d � Z d d � Z d d d � Z d d � Z d d d � Z d d � Z d d � Z d d � Z d S)�_BaseSelectorImplc C s i | _ t | � | _ d S)N)r r �_map)r r r r r � s z_BaseSelectorImpl.__init__c C sZ y t | � SWnE t k rU x- | j j � D] } | j | k r. | j Sq. W� Yn Xd S)N)r r r �valuesr r )r r �keyr r r r � s z!_BaseSelectorImpl._fileobj_lookupNc C s� | s | t t B@r+ t d j | � � � t | | j | � | | � } | j | j k rv t d j | | 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 r8 r r r r' � s z_BaseSelectorImpl.registerc C sP y | j j | j | � � } Wn* t k rK t d j | � � d � Yn X| S)Nz{!r} is not registered)r �popr r r )r r r8 r r r r( � s z _BaseSelectorImpl.unregisterc C s� y | j | j | � } Wn* t k rF t d j | � � d � Yn X| | j k r{ | j | � | j | | | � } n1 | | j k r� | j d | � } | | j | j <| S)Nz{!r} is not registeredr ) r r r r r r( r' r �_replacer )r r r r r8 r r r r) � s z_BaseSelectorImpl.modifyc C s | j j � d | _ d S)N)r �clearr6 )r r r r r, s z_BaseSelectorImpl.closec C s | j S)N)r6 )r r r r r- s z_BaseSelectorImpl.get_mapc C s, y | j | SWn t k r' d SYn Xd S)N)r r )r r r r r � _key_from_fd s z _BaseSelectorImpl._key_from_fd) r" r# r$ r r r' r( r) r, r- r> r r r r r5 � s r5 c s� e Z d Z � f d d � Z d � f d d � Z � f d d � Z e j d k rf d d d � Z n e j Z d d d � Z � S) �SelectSelectorc s) t � j � t � | _ t � | _ d S)N)�superr �set�_readers�_writers)r )� __class__r r r s zSelectSelector.__init__Nc sV t � j | | | � } | t @r5 | j j | j � | t @rR | j j | j � | S)N)r@ r' r9 rB �addr r: rC )r r r r r8 )rD r r r' ! s zSelectSelector.registerc s< t � j | � } | j j | j � | j j | j � | S)N)r@ r( rB �discardr rC )r r r8 )rD r r r( ) s zSelectSelector.unregister�win32c C s2 t j | | | | � \ } } } | | | g f S)N)r+ )r �r�w�_r* �xr r r �_select0 s !zSelectSelector._selectc C s� | d k r d n t | d � } g } y+ | j | j | j g | � \ } } } Wn t k rj | SYn Xt | � } t | � } xs | | BD]g } d } | | k r� | t O} | | k r� | t O} | j | � } | r� | j | | | j @f � q� W| S)Nr ) �maxrL rB rC �InterruptedErrorrA r9 r: r> �appendr ) r r* �readyrH rI rJ r r r8 r r r r+ 6 s$ !+ zSelectSelector.select) r" r# r$ r r' r( �sys�platformrL r+ r r )rD r r? s r? �pollc sX e Z d Z � f d d � Z d � f d d � Z � f d d � Z d d d � Z � S) � PollSelectorc s t � j � t j � | _ d S)N)r@ r r+ rS �_poll)r )rD r r r Q s zPollSelector.__init__Nc sf t � j | | | � } d } | t @r5 | t j O} | t @rL | t j O} | j j | j | � | S)Nr ) r@ r' r9 r+ �POLLINr: �POLLOUTrU r )r r r r r8 � poll_events)rD r r r' U s zPollSelector.registerc s) t � j | � } | j j | j � | S)N)r@ r( rU r )r r r8 )rD r r r( _ s zPollSelector.unregisterc C s� | d k r d } n( | d k r* d } n t j | d � } g } y | j j | � } Wn t k rq | SYn Xxy | D]q \ } } d } | t j @r� | t O} | t j @r� | t O} | j | � } | ry | j | | | j @f � qy W| S)Nr g @�@) �math�ceilrU rS rN r+ rV r: rW r9 r> rO r )r r* rP � fd_event_listr �eventr r8 r r r r+ d s( zPollSelector.select)r" r# r$ r r' r( r+ r r )rD r rT N s rT �epollc sv e Z d Z � f d d � Z d d � Z d � f d d � Z � f d d � Z d d d � Z � f d d � Z � S)� EpollSelectorc s t � j � t j � | _ d S)N)r@ r r+ r] �_epoll)r )rD r r r � s zEpollSelector.__init__c C s | j j � S)N)r_ r )r r r r r � s zEpollSelector.filenoNc sf t � j | | | � } d } | t @r5 | t j O} | t @rL | t j O} | j j | j | � | S)Nr ) r@ r' r9 r+ �EPOLLINr: �EPOLLOUTr_ r )r r r r r8 Z epoll_events)rD r r r' � s zEpollSelector.registerc sB t � j | � } y | j j | j � Wn t k r= Yn X| S)N)r@ r( r_ r �OSError)r r r8 )rD r r r( � s zEpollSelector.unregisterc C s | d k r d } n, | d k r* d } n t j | d � d } t t | j � d � } g } y | j j | | � } Wn t k r� | SYn Xxy | D]q \ } } d } | t j @r� | t O} | t j @r� | t O} | j | � } | r� | j | | | j @f � q� W| S)Nr r g @�@g����MbP?���)rY rZ rM r r r_ rS rN r+ r` r: ra r9 r> rO r ) r r* �max_evrP r[ r r\ r r8 r r r r+ � s* zEpollSelector.selectc s | j j � t � j � d S)N)r_ r, r@ )r )rD r r r, � s zEpollSelector.close) r" r# r$ r r r' r( r+ r, r r )rD r r^ � s r^ �devpollc sv e Z d Z � f d d � Z d d � Z d � f d d � Z � f d d � Z d d d � Z � f d d � Z � S)�DevpollSelectorc s t � j � t j � | _ d S)N)r@ r r+ re �_devpoll)r )rD r r r � s zDevpollSelector.__init__c C s | j j � S)N)rg r )r r r r r � s zDevpollSelector.filenoNc sf t � j | | | � } d } | t @r5 | t j O} | t @rL | t j O} | j j | j | � | S)Nr ) r@ r' r9 r+ rV r: rW rg r )r r r r r8 rX )rD r r r' � s zDevpollSelector.registerc s) t � j | � } | j j | j � | S)N)r@ r( rg r )r r r8 )rD r r r( � s zDevpollSelector.unregisterc C s� | d k r d } n( | d k r* d } n t j | d � } g } y | j j | � } Wn t k rq | SYn Xxy | D]q \ } } d } | t j @r� | t O} | t j @r� | t O} | j | � } | ry | j | | | j @f � qy W| S)Nr g @�@) rY rZ rg rS rN r+ rV r: rW r9 r> rO r )r r* rP r[ r r\ r r8 r r r r+ � s( zDevpollSelector.selectc s | j j � t � j � d S)N)rg r, r@ )r )rD r r r, � s zDevpollSelector.close) r" r# r$ r r r' r( r+ r, r r )rD r rf � s rf �kqueuec sv e Z d Z � f d d � Z d d � Z d � f d d � Z � f d d � Z d d d � Z � f d d � Z � S)�KqueueSelectorc s t � j � t j � | _ d S)N)r@ r r+ rh �_kqueue)r )rD r r r s zKqueueSelector.__init__c C s | j j � S)N)rj r )r r r r r s zKqueueSelector.filenoNc s� t � j | | | � } | t @rY t j | j t j t j � } | j j | g d d � | t @r� t j | j t j t j � } | j j | g d d � | S)Nr ) r@ r' r9 r+ �keventr �KQ_FILTER_READZ KQ_EV_ADDrj �controlr: �KQ_FILTER_WRITE)r r r r r8 �kev)rD r r r' s zKqueueSelector.registerc s� t � j | � } | j t @ro t j | j t j t j � } y | j j | g d d � Wn t k rn Yn X| j t @r� t j | j t j t j � } y | j j | g d d � Wn t k r� Yn X| S)Nr )r@ r( r r9 r+ rk r rl Z KQ_EV_DELETErj rm rb r: rn )r r r8 ro )rD r r r( s zKqueueSelector.unregisterc C s� | d k r d n t | d � } t | j � } g } y | j j d | | � } Wn t k rj | SYn Xx� | D] } | j } | j } d } | t j k r� | t O} | t j k r� | t O} | j | � } | rr | j | | | j @f � qr W| S)Nr )rM r r rj rm rN Zident�filterr+ rl r9 rn r: r> rO r ) r r* rd rP Zkev_listro r Zflagr r8 r r r r+ + s& ! zKqueueSelector.selectc s | j j � t � j � d S)N)rj r, r@ )r )rD r r r, A s zKqueueSelector.close) r" r# r$ r r r' r( r+ r, r r )rD r ri s ri r � )�abcr r � collectionsr r rY r+ rQ r9 r: r r r r% r5 r? �hasattrrT r^ rf ri �globalsZDefaultSelectorr r r r �<module> s: ~U31C8I