U wy]Ǿ@sdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZddl mZddl mZddl mZddl mZdd l mZdd l mZdd l mZdd l mZdd l mZddlmZdZe jdkredddZGdddejZGdddej Z!Gdddej"ej#Z$Gdddej%Z&GdddZ'ddZ(Gd d!d!e'Z)Gd"d#d#e)Z*Gd$d%d%e)Z+Gd&d'd'e'Z,Gd(d)d)e'Z-Gd*d+d+ej.Z/eZ0e/Z1dS),z2Selector event loop for Unix with signal handling.N) base_events)base_subprocess) constants) coroutines)events) exceptions)futures)selector_events)tasks) transports)logger)SelectorEventLoopAbstractChildWatcherSafeChildWatcherFastChildWatcherMultiLoopChildWatcherThreadedChildWatcherDefaultEventLoopPolicywin32z+Signals are not really supported on WindowscCsdS)zDummy signal handler.N)signumframerrP/home/stadmin/Documents/SimTableSoftware/Python-3.8.0/Lib/asyncio/unix_events.py_sighandler_noop*srcseZdZdZd)fdd ZfddZddZd d Zd d Zd dZ ddZ d*ddZ d+ddZ d,ddZ ddZd-dddddddZd.dddddddd Zd!d"Zd#d$Zd%d&Zd'd(ZZS)/_UnixSelectorEventLoopzdUnix event loop. Adds signal handling and UNIX Domain Socket support to SelectorEventLoop. Ncst|i|_dSN)super__init___signal_handlers)selfselector __class__rrr5s z_UnixSelectorEventLoop.__init__csZtts.t|jD]}||qn(|jrVtjd|dt |d|j dS)NzClosing the loop z@ on interpreter shutdown stage, skipping signal handlers removalsource) rclosesys is_finalizinglistrremove_signal_handlerwarningswarnResourceWarningclearr sigr"rrr&9s z_UnixSelectorEventLoop.closecCs|D]}|sq||qdSr)_handle_signal)r datarrrr_process_self_dataGsz)_UnixSelectorEventLoop._process_self_datac GsLt|st|rtd|||zt|j Wn2t t fk rt}zt t |W5d}~XYnXt|||d}||j|<zt|tt|dWnt k rF}zz|j|=|jsztdWn4t t fk r}ztd|W5d}~XYnX|jtjkr4t d|dnW5d}~XYnXdS)zAdd 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()NFset_wakeup_fd(-1) failed: %ssig  cannot be caught)r iscoroutineiscoroutinefunction TypeError _check_signal _check_closedsignal set_wakeup_fdZ_csockfileno ValueErrorOSError RuntimeErrorstrrHandlerr siginterruptr infoerrnoEINVAL)r r0callbackargsexchandleZnexcrrradd_signal_handlerNs2    z)_UnixSelectorEventLoop.add_signal_handlercCs8|j|}|dkrdS|jr*||n ||dS)z2Internal helper that is the actual signal handler.N)rget _cancelledr*_add_callback_signalsafe)r r0rLrrrr1{s   z%_UnixSelectorEventLoop._handle_signalc Cs||z |j|=Wntk r,YdSX|tjkr@tj}ntj}zt||WnBtk r}z$|jtj krt d|dnW5d}~XYnX|jszt dWn2t tfk r}zt d|W5d}~XYnXdS)zwRemove a handler for a signal. UNIX only. Return True if a signal handler was removed, False if not. Fr6r7Nr4r5T)r;rKeyErrorr=SIGINTdefault_int_handlerSIG_DFLrArGrHrBr>r@r rF)r r0handlerrKrrrr*s(    z,_UnixSelectorEventLoop.remove_signal_handlercCs6t|tstd||tkr2td|dS)zInternal 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 zinvalid signal number N) isinstanceintr:r= valid_signalsr@r/rrrr;s  z$_UnixSelectorEventLoop._check_signalcCst|||||Sr)_UnixReadPipeTransportr pipeprotocolwaiterextrarrr_make_read_pipe_transportsz0_UnixSelectorEventLoop._make_read_pipe_transportcCst|||||Sr)_UnixWritePipeTransportrZrrr_make_write_pipe_transportsz1_UnixSelectorEventLoop._make_write_pipe_transportc st} | std|} t||||||||f| |d| } | | |j| z| IdHWnDt t fk rYn,t k r| | IdHYnXW5QRX| S)NzRasyncio.get_child_watcher() is not activated, subprocess support is not installed.)r]r^)rget_child_watcher is_activerB create_future_UnixSubprocessTransportadd_child_handlerget_pid_child_watcher_callback SystemExitKeyboardInterrupt BaseExceptionr&_wait) r r\rJshellstdinstdoutstderrbufsizer^kwargswatcherr]transprrr_make_subprocess_transports8   z1_UnixSelectorEventLoop._make_subprocess_transportcCs||j|dSr)call_soon_threadsafe_process_exited)r pid returncodertrrrrhsz._UnixSelectorEventLoop._child_watcher_callback)sslsockserver_hostnamessl_handshake_timeoutc s |dkst|tst|r,|dkrLtdn |dk r.cb)add_done_callback)r rr{rrrrrsz6_UnixSelectorEventLoop._sock_add_cancellation_callback)N)NN)NN)N)N)N)__name__ __module__ __qualname____doc__rr&r3rMr1r*r;r_rarurhrrrrrr __classcell__rrr"rr/sH -       . CFrcseZdZdZdfdd ZddZddZd d Zd d Zd dZ ddZ ddZ ddZ e jfddZdddZddZddZZS) rYiNcst|||jd<||_||_||_||_d|_d|_ t |jj }t |st |st |sd|_d|_d|_tdt |jd|j|jj||j|jj|j|j|dk r|jtj|ddS)Nr[Fz)Pipe transport is for pipes/sockets only.)rr_extra_loop_piper?_fileno _protocol_closing_pausedrrrrS_ISFIFOrS_ISCHRr@ set_blocking call_soonconnection_made _add_reader _read_readyr _set_result_unless_cancelled)r rr[r\r]r^moder"rrrs:      z_UnixReadPipeTransport.__init__cCs|jjg}|jdkr |dn|jr0|d|d|jt|jdd}|jdk r|dk rt ||jt j }|r|dq|dn |jdk r|dn |dd d |S) Nclosedclosingfd= _selectorpollingidleopen<{}> )r#rrappendrrgetattrrr _test_selector_event selectors EVENT_READformatjoin)r rFr!rrrr__repr__s(         z_UnixReadPipeTransport.__repr__c Cszt|j|j}WnDttfk r,Yntk rX}z||dW5d}~XYn^X|rl|j |nJ|j rt d|d|_|j |j|j |jj|j |jddS)Nz"Fatal read error on pipe transport%r was closed by peerT)rreadrmax_sizerrrA _fatal_errorr data_receivedr get_debugr rFr_remove_readerr eof_received_call_connection_lost)r r2rKrrrrs  z"_UnixReadPipeTransport._read_readycCs>|js |jrdSd|_|j|j|jr:td|dS)NTz%r pauses reading)rrrrrrr debugr rrr pause_readings   z$_UnixReadPipeTransport.pause_readingcCsB|js |jsdSd|_|j|j|j|jr>td|dS)NFz%r resumes reading) rrrrrrrr rrrrrresume_readings   z%_UnixReadPipeTransport.resume_readingcCs ||_dSrrr r\rrr set_protocol sz#_UnixReadPipeTransport.set_protocolcCs|jSrrrrrr get_protocolsz#_UnixReadPipeTransport.get_protocolcCs|jSrrrrrr is_closingsz!_UnixReadPipeTransport.is_closingcCs|js|ddSr)r_closerrrrr&sz_UnixReadPipeTransport.closecCs,|jdk r(|d|t|d|jdSNzunclosed transport r$rr-r&r _warnrrr__del__s z_UnixReadPipeTransport.__del__Fatal error on pipe transportcCsZt|tr4|jtjkr4|jrLtjd||ddn|j||||j d| |dSNz%r: %sTexc_info)message exceptionrr\) rVrArGZEIOrrr rcall_exception_handlerrrr rKr rrrrs z#_UnixReadPipeTransport._fatal_errorcCs(d|_|j|j|j|j|dSNT)rrrrrrr rKrrrr-sz_UnixReadPipeTransport._closecCs4z|j|W5|jd|_d|_d|_XdSrrr&rrconnection_lostrrrrr2s  z,_UnixReadPipeTransport._call_connection_lost)NN)r)rrrrrrrrrrrrr&r+r,rrrrrrrr"rrYs rYcseZdZd%fdd ZddZddZdd Zd d Zd d ZddZ ddZ ddZ ddZ ddZ ddZejfddZddZd&dd Zd'd!d"Zd#d$ZZS)(r`Nc st||||jd<||_||_||_t|_d|_ d|_ t |jj }t|}t|}t|} |s|s| sd|_d|_d|_tdt |jd|j|jj|| s|rtjds|j|jj|j|j|dk r|jtj|ddS)Nr[rFz?Pipe transport is only for pipes, sockets and character devicesaix)rrrrr?rr bytearray_buffer _conn_lostrrrrrrrrr@rrrrr'platform startswithrrr r) r rr[r\r]r^rZis_charZis_fifoZ is_socketr"rrr?s:        z _UnixWritePipeTransport.__init__cCs|jjg}|jdkr |dn|jr0|d|d|jt|jdd}|jdk r|dk rt ||jt j }|r|dn |d| }|d|n |jdk r|dn |dd d |S) Nrrrrrrzbufsize=rrr)r#rrrrrrrr rr EVENT_WRITEget_write_buffer_sizerr)r rFr!rrqrrrrds,         z _UnixWritePipeTransport.__repr__cCs t|jSr)lenrrrrrr|sz-_UnixWritePipeTransport.get_write_buffer_sizecCs6|jrtd||jr*|tn|dS)Nr)rrr rFrrBrokenPipeErrorrrrrrs   z#_UnixWritePipeTransport._read_readyc CsRt|tttfstt|t|tr.t|}|s6dS|jsB|jrj|jtj krXt d|jd7_dS|j s8zt |j|}Wntttfk rd}YnZttfk rYnBtk r}z$|jd7_||dWYdSd}~XYnX|t|kr dS|dkr&t||d}|j|j|j|j |7_ |dS)Nz=pipe closed by peer or os.write(pipe, data) raised exception.rr#Fatal write error on pipe transport)rVbytesr memoryviewrreprrrr!LOG_THRESHOLD_FOR_CONNLOST_WRITESr warningrrwriterrrrirjrkrrrZ _add_writer _write_ready_maybe_pause_protocol)r r2nrKrrrr$s8      z_UnixWritePipeTransport.writec Cs|jstdzt|j|j}Wnttfk r:Ynttfk rRYnt k r}z6|j |j d7_ |j |j||dW5d}~XYnhX|t|jkr|j |j |j||jr|j |j|ddS|dkr |jd|=dS)NzData should not be emptyrrr)rrrr$rrrrirjrkr.rr_remove_writerrr_maybe_resume_protocolrrr)r r'rKrrrr%s,    z$_UnixWritePipeTransport._write_readycCsdSrrrrrr can_write_eofsz%_UnixWritePipeTransport.can_write_eofcCsB|jr dS|jstd|_|js>|j|j|j|jddSr) rrrrrrrrrrrrr write_eofs z!_UnixWritePipeTransport.write_eofcCs ||_dSrrrrrrrsz$_UnixWritePipeTransport.set_protocolcCs|jSrrrrrrrsz$_UnixWritePipeTransport.get_protocolcCs|jSrrrrrrrsz"_UnixWritePipeTransport.is_closingcCs|jdk r|js|dSr)rrr+rrrrr&sz_UnixWritePipeTransport.closecCs,|jdk r(|d|t|d|jdSrrrrrrrs z_UnixWritePipeTransport.__del__cCs|ddSr)rrrrrabortsz_UnixWritePipeTransport.abortrcCsNt|tr(|jr@tjd||ddn|j||||jd||dSr ) rVrArrr rrrrrrrrrs  z$_UnixWritePipeTransport._fatal_errorcCsFd|_|jr|j|j|j|j|j|j|j|dSr) rrrr(rr.rrrrrrrrs  z_UnixWritePipeTransport._closecCs4z|j|W5|jd|_d|_d|_XdSrrrrrrrs  z-_UnixWritePipeTransport._call_connection_lost)NN)r)N)rrrrrrrr$r%r*r+rrrr&r+r,rr,rrrrrrr"rr`<s"% #   r`c@seZdZddZdS)rec Ksd}|tjkrt\}}zPtj|f||||d|d||_|dk rh|t|d|d|j_ d}W5|dk r||XdS)NF)rmrnrorpuniversal_newlinesrqwb) buffering) subprocessPIPEr socketpairr&Popen_procrdetachrn) r rJrmrnrorprqrrZstdin_wrrr_start s.  z_UnixSubprocessTransport._startN)rrrr6rrrrre srec@sHeZdZdZddZddZddZdd Zd d Zd d Z ddZ 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 tdS)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. NNotImplementedErrorr rxrIrJrrrrf9s z&AbstractChildWatcher.add_child_handlercCs tdS)zRemoves the handler for process 'pid'. The function returns True if the handler was successfully removed, False if there was nothing to remove.Nr7r rxrrrremove_child_handlerDsz)AbstractChildWatcher.remove_child_handlercCs tdS)zAttach 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. Nr7r rrrr attach_loopLsz AbstractChildWatcher.attach_loopcCs tdS)zlClose the watcher. This must be called to make sure that any underlying resource is freed. Nr7rrrrr&VszAbstractChildWatcher.closecCs tdS)zReturn ``True`` if the watcher is active and is used by the event loop. Return True if the watcher is installed and ready to handle process exit notifications. Nr7rrrrrc]szAbstractChildWatcher.is_activecCs tdS)zdEnter the watcher's context and allow starting new processes This function must return selfNr7rrrr __enter__fszAbstractChildWatcher.__enter__cCs tdS)zExit the watcher's contextNr7r abcrrr__exit__lszAbstractChildWatcher.__exit__N) rrrrrfr;r=r&rcr>rCrrrrr"s   rcCs2t|rt| St|r*t|S|SdSr)r WIFSIGNALEDWTERMSIG WIFEXITED WEXITSTATUS)statusrrr_compute_returncodeqs     rIc@sDeZdZddZddZddZddZd d Zd d Zd dZ dS)BaseChildWatchercCsd|_i|_dSr)r _callbacksrrrrrszBaseChildWatcher.__init__cCs|ddSr)r=rrrrr&szBaseChildWatcher.closecCs|jdk o|jSr)r is_runningrrrrrcszBaseChildWatcher.is_activecCs tdSrr7)r expected_pidrrr _do_waitpidszBaseChildWatcher._do_waitpidcCs tdSrr7rrrr_do_waitpid_allsz BaseChildWatcher._do_waitpid_allcCs~|dkst|tjst|jdk r<|dkr<|jrszSafeChildWatcher.__enter__cCsdSrrr?rrrrCszSafeChildWatcher.__exit__cGs||f|j|<||dSr)rKrNr9rrrrfsz"SafeChildWatcher.add_child_handlercCs*z|j|=WdStk r$YdSXdSNTFrKrQr:rrrr;s z%SafeChildWatcher.remove_child_handlercCst|jD]}||q dSrr)rKrNr:rrrrOsz SafeChildWatcher._do_waitpid_allcCs|dks tzt|tj\}}Wn(tk rJ|}d}td|Yn.X|dkrXdSt|}|j rxt d||z|j |\}}Wn.t k r|j rtjd|ddYnX|||f|dS)Nr8Unknown child process pid %d, will report returncode 255$process %s exited with returncode %s'Child watcher got an unexpected pid: %rTr )rrwaitpidWNOHANGChildProcessErrorr r#rIrrrrKpoprQ)r rMrxrHryrIrJrrrrNs6     zSafeChildWatcher._do_waitpid) rrrrr&r>rCrfr;rOrNrrrr"rrs rcsTeZdZdZfddZfddZddZdd Zd d Zd d Z ddZ 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$tt|_i|_d|_dSr)rr threadingLock_lock_zombies_forksrr"rrrs  zFastChildWatcher.__init__cs"|j|jtdSr)rKr.rcrr&rr"rrr&s  zFastChildWatcher.closec Cs0|j |jd7_|W5QRSQRXdS)Nr)rbrdrrrrr>szFastChildWatcher.__enter__c Cs^|jB|jd8_|js"|js0W5QRdSt|j}|jW5QRXtd|dS)Nrz5Caught subprocesses termination from unknown pids: %s)rbrdrcrCr.r r#)r r@rArBZcollateral_victimsrrrrCs  zFastChildWatcher.__exit__c Gst|jstd|jFz|j|}Wn.tk rT||f|j|<YW5QRdSXW5QRX|||f|dS)NzMust use the context manager)rdrrbrcr_rQrK)r rxrIrJryrrrrf'sz"FastChildWatcher.add_child_handlercCs*z|j|=WdStk r$YdSXdSrUrVr:rrrr;5s z%FastChildWatcher.remove_child_handlerc Csztdtj\}}Wntk r,YdSX|dkr:dSt|}|jz|j|\}}WnNtk r|j r||j |<|j rt d||YW5QRqd}YnX|j rt d||W5QRX|dkrt d||q|||f|qdS)Nr4rz,unknown process %s exited with returncode %srZz8Caught subprocess termination from unknown pid: %d -> %d)rr\r]r^rIrbrKr_rQrdrcrrr rr#)r rxrHryrIrJrrrrO<s@    z FastChildWatcher._do_waitpid_all) rrrrrr&r>rCrfr;rOrrrr"rrs  rc@sheZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ ddZ ddZdS)ra~A watcher that doesn't require running loop in the main thread. This implementation registers a SIGCHLD signal handler on instantiation (which may conflict with other code that install own handler for this signal). The solution is safe but it has a significant overhead when handling a big number of processes (*O(n)* each time a SIGCHLD is received). cCsi|_d|_dSr)rK_saved_sighandlerrrrrrzszMultiLoopChildWatcher.__init__cCs |jdk Sr)rerrrrrc~szMultiLoopChildWatcher.is_activecCsP|j|jdk rLttj}||jkr6tdnttj|jd|_dS)Nz+SIGCHLD handler was changed by outside code) rKr.rer= getsignalrRrSr r#)r rUrrrr&s     zMultiLoopChildWatcher.closecCs|Srrrrrrr>szMultiLoopChildWatcher.__enter__cCsdSrrr exc_typeexc_valexc_tbrrrrCszMultiLoopChildWatcher.__exit__cGs&t}|||f|j|<||dSr)rget_running_looprKrN)r rxrIrJrrrrrfsz'MultiLoopChildWatcher.add_child_handlercCs*z|j|=WdStk r$YdSXdSrUrVr:rrrr;s z*MultiLoopChildWatcher.remove_child_handlercCsJ|jdkrFttj|j|_|jdkr8tdtj|_ttjddS)NzaPrevious SIGCHLD handler was set by non-Python code, restore to default handler on watcher close.F)rer=rRrSr r#rTrEr<rrrr=s    z!MultiLoopChildWatcher.attach_loopcCst|jD]}||q dSrrWr:rrrrOsz%MultiLoopChildWatcher._do_waitpid_allc Cs|dks tzt|tj\}}Wn,tk rN|}d}td|d}YnX|dkr\dSt|}d}z|j |\}}}Wn$t k rtjd|ddYnHX| rtd||n.|r| rt d |||j|||f|dS) NrrXrYFTr[r %Loop %r that handles pid %r is closedrZ)rrr\r]r^r r#rIrKr_rQ is_closedrrrv) r rMrxrHry debug_logrrIrJrrrrNs<    z!MultiLoopChildWatcher._do_waitpidc CsLz |Wn:ttfk r&Yn"tk rFtjdddYnXdS)NrTTr )rOrirjrkr r#)r rrrrrrSs  zMultiLoopChildWatcher._sig_chldN)rrrrrrcr&r>rCrfr;r=rOrNrSrrrrrgs %rc@sfeZdZdZddZddZddZdd Zd d Ze j fd d Z ddZ ddZ ddZddZdS)raAThreaded child watcher implementation. The watcher uses a thread per process for waiting for the process finish. It doesn't require subscription on POSIX signal but a thread creation is not free. The watcher has O(1) complexity, its performance doesn't depend on amount of spawn processes. cCstd|_i|_dSr) itertoolsr _pid_counter_threadsrrrrrs zThreadedChildWatcher.__init__cCsdSrrrrrrrcszThreadedChildWatcher.is_activecCsdSrrrrrrr&szThreadedChildWatcher.closecCs|Srrrrrrr>szThreadedChildWatcher.__enter__cCsdSrrrgrrrrCszThreadedChildWatcher.__exit__cCs6ddt|jD}|r2||jdt|ddS)NcSsg|]}|r|qSr)is_alive).0threadrrr sz0ThreadedChildWatcher.__del__..z0 has registered but not finished child processesr$)r)rqvaluesr#r-)r rthreadsrrrrs  zThreadedChildWatcher.__del__cGsFt}tj|jdt|j||||fdd}||j|<|dS)Nzwaitpid-T)targetnamerJdaemon) rrkr`ThreadrNnextrprqstart)r rxrIrJrrtrrrrfs  z&ThreadedChildWatcher.add_child_handlercCsdSrrr:rrrr;sz)ThreadedChildWatcher.remove_child_handlercCsdSrrr<rrrr=sz ThreadedChildWatcher.attach_loopcCs|dks tzt|d\}}Wn(tk rH|}d}td|Yn Xt|}|rhtd||| rtd||n|j |||f||j |dS)NrrXrYrZrl) rrr\r^r r#rIrrrmrvrqr_)r rrMrIrJrxrHryrrrrNs(  z ThreadedChildWatcher._do_waitpidN)rrrrrrcr&r>rCr+r,rrfr;r=rNrrrrrs  rcsHeZdZdZeZfddZddZfddZdd Z d d Z Z S) _UnixDefaultEventLoopPolicyz:UNIX event loop policy with a watcher for child processes.cstd|_dSr)rr_watcherrr"rrr6s z$_UnixDefaultEventLoopPolicy.__init__c CsHtj8|jdkr:t|_tttjr:|j|j j W5QRXdSr) rrbrrrVr`current_thread _MainThreadr=_localrrrrr _init_watcher:s z)_UnixDefaultEventLoopPolicy._init_watchercs6t||jdk r2tttjr2|j|dS)zSet 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)rset_event_looprrVr`rrr=r<r"rrrBs   z*_UnixDefaultEventLoopPolicy.set_event_loopcCs|jdkr||jS)z~Get the watcher for child processes. If not yet set, a ThreadedChildWatcher object is automatically created. N)rrrrrrrbPs z-_UnixDefaultEventLoopPolicy.get_child_watchercCs4|dkst|tst|jdk r*|j||_dS)z$Set the watcher for child processes.N)rVrrrr&)r rsrrrset_child_watcherZs  z-_UnixDefaultEventLoopPolicy.set_child_watcher) rrrrr _loop_factoryrrrrbrrrrr"rr~2s   r~)2rrGrrorrr=rrr0r'r`r+rrrrrrr r r r logr __all__r ImportErrorrZBaseSelectorEventLoopr ReadTransportrY_FlowControlMixinWriteTransportr`ZBaseSubprocessTransportrerrIrJrrrrBaseDefaultEventLoopPolicyr~rrrrrrs`             NO5JiyR3