o 0¦iÒjã@s„dZdZddlZddlZddlZddlZddlZddlZddlm Z Gdd„dƒZ Gdd „d e ƒZGd d„dƒZGdd „d ƒZ Gdd„dƒZGdd„deƒZdae ¡ZGdd„dejƒZeƒZdd„Zdd„Zdd„Zdd„Zdd„Zdd„Zd d!„Zd.d#d$„Zd%d&„Zd'd(„Zd)d*„Z d+d,„Z!eZ"eZ#eZ$eZ%eZ&zdd-l'mZmZmZmZmZWn e(yµYdSweZ)eZ*eZ+eZ,eZ-dS)/z!Event loop and event loop policy.)ÚAbstractEventLoopPolicyÚAbstractEventLoopÚAbstractServerÚHandleÚTimerHandleÚget_event_loop_policyÚset_event_loop_policyÚget_event_loopÚset_event_loopÚnew_event_loopÚget_child_watcherÚset_child_watcherÚ_set_running_loopÚget_running_loopÚ_get_running_loopéNé)Úformat_helpersc@sFeZdZdZdZddd„Zdd„Zdd „Zd d„Zdd „Z dd„Z dS)rz1Object returned by callback registration methods.)Ú _callbackÚ_argsÚ _cancelledÚ_loopÚ_source_tracebackÚ_reprÚ__weakref__Ú_contextNcCs^|durt ¡}||_||_||_||_d|_d|_|j ¡r*t t d¡¡|_ dSd|_ dS)NFr)ÚcontextvarsZcopy_contextrrrrrrÚ get_debugrÚ extract_stackÚsysÚ _getframer)ÚselfÚcallbackÚargsÚloopÚcontext©r%ú5/opt/alt/python310/lib64/python3.10/asyncio/events.pyÚ__init__s ÿ zHandle.__init__cCsl|jjg}|jr | d¡|jdur| t |j|j¡¡|jr4|jd}| d|d›d|d›¡|S)NÚ cancelledéÿÿÿÿzcreated at rú:r) Ú __class__Ú__name__rÚappendrrÚ_format_callback_sourcerr)r ÚinfoÚframer%r%r&Ú _repr_info.s ÿ zHandle._repr_infocCs(|jdur|jS| ¡}d d |¡¡S)Nz<{}>ú )rr1ÚformatÚjoin)r r/r%r%r&Ú__repr__:s zHandle.__repr__cCs4|jsd|_|j ¡rt|ƒ|_d|_d|_dSdS)NT)rrrÚreprrrr©r r%r%r&Úcancel@s øz Handle.cancelcCó|jS©N)rr7r%r%r&r(KszHandle.cancelledc Cs¢z|jj|jg|j¢RŽWd}dSttfy‚tyP}z*t |j|j¡}d|›}|||dœ}|j r=|j |d<|j |¡WYd}~d}dSd}~ww)NzException in callback )ÚmessageZ exceptionÚhandleZsource_traceback)rÚrunrrÚ SystemExitÚKeyboardInterruptÚ BaseExceptionrr.rrÚcall_exception_handler)r ÚexcÚcbÚmsgr$r%r%r&Ú_runNs(òÿ ý €ôzHandle._runr:)r,Ú __module__Ú__qualname__Ú__doc__Ú __slots__r'r1r5r8r(rEr%r%r%r&rs rcszeZdZdZddgZd‡fdd„ Z‡fdd„Zd d „Zdd„Zd d„Z dd„Z dd„Zdd„Z‡fdd„Z dd„Z‡ZS)rz7Object returned by timed callback registration methods.Ú _scheduledÚ_whenNcs<|dusJ‚tƒ ||||¡|jr|jd=||_d|_dS)Nr)F)Úsuperr'rrKrJ)r Úwhenr!r"r#r$©r+r%r&r'gs zTimerHandle.__init__cs0tƒ ¡}|jr dnd}| |d|j›¡|S)Nérzwhen=)rLr1rÚinsertrK)r r/ÚposrNr%r&r1os zTimerHandle._repr_infocCs t|jƒSr:)ÚhashrKr7r%r%r&Ú__hash__us zTimerHandle.__hash__cCst|tƒr|j|jkStSr:©Ú isinstancerrKÚNotImplemented©r Úotherr%r%r&Ú__lt__xó zTimerHandle.__lt__cCs$t|tƒr|j|jkp| |¡StSr:©rUrrKÚ__eq__rVrWr%r%r&Ú__le__}ó zTimerHandle.__le__cCst|tƒr|j|jkStSr:rTrWr%r%r&Ú__gt__‚rZzTimerHandle.__gt__cCs$t|tƒr|j|jkp| |¡StSr:r[rWr%r%r&Ú__ge__‡r^zTimerHandle.__ge__cCs>t|tƒr|j|jko|j|jko|j|jko|j|jkStSr:)rUrrKrrrrVrWr%r%r&r\Œs ÿ þ ýzTimerHandle.__eq__cs |js |j |¡tƒ ¡dSr:)rrÚ_timer_handle_cancelledrLr8r7rNr%r&r8”szTimerHandle.cancelcCr9)zŒReturn a scheduled callback time. The time is an absolute timestamp, using the same time reference as loop.time(). )rKr7r%r%r&rM™szTimerHandle.whenr:)r,rFrGrHrIr'r1rSrYr]r_r`r\r8rMÚ __classcell__r%r%rNr&rbsrc@sPeZdZdZdd„Zdd„Zdd„Zdd „Zd d„Zdd „Z dd„Z dd„ZdS)rz,Abstract server returned by create_server().cCót‚)z5Stop serving. This leaves existing connections open.©ÚNotImplementedErrorr7r%r%r&Úclose¥ózAbstractServer.closecCrc)z4Get the event loop the Server object is attached to.rdr7r%r%r&Úget_loop©rgzAbstractServer.get_loopcCrc)z3Return True if the server is accepting connections.rdr7r%r%r&Ú is_servingrgzAbstractServer.is_servingcÃót‚)zStart accepting connections. This method is idempotent, so it can be called when the server is already being serving. rdr7r%r%r&Ú start_serving±ó€zAbstractServer.start_servingcÃrj)z…Start accepting connections until the coroutine is cancelled. The server is closed when the coroutine is cancelled. rdr7r%r%r&Ú serve_forever¹ó€zAbstractServer.serve_forevercÃrj)z*Coroutine to wait until service is closed.rdr7r%r%r&Úwait_closedÀó€zAbstractServer.wait_closedcÃs|Sr:r%r7r%r%r&Ú __aenter__Äó€zAbstractServer.__aenter__cÇs| ¡| ¡IdHdSr:)rfro)r rBr%r%r&Ú __aexit__Çs€zAbstractServer.__aexit__N)r,rFrGrHrfrhrirkrmrorqrsr%r%r%r&r¢src@seZdZdZdd„Zdd„Zdd„Zdd „Zd d„Zdd „Z dd„Z dd„Zdd„Zddœdd„Z ddœdd„Zddœdd„Zdd„Zdd„Zdd œd!d"„Zddœd#d$„Zd%d&„Zd'd(„Zd)d)d)d)d*œd+d,„Zd{d-d.„Z d|dd)d)d)ddddddd/œ d0d1„Z d|ejejdd2ddddd3d4œ d5d6„Zd}d3d7œd8d9„Zd:ddd;œdœd?d@„Z d~dd2ddd3dAœdBdC„Z dddDœdEdF„Z! d|d)d)d)dddddGœdHdI„Z"dJdK„Z#dLdM„Z$e%j&e%j&e%j&dNœdOdP„Z'e%j&e%j&e%j&dNœdQdR„Z(dSdT„Z)dUdV„Z*dWdX„Z+dYdZ„Z,d[d\„Z-d]d^„Z.d_d`„Z/dadb„Z0dcdd„Z1d}dd7œdedf„Z2dgdh„Z3didj„Z4dkdl„Z5dmdn„Z6dodp„Z7dqdr„Z8dsdt„Z9dudv„Z:dwdx„Z;dydz„Zr~z+AbstractEventLoop.default_exception_handlercCrcr:rdrÑr%r%r&rAAr~z(AbstractEventLoop.call_exception_handlercCrcr:rdr7r%r%r&rFr~zAbstractEventLoop.get_debugcCrcr:rd)r Zenabledr%r%r&Ú set_debugIr~zAbstractEventLoop.set_debug)r©NN)rNr:)=r,rFrGrHrtrurvrwrxrfryrzrar}r{rr€rr„r…rˆr‰rr‘ršÚsocketZ AF_UNSPECZ AI_PASSIVErŸr¥r§r©rªr«rr°r²Ú subprocessÚPIPEr¸r¹r¼r¾r¿rÀrÂrÃrÅrÆrÇrÈrÊrËrÍrÎrÏrÐrÒrArrÓr%r%r%r&rÌsÆÿ ÿú ÿú5ÿ ýÿüÿü"ýÿü% ýýÿrc@s8eZdZdZdd„Zdd„Zdd„Zdd „Zd d„ZdS) rz-Abstract policy for accessing the event loop.cCrc)a:Get the event loop for the current context. Returns an event loop object implementing the BaseEventLoop interface, or raises an exception in case no event loop has been set for the current context and the current policy does not specify to create one. It should never return None.rdr7r%r%r&rPsz&AbstractEventLoopPolicy.get_event_loopcCrc)z3Set the event loop for the current context to loop.rd©r r#r%r%r&r Zrgz&AbstractEventLoopPolicy.set_event_loopcCrc)zÑCreate and return a new event loop object according to this policy's rules. If there's need to set this loop as the event loop for the current context, set_event_loop must be called explicitly.rdr7r%r%r&r ^sz&AbstractEventLoopPolicy.new_event_loopcCrc)z$Get the watcher for child processes.rdr7r%r%r&rfrgz)AbstractEventLoopPolicy.get_child_watchercCrc)z$Set the watcher for child processes.rd)r Úwatcherr%r%r&rjrgz)AbstractEventLoopPolicy.set_child_watcherN) r,rFrGrHrr r rrr%r%r%r&rMs rc@sFeZdZdZdZGdd„dejƒZdd„Zdd„Z d d „Z dd„ZdS) ÚBaseDefaultEventLoopPolicyaßDefault policy implementation for accessing the event loop. In this policy, each thread has its own event loop. However, we only automatically create an event loop by default for the main thread; other threads by default have no event loop. Other policies may have different rules (e.g. a single global event loop, or automatically creating an event loop per thread, or using some other notion of context to which an event loop is associated). Nc@seZdZdZdZdS)z!BaseDefaultEventLoopPolicy._LocalNF)r,rFrGrÚ_set_calledr%r%r%r&Ú_Local~srÜcCs| ¡|_dSr:)rÜÚ_localr7r%r%r&r'‚sz#BaseDefaultEventLoopPolicy.__init__cCsX|jjdur|jjst ¡t ¡ur| | ¡¡|jjdur(tdt ¡j ƒ‚|jjS)zvGet the event loop for the current context. Returns an instance of EventLoop or raises an exception. Nz,There is no current event loop in thread %r.) rÝrrÛÚ threadingZcurrent_threadZmain_threadr r ÚRuntimeErrorr‚r7r%r%r&r…sÿÿz)BaseDefaultEventLoopPolicy.get_event_loopcCs*d|j_|dust|tƒsJ‚||j_dS)zSet the event loop.TN)rÝrÛrUrrrØr%r%r&r •sz)BaseDefaultEventLoopPolicy.set_event_loopcCs| ¡S)zvCreate a new event loop. You must call set_event_loop() to make this the current event loop. )Ú _loop_factoryr7r%r%r&r ›sz)BaseDefaultEventLoopPolicy.new_event_loop)r,rFrGrHràrÞÚlocalrÜr'rr r r%r%r%r&rÚosrÚc@seZdZdZdS)Ú_RunningLooprÔN)r,rFrGÚloop_pidr%r%r%r&râ¯srâcCstƒ}|durtdƒ‚|S)zrReturn the running event loop. Raise a RuntimeError if there is none. This function is thread-specific. Nzno running event loop)rrß©r#r%r%r&r¶srcCs*tj\}}|dur|t ¡kr|SdSdS)z—Return the running event loop or None. This is a low-level function intended to be used by event loops. This function is thread-specific. N)Ú _running_looprãÚosÚgetpid)Zrunning_loopÚpidr%r%r&rÂs ÿrcCs|t ¡ft_dS)zŒSet the running event loop. This is a low-level function intended to be used by event loops. This function is thread-specific. N)rærçrårãrär%r%r&r Îsr cCsTttdurddlm}|ƒaWdƒdSWdƒdS1s#wYdS)Nr©ÚDefaultEventLoopPolicy)Ú_lockÚ_event_loop_policyÚrêrér%r%r&Ú_init_event_loop_policyØsý"ÿrîcCstdurtƒtS)z"Get the current event loop policy.N)rìrîr%r%r%r&ràsrcCs|dust|tƒsJ‚|adS)zZSet the current event loop policy. If policy is None, the default policy is restored.N)rUrrì)Zpolicyr%r%r&rçsrcCstƒS)aGReturn an asyncio event loop. When called from a coroutine or a callback (e.g. scheduled with call_soon or similar API), this function will always return the running event loop. If there is no running event loop set, the function will return the result of `get_event_loop_policy().get_event_loop()` call. )Ú_py__get_event_loopr%r%r%r&rðs récCstƒ}|dur |Stƒ ¡Sr:)rrr)Ú stacklevelZcurrent_loopr%r%r&Ú_get_event_loopýs ròcCstƒ |¡dS)zCEquivalent to calling get_event_loop_policy().set_event_loop(loop).N)rr rär%r%r&r sr cCó tƒ ¡S)z?Equivalent to calling get_event_loop_policy().new_event_loop().)rr r%r%r%r&r ó r cCró)zBEquivalent to calling get_event_loop_policy().get_child_watcher().)rrr%r%r%r&rrôrcCstƒ |¡S)zMEquivalent to calling get_event_loop_policy().set_child_watcher(watcher).)rr)rÙr%r%r&rsr)rr rrrò)rð).rHÚ__all__rrærÕrÖrrÞrírrrrrrrÚrìZLockrërárârårrr rîrrrròr r rrZ_py__get_running_loopZ_py__set_running_loopZ_py_get_running_loopZ_py_get_event_looprïZ_asyncioÚImportErrorZ_c__get_running_loopZ_c__set_running_loopZ_c_get_running_loopZ_c_get_event_loopZ_c__get_event_loopr%r%r%r&ÚsbJ@*"9 ÿ