a ið3e†ã@sädZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z ddl m Z ddl mZddl mZdd l mZdd l mZdd l mZdd l mZdd lmZddlmZgd¢Zejdkrêedƒ‚dd„ZGdd„dejƒZeedƒrdd„ZnddlZdd„ZGdd„dej ƒZ!Gdd„dej"ej#ƒZ$eedƒrfej%Z&nddlZdd „Z&Gd!d"„d"e j'ƒZ(Gd#d$„d$ƒZ)Gd%d&„d&e)ƒZ*Gd'd(„d(e*ƒZ+Gd)d*„d*e*ƒZ,Gd+d,„d,ej-ƒZ.eZ/e.Z0dS)-z2Selector event loop for Unix with signal handling.éNé)Ú base_events)Úbase_subprocess)Ú constants)Ú coroutines)Úevents)Úfutures)Úselector_events)Ú selectors)Ú transports)Ú coroutine)Úlogger)ÚSelectorEventLoopÚAbstractChildWatcherÚSafeChildWatcherÚFastChildWatcherÚDefaultEventLoopPolicyÚwin32z+Signals are not really supported on WindowscCsdS)zDummy signal handler.N©)ÚsignumÚframerrúF/home/pi/bot/my_env/lib/python3.9/site-packages/asyncio/unix_events.pyÚ_sighandler_noop$srcs¶eZdZdZd"‡fdd„ Zdd„Z‡fdd„Zd d „Zd d „Zd d„Z dd„Z dd„Z d#dd„Z d$dd„Z ed%dd„ƒZdd„Zeddddœdd„ƒZed&ddddœd d!„ƒZ‡ZS)'Ú_UnixSelectorEventLoopzdUnix event loop. Adds signal handling and UNIX Domain Socket support to SelectorEventLoop. Ncstƒ |¡i|_dS©N)ÚsuperÚ__init__Ú_signal_handlers)ÚselfÚselector©Ú __class__rrr/s z_UnixSelectorEventLoop.__init__cCst ¡Sr)ÚsocketÚ socketpair©rrrrÚ _socketpair3sz"_UnixSelectorEventLoop._socketpaircs(tƒ ¡t|jƒD]}| |¡qdSr)rÚcloseÚlistrÚremove_signal_handler©rÚsigr rrr&6s z_UnixSelectorEventLoop.closecCs|D]}|sq| |¡qdSr)Ú_handle_signal)rÚdatarrrrÚ_process_self_data;sz)_UnixSelectorEventLoop._process_self_datac GsNt |¡st |¡rtdƒ‚| |¡| ¡zt |j  ¡¡Wn4t t fyv}zt t |ƒƒ‚WYd}~n d}~00t |||¡}||j|<zt |t¡t |d¡Wnœt yH}z‚|j|=|jszt d¡Wn6t t fy}zt d|¡WYd}~n d}~00|jtjkr2t d |¡ƒ‚n‚WYd}~n d}~00dS)zÃAdd a handler for a signal. UNIX only. Raise ValueError if the signal number is invalid or uncatchable. Raise RuntimeError if there is a problem setting up the handler. z3coroutines cannot be used with add_signal_handler()NFéÿÿÿÿúset_wakeup_fd(-1) failed: %súsig {} cannot be caught)rÚ iscoroutineÚiscoroutinefunctionÚ TypeErrorÚ _check_signalZ _check_closedÚsignalÚ set_wakeup_fdZ_csockÚfilenoÚ ValueErrorÚOSErrorÚ RuntimeErrorÚstrrÚHandlerrÚ siginterruptr ÚinfoÚerrnoÚEINVALÚformat)rr*ÚcallbackÚargsÚexcÚhandleZnexcrrrÚadd_signal_handlerBs2 ÿ "  "z)_UnixSelectorEventLoop.add_signal_handlercCs8|j |¡}|durdS|jr*| |¡n | |¡dS)z2Internal helper that is the actual signal handler.N)rÚgetZ _cancelledr(Z_add_callback_signalsafe)rr*rErrrr+os   z%_UnixSelectorEventLoop._handle_signalc Csæ| |¡z |j|=Wnty*YdS0|tjkr>tj}ntj}zt ||¡WnBty–}z*|jtj kr€t d  |¡ƒ‚n‚WYd}~n d}~00|jsâzt  d¡Wn4t tfyà}zt d|¡WYd}~n d}~00dS)zwRemove a handler for a signal. UNIX only. Return True if a signal handler was removed, False if not. Fr0Nr.r/T)r4rÚKeyErrorr5ÚSIGINTÚdefault_int_handlerÚSIG_DFLr9r?r@r:rAr6r8r r>)rr*ÚhandlerrDrrrr(ys(     "z,_UnixSelectorEventLoop.remove_signal_handlercCsFt|tƒstd |¡ƒ‚d|kr.tjksBntd |tj¡ƒ‚dS)zÁInternal helper to validate a signal. Raise ValueError if the signal number is invalid or uncatchable. Raise RuntimeError if there is a problem setting up the handler. zsig must be an int, not {!r}rzsig {} out of range(1, {})N)Ú isinstanceÚintr3rAr5ÚNSIGr8r)rrrr4™s   ÿz$_UnixSelectorEventLoop._check_signalcCst|||||ƒSr)Ú_UnixReadPipeTransport©rÚpipeÚprotocolÚwaiterÚextrarrrÚ_make_read_pipe_transport¦sz0_UnixSelectorEventLoop._make_read_pipe_transportcCst|||||ƒSr)Ú_UnixWritePipeTransportrQrrrÚ_make_write_pipe_transportªsz1_UnixSelectorEventLoop._make_write_pipe_transportc  ksÎt ¡²} tj|d} t||||||||f| |dœ| ¤Ž} |  |  ¡|j| ¡z| EdHWn(ty„} z| }WYd} ~ nd} ~ 00d}|dur¬|   ¡|   ¡EdH|‚Wdƒn1sÀ0Y| S)N)Úloop)rTrU) rÚget_child_watcherrZFutureÚ_UnixSubprocessTransportÚadd_child_handlerZget_pidÚ_child_watcher_callbackÚ Exceptionr&Ú_wait)rrSrCÚshellÚstdinÚstdoutÚstderrÚbufsizerUÚkwargsÚwatcherrTÚtransprDÚerrrrrÚ_make_subprocess_transport®s,   ÿþý ÿ"z1_UnixSelectorEventLoop._make_subprocess_transportcCs| |j|¡dSr)Zcall_soon_threadsafeZ_process_exited)rÚpidÚ returncodergrrrr]Ìsz._UnixSelectorEventLoop._child_watcher_callback)ÚsslÚsockÚserver_hostnameccsÜ|dust|tƒsJ‚|r,|durú ) r!rrÚappendr˜rr Ú_test_selector_eventrŽÚ _selectorr Ú EVENT_READÚjoin)rr>r¢rrrÚ__repr__Cs      þ   z_UnixReadPipeTransport.__repr__c Csºzt |j|j¡}WnDttfy*YnŒtyX}z| |d¡WYd}~nfd}~00|rl|j  |¡nJ|j   ¡r‚t   d|¡d|_|j  |j¡|j  |jj¡|j  |jd¡dS)Nz"Fatal read error on pipe transportú%r was closed by peerT)r‡ÚreadrÚmax_sizeÚBlockingIOErrorÚInterruptedErrorr9Ú _fatal_errorr—Z data_receivedrŽÚ get_debugr r>r˜Ú remove_readerr™Z eof_receivedÚ_call_connection_lost)rr,rDrrrrœVs"  z"_UnixReadPipeTransport._read_readycCs|j |j¡dSr)rŽr³rr$rrrÚ pause_readinghsz$_UnixReadPipeTransport.pause_readingcCs|j |j|j¡dSr)rŽr›rrœr$rrrÚresume_readingksz%_UnixReadPipeTransport.resume_readingcCs|js| d¡dSr)r˜Ú_closer$rrrr&nsz_UnixReadPipeTransport.close©éécCs(|jdur$t d|t¡|j ¡dS©Nzunclosed transport %r©rÚwarningsÚwarnÚResourceWarningr&r$rrrÚ__del__vs z_UnixReadPipeTransport.__del__úFatal error on pipe transportcCsZt|tƒr4|jtjkr4|j ¡rLtjd||ddn|j ||||j dœ¡|  |¡dS©Nz%r: %sT©Úexc_info)ÚmessageÚ exceptionrurS) rMr9r?ZEIOrŽr²r ÚdebugÚcall_exception_handlerr—r·©rrDrÅrrrr±{s üz#_UnixReadPipeTransport._fatal_errorcCs(d|_|j |j¡|j |j|¡dS©NT)r˜rŽr³rr™r´©rrDrrrr·‰sz_UnixReadPipeTransport._closecCsPz,|j |¡W|j ¡d|_d|_d|_n|j ¡d|_d|_d|_0dSr©r—Zconnection_lostrr&rŽrËrrrr´Žs ý z,_UnixReadPipeTransport._call_connection_lost)NN)rÁ)rr‚rƒr®rr«rœrµr¶r&ÚsysÚ version_inforÀr±r·r´r…rrr rrP)s  rPcs”eZdZd ‡fdd„ Zdd„Zdd„Zdd „Zd d „Zd d „Zdd„Z dd„Z dd„Z e j dkrhdd„Zdd„Zd!dd„Zd"dd„Zdd„Z‡ZS)#rWNcsØtƒ ||¡||jd<||_| ¡|_t |j¡j}t   |¡}|s`t   |¡s`t   |¡s`t dƒ‚t|jƒ||_g|_d|_d|_|j |jj|¡|s¤tj d¡s¼|j |jj|j|j¡|durÔ|j |jd¡dS)NrRz?Pipe transport is only for pipes, sockets and character devicesrFÚaix)rrrrr7rr‡r‘r’r“r•r”r–r8r‰r—Ú_bufferÚ _conn_lostr˜rŽr™ršrÍÚplatformÚ startswithr›rœr)rrYrRrSrTrUržÚ is_socketr rrr›s0   ÿþ  ÿz _UnixWritePipeTransport.__init__cCsª|jjg}|jdur | d¡n|jr0| d¡| d|j¡|jdur’t |jj |jt j ¡}|rp| d¡n | d¡|  ¡}| d|¡n | d¡dd  |¡S) NrŸr r¡r¢r£z bufsize=%sr¤r¥)r!rrr¦r˜rr r§rŽr¨r Ú EVENT_WRITEÚget_write_buffer_sizerª)rr>r¢rdrrrr«»s$     þ   z _UnixWritePipeTransport.__repr__cCstdd„|jDƒƒS)Ncss|]}t|ƒVqdSr)Úlen)Ú.0r,rrrÚ Òóz@_UnixWritePipeTransport.get_write_buffer_size..)ÚsumrÐr$rrrrÖÑsz-_UnixWritePipeTransport.get_write_buffer_sizecCs6|j ¡rt d|¡|jr*| tƒ¡n| ¡dS)Nr¬)rŽr²r r>rÐr·ÚBrokenPipeErrorr$rrrrœÔs   z#_UnixWritePipeTransport._read_readyc Cs.t|tttfƒsJt|ƒƒ‚t|tƒr.t|ƒ}|s6dS|jsB|jrj|jtjkrXt   d¡|jd7_dS|j szt   |j|¡}WnXttfyžd}Yn@tyÜ}z(|jd7_| |d¡WYd}~dSd}~00|t|ƒkrîdS|dkr||d…}|j |j|j¡|j  |¡| ¡dS)Nz=pipe closed by peer or os.write(pipe, data) raised exception.rrú#Fatal write error on pipe transport)rMÚbytesÚ bytearrayÚ memoryviewÚreprrÑr˜rZ!LOG_THRESHOLD_FOR_CONNLOST_WRITESr ÚwarningrÐr‡Úwriterr¯r°r^r±r×rŽZ add_writerÚ _write_readyr¦Z_maybe_pause_protocol©rr,ÚnrDrrrrãÝs4         z_UnixWritePipeTransport.writec Csd |j¡}|sJdƒ‚|j ¡zt |j|¡}WnlttfyV|j |¡Yn¸t y }z4|j d7_ |j   |j¡|  |d¡WYd}~nvd}~00|t|ƒkrì|j   |j¡| ¡|jsè|jrè|j  |j¡| d¡dS|dkr||d…}|j |¡dS)NrÚzData should not be emptyrrÝr)rªrÐÚclearr‡rãrr¯r°r¦r^rÑrŽÚ remove_writerr±r×Z_maybe_resume_protocolr˜r³r´rårrrräþs*   "     z$_UnixWritePipeTransport._write_readycCsdSrÊrr$rrrÚ can_write_eofsz%_UnixWritePipeTransport.can_write_eofcCsB|jr dS|jsJ‚d|_|js>|j |j¡|j |jd¡dSrÊ)r˜rrÐrŽr³rr™r´r$rrrÚ write_eofs z!_UnixWritePipeTransport.write_eofcCs|jdur|js| ¡dSr)rr˜rêr$rrrr&&sz_UnixWritePipeTransport.closer¸cCs(|jdur$t d|t¡|j ¡dSr»r¼r$rrrrÀ/s z_UnixWritePipeTransport.__del__cCs| d¡dSr)r·r$rrrÚabort4sz_UnixWritePipeTransport.abortrÁcCsRt|ttfƒr,|j ¡rDtjd||ddn|j ||||jdœ¡|  |¡dSrÂ) rMrÜÚConnectionResetErrorrŽr²r rÇrÈr—r·rÉrrrr±7s üz$_UnixWritePipeTransport._fatal_errorcCsFd|_|jr|j |j¡|j ¡|j |j¡|j |j|¡dSrÊ) r˜rÐrŽrèrrçr³r™r´rËrrrr·Es  z_UnixWritePipeTransport._closecCsPz,|j |¡W|j ¡d|_d|_d|_n|j ¡d|_d|_d|_0dSrrÌrËrrrr´Ms ý z-_UnixWritePipeTransport._call_connection_lost)NN)rÁ)N)rr‚rƒrr«rÖrœrãrärérêr&rÍrÎrÀrër±r·r´r…rrr rrW˜s  !    rWÚset_inheritablecCsNttddƒ}t |tj¡}|s4t |tj||B¡nt |tj||@¡dS)NZ FD_CLOEXECr)ÚgetattrrŠZF_GETFDZF_SETFD)rˆÚ inheritableZ cloexec_flagÚoldrrrÚ_set_inheritable]s  rñc@seZdZdd„ZdS)r[c Ksvd}|tjkr*|j ¡\}}t| ¡dƒtj|f||||d|dœ|¤Ž|_|durr| ¡t |  ¡d|d|j_ dS)NF)r`rarbrcÚuniversal_newlinesrdÚwb)Ú buffering) Ú subprocessÚPIPErŽr%rñr7ÚPopenÚ_procr&ÚopenÚdetachra) rrCr`rarbrcrdreZstdin_wrrrÚ_startis ÿþþz_UnixSubprocessTransport._startN)rr‚rƒrûrrrrr[gsr[c@s@eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dS)raHAbstract base class for monitoring child processes. Objects derived from this class monitor a collection of subprocesses and report their termination or interruption by a signal. New callbacks are registered with .add_child_handler(). Starting a new process must be done within a 'with' block to allow the watcher to suspend its activity until the new process if fully registered (this is needed to prevent a race condition in some implementations). Example: with watcher: proc = subprocess.Popen("sleep 1") watcher.add_child_handler(proc.pid, callback) Notes: Implementations of this class must be thread-safe. Since child watcher objects may catch the SIGCHLD signal and call waitpid(-1), there should be only one active object per process. cGs tƒ‚dS)aRegister a new child handler. Arrange for callback(pid, returncode, *args) to be called when process 'pid' terminates. Specifying another callback for the same process replaces the previous handler. Note: callback() must be thread-safe. N©ÚNotImplementedError©rrjrBrCrrrr\—s z&AbstractChildWatcher.add_child_handlercCs tƒ‚dS)z Removes the handler for process 'pid'. The function returns True if the handler was successfully removed, False if there was nothing to remove.Nrü©rrjrrrÚremove_child_handler¢sz)AbstractChildWatcher.remove_child_handlercCs tƒ‚dS)zÔAttach the watcher to an event loop. If the watcher was previously attached to an event loop, then it is first detached before attaching to the new loop. Note: loop may be None. Nrü©rrYrrrÚ attach_loopªsz AbstractChildWatcher.attach_loopcCs tƒ‚dS)zlClose the watcher. This must be called to make sure that any underlying resource is freed. Nrür$rrrr&´szAbstractChildWatcher.closecCs tƒ‚dS)zdEnter the watcher's context and allow starting new processes This function must return selfNrür$rrrÚ __enter__»szAbstractChildWatcher.__enter__cCs tƒ‚dS)zExit the watcher's contextNrü©rÚaÚbÚcrrrÚ__exit__ÁszAbstractChildWatcher.__exit__N) rr‚rƒr„r\rrr&rrrrrrr€s  rc@sDeZdZdd„Zdd„Zdd„Zdd„Zd d „Zd d „Zd d„Z dS)ÚBaseChildWatchercCs d|_dSr)rŽr$rrrrÈszBaseChildWatcher.__init__cCs| d¡dSr)rr$rrrr&ËszBaseChildWatcher.closecCs tƒ‚dSrrü)rÚ expected_pidrrrÚ _do_waitpidÎszBaseChildWatcher._do_waitpidcCs tƒ‚dSrrür$rrrÚ_do_waitpid_allÑsz BaseChildWatcher._do_waitpid_allcCsZ|dust|tjƒsJ‚|jdur0|j tj¡||_|durV| tj|j¡|  ¡dSr) rMrZAbstractEventLooprŽr(r5ÚSIGCHLDrFÚ _sig_chldr rrrrrÔs zBaseChildWatcher.attach_loopc CsHz | ¡Wn6tyB}z|j d|dœ¡WYd}~n d}~00dS)Nz$Unknown exception in SIGCHLD handler)rÅrÆ)r r^rŽrÈrËrrrrâs þzBaseChildWatcher._sig_chldcCs2t |¡rt |¡ St |¡r*t |¡S|SdSr)r‡Ú WIFSIGNALEDÚWTERMSIGÚ WIFEXITEDÚ WEXITSTATUS)rÚstatusrrrÚ_compute_returncodeîs     z$BaseChildWatcher._compute_returncodeN) rr‚rƒrr&r r rrrrrrrr Æs r cs\eZdZdZ‡fdd„Z‡fdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z ‡Z S)rad'Safe' child watcher implementation. This implementation avoids disrupting other code spawning processes by polling explicitly each process in the SIGCHLD handler instead of calling os.waitpid(-1). This is a safe solution but it has a significant overhead when handling a big number of children (O(n) each time SIGCHLD is raised) cstƒ ¡i|_dSr)rrÚ _callbacksr$r rrrs zSafeChildWatcher.__init__cs|j ¡tƒ ¡dSr)rrçrr&r$r rrr& s zSafeChildWatcher.closecCs|Srrr$rrrrszSafeChildWatcher.__enter__cCsdSrrrrrrrszSafeChildWatcher.__exit__cGs||f|j|<| |¡dSr)rr rþrrrr\sz"SafeChildWatcher.add_child_handlercCs(z|j|=WdSty"YdS0dS©NTF©rrHrÿrrrrs  z%SafeChildWatcher.remove_child_handlercCst|jƒD]}| |¡q dSr)r'rr rÿrrrr "sz SafeChildWatcher._do_waitpid_allcCsÐ|dks J‚zt |tj¡\}}Wn&tyH|}d}t d|¡Yn00|dkrVdS| |¡}|j ¡rxt  d||¡z|j   |¡\}}Wn,t y¸|j ¡r´tjd|ddYn0|||g|¢RŽdS)Nréÿz8Unknown child process pid %d, will report returncode 255ú$process %s exited with returncode %sz'Child watcher got an unexpected pid: %rTrÃ) r‡ÚwaitpidÚWNOHANGÚChildProcessErrorr rârrŽr²rÇrÚpoprH)rr rjrrkrBrCrrrr 's2  þ   ÿ  ÿ zSafeChildWatcher._do_waitpid) rr‚rƒr„rr&rrr\rr r r…rrr rrüs  rcsTeZdZdZ‡fdd„Z‡fdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z ‡Z S)raW'Fast' child watcher implementation. This implementation reaps every terminated processes by calling os.waitpid(-1) directly, possibly breaking other code spawning processes and waiting for their termination. There is no noticeable overhead when handling a big number of children (O(1) each time a child terminates). cs*tƒ ¡i|_t ¡|_i|_d|_dS)Nr)rrrÚ threadingÚLockÚ_lockÚ_zombiesÚ_forksr$r rrrTs   zFastChildWatcher.__init__cs"|j ¡|j ¡tƒ ¡dSr)rrçr!rr&r$r rrr&[s  zFastChildWatcher.closecCs<|j"|jd7_|WdƒS1s.0YdS)Nr)r r"r$rrrr`szFastChildWatcher.__enter__cCst|jN|jd8_|js"|js2WdƒdSt|jƒ}|j ¡Wdƒn1sZ0Yt d|¡dS)Nrz5Caught subprocesses termination from unknown pids: %s)r r"r!r;rçr râ)rrrrZcollateral_victimsrrrrfs  (þzFastChildWatcher.__exit__c GsŠ|jsJdƒ‚|jPz|j |¡}Wn.tyT||f|j|<YWdƒdS0Wdƒn1sj0Y|||g|¢RŽdS)NzMust use the context manager)r"r r!rrHr)rrjrBrCrkrrrr\ts 2z"FastChildWatcher.add_child_handlercCs(z|j|=WdSty"YdS0dSrrrÿrrrrs  z%FastChildWatcher.remove_child_handlerc Cszt dtj¡\}}Wnty*YdS0|dkr8dS| |¡}|jŒz|j |¡\}}WnNty¬|j r¤||j |<|j   ¡r”t  d||¡YWdƒqd}Yn0|j   ¡rÆt  d||¡Wdƒn1sÚ0Y|durþt  d||¡q|||g|¢RŽqdS)Nr.rz,unknown process %s exited with returncode %srz8Caught subprocess termination from unknown pid: %d -> %d)r‡rrrrr rrrHr"r!rŽr²r rÇrâ)rrjrrkrBrCrrrr ˆs:     þ  ÿ" þz FastChildWatcher._do_waitpid_all) rr‚rƒr„rr&rrr\rr r…rrr rrJs   rcsHeZdZdZeZ‡fdd„Zdd„Z‡fdd„Zdd „Z d d „Z ‡Z S) Ú_UnixDefaultEventLoopPolicyz:UNIX event loop policy with a watcher for child processes.cstƒ ¡d|_dSr)rrÚ_watcherr$r rrr·s z$_UnixDefaultEventLoopPolicy.__init__cCs\tjB|jdur:tƒ|_tt ¡tjƒr:|j |j j ¡Wdƒn1sN0YdSr) rr r$rrMrÚcurrent_threadÚ _MainThreadrÚ_localrŽr$rrrÚ _init_watcher»s ÿz)_UnixDefaultEventLoopPolicy._init_watchercs6tƒ |¡|jdur2tt ¡tjƒr2|j |¡dS)zÑSet the event loop. As a side effect, if a child watcher was set before, then calling .set_event_loop() from the main thread will call .attach_loop(loop) on the child watcher. N)rÚset_event_loopr$rMrr%r&rrr rrr)Ãs   ÿz*_UnixDefaultEventLoopPolicy.set_event_loopcCs|jdur| ¡|jS)zzGet the watcher for child processes. If not yet set, a SafeChildWatcher object is automatically created. N)r$r(r$rrrrZÑs z-_UnixDefaultEventLoopPolicy.get_child_watchercCs4|dust|tƒsJ‚|jdur*|j ¡||_dS)z$Set the watcher for child processes.N)rMrr$r&)rrfrrrÚset_child_watcherÛs  z-_UnixDefaultEventLoopPolicy.set_child_watcher) rr‚rƒr„rZ _loop_factoryrr(r)rZr*r…rrr rr#³s   r#)1r„r?r‡r5r"r“rõrÍrr½Úrrrrrrr r r r Úlogr Ú__all__rÒÚ ImportErrorrZBaseSelectorEventLooprÚhasattrr‰rŠZ ReadTransportrPZ_FlowControlMixinZWriteTransportrWrírñZBaseSubprocessTransportr[rr rrZBaseDefaultEventLoopPolicyr#rrrrrrÚs^            u  oÿ@  F6Ni2