← Back
Editing: selectors.cpython-35.opt-2.pyc
���]�K � @ 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 d e _ e j d* k r� d e j _ d e j _ d e j _ d e j _ Gd d � d e � Z Gd d � d d e �Z Gd d � d e � Z Gd d � d e � Z e e d � rKGd d � d e � Z e e d � rpGd d! � d! e � Z e e d" � r�Gd# d$ � d$ e � Z e e d% � r�Gd& d' � d' e � Z d' e � k r�e Z nN d! e � k r�e Z n6 d$ e � k re Z n d e � k re 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 �./opt/alt/python35/lib64/python3.5/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 Z d Z d d � Z d d � Z d d � Z d d � Z d S) �_SelectorMappingc C s | | _ d S)N)� _selector)�self�selectorr r r �__init__> s z_SelectorMapping.__init__c C s t | j j � S)N)�lenr � _fd_to_key)r r r r �__len__A 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__D s z _SelectorMapping.__getitem__c C s t | j j � S)N)�iterr r )r r r r �__iter__K s z_SelectorMapping.__iter__N)�__name__� __module__� __qualname__r r r" r$ r r r r r ; 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 �register^ s zBaseSelector.registerc C s t � d S)N)r) )r r r r r � unregisteru 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 r0 � 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/ r3 r0 r4 r6 r r r r r( O 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 r; 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 r; 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 r; r r r r, � s z_BaseSelectorImpl.modifyc C s | j j � d | _ d S)N)r �clearr9 )r r r r r/ s z_BaseSelectorImpl.closec C s | j S)N)r9 )r r r r r0 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/ r0 rA r r r r r8 � s r8 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)rC r* r< rE �addr r= rF )r r r r r; )rG r r r* * s zSelectSelector.registerc s< t � j | � } | j j | j � | j j | j � | S)N)rC r+ rE �discardr rF )r r r; )rG r r r+ 2 s zSelectSelector.unregister�win32c C s2 t j | | | | � \ } } } | | | g f S)N)r. )r �r�w�_r- �xr r r �_select9 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 ) �maxrO rE rF �InterruptedErrorrD r< r= rA �appendr ) r r- �readyrK rL rM r r r; r r r r. ? s$ !+ zSelectSelector.select) r% r& r' r r* r+ �sys�platformrO r. r r )rG r rB " s rB �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)rC r r. rV �_poll)r )rG r r r Z s zPollSelector.__init__Nc sf t � j | | | � } d } | t @r5 | t j O} | t @rL | t j O} | j j | j | � | S)Nr ) rC r* r< r. �POLLINr= �POLLOUTrX r )r r r r r; � poll_events)rG r r r* ^ s zPollSelector.registerc s) t � j | � } | j j | j � | S)N)rC r+ rX r )r r r; )rG r r r+ h 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�ceilrX rV rQ r. rY r= rZ r< rA rR r )r r- rS � fd_event_listr �eventr r; r r r r. m s( zPollSelector.select)r% r& r' r r* r+ r. r r )rG r rW W s rW �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)rC r r. r` �_epoll)r )rG r r r � s zEpollSelector.__init__c C s | j j � S)N)rb r )r r r r r � s zEpollSelector.filenoNc s� t � j | | | � } d } | t @r5 | t j O} | t @rL | t j O} y | j j | j | � Wn% t k r� t � j | � � Yn X| S)Nr ) rC r* r< r. �EPOLLINr= �EPOLLOUTrb r � BaseExceptionr+ )r r r r r; � epoll_events)rG r r r* � s zEpollSelector.registerc sB t � j | � } y | j j | j � Wn t k r= Yn X| S)N)rC r+ rb r �OSError)r r r; )rG 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?���)r\ r] rP r r rb rV rQ r. rc r= rd r< rA rR r ) r r- �max_evrS r^ r r_ r r; r r r r. � s* zEpollSelector.selectc s | j j � t � j � d S)N)rb r/ rC )r )rG r r r/ � s zEpollSelector.close) r% r& r' r r r* r+ r. r/ r r )rG r ra � s ra �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)rC r r. rj �_devpoll)r )rG r r r � s zDevpollSelector.__init__c C s | j j � S)N)rl 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 ) rC r* r< r. rY r= rZ rl r )r r r r r; r[ )rG r r r* � s zDevpollSelector.registerc s) t � j | � } | j j | j � | S)N)rC r+ rl r )r r r; )rG 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 @�@) r\ r] rl rV rQ r. rY r= rZ r< rA rR r )r r- rS r^ r r_ r r; r r r r. � s( zDevpollSelector.selectc s | j j � t � j � d S)N)rl r/ rC )r )rG r r r/ s zDevpollSelector.close) r% r& r' r r r* r+ r. r/ r r )rG r rk � s rk �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)rC r r. rm �_kqueue)r )rG r r r s zKqueueSelector.__init__c C s | j j � S)N)ro r )r r r r r s zKqueueSelector.filenoNc s� t � j | | | � } y� | t @r\ 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 � Wn% t k r� t � j | � � Yn X| S)Nr )rC r* r< r. �keventr �KQ_FILTER_READZ KQ_EV_ADDro �controlr= �KQ_FILTER_WRITEre r+ )r r r r r; �kev)rG 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 )rC r+ r r< r. rp r rq Z KQ_EV_DELETEro rr rg r= rs )r r r; rt )rG 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 )rP r r ro rr rQ �ident�filterr. rq r< rs r= rA rR r ) r r- ri rS Zkev_listrt r �flagr r; r r r r. < s& ! zKqueueSelector.selectc s | j j � t � j � d S)N)ro r/ rC )r )rG r r r/ R s zKqueueSelector.close) r% r& r' r r r* r+ r. r/ r r )rG r rn s rn r � )r r ) �abcr r � collectionsr r r\ r. rT r< r= r r �__doc__� version_infor r r r r r( r8 rB �hasattrrW ra rk rn �globals�DefaultSelectorr r r r �<module> sF ~U31G8M
Save File
Cancel