آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ 3 \îKم@sٹddlmZmZddlmZmZddlZddlZddlZd(Z d)Z dd„Zeddd d dgƒZde_ ejd*krٹdej_ dej_ dej_ dej_ Gdd„deƒZGdd„dedچZGdd„deƒZGdd„deƒZeedƒrوGdd„deƒZeedƒگrGd d!„d!eƒZeed"ƒگrGd#d$„d$eƒZeed%ƒگr:Gd&d'„d'eƒZd'eƒkگrLeZn:d!eƒkگr^eZn(d$eƒkگrpeZndeƒkگr‚eZneZdS)+é)عABCMetaعabstractmethod)ع namedtupleعMappingNéc Csft|tƒr|}nsz_SelectorMapping.__init__cCst|jjƒS)N)عlenrع _fd_to_key)rrrrع__len__Asz_SelectorMapping.__len__cCsBy|jj|ƒ}|jj|Stk r<tdj|ƒƒd‚YnXdS)Nz{!r} is not registered)rع_fileobj_lookuprعKeyErrorr )rrrrrrع__getitem__Ds z_SelectorMapping.__getitem__cCst|jjƒS)N)عiterrr)rrrrع__iter__Ksz_SelectorMapping.__iter__N)ع__name__ع __module__ع__qualname__rrr!r#rrrrr;src@sjeZdZeddd„ƒZedd„ƒZddd„Zeddd „ƒZd d„Zdd „Z edd„ƒZ dd„Zdd„ZdS)عBaseSelectorNcCst‚dS)N)عNotImplementedError)rrrrrrrعregister^szBaseSelector.registercCst‚dS)N)r()rrrrrع unregisteruszBaseSelector.unregistercCs|j|ƒ|j|||ƒS)N)r*r))rrrrrrrعmodifyˆs zBaseSelector.modifycCst‚dS)N)r()rعtimeoutrrrعselect™szBaseSelector.selectcCsdS)Nr)rrrrعclose¬szBaseSelector.closecCsJ|jƒ}|dkrtdƒ‚y||Stk rDtdj|ƒƒd‚YnXdS)NzSelector is closedz{!r} is not registered)عget_mapعRuntimeErrorr r )rrعmappingrrrعget_key³szBaseSelector.get_keycCst‚dS)N)r()rrrrr/ءszBaseSelector.get_mapcCs|S)Nr)rrrrع __enter__ئszBaseSelector.__enter__cGs|jƒdS)N)r.)rعargsrrrع__exit__ةszBaseSelector.__exit__)N)N)N) r$r%r&rr)r*r+r-r.r2r/r3r5rrrrr'Os r')ع metaclassc@sPeZdZdd„Zdd„Zddd„Zdd „Zdd d„Zdd „Zdd„Z dd„Z dS)ع_BaseSelectorImplcCsi|_t|ƒ|_dS)N)rrع_map)rrrrrذsz_BaseSelectorImpl.__init__cCsHyt|ƒStk rBx"|jjƒD]}|j|kr$|jSq$W‚YnXdS)N)rrrعvaluesrr)rrعkeyrrrrضs z!_BaseSelectorImpl._fileobj_lookupNcCsd|s|ttB@r"tdj|ƒƒ‚t||j|ƒ||ƒ}|j|jkrTtdj||jƒƒ‚||j|j<|S)NzInvalid events: {!r}z"{!r} (FD {}) is already registered) ع EVENT_READعEVENT_WRITErr rrrrr )rrrrr:rrrr)ész_BaseSelectorImpl.registercCs@y|jj|j|ƒƒ}Wn$tk r:tdj|ƒƒd‚YnX|S)Nz{!r} is not registered)rعpoprr r )rrr:rrrr*ِs z_BaseSelectorImpl.unregistercCs„y|j|j|ƒ}Wn$tk r8tdj|ƒƒd‚YnX||jkr^|j|ƒ|j|||ƒ}n"||jkr€|j|dچ}||j|j <|S)Nz{!r} is not registered)r) rrr r rr*r)rع_replacer)rrrrr:rrrr+‎s z_BaseSelectorImpl.modifycCs|jjƒd|_dS)N)rعclearr8)rrrrr.s z_BaseSelectorImpl.closecCs|jS)N)r8)rrrrr/sz_BaseSelectorImpl.get_mapcCs$y |j|Stk rdSXdS)N)rr )rrrrrع_key_from_fds z_BaseSelectorImpl._key_from_fd)N)N)r$r%r&rrr)r*r+r.r/r@rrrrr7حs r7cs\eZdZ‡fdd„Zd ‡fdd„ Z‡fdd„ZejdkrDdd d „Zne j Zddd„Z ‡Z S)عSelectSelectorcstƒjƒtƒ|_tƒ|_dS)N)عsuperrعsetع_readersع_writers)r)ع __class__rrr%s zSelectSelector.__init__Ncs@tƒj|||ƒ}|t@r&|jj|jƒ|t@r<|jj|jƒ|S)N)rBr)r;rDعaddrr<rE)rrrrr:)rFrrr)*szSelectSelector.registercs,tƒj|ƒ}|jj|jƒ|jj|jƒ|S)N)rBr*rDعdiscardrrE)rrr:)rFrrr*2szSelectSelector.unregisterZwin32cCs$tj||||ƒ\}}}|||gfS)N)r-)rعrعwع_r,عxrrrع_select9szSelectSelector._selectc Cs؛|dkrdnt|dƒ}g}y|j|j|jg|ƒ\}}}Wntk rL|SXt|ƒ}t|ƒ}xV||BD]J}d}||kr€|tO}||krگ|tO}|j|ƒ}|rh|j |||j @fƒqhW|S)Nr)عmaxrMrDrEعInterruptedErrorrCr;r<r@عappendr) rr,عreadyrIrJrKrrr:rrrr-?s$ zSelectSelector.select)N)N)N)r$r%r&rr)r*عsysعplatformrMr-ع __classcell__rr)rFrrA"s rAعpollcs@eZdZ‡fdd„Zd ‡fdd„ Z‡fdd„Zddd „Z‡ZS)عPollSelectorcstƒjƒtjƒ|_dS)N)rBrr-rUع_poll)r)rFrrrZs zPollSelector.__init__NcsLtƒj|||ƒ}d}|t@r&|tjO}|t@r8|tjO}|jj|j|ƒ|S)Nr) rBr)r;r-عPOLLINr<عPOLLOUTrWr)rrrrr:عpoll_events)rFrrr)^s zPollSelector.registercstƒj|ƒ}|jj|jƒ|S)N)rBr*rWr)rrr:)rFrrr*hszPollSelector.unregisterc Cs¸|dkrd}n|dkrd}ntj|dƒ}g}y|jj|ƒ}Wntk rR|SXx^|D]V\}}d}|tj@rz|tO}|tj@rژ|t O}|j |ƒ}|rZ|j|||j@fƒqZW|S)Nrg@ڈ@) عmathعceilrWrUrOr-rXr<rYr;r@rPr)rr,rQع fd_event_listrعeventrr:rrrr-ms( zPollSelector.select)N)N)r$r%r&rr)r*r-rTrr)rFrrVWs rVعepollcsTeZdZ‡fdd„Zdd„Zd‡fdd„ Z‡fdd „Zdd d„Z‡fdd „Z‡Z S)ع EpollSelectorcstƒjƒtjƒ|_dS)N)rBrr-r_ع_epoll)r)rFrrrچs zEpollSelector.__init__cCs |jjƒS)N)rar )rrrrr ‘szEpollSelector.filenoNcsttƒj|||ƒ}d}|t@r&|tjO}|t@r8|tjO}y|jj|j|ƒWn"t k rntƒj |ƒ‚YnX|S)Nr)rBr)r;r-عEPOLLINr<عEPOLLOUTrarع BaseExceptionr*)rrrrr:Zepoll_events)rFrrr)”s zEpollSelector.registercs8tƒj|ƒ}y|jj|jƒWntk r2YnX|S)N)rBr*rarعOSError)rrr:)rFrrr*¢szEpollSelector.unregisterc Csخ|dkrd}n |dkrd}ntj|dƒd}tt|jƒdƒ}g}y|jj||ƒ}Wntk rh|SXx^|D]V\}}d}|tj @rگ|t O}|tj@r¤|tO}|j |ƒ}|rp|j|||j@fƒqpW|S)Nrrg@ڈ@gü©ٌزMbP?éےےےے)r[r\rNrrrarUrOr-rbr<rcr;r@rPr) rr,عmax_evrQr]rr^rr:rrrr-¬s* zEpollSelector.selectcs|jjƒtƒjƒdS)N)rar.rB)r)rFrrr.جs zEpollSelector.close)N)N) r$r%r&rr r)r*r-r.rTrr)rFrr`ٹs r`عdevpollcsTeZdZ‡fdd„Zdd„Zd‡fdd„ Z‡fdd „Zdd d„Z‡fdd „Z‡Z S)عDevpollSelectorcstƒjƒtjƒ|_dS)N)rBrr-rhع_devpoll)r)rFrrrضs zDevpollSelector.__init__cCs |jjƒS)N)rjr )rrrrr عszDevpollSelector.filenoNcsLtƒj|||ƒ}d}|t@r&|tjO}|t@r8|tjO}|jj|j|ƒ|S)Nr) rBr)r;r-rXr<rYrjr)rrrrr:rZ)rFrrr)فs zDevpollSelector.registercstƒj|ƒ}|jj|jƒ|S)N)rBr*rjr)rrr:)rFrrr*çszDevpollSelector.unregisterc Cs¸|dkrd}n|dkrd}ntj|dƒ}g}y|jj|ƒ}Wntk rR|SXx^|D]V\}}d}|tj@rz|tO}|tj@rژ|t O}|j |ƒ}|rZ|j|||j@fƒqZW|S)Nrg@ڈ@) r[r\rjrUrOr-rXr<rYr;r@rPr)rr,rQr]rr^rr:rrrr-ىs( zDevpollSelector.selectcs|jjƒtƒjƒdS)N)rjr.rB)r)rFrrr.s zDevpollSelector.close)N)N) r$r%r&rr r)r*r-r.rTrr)rFrriسs riعkqueuecsTeZdZ‡fdd„Zdd„Zd‡fdd„ Z‡fdd „Zdd d„Z‡fdd „Z‡Z S)عKqueueSelectorcstƒjƒtjƒ|_dS)N)rBrr-rkع_kqueue)r)rFrrrs zKqueueSelector.__init__cCs |jjƒS)N)rmr )rrrrr szKqueueSelector.filenoNcsکtƒj|||ƒ}y`|t@r@tj|jtjtjƒ}|jj |gddƒ|t @rntj|jtjtjƒ}|jj |gddƒWn"tk r’tƒj |ƒ‚YnX|S)Nr)rBr)r;r-عkeventrعKQ_FILTER_READZ KQ_EV_ADDrmعcontrolr<عKQ_FILTER_WRITErdr*)rrrrr:عkev)rFrrr)szKqueueSelector.registercs¤tƒj|ƒ}|jt@rVtj|jtjtjƒ}y|j j |gddƒWntk rTYnX|jt@r tj|jtj tjƒ}y|j j |gddƒWntk r‍YnX|S)Nr)rBr*rr;r-rnrroZKQ_EV_DELETErmrprer<rq)rrr:rr)rFrrr*'s zKqueueSelector.unregisterc Cs¶|dkrdnt|dƒ}t|jƒ}g}y|jjd||ƒ}Wntk rL|SXxb|D]Z}|j}|j}d}|tj krz|t O}|tjkrŒ|tO}|j |ƒ} | rT|j| || j@fƒqTW|S)Nr)rNrrrmrprOZidentعfilterr-ror;rqr<r@rPr) rr,rgrQZkev_listrrrعflagrr:rrrr-<s& zKqueueSelector.selectcs|jjƒtƒjƒdS)N)rmr.rB)r)rFrrr.Rs zKqueueSelector.close)N)N) r$r%r&rr r)r*r-r.rTrr)rFrrl s rlré)rr)عabcrrعcollectionsrrr[r-rRr;r<rrع__doc__عversion_inforrrrrr'r7rAعhasattrrVr`rirlعglobalsZDefaultSelectorrrrrعsF ~U3 1G8M