python (3.11.7)

(root)/
lib/
python3.11/
asyncio/
__pycache__/
unix_events.cpython-311.opt-2.pyc

e	ddlZddlZddlZddlZddlZddlZddlZddlZddlZddl	Z	ddl
Z
ddlZddlm
Z
ddlmZddlmZddlmZddlmZddlmZdd	lmZdd
lmZddlmZddlmZdd
lmZdZe	jdkreddZdZGddejZGddej Z!Gddej"ej#Z$Gddej%Z&GddZ'Gdde'Z(Gdd e'Z)Gd!d"e)Z*Gd#d$e)Z+Gd%d&e'Z,Gd'd(e'Z-Gd)d*ej.Z/eZ0e/Z1dS)+N)base_events)base_subprocess)	constants)
coroutines)events)
exceptions)futures)selector_events)tasks)
transports)logger)SelectorEventLoopAbstractChildWatcherSafeChildWatcherFastChildWatcherPidfdChildWatcherMultiLoopChildWatcherThreadedChildWatcherDefaultEventLoopPolicywin32z+Signals are not really supported on Windowsc	dSN)signumframes  G/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/asyncio/unix_events.py_sighandler_noopr*s
DcP	tj|S#t$r|cYSwxYwr)oswaitstatus_to_exitcode
ValueError)statuss rr"r"/s>(000


	s%%ceZdZ	dfd	ZfdZdZdZdZdZdZ			dd	Z
		dd
Z	ddZdZ
	ddddddd
dZ	dddddddddZdZdZdZdZxZS)_UnixSelectorEventLoopNcXt|i|_dSr)super__init___signal_handlers)selfselector	__class__s  rr)z_UnixSelectorEventLoop.__init__?s)
""" "rcNttjs.t	|jD]}||dS|jr;tjd|dt||j
dSdS)NzClosing the loop z@ on interpreter shutdown stage, skipping signal handlers removalsource)r(closesys
is_finalizinglistr*remove_signal_handlerwarningswarnResourceWarningclear)r+sigr-s  rr1z_UnixSelectorEventLoop.closeCs


 ""
	.D122
0
0**3////
0
0$
.
I$III.%)	++++
%++-----

.
.rc@|D]}|s||dSr)_handle_signal)r+datars   r_process_self_dataz)_UnixSelectorEventLoop._process_self_dataQs=	(	(F
''''		(	(rcT	tj|stj|rtd|||	t
j|j	n5#ttf$r!}tt|d}~wwxYwtj|||d}||j|<	t
j|t"t
j|ddS#t$r}|j|=|jsI	t
jdn3#ttf$r}t'jd|Yd}~nd}~wwxYw|jt*jkrtd|dd}~wwxYw)Nz3coroutines cannot be used with add_signal_handler()Fset_wakeup_fd(-1) failed: %ssig  cannot be caught)riscoroutineiscoroutinefunction	TypeError
_check_signal
_check_closedsignal
set_wakeup_fd_csockfilenor#OSErrorRuntimeErrorstrrHandler*rsiginterruptrinfoerrnoEINVAL)r+r:callbackargsexchandlenexcs       radd_signal_handlerz)_UnixSelectorEventLoop.add_signal_handlerXs	

"8,,	9.x88	9899
93	)

 !3!3!5!56666G$	)	)	)s3xx(((	)xtT::%+c"	
M#/000
U+++++			%c*(
FF(,,,,"G,FFFK >EEEEEEEEFyEL(("#@##@#@#@AAA	sZ#+BC B<<C&/D
F'!F"1EF"E6E1,F"1E66,F""F'c	|j|}|dS|jr||dS||dSr)r*get
_cancelledr5_add_callback_signalsafe)r+r:rXs   rr<z%_UnixSelectorEventLoop._handle_signalsd@&**3//>F	2&&s+++++))&11111rc	||	|j|=n#t$rYdSwxYw|tjkr
tj}ntj}	tj||n;#t$r.}|jtj	krtd|dd}~wwxYw|jsI	tjdn3#ttf$r}tjd|Yd}~nd}~wwxYwdS)NFrBrCr@rAT)rGr*KeyErrorrISIGINTdefault_int_handlerSIG_DFLrMrSrTrNrJr#rrR)r+r:handlerrWs    rr5z,_UnixSelectorEventLoop.remove_signal_handlersP		
3	%c**			55	&-0GGnG	M#w''''			yEL(("#@##@#@#@AAA		$	A
A$R(((((
A
A
A:C@@@@@@@@
Ats<!
//A22
B*<)B%%B*5C

C:C55C:c	t|tstd||tjvrtd|dS)Nzsig must be an int, not zinvalid signal number )
isinstanceintrFrI
valid_signalsr#)r+r:s  rrGz$_UnixSelectorEventLoop._check_signalsf	
#s##	@>s>>???f*,,,,;c;;<<<-,rc(t|||||Sr)_UnixReadPipeTransportr+pipeprotocolwaiterextras     r_make_read_pipe_transportz0_UnixSelectorEventLoop._make_read_pipe_transports%dD(FEJJJrc(t|||||Sr)_UnixWritePipeTransportrks     r_make_write_pipe_transportz1_UnixSelectorEventLoop._make_write_pipe_transports&tT8VUKKKrc	
Ktj5}
|
std|}t||||||||f||d|	}|
||j|	|d{VnN#ttf$rt$r0||
d{VwxYw	dddn#1swxYwY|S)NzRasyncio.get_child_watcher() is not activated, subprocess support is not installed.)rnro)rget_child_watcher	is_activerN
create_future_UnixSubprocessTransportadd_child_handlerget_pid_child_watcher_callback
SystemExitKeyboardInterrupt
BaseExceptionr1_wait)
r+rmrVshellstdinstdoutstderrbufsizerokwargswatcherrntransps
             r_make_subprocess_transportz1_UnixSelectorEventLoop._make_subprocess_transports
%
'
'	7$$&&
K
#$JKKK''))F-dHdE.3VVW85;5881788F

%%fnn&6&6&*&BF
L
L
L
 12


 


llnn$$$$$$$
#															2
s+A=C8BC8AC((C88C<?C<cH||j|j|dSr)call_soon_threadsafe	call_soon_process_exited)r+pid
returncoders    rr{z._UnixSelectorEventLoop._child_watcher_callbacks%!!$.&2H*UUUUUr)sslsockserver_hostnamessl_handshake_timeoutssl_shutdown_timeoutcK|r|tdn3|td|td|td||tdtj|}tjtjtjd}	|d|||d{Vn|#|xYw|td|j	tjks|j
tjkrtd	||d|||||||
d{V\}}	||	fS)Nz/you have to pass server_hostname when using sslz+server_hostname is only meaningful with ssl1ssl_handshake_timeout is only meaningful with ssl0ssl_shutdown_timeout is only meaningful with ssl3path and sock can not be specified at the same timerFzno path and sock were specified.A UNIX Domain Stream Socket was expected, got )rr)r#r!fspathsocketAF_UNIXSOCK_STREAMsetblockingsock_connectr1familytype_create_connection_transport)
r+protocol_factorypathrrrrr	transportrms
          rcreate_unix_connectionz-_UnixSelectorEventLoop.create_unix_connections	H& EGGG'* !NOOO$0 GIII#/ FHHH IKKK9T??D=1CQGGD
  '''''d3333333333


| !BCCCv~--I!333 MTMMOOOU###$($E$E"C"7!5%F%7%7777777	8(""s1CC%dT)rbacklogrrr
start_servingc	Kt|trtd||std||std|Z|tdt	j|}t
jtjtj}|ddvry	tj
t	j	|jrt	j|n8#t$rYn,t$r }	tjd||	Yd}	~	nd}	~	wwxYw	||n#t$rP}
||
jt&jkr!d|d	}tt&j|dd}
~
w|xYw|td
|jtjks|jtjkrtd||dt1j||g|||||}|r.|t7jdd{V|S)
Nz*ssl argument must be an SSLContext or Nonerrrr)rz2Unable to check or remove stale UNIX socket %r: %rzAddress z is already in usez-path was not specified, and no sock specifiedrF)rfboolrFr#r!rrrrstatS_ISSOCKst_moderemoveFileNotFoundErrorrMrerrorbindr1rS
EADDRINUSErrrrServer_start_servingrsleep)
r+rrrrrrrrerrrWmsgservers
             rcreate_unix_serverz)_UnixSelectorEventLoop.create_unix_serversc4  	JHIII ,S,CEE
E +C+BDD
D IKKK9T??D=1CDDDAwk))6}RWT]]%:;;(	$(D666L"*+/666666666


		$




9 000@T???C!%"2C88dB


| CEEEv~--I!333 MTMMOOO	
#D4&2B$'2G$8::	!!!###+a..       
s7)?C))
D5	D>DD"D88
F'AF

F'c
K	tjn"#t$rtjdwxYw	|}n2#ttjf$r}tjdd}~wwxYw	tj|j	}n"#t$rtjdwxYw|r|n|}|sdS|}	||	d|||||d|	d{VS)Nzos.sendfile() is not availableznot a regular filer)
r!sendfileAttributeErrorr	SendfileNotAvailableErrorrLioUnsupportedOperationfstatst_sizerMrw_sock_sendfile_native_impl)
r+rfileoffsetcountrLrfsize	blocksizefuts
          r_sock_sendfile_nativez,_UnixSelectorEventLoop._sock_sendfile_native`sN	2KKK	2	2	26022
2	2	M[[]]FF 78	M	M	M67KLLL	M	MHV$$,EE	M	M	M67KLLL	M"-EE		1  ""''T4(.y!	E	E	Eyyyyyys+0A		A8A33A8<BB5c	
L|}	||||r||||dS|r9||z
}|dkr.||||||dS	tj|	|||}
|
dkr.||||||dS||
z
}||
z
}||||||	|j	||	||||||

dS#ttf$r?||||||	|j	||	||||||

YdSt$r}|N|j
tjkr9t|t ur#t!dtj}||_|}|dkrAt%jd}
||||||
n2||||||Yd}~dSYd}~dSd}~wt*t,f$rt.$r7}||||||Yd}~dSd}~wwxYw)Nrzsocket is not connectedzos.sendfile call failed)rL
remove_writer	cancelled_sock_sendfile_update_filepos
set_resultr!r_sock_add_cancellation_callback
add_writerrBlockingIOErrorInterruptedErrorrMrSENOTCONNrConnectionError	__cause__r	r
set_exceptionr|r}r~)r+r
registered_fdrrLrrr
total_sentfdsentrWnew_excrs              rrz1_UnixSelectorEventLoop._sock_sendfile_native_implwsb
[[]]$

}---==??	..vvzJJJF	
*IA~~2266:NNNz***1	F;r669==DJqyy2266:NNNz*****$d"
 (88dCCCD$CS "D& &y*FFFFF[ !12	B	B	B$44S$???OOB ?f"E9j
B
B
B
B
B
B	'	'	')I//II_44
*-u~??$'!Q
!:-//2266:NNN!!#&&&&2266:NNN!!#&&&&&&&&&'&&&&&-.				#	#	#..vvzJJJc"""""""""	#s,D''AJ#6	J#?CIJ#,,JJ#cV|dkr"tj||tjdSdSNr)r!lseekSEEK_SET)r+rLrrs    rrz4_UnixSelectorEventLoop._sock_sendfile_update_fileposs.>>HVVR[11111>rc@fd}||dS)Nc|r1}|dkr|dSdSdS)Nr@)rrLr)rrr+rs  rcbzB_UnixSelectorEventLoop._sock_add_cancellation_callback.<locals>.cbsR}}
+[[]]88&&r*****
+
+8r)add_done_callback)r+rrrs` ` rrz6_UnixSelectorEventLoop._sock_add_cancellation_callbacks>	+	+	+	+	+	+
	b!!!!!rrNN)__name__
__module____qualname__r)r1r>rZr<r5rGrprsrr{rrrrrr
__classcell__r-s@rr&r&9s
######.....(((+++Z222@
=
=
=@D(,KKKKAE)-LLLL04<VVV
*.0#4 "&!%0#0#0#0#0#f*.Gs"&!%GGGGGR.DFDFDFL222"""""""rr&ceZdZdZdfd	ZdZdZdZdZdZ	d	Z
d
ZdZdZ
d
ZejfdZddZdZdZxZS)rjiNct|||jd<||_||_||_||_d|_d|_	tj|jj}tj|sLtj|s8tj|s$d|_d|_d|_t#dtj|jd|j|jj||j|j|j|j|(|jt.j|ddSdS)NrlFz)Pipe transport is for pipes/sockets only.)r(r)_extra_loop_piperL_fileno	_protocol_closing_pausedr!rrrS_ISFIFOrS_ISCHRr#set_blockingrconnection_made_add_reader_read_readyr
_set_result_unless_cancelled)r+looprlrmrnromoder-s       rr)z_UnixReadPipeTransport.__init__sb
"F

{{}}!
x%%-
d##	J
d##	JT""	JDJDL!DNHIII
e,,,
T^;TBBB
T-!\4+;	=	=	=J  !E!'
/
/
/
/
/rch|sdS|j||dSr)
is_readingrr)r+rrUs   rrz"_UnixReadPipeTransport._add_readers7  	F
r8,,,,,rc"|jo|jSr)rrr+s rrz!_UnixReadPipeTransport.is_readings<5
$55rc`|jjg}|j|dn|jr|d|d|jt
|jdd}|jU|Stj	||jtj}|r|dnH|dn2|j|dn|ddd	
|S)
Nclosedclosingfd=	_selectorpollingidleopen<{}> )r-rrappendrrgetattrrr_test_selector_event	selectors
EVENT_READformatjoin)r+rRr,rs    r__repr__z_UnixReadPipeTransport.__repr__s '(:KK!!!!
]	#KK	"""($,(()))4:{D99:!h&:%:$,	(<>>G
$I&&&&F####
Z
#KKKK!!!}}SXXd^^,,,rc4	tj|j|j}|r|j|dS|jrtj	d|d|_
|j|j|j|jj
|j|jddS#tt f$rYdSt"$r!}||dYd}~dSd}~wwxYw)N%r was closed by peerTz"Fatal read error on pipe transport)r!readrmax_sizer
data_receivedr	get_debugrrRr_remove_readerreof_received_call_connection_lostrrrM_fatal_error)r+r=rWs   rrz"_UnixReadPipeTransport._read_ready	s5	G74<77D
G,,T22222:''))?K 7>>> $

))$,777
$$T^%@AAA
$$T%?FFFFF !12			DD	I	I	Ic#GHHHHHHHHH	IsCD-	D6DDc|sdSd|_|j|j|jrt
jd|dSdS)NTz%r pauses reading)rrrrrrrdebugrs r
pause_readingz$_UnixReadPipeTransport.pause_readingsq  	F
!!$,///:!!	4L,d33333	4	4rc|js|jsdSd|_|j|j|j|jrtjd|dSdS)NFz%r resumes reading)	rrrrrrrrrrs rresume_readingz%_UnixReadPipeTransport.resume_reading#sw=		F
t|T-=>>>:!!	5L-t44444	5	5rc||_dSrrr+rms  rset_protocolz#_UnixReadPipeTransport.set_protocol+
!rc|jSrr#rs rget_protocolz#_UnixReadPipeTransport.get_protocol.
~rc|jSrrrs r
is_closingz!_UnixReadPipeTransport.is_closing1
}rcB|js|ddSdSr)r_closers rr1z_UnixReadPipeTransport.close4s.}	KK		rcv|j1|d|t||jdSdSNzunclosed transport r/rr8r1r+_warns  r__del__z_UnixReadPipeTransport.__del__8L:!E000/$OOOOJ"!rFatal error on pipe transportc0t|trG|jtjkr2|jrt
jd||dn$|j||||j	d|
|dSNz%r: %sTexc_info)message	exceptionrrm)rfrMrSEIOrrrrcall_exception_handlerrr/r+rWr<s   rrz#_UnixReadPipeTransport._fatal_error=ssG$$		ei)?)?z##%%
EXtWtDDDDJ--" ! N	//


	
Crcd|_|j|j|j|j|dSNT)rrrrrrr+rWs  rr/z_UnixReadPipeTransport._closeKsB

!!$,///
T7=====rc	|j||jd|_d|_d|_dS#|jd|_d|_d|_wxYwrrconnection_lostrr1rrCs  rrz,_UnixReadPipeTransport._call_connection_lostP	N**3///JDJ!DNDJJJ
JDJ!DNDJA0A<rr7)rrrrr)rrrrrr!r%r(r,r1r6r7r5rr/rrrs@rrjrjs(H//////<---
666---*GGG$444555"""%M
>>>
rrjceZdZdfd	ZdZdZdZdZdZdZ	d	Z
d
ZdZdZ
d
ZejfdZdZddZddZdZxZS)rrNcpt||||jd<||_||_||_t|_d|_	d|_
tj|jj
}tj|}tj|}tj|}	|s(|s&|	s$d|_d|_d|_t%dtj|jd|j|jj||	s!|rOt.jds0|j|jj|j|j|(|jt8j|ddSdS)NrlrFz?Pipe transport is only for pipes, sockets and character devicesaix)r(r)rrrLrr	bytearray_buffer
_conn_lostrr!rrrrrrr#rrrrr2platform
startswithrrr
r)r+rrlrmrnroris_charis_fifo	is_socketr-s          rr)z _UnixWritePipeTransport.__init__]s
%%%"F
{{}}! {{
x%%-,t$$-%%M$''		E7	Ei	EDJDL!DNDEE
E	e,,,
T^;TBBB
	A	A)@)@)G)G	AJ  !7!%t/?
A
A
AJ  !E!'
/
/
/
/
/rc|jjg}|j|dn|jr|d|d|jt
|jdd}|j|tj	||jtj}|r|dn|d|}|d|n2|j|dn|dd	
d
|S)Nrrrrrrzbufsize=rr	r
)r-rrrrrrrrr
rEVENT_WRITEget_write_buffer_sizerr)r+rRr,rrs     rrz _UnixWritePipeTransport.__repr__sL'(:KK!!!!
]	#KK	"""($,(()))4:{D99:!h&:%:$,	(=??G
$I&&&&F###0022GKK,7,,----
Z
#KKKK!!!}}SXXd^^,,,rc*t|jSr)lenrNrs rrWz-_UnixWritePipeTransport.get_write_buffer_sizes4<   rc|jrtjd||jr#|t
dS|dS)Nr)rrrrRrNr/BrokenPipeErrorrs rrz#_UnixWritePipeTransport._read_readysd:!!	7K/666<	KK))*****KKMMMMMrct|trt|}|sdS|js|jr;|jt
jkrtjd|xjdz
c_dS|j	s	tj|j|}nc#ttf$rd}YnNtt f$rt"$r1}|xjdz
c_||dYd}~dSd}~wwxYw|t'|krdS|dkrt||d}|j|j|j|xj	|z
c_	|dS)Nz=pipe closed by peer or os.write(pipe, data) raised exception.rr#Fatal write error on pipe transport)rfrM
memoryviewrOrr!LOG_THRESHOLD_FOR_CONNLOST_WRITESrwarningrNr!writerrrr|r}r~rrYr_add_writer_write_ready_maybe_pause_protocol)r+r=nrWs    rraz_UnixWritePipeTransport.writesdI&&	$d##D	F?	dm	)"MMM HIIIOOq OOF|	D	
HT\400#%56


 12


 


1$!!#'LMMM
CII~~Q!$''+J""4<1BCCC""$$$$$s:BC5*C5&C00C5c	tj|j|j}|t	|jkr|j|j|j||j	r4|j
|j|ddS|dkr|jd|=dSdS#ttf$rYdSttf$rt $ri}|j|xjdz
c_|j|j||dYd}~dSd}~wwxYw)Nrrr])r!rarrNrYr9r_remove_writer_maybe_resume_protocolrrrrrr|r}r~rOr)r+rerWs   rrcz$_UnixWritePipeTransport._write_readys	%t|44AC%%%%""$$$
))$,777++---=5J--dl;;;..t444QL!$$$) !12			DD-.				J	J	JL   OOq OO
J%%dl333c#HIIIIIIIII
	JsCE-*E-AE((E-cdSrBrrs r
can_write_eofz%_UnixWritePipeTransport.can_write_eoftrc|jrdSd|_|jsA|j|j|j|jddSdSrB)rrNrrrrrrs r	write_eofz!_UnixWritePipeTransport.write_eofsh=	F
|	CJ%%dl333J  !;TBBBBB	C	Crc||_dSrr#r$s  rr%z$_UnixWritePipeTransport.set_protocolr&rc|jSrr#rs rr(z$_UnixWritePipeTransport.get_protocolr)rc|jSrr+rs rr,z"_UnixWritePipeTransport.is_closingr-rcR|j|js|dSdSdSr)rrrmrs rr1z_UnixWritePipeTransport.closes5:!$-!NN"!!!rcv|j1|d|t||jdSdSr1r2r3s  rr5z_UnixWritePipeTransport.__del__r6rc0|ddSr)r/rs rabortz_UnixWritePipeTransport.abortsDrr7ct|tr2|jrt	jd||dn$|j||||jd||dSr9)	rfrMrrrrr?rr/r@s   rrz$_UnixWritePipeTransport._fatal_errorsc7##		z##%%
EXtWtDDDDJ--" ! N	//


	
Crcd|_|jr|j|j|j|j|j|j|j|dSrB)	rrNrrgrr9rrrrCs  rr/z_UnixWritePipeTransport._closesx
<	4J%%dl333
!!$,///
T7=====rc	|j||jd|_d|_d|_dS#|jd|_d|_d|_wxYwrrErCs  rrz-_UnixWritePipeTransport._call_connection_lostrGrHrrIr)rrrr)rrWrrarcrjrmr%r(r,r1r6r7r5rtrr/rrrs@rrrrrZsH#/#/#/#/#/#/J---0!!!!%!%!%F%%%8CCC"""
%M
>>>>rrrceZdZdZdS)rxc
d}|tjkr5tjdrtj\}}	tj|f||||d|d||_|D|	t|d||j_d}|*|	|	dSdS#|)|	|	wwxYw)NrLF)rrrruniversal_newlinesrwb)	buffering)
subprocessPIPEr2rPrQr
socketpairPopen_procr1rdetachr)	r+rVrrrrrrstdin_ws	         r_startz_UnixSubprocessTransport._start)sJO##(?(?(F(F#
$.00NE7	 #)E!vf#('EE=CEEDJ"


#'(8(8$'#R#R#R
 "




#"w"




#s
	A$C-DN)rrrrrrrrxrx's#     rrxc:eZdZ	dZdZdZdZdZdZdZ	dS)	rc 	trNotImplementedErrorr+rrUrVs    rryz&AbstractChildWatcher.add_child_handlerVs	"###rc 	trrr+rs  rremove_child_handlerz)AbstractChildWatcher.remove_child_handleras	1
"###rc 	trrr+rs  rattach_loopz AbstractChildWatcher.attach_loopis	"###rc 	trrrs rr1zAbstractChildWatcher.closess	"###rc 	trrrs rrvzAbstractChildWatcher.is_activezs	"###rc 	trrrs r	__enter__zAbstractChildWatcher.__enter__s	*"###rc 	trrr+abcs    r__exit__zAbstractChildWatcher.__exit__s(!###rN)
rrrryrrr1rvrrrrrrr?s,	$	$	$$$$$$$$$$$$$$$$$$$$$rrcFeZdZ	dZdZdZdZdZdZdZ	dZ
d	Zd
S)rc"d|_i|_dSrr
_callbacksrs rr)zPidfdChildWatcher.__init__
rc|Srrrs rrzPidfdChildWatcher.__enter__rcdSrr)r+exc_type	exc_value
exc_tracebacks    rrzPidfdChildWatcher.__exit__rcF|jduo|jSrr
is_runningrs rrvzPidfdChildWatcher.is_active"z%A$**?*?*A*AArc0|ddSrrrs rr1zPidfdChildWatcher.closerc6|j#|!|jrtjdt|jD]4\}}}|j|tj|5|j	||_dSNzCA loop is being detached from a child watcher with pending handlers)
rrr6r7RuntimeWarningvaluesrr!r1r9)r+rpidfd_s    rrzPidfdChildWatcher.attach_loops:!dltlM=
 
 
  ?1133		KE1aJ%%e,,,HUOOOO


rc|j|}||d||f|j|<dStj|}|j||j||||f|j|<dSr)rr\r!
pidfd_openrr_do_wait)r+rrUrVexistingrs      rryz#PidfdChildWatcher.add_child_handlers~?&&s++#+A;$#>DOC   M#&&EJ""5$-===#((D#8DOC   rcR|j|\}}}|j|	t	j|d\}}t
|}n'#t$rd}tj	d|YnwxYwt	j
||||g|RdS)NrzJchild process pid %d exit status already read:  will report returncode 255)rpoprrr!waitpidr"ChildProcessErrorrr`r1)r+rrrUrVrr$rs        rrzPidfdChildWatcher._do_waits $ 3 3C 8 8x
!!%(((	8
3**IAv077JJ!			JN.




			j(4((((((sA""!BBc	|j|\}}}n#t$rYdSwxYw|j|tj|dS)NFT)rrr`rrr!r1)r+rrrs    rrz&PidfdChildWatcher.remove_child_handlersn	/--c22KE1aa			55	
!!%(((
ts!
//N)rrrr)rrrvr1rryrrrrrrrs	


BBB


999)))&rrc8eZdZdZdZdZdZdZdZdZ	dS)	BaseChildWatcherc"d|_i|_dSrrrs rr)zBaseChildWatcher.__init__rrc0|ddSrrrs rr1zBaseChildWatcher.closerrcF|jduo|jSrrrs rrvzBaseChildWatcher.is_activerrctrr)r+expected_pids  r_do_waitpidzBaseChildWatcher._do_waitpid!###rctrrrs r_do_waitpid_allz BaseChildWatcher._do_waitpid_allrrc8|j#|!|jrtjdt|j$|jtj||_|;|tj|j	|
dSdSr)rrr6r7rr5rISIGCHLDrZ	_sig_chldrrs  rrzBaseChildWatcher.attach_loops:!dltlM=
 
 
 
:!J,,V^<<<
##FNDNCCC
  """""rc	|dS#ttf$rt$r(}|jd|dYd}~dSd}~wwxYw)N$Unknown exception in SIGCHLD handler)r<r=)rr|r}r~rr?rCs  rrzBaseChildWatcher._sig_chlds	  """""-.						
J--A //








		sAAAN)
rrrr)r1rvrrrrrrrrrsBBB$$$$$$###(rrcDeZdZ	fdZdZdZdZdZdZdZ	xZ
S)rcz|jtdSr)rr9r(r1r+r-s rr1zSafeChildWatcher.closes,


rc|Srrrs rrzSafeChildWatcher.__enter__ rrcdSrrrs    rrzSafeChildWatcher.__exit__#rrcH||f|j|<||dSr)rrrs    rryz"SafeChildWatcher.add_child_handler&s/ ($/	
rc:	|j|=dS#t$rYdSwxYwNTFrr`rs  rrz%SafeChildWatcher.remove_child_handler,8	$4			55	
c^t|jD]}||dSrr4rrrs  rrz SafeChildWatcher._do_waitpid_all3s<((	"	"CS!!!!	"	"rc	tj|tj\}}|dkrdSt|}|jrt
jd||n)#t$r|}d}t
j	d|YnwxYw	|j
|\}}|||g|RdS#t$r7|jrt
j	d|dYdSYdSwxYw)Nr$process %s exited with returncode %sr8Unknown child process pid %d, will report returncode 255'Child watcher got an unexpected pid: %rTr:)
r!rWNOHANGr"rrrrrr`rrr`)r+rrr$rrUrVs       rrzSafeChildWatcher._do_waitpid8so	7*\2:>>KCaxx/77Jz##%%
7C):777!			CJNJ




	$		-!_0055NHd
HS*,t,,,,,,	3	3	3z##%%
3H"T3333333
3
3
3	3s#"A++#BBB>>:C?>C?)rrrr1rrryrrrrrs@rrrs


"""
 - - - - - - -rrcHeZdZ	fdZfdZdZdZdZdZdZ	xZ
S)rcttj|_i|_d|_dSr)r(r)	threadingLock_lock_zombies_forksrs rr)zFastChildWatcher.__init__es:
^%%

rc|j|jtdSr)rr9rr(r1rs rr1zFastChildWatcher.closeks@



rch|j5|xjdz
c_|cdddS#1swxYwYdS)Nr)rrrs rrzFastChildWatcher.__enter__ps
Z		KK1KK																		s'++c |j5|xjdzc_|js|js	ddddSt|j}|jdddn#1swxYwYtjd|dS)Nrz5Caught subprocesses termination from unknown pids: %s)rrrrOr9rr`)r+rrrcollateral_victimss     rrzFastChildWatcher.__exit__vs
Z	"	"KK1KK{
$-
		"	"	"	"	"	"	"	""%T]!3!3M!!!	"	"	"	"	"	"	"	"	"	"	"	"	"	"	"	C	 	 	 	 	 s A.-A..A25A2c|j5	|j|}n(#t$r||f|j|<YddddSwxYw	dddn#1swxYwY|||g|RdSr)rrrr`r)r+rrUrVrs     rryz"FastChildWatcher.add_child_handlersZ		
!]..s33




'/~$
								
																j(4((((((s0A%AA
A	A

AA!Ac:	|j|=dS#t$rYdSwxYwrrrs  rrz%FastChildWatcher.remove_child_handlerrrc~		tjdtj\}}|dkrdSt|}n#t$rYdSwxYw|j5	|j|\}}|j	rtjd||n_#t$rR|j
rF||j|<|j	rtjd||Ydddd}YnwxYwdddn#1swxYwY|tjd||n
|||g|R=)NTr@rrz,unknown process %s exited with returncode %sz8Caught subprocess termination from unknown pid: %d -> %d)r!rrr"rrrrrrrrr`rrr`)r+rr$rrUrVs      rrz FastChildWatcher._do_waitpid_alls%	1

< jRZ88V
!88F3F;;

%




6
66%)_%8%8%=%=NHdz++--6%K%(*666 
$
$
${!-7
c*://11:"L*>),j:::!
6
6
6
6
6
6
6 $HHH
$
6
6
6
6
6
6
6
6
6
6
6
6
6
6
6& #Z1111j040000K%	1sR"=
A
ADB$40D$A
D.D;D=D?DDDD)rrrr)r1rrryrrrrs@rrr[s
   )))(1(1(1(1(1(1(1rrcReZdZ	dZdZdZdZdZdZdZ	dZ
d	Zd
ZdZ
dS)
rc"i|_d|_dSr)r_saved_sighandlerrs rr)zMultiLoopChildWatcher.__init__s!%rc|jduSr)rrs rrvzMultiLoopChildWatcher.is_actives%T11rc|j|jdStjtj}||jkrtjdn$tjtj|jd|_dS)Nz+SIGCHLD handler was changed by outside code)	rr9rrI	getsignalrrrr`)r+rds  rr1zMultiLoopChildWatcher.closes|!)F"6>22dn$$NHIIIIM&.$*@AAA!%rc|Srrrs rrzMultiLoopChildWatcher.__enter__rrcdSrrr+rexc_valexc_tbs    rrzMultiLoopChildWatcher.__exit__rrcptj}|||f|j|<||dSr)rget_running_looprr)r+rrUrVrs     rryz'MultiLoopChildWatcher.add_child_handlers?&(( $h5	
rc:	|j|=dS#t$rYdSwxYwrrrs  rrz*MultiLoopChildWatcher.remove_child_handlerrrc|jdStjtj|j|_|j%t	jdtj|_tjtjddS)NzaPrevious SIGCHLD handler was set by non-Python code, restore to default handler on watcher close.F)rrIrrrr`rcrQrs  rrz!MultiLoopChildWatcher.attach_loopsw
!-F!'v~t~!N!N!)NJ
K
K
K%+^D"	FNE22222rc^t|jD]}||dSrrrs  rrz%MultiLoopChildWatcher._do_waitpid_alls<((	"	"CS!!!!	"	"rc4	tj|tj\}}|dkrdSt|}d}n+#t$r|}d}tjd|d}YnwxYw	|j|\}}}|	rtjd||dS|r*|
rtjd|||j|||g|RdS#t$rtjd|d	YdSwxYw)
NrTrrF%Loop %r that handles pid %r is closedrrr:)r!rrr"rrr`rr	is_closedrrrr`)	r+rrr$r	debug_logrrUrVs	         rrz!MultiLoopChildWatcher._do_waitpids	*\2:>>KCaxx/77JII!			CJNJ


III	 	L#'?#6#6s#;#; D(D~~
LFcRRRRR;!1!1;L!G!-z;;;))(CKdKKKKKK	/	/	/
ND
/
/
/
/
/
/
/	/s!">%A&%A&*C22!DDc	|dS#ttf$rt$rt	jddYdSwxYw)NrTr:)rr|r}r~rr`)r+rrs   rrzMultiLoopChildWatcher._sig_chld8sy	R  """""-.				R	R	RNADQQQQQQQ	Rs1A
A
N)rrrr)rvr1rrryrrrrrrrrrrs	$&&&222
&
&
&


333""""#L#L#LJRRRRRrrcZeZdZ	dZdZdZdZdZej	fdZ
dZdZd	Z
d
ZdS)rcFtjd|_i|_dSr)	itertoolsr_pid_counter_threadsrs rr)zThreadedChildWatcher.__init__Ns%OA..


rcdSrBrrs rrvzThreadedChildWatcher.is_activeRrkrcdSrrrs rr1zThreadedChildWatcher.closeUrrc|Srrrs rrzThreadedChildWatcher.__enter__XrrcdSrrrs    rrzThreadedChildWatcher.__exit__[rrcdt|jD}|r||jdt|dSdS)Nc:g|]}||Sr)is_alive).0threads  r
<listcomp>z0ThreadedChildWatcher.__del__.<locals>.<listcomp>_s6)))foo'')6)))rz0 has registered but not finished child processesr/)r4rrr-r8)r+r4threadss   rr5zThreadedChildWatcher.__del__^s}))T]-A-A-C-C(D(D)))	ET^UUU!





		rctj}tj|jdt|j||||fd}||j|<|dS)Nzasyncio-waitpid-T)targetnamerVdaemon)	rrrThreadrnextrrstart)r+rrUrVrrs      rryz&ThreadedChildWatcher.add_child_handlerfsp&((!)9'S$t?P:Q:Q'S'S(,c8T'B)-///$
crcdSrBrrs  rrz)ThreadedChildWatcher.remove_child_handleros	trcdSrrrs  rrz ThreadedChildWatcher.attach_loopurrc	tj|d\}}t|}|rt	jd||n)#t$r|}d}t	jd|YnwxYw|rt	jd||n|j	|||g|R|j
|dS)Nrrrrr)r!rr"rrrrr`rrrr)r+rrrUrVrr$rs        rrz ThreadedChildWatcher._do_waitpidxs	7*\155KC077J~~
7C):777!			CJNJ




	>>	HNBD#NNNN%D%hZG$GGGG
,'''''sA#A:9A:N)rrrr)rvr1rrr6r7r5ryrrrrrrrrAs






%M


(((((rrc@eZdZ	eZfdZdZfdZdZdZ	xZ
S)_UnixDefaultEventLoopPolicycVtd|_dSr)r(r)_watcherrs rr)z$_UnixDefaultEventLoopPolicy.__init__s$



rctj5|jt|_ddddS#1swxYwYdSr)rrrrrs r
_init_watcherz)_UnixDefaultEventLoopPolicy._init_watchers
\	7	7}$ 4 6 6
	7	7	7	7	7	7	7	7	7	7	7	7	7	7	7	7	7	7s599c	t||jBtjtjur|j|dSdSdSr)r(set_event_looprrcurrent_threadmain_threadr)r+rr-s  rr#z*_UnixDefaultEventLoopPolicy.set_event_loopsq		t$$$M%(**i.C.E.EEEM%%d+++++
&%EErcH	|j||jSr)rr!rs rruz-_UnixDefaultEventLoopPolicy.get_child_watchers+	=    }rcV	|j|j||_dSr)rr1)r+rs  rset_child_watcherz-_UnixDefaultEventLoopPolicy.set_child_watchers.2=$M!!!


r)rrrr&
_loop_factoryr)r!r#rur(rrs@rrrsD*M777
,,,,,       rr)2rSrrr!rrIrrr}r2rr6rrrrrr	r
rrr
logr__all__rPImportErrorrr"BaseSelectorEventLoopr&
ReadTransportrj_FlowControlMixinWriteTransportrrBaseSubprocessTransportrxrrrrrrrBaseDefaultEventLoopPolicyrrrrrr<module>r4s8								











<7
+C
D
DD			
N"N"N"N"N"_BN"N"N"bMMMMMZ5MMM`JJJJJj:(7JJJZ     F   0L$L$L$L$L$L$L$L$^KKKKK,KKK\22222+222jG-G-G-G-G-'G-G-G-Tf1f1f1f1f1'f1f1f1RzRzRzRzRzR0zRzRzRzO(O(O(O(O(/O(O(O(d- - - - - &"C- - - `+4r