B n\?Q?J@s|dZddlZddlZddlZddlZddlZddlZddlmZGddde Z GdddZ Gd d d e Z Gd d d Z Gd ddZGdddZGdddeZdaeZGdddejZeZddZddZddZddZddZdd Zd!d"Zd#d$Zd%d&Zd'd(Z d)d*Z!eZ"eZ#eZ$eZ%ydd+l&mZmZmZmZWne'k rfYnXeZ(eZ)eZ*eZ+dS),)AbstractEventLoopPolicyAbstractEventLoopAbstractServerHandle TimerHandleSendfileNotAvailableErrorget_event_loop_policyset_event_loop_policyget_event_loopset_event_loopnew_event_loopget_child_watcherset_child_watcher_set_running_loopget_running_loop_get_running_loopN)format_helpersc@s eZdZdS)rN)__name__ __module__ __qualname__rr1/opt/alt/python37/lib/python3.7/asyncio/events.pyrsrc@sBeZdZdZdddZddZddZd d Zd d Zd dZ dS)r) _callback_args _cancelled_loop_source_traceback_repr __weakref___contextNcCs\|dkrt}||_||_||_||_d|_d|_|jrRt t d|_ nd|_ dS)NFr) contextvarsZ copy_contextr rrrrr get_debugr extract_stacksys _getframer)selfcallbackargsloopcontextrrr__init__'s zHandle.__init__cCsl|jjg}|jr|d|jdk r:|t|j|j|jrh|jd}|d|dd|d|S)N cancelledz created at r:r) __class__rrappendrr_format_callback_sourcerr)r&infoframerrr _repr_info6s    zHandle._repr_infocCs(|jdk r|jS|}dd|S)Nz<{}> )rr4formatjoin)r&r2rrr__repr__Bs zHandle.__repr__cCs0|js,d|_|jr t||_d|_d|_dS)NT)rrr"reprrrr)r&rrrcancelHs   z Handle.cancelcCs|jS)N)r)r&rrrr,SszHandle.cancelledc Csy|jj|jf|jWndtk r~}zFt|j|j}d|}|||d}|jrb|j|d<|j |Wdd}~XYnXd}dS)NzException in callback )messageZ exceptionhandleZsource_traceback) r runrr Exceptionrr1rrcall_exception_handler)r&exccbmsgr*rrr_runVs   z Handle._run)N) rrr __slots__r+r4r8r:r,rCrrrrr s   rcs~eZdZddgZdfdd ZfddZdd Zd d Zd d ZddZ ddZ ddZ ddZ fddZ ddZZS)r _scheduled_whenNcs0t|||||jr |jd=||_d|_dS)Nr-F)superr+rrFrE)r&whenr'r(r)r*)r/rrr+ms zTimerHandle.__init__cs0t}|jrdnd}||d|j|S)Nrzwhen=)rGr4rinsertrF)r&r2pos)r/rrr4us zTimerHandle._repr_infocCs t|jS)N)hashrF)r&rrr__hash__{szTimerHandle.__hash__cCs |j|jkS)N)rF)r&otherrrr__lt__~szTimerHandle.__lt__cCs|j|jkrdS||S)NT)rF__eq__)r&rNrrr__le__s zTimerHandle.__le__cCs |j|jkS)N)rF)r&rNrrr__gt__szTimerHandle.__gt__cCs|j|jkrdS||S)NT)rFrP)r&rNrrr__ge__s zTimerHandle.__ge__cCs>t|tr:|j|jko8|j|jko8|j|jko8|j|jkStS)N) isinstancerrFrrrNotImplemented)r&rNrrrrPs      zTimerHandle.__eq__cCs||}|tkrtS| S)N)rPrU)r&rNZequalrrr__ne__s zTimerHandle.__ne__cs |js|j|tdS)N)rr_timer_handle_cancelledrGr:)r&)r/rrr:s zTimerHandle.cancelcCs|jS)N)rF)r&rrrrHszTimerHandle.when)N)rrrrDr+r4rMrOrQrRrSrPrVr:rH __classcell__rr)r/rrhs  rc@sLeZdZddZddZddZddZd d Zd d Zd dZ ddZ dS)rcCstdS)N)NotImplementedError)r&rrrcloseszAbstractServer.closecCstdS)N)rY)r&rrrget_loopszAbstractServer.get_loopcCstdS)N)rY)r&rrr is_servingszAbstractServer.is_servingcstdS)N)rY)r&rrr start_servingszAbstractServer.start_servingcstdS)N)rY)r&rrr serve_foreverszAbstractServer.serve_forevercstdS)N)rY)r&rrr wait_closedszAbstractServer.wait_closedcs|S)Nr)r&rrr __aenter__szAbstractServer.__aenter__cs||IdHdS)N)rZr_)r&r@rrr __aexit__szAbstractServer.__aexit__N) rrrrZr[r\r]r^r_r`rarrrrrsrc @sHeZdZddZddZddZddZd d Zd d Zd dZ ddZ ddZ ddZ ddZ ddZddZddZddZdd Zd!d"Zd#d#d#d#d$d%d&Zdsd'd(Zdtd)d#d#d#d)d)d)d)d*d+d,Zduejejd)d-d)d)d)d)d.d/ d0d1Zdvd.d2d3d4Zd5d)d)d6d7d8Zdwd)d)d)d)d9d:d;Zdxd)d-d)d)d.d<d=d>Zdyd#d#d#d)d)d)d)d?d@dAZdBdCZ dDdEZ!e"j#e"j#e"j#dFdGdHZ$e"j#e"j#e"j#dFdIdJZ%dKdLZ&dMdNZ'dOdPZ(dQdRZ)dSdTZ*dUdVZ+dWdXZ,dYdZZ-d[d\Z.dzd)d2d]d^Z/d_d`Z0dadbZ1dcddZ2dedfZ3dgdhZ4didjZ5dkdlZ6dmdnZ7dodpZ8dqdrZ9d)S){rcCstdS)N)rY)r&rrr run_foreverszAbstractEventLoop.run_forevercCstdS)N)rY)r&Zfuturerrrrun_until_completesz$AbstractEventLoop.run_until_completecCstdS)N)rY)r&rrrstopszAbstractEventLoop.stopcCstdS)N)rY)r&rrr is_runningszAbstractEventLoop.is_runningcCstdS)N)rY)r&rrr is_closedszAbstractEventLoop.is_closedcCstdS)N)rY)r&rrrrZs zAbstractEventLoop.closecstdS)N)rY)r&rrrshutdown_asyncgenssz$AbstractEventLoop.shutdown_asyncgenscCstdS)N)rY)r&r<rrrrWsz)AbstractEventLoop._timer_handle_cancelledcGs|jd|f|S)Nr) call_later)r&r'r(rrr call_soonszAbstractEventLoop.call_sooncGstdS)N)rY)r&Zdelayr'r(rrrrh szAbstractEventLoop.call_latercGstdS)N)rY)r&rHr'r(rrrcall_at szAbstractEventLoop.call_atcCstdS)N)rY)r&rrrtimeszAbstractEventLoop.timecCstdS)N)rY)r&rrr create_futureszAbstractEventLoop.create_futurecCstdS)N)rY)r&cororrr create_taskszAbstractEventLoop.create_taskcGstdS)N)rY)r&r'r(rrrcall_soon_threadsafesz&AbstractEventLoop.call_soon_threadsafecstdS)N)rY)r&executorfuncr(rrrrun_in_executor sz!AbstractEventLoop.run_in_executorcCstdS)N)rY)r&rprrrset_default_executor#sz&AbstractEventLoop.set_default_executorr)familytypeprotoflagscstdS)N)rY)r&hostportrtrurvrwrrr getaddrinfo(szAbstractEventLoop.getaddrinfocstdS)N)rY)r&Zsockaddrrwrrr getnameinfo,szAbstractEventLoop.getnameinfoN)sslrtrvrwsock local_addrserver_hostnamessl_handshake_timeoutc stdS)N)rY) r&protocol_factoryrxryr|rtrvrwr}r~rrrrrcreate_connection/sz#AbstractEventLoop.create_connectiondT) rtrwr}backlogr| reuse_address reuse_portrr]c stdS)N)rY) r&rrxryrtrwr}rr|rrrr]rrr create_server7s3zAbstractEventLoop.create_server)fallbackcstdS)N)rY)r& transportfileoffsetcountrrrrsendfilelszAbstractEventLoop.sendfileF) server_siderrcstdS)N)rY)r&rZprotocolZ sslcontextrrrrrr start_tlsts zAbstractEventLoop.start_tls)r|r}rrcstdS)N)rY)r&rpathr|r}rrrrrcreate_unix_connectionsz(AbstractEventLoop.create_unix_connection)r}rr|rr]cstdS)N)rY)r&rrr}rr|rr]rrrcreate_unix_serversz$AbstractEventLoop.create_unix_server)rtrvrwrrallow_broadcastr}c stdS)N)rY) r&rr~Z remote_addrrtrvrwrrrr}rrrcreate_datagram_endpoints!z*AbstractEventLoop.create_datagram_endpointcstdS)N)rY)r&rpiperrrconnect_read_pipes z#AbstractEventLoop.connect_read_pipecstdS)N)rY)r&rrrrrconnect_write_pipes z$AbstractEventLoop.connect_write_pipe)stdinstdoutstderrcstdS)N)rY)r&rcmdrrrkwargsrrrsubprocess_shellsz"AbstractEventLoop.subprocess_shellcstdS)N)rY)r&rrrrr(rrrrsubprocess_execsz!AbstractEventLoop.subprocess_execcGstdS)N)rY)r&fdr'r(rrr add_readerszAbstractEventLoop.add_readercCstdS)N)rY)r&rrrr remove_readerszAbstractEventLoop.remove_readercGstdS)N)rY)r&rr'r(rrr add_writerszAbstractEventLoop.add_writercCstdS)N)rY)r&rrrr remove_writerszAbstractEventLoop.remove_writercstdS)N)rY)r&r}nbytesrrr sock_recvszAbstractEventLoop.sock_recvcstdS)N)rY)r&r}bufrrrsock_recv_into sz AbstractEventLoop.sock_recv_intocstdS)N)rY)r&r}datarrr sock_sendall szAbstractEventLoop.sock_sendallcstdS)N)rY)r&r}Zaddressrrr sock_connectszAbstractEventLoop.sock_connectcstdS)N)rY)r&r}rrr sock_acceptszAbstractEventLoop.sock_acceptcstdS)N)rY)r&r}rrrrrrr sock_sendfileszAbstractEventLoop.sock_sendfilecGstdS)N)rY)r&sigr'r(rrradd_signal_handlersz$AbstractEventLoop.add_signal_handlercCstdS)N)rY)r&rrrrremove_signal_handlersz'AbstractEventLoop.remove_signal_handlercCstdS)N)rY)r&factoryrrrset_task_factory#sz"AbstractEventLoop.set_task_factorycCstdS)N)rY)r&rrrget_task_factory&sz"AbstractEventLoop.get_task_factorycCstdS)N)rY)r&rrrget_exception_handler+sz'AbstractEventLoop.get_exception_handlercCstdS)N)rY)r&Zhandlerrrrset_exception_handler.sz'AbstractEventLoop.set_exception_handlercCstdS)N)rY)r&r*rrrdefault_exception_handler1sz+AbstractEventLoop.default_exception_handlercCstdS)N)rY)r&r*rrrr?4sz(AbstractEventLoop.call_exception_handlercCstdS)N)rY)r&rrrr"9szAbstractEventLoop.get_debugcCstdS)N)rY)r&Zenabledrrr set_debug<szAbstractEventLoop.set_debug)r)NN)NN)rN)N)N)NN)rN):rrrrbrcrdrerfrZrgrWrirhrjrkrlrnrorrrsrzr{rsocketZ AF_UNSPECZ AI_PASSIVErrrrrrrr subprocessPIPErrrrrrrrrrrrrrrrrrrr?r"rrrrrrs  / !  rc@s4eZdZddZddZddZddZd d Zd S) rcCstdS)N)rY)r&rrrr Csz&AbstractEventLoopPolicy.get_event_loopcCstdS)N)rY)r&r)rrrr Msz&AbstractEventLoopPolicy.set_event_loopcCstdS)N)rY)r&rrrr Qsz&AbstractEventLoopPolicy.new_event_loopcCstdS)N)rY)r&rrrr Ysz)AbstractEventLoopPolicy.get_child_watchercCstdS)N)rY)r&watcherrrrr ]sz)AbstractEventLoopPolicy.set_child_watcherN)rrrr r r r r rrrrr@s  rc@sBeZdZdZGdddejZddZddZdd Z d d Z dS) BaseDefaultEventLoopPolicyNc@seZdZdZdZdS)z!BaseDefaultEventLoopPolicy._LocalNF)rrrr _set_calledrrrr_LocalqsrcCs||_dS)N)r_local)r&rrrr+usz#BaseDefaultEventLoopPolicy.__init__cCsX|jjdkr2|jjs2tttjr2|||jjdkrPt dtj |jjS)Nz,There is no current event loop in thread %r.) rrrrT threadingZcurrent_threadZ _MainThreadr r RuntimeErrorname)r&rrrr xs  z)BaseDefaultEventLoopPolicy.get_event_loopcCsd|j_||j_dS)NT)rrr)r&r)rrrr sz)BaseDefaultEventLoopPolicy.set_event_loopcCs|S)N) _loop_factory)r&rrrr sz)BaseDefaultEventLoopPolicy.new_event_loop) rrrrrlocalrr+r r r rrrrrbs  rc@seZdZdZdS) _RunningLoop)NNN)rrrloop_pidrrrrrsrcCst}|dkrtd|S)Nzno running event loop)rr)r)rrrrsrcCs&tj\}}|dk r"|tkr"|SdS)N) _running_looprosgetpid)Z running_looppidrrrrs rcCs|tft_dS)N)rrrr)r)rrrrsrc Cs.t tdkr ddlm}|aWdQRXdS)Nr)DefaultEventLoopPolicy)_lock_event_loop_policyr)rrrr_init_event_loop_policys rcCstdkrttS)N)rrrrrrrsrcCs|adS)N)r)ZpolicyrrrrsrcCst}|dk r|StS)N)rrr )Z current_looprrrr s r cCst|dS)N)rr )r)rrrr sr cCs tS)N)rr rrrrr sr cCs tS)N)rr rrrrr sr cCs t|S)N)rr )rrrrr sr )rrrr ),__all__r!rrrr$rrrrrrrrrrrrZLockrrrrrrrrrrr r r r r Z_py__get_running_loopZ_py__set_running_loopZ_py_get_running_loopZ_py_get_event_loopZ_asyncio ImportErrorZ_c__get_running_loopZ_c__set_running_loopZ_c_get_running_loopZ_c_get_event_looprrrrsV  H@*p"9