ВђВВђВВђВВђВВђВВђВВђВВђВВђВВђВВђВВђВВђВВђВВђВВђВВђВВђВ U Ўк,aЃHг@sўddlmZmZddlmZddlmZddlZddlZddl Z dZ dZdd„Zed d ddd gѓZ de _e jdkr’de j_de j_de j_de j_Gdd„deѓZGdd„dedЌZGdd„deѓZGdd„deѓZGdd„deѓZeedѓrюGd d!„d!eѓZeed"ѓђrGd#d$„d$eѓZeed%ѓђr6Gd&d'„d'eѓZeed(ѓђrRGd)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 Csft|tѓr|}ntd |Ўѓd‚YnXdS©Nъ{!r} is not registered)rЪ_fileobj_lookuprЪKeyErrorr)rrrrrrЪ__getitem__Es z_SelectorMapping.__getitem__cCst|jjѓSr)Ъiterrrr rrrЪ__iter__Lsz_SelectorMapping.__iter__N)Ъ__name__Ъ __module__Ъ__qualname__rr!r&r(rrrrr<src@sjeZdZeddd„ѓZedd„ѓZddd„Zeddd „ѓZd d„Zdd „Z edd„ѓZ dd„Zdd„ZdS)ЪBaseSelectorNcCst‚dSr©ЪNotImplementedError©rrrrrrrЪregister_szBaseSelector.registercCst‚dSrr-)rrrrrЪ unregistervszBaseSelector.unregistercCs| |Ў| |||ЎSr)r1r0r/rrrЪmodify‰s zBaseSelector.modifycCst‚dSrr-)rЪtimeoutrrrЪselectљszBaseSelector.selectcCsdSrrr rrrЪcloseszBaseSelector.closecCsL| Ў}|dkrtdѓ‚z ||WStk rFtd |Ўѓd‚YnXdS)NzSelector is closedr#)Ъget_mapЪRuntimeErrorr%r)rrЪmappingrrrЪget_keyґs zBaseSelector.get_keycCst‚dSrr-r rrrr6ВszBaseSelector.get_mapcCs|Srrr rrrЪ __enter__ЗszBaseSelector.__enter__cGs| ЎdSr)r5)rЪargsrrrЪ__exit__КszBaseSelector.__exit__)N)N)N) r)r*r+rr0r1r2r4r5r9r6r:r<rrrrr,Ps r,)Ъ metaclassc@sPeZdZdd„Zdd„Zddd„Zdd „Zdd d„Zdd „Zdd„Z dd„Z dS)Ъ_BaseSelectorImplcCsi|_t|ѓ|_dSr)rrЪ_mapr rrrrСsz_BaseSelectorImpl.__init__cCsNz t|ѓWStk rH|j ЎD]}|j|kr$|jYSq$‚YnXdSr)rr rЪvaluesrr©rrЪkeyrrrr$Чs z!_BaseSelectorImpl._fileobj_lookupNcCsb|r|ttB@r td |Ўѓ‚t|| |Ў||ѓ}|j|jkrRtd ||jЎѓ‚||j|j<|S)NzInvalid events: {!r}z"{!r} (FD {}) is already registered) Ъ EVENT_READЪEVENT_WRITEr rrr$rrr%©rrrrrBrrrr0кsяz_BaseSelectorImpl.registercCs@z|j | |ЎЎ}Wn$tk r:td |Ўѓd‚YnX|Sr")rЪpopr$r%rrArrrr1чs z_BaseSelectorImpl.unregistercCs„z|j| |Ў}Wn$tk r8td |Ўѓd‚YnX||jkr^| |Ў| |||Ў}n"||jkrЂ|j|dЌ}||j|j <|S)Nr#)r) rr$r%rrr1r0rЪ_replacerrErrrr2юs z_BaseSelectorImpl.modifycCs|j Ўd|_dSr)rЪclearr?r rrrr5s z_BaseSelectorImpl.closecCs|jSr)r?r rrrr6sz_BaseSelectorImpl.get_mapcCs(z|j|WStk r"YdSXdSr)rr%)rrrrrЪ_key_from_fds z_BaseSelectorImpl._key_from_fd)N)N)r)r*r+rr$r0r1r2r5r6rIrrrrr>Оs r>cs\eZdZ‡fdd„Zd ‡fdd„ Z‡fdd„ZejdkrDdd d „Zne j Zddd„Z ‡Z S)ЪSelectSelectorcstѓ Ўtѓ|_tѓ|_dSr)ЪsuperrЪsetЪ_readersЪ_writersr ©Ъ __class__rrr%s zSelectSelector.__init__Ncs@tѓ |||Ў}|t@r&|j |jЎ|t@r<|j |jЎ|Sr)rKr0rCrMЪaddrrDrNrErOrrr0*szSelectSelector.registercs,tѓ |Ў}|j |jЎ|j |jЎ|Sr)rKr1rMЪdiscardrrNrArOrrr12szSelectSelector.unregisterZwin32cCs$t ||||Ў\}}}|||gfSr)r4)rЪrЪwЪ_r3ЪxrrrЪ_select9szSelectSelector._selectc Csє|dkrdnt|dѓ}g}z| |j|jg|Ў\}}}Wntk rP|YSXt|ѓ}t|ѓ}||BD]J}d}||kr‚|tO}||kr’|tO}| |Ў}|rj| |||j @fЎqj|S©Nr)ЪmaxrWrMrNЪInterruptedErrorrLrCrDrIЪappendr) rr3ЪreadyrSrTrUrrrBrrrr4?s$ zSelectSelector.select)N)N)N)r)r*r+rr0r1ЪsysЪplatformrWr4Ъ __classcell__rrrOrrJ"s rJcsZeZdZdZdZdZ‡fdd„Zd‡fdd„ Z‡fdd„Zd ‡fdd „ Z dd d„Z ‡ZS)Ъ_PollLikeSelectorNcstѓ Ў| Ў|_dSr)rKrЪ _selector_clsrr rOrrr[s z_PollLikeSelector.__init__csltѓ |||Ў}d}|t@r&||jO}|t@r8||jO}z|j |j|ЎWntѓ |Ў‚YnX|SrX) rKr0rCЪ_EVENT_READrDЪ_EVENT_WRITErrr1)rrrrrBZ poller_eventsrOrrr0_s z_PollLikeSelector.registercs8tѓ |Ў}z|j |jЎWntk r2YnX|Sr)rKr1rrЪOSErrorrArOrrr1msz_PollLikeSelector.unregistercsФz|j| |Ў}Wn$tk r8t|›dќѓd‚YnXd}||jkr¤d}|t@r^||jO}|t@rp||jO}z|j |j |ЎWntѓ |Ў‚YnXd}||j krІd}|rР|j||dЌ}||j|j <|S)Nz is not registeredFrT)rr)rr$r%rrCrbrDrcrr2rrKr1rrG)rrrrrBZchangedZselector_eventsrOrrr2ws. z_PollLikeSelector.modifycCsё|dkrd}n|dkrd}nt |dЎ}g}z|j |Ў}Wntk rV|YSX|D]V\}}d}||j@r||tO}||j@rђ|tO}| |Ў}|r\| |||j@fЎq\|S)Nrз@Џ@)ЪmathЪceilrЪpollrZrbrDrcrCrIr[r)rr3r\Ъ fd_event_listrЪeventrrBrrrr4’s( z_PollLikeSelector.select)N)N)N)r)r*r+rarbrcrr0r1r2r4r_rrrOrr`Us r`rhc@seZdZejZejZejZ dS)ЪPollSelectorN) r)r*r+r4rhraЪPOLLINrbЪPOLLOUTrcrrrrrk±srkЪepollcs@eZdZejZejZejZ dd„Z ddd„Z‡fdd„Z‡ZS) Ъ EpollSelectorcCs |j ЎSr©rr r rrrr АszEpollSelector.filenoNc CsО|dkrd}n |dkrd}nt |dЎd}tt|jѓdѓ}g}z|j ||Ў}Wntk rl|YSX|D]V\}}d}|tj @r’|t O}|tj@r¦|tO}| |Ў}|rr| |||j@fЎqr|S)Nйяяяяrregь©сТMbP?r)rfrgrYrrrrhrZr4ЪEPOLLINrDЪEPOLLOUTrCrIr[r) rr3Ъmax_evr\rirrjrrBrrrr4Гs* zEpollSelector.selectcs|j Ўtѓ ЎdSr©rr5rKr rOrrr5гs zEpollSelector.close)N) r)r*r+r4rnrarrrbrsrcr r5r_rrrOrroєs roЪdevpollcs6eZdZejZejZejZ dd„Z ‡fdd„Z‡ZS)ЪDevpollSelectorcCs |j ЎSrrpr rrrr рszDevpollSelector.filenocs|j Ўtѓ ЎdSrrur rOrrr5уs zDevpollSelector.close) r)r*r+r4rvrarlrbrmrcr r5r_rrrOrrwкs rwЪkqueuecsTeZdZ‡fdd„Zdd„Zd‡fdd„ Z‡fdd „Zdd d„Z‡fdd „Z‡Z S)ЪKqueueSelectorcstѓ Ўt Ў|_dSr)rKrr4rxrr rOrrrэs zKqueueSelector.__init__cCs |j ЎSrrpr rrrr szKqueueSelector.filenoNcsђtѓ |||Ў}z`|t@r@t |jtjtjЎ}|j |gddЎ|t @rnt |jtjtjЎ}|j |gddЎWntѓ |Ў‚YnX|SrX) rKr0rCr4ЪkeventrЪKQ_FILTER_READZ KQ_EV_ADDrЪcontrolrDЪKQ_FILTER_WRITEr1)rrrrrBЪkevrOrrr0s яяzKqueueSelector.registercs¤tѓ |Ў}|jt@rVt |jtjtjЎ}z|j |gddЎWntk rTYnX|jt@r t |jtj tjЎ}z|j |gddЎWntk rћYnX|SrX)rKr1rrCr4rzrr{ZKQ_EV_DELETErr|rdrDr})rrrBr~rOrrr1s$ я яzKqueueSelector.unregisterc Cs¶|dkrdnt|dѓ}t|jѓ}g}z|j d||Ў}Wntk rP|YSX|D]Z}|j}|j}d}|tj kr||t O}|tjkrЋ|tO}| |Ў} | rV| | || j@fЎqV|SrX)rYrrrr|rZZidentЪfilterr4r{rCr}rDrIr[r) rr3rtr\Zkev_listr~rЪflagrrBrrrr4)s& zKqueueSelector.selectcs|j Ўtѓ ЎdSrrur rOrrr5?s zKqueueSelector.close)N)N) r)r*r+rr r0r1r4r5r_rrrOrryъs ry) ЪabcrrЪcollectionsrZcollections.abcrrfr4r]rCrDrrЪ__doc__Ъversion_inforrrrrr,r>rJr`ЪhasattrrkrorwryЪglobalsZDefaultSelectorrrrrЪsJ ~T3Z .M