+
   '푤                       ^ RI t ^ RIt^ RIt^ RIt^ RIt^ RIt^RIHt ^RIHt ^RI	H
t
  ! R R]P                  4      t ! R R]P                  4      t ! R	 R
]]P                  4      tR# )    N)	protocols)
transports)loggerc                   
  a a ] tR t^t oRV 3R lltR tR tR tR tR t	R t
]P                  3R ltR	 tR
 tR tR t]P&                  R8X  d   R tR tR tM	R tR tR tR tR tR tR tR tR tR tR tRtVt V ;t!# )BaseSubprocessTransportc                  < \         SV `  V
4       R V n        W n        Wn        RV n        RV n        RV n        \        4       V n	        \        P                  ! 4       V n        / V n        R V n        V\        P                   8X  d   RV P                  ^ &   V\        P                   8X  d   RV P                  ^&   V\        P                   8X  d   RV P                  ^&    V P"                  ! R
RVRVRVRVRVRV/VB  T P
                  P&                  T n        T P
                  T P(                  R&   T P                  P+                  4       '       dJ   \-        T\.        \0        34      '       d   TpM	T^ ,          p\2        P4                  ! R	YP                  4       T P                  P7                  T P9                  T	4      4       R#    T P%                  4        h ; i)FNargsshellstdinstdoutstderrbufsize
subprocesszprocess %r created: pid %s )super__init___closed	_protocol_loop_proc_pid_returncodeset_exit_waiterscollectionsdeque_pending_calls_pipes	_finishedr   PIPE_startclosepid_extra	get_debug
isinstancebytesstrr   debugcreate_task_connect_pipes)selfloopprotocolr	   r
   r   r   r   r   waiterextrakwargsprogram	__class__s   &&&&&&&&&&&, ./usr/lib/python3.14/asyncio/base_subprocess.pyr    BaseSubprocessTransport.__init__   s    	!

	 U)//1JOO#!DKKNZ__$!DKKNZ__$!DKKN	KK BT B Be BF B%B/6B:@B JJNN	$(JJL!::!!$--q'LL5 ))- 	

t226:;	JJLs   G Gc                   V P                   P                  .pV P                  '       d   VP                  R 4       V P                  e   VP                  RV P                   24       V P
                  e    VP                  RV P
                   24       M1V P                  e   VP                  R4       MVP                  R4       V P                  P                  ^ 4      pVe   VP                  RVP                   24       V P                  P                  ^4      pV P                  P                  ^4      pVe%   WCJ d    VP                  RVP                   24       MDVe   VP                  RVP                   24       Ve   VP                  RVP                   24       R	P                  R
P                  V4      4      # )closedzpid=zreturncode=runningznot startedzstdin=zstdout=stderr=zstdout=zstderr=z<{}> )r3   __name__r   appendr   r   r   getpipeformatjoin)r,   infor   r   r   s   &    r4   __repr__ BaseSubprocessTransport.__repr__:   sX   ''(<<<KK!99 KK$tyyk*+'KK+d&6&6%789YY"KK	"KK&"KK&-.##&"2KK.67!gfkk]34!gfkk]34}}SXXd^,,    c                    \         hN)NotImplementedError)r,   r	   r
   r   r   r   r   r1   s   &&&&&&&,r4   r!   BaseSubprocessTransport._startW   s    !!rC   c                    Wn         R # rE   r   )r,   r.   s   &&r4   set_protocol$BaseSubprocessTransport.set_protocolZ   s    !rC   c                    V P                   # rE   rI   r,   s   &r4   get_protocol$BaseSubprocessTransport.get_protocol]   s    ~~rC   c                    V P                   # rE   )r   rM   s   &r4   
is_closing"BaseSubprocessTransport.is_closing`   s    ||rC   c                z   V P                   '       d   R # RV n         V P                  P                  4        FY  pVf   K	  V P                  '       g   K  V P                  P	                  4       '       d   K?  VP
                  P                  4        K[  	  V P                  e   V P                  fs   V P                  P                  4       fU   V P                  P                  4       '       d   \        P                  ! RV 4        V P                  P                  4        R # R # R # R #   \        \        3 d     R # i ; i)NTz$Close running child process: kill %r)r   r   valuesr   	is_closedr=   r"   r   r   pollr%   r   warningkillProcessLookupErrorPermissionError)r,   protos   & r4   r"   BaseSubprocessTransport.closec   s    <<<[['')E}
 zzz$**"6"6"8"8

  " * JJ"  ( 

!)zz##%%EtL

! * ) # '8 s   D% %D:9D:c                t    V P                   '       g&   V! R V : 2\        V R7       V P                  4        R# R# )zunclosed transport )sourceN)r   ResourceWarningr"   )r,   _warns   &&r4   __del__BaseSubprocessTransport.__del__   s-    |||'x0/$OJJL rC   c                    V P                   # rE   )r   rM   s   &r4   get_pidBaseSubprocessTransport.get_pid   s    yyrC   c                    V P                   # rE   )r   rM   s   &r4   get_returncode&BaseSubprocessTransport.get_returncode   s    rC   c                `    WP                   9   d   V P                   V,          P                  # R # rE   )r   r=   )r,   fds   &&r4   get_pipe_transport*BaseSubprocessTransport.get_pipe_transport   s#    ;;r?'''rC   c                6    V P                   f   \        4       hR # rE   )r   rY   rM   s   &r4   _check_proc#BaseSubprocessTransport._check_proc   s    ::$&& rC   win32c                \    V P                  4        V P                  P                  V4       R # rE   )rn   r   send_signalr,   signals   &&r4   rr   #BaseSubprocessTransport.send_signal   s     JJ""6*rC   c                Z    V P                  4        V P                  P                  4        R # rE   )rn   r   	terminaterM   s   &r4   rw   !BaseSubprocessTransport.terminate   s    JJ  "rC   c                Z    V P                  4        V P                  P                  4        R # rE   )rn   r   rX   rM   s   &r4   rX   BaseSubprocessTransport.kill   s    JJOOrC   c                    V P                  4        V P                  e   R #  \        P                  ! V P                  P
                  V4       R #   \         d     R # i ; irE   )rn   r   osrX   r   r#   rY   rs   s   &&r4   rr   ru      sJ    +

/% s   +A AAc                D    V P                  \        P                  4       R # rE   )rr   rt   SIGTERMrM   s   &r4   rw   rx          V^^,rC   c                D    V P                  \        P                  4       R # rE   )rr   rt   SIGKILLrM   s   &r4   rX   rz      r   rC   c                  a "    S P                   pS P                  pVP                  e:   VP                  V 3R lVP                  4      G R j  xL
 w  rEVS P                  ^ &   VP
                  e:   VP                  V 3R lVP
                  4      G R j  xL
 w  rEVS P                  ^&   VP                  e:   VP                  V 3R lVP                  4      G R j  xL
 w  rEVS P                  ^&   S P                  f   Q hVP                  S P                  P                  S 4       S P                   F  w  rgVP                  ! V.VO5!   K  	  R S n        Ve,   VP                  4       '       g   VP                  R 4       R # R # R #  EL; L L  \        \        3 d    h \          d   pS P                  P#                  4        F#  p	T	f   K	  T	P$                  P'                  4        K%  	  XP                  TP
                  TP                  3 F  p
T
f   K	  T
P'                  4        K  	  Te4   TP                  4       '       g   TP)                  T4        R p?R #  R p?R #  R p?R # R p?ii ; i5i)Nc                     < \        S ^ 4      # )r   )WriteSubprocessPipeProtorM   s   r4   <lambda>8BaseSubprocessTransport._connect_pipes.<locals>.<lambda>   s    4T1=rC   c                     < \        S ^4      # )   ReadSubprocessPipeProtorM   s   r4   r   r          3D!<rC   c                     < \        S ^4      # )   r   rM   s   r4   r   r      r   rC   )r   r   r   connect_write_piper   r   connect_read_piper   r   	call_soonr   connection_made	cancelled
set_result
SystemExitKeyboardInterruptBaseExceptionrT   r=   r"   set_exception)r,   r/   procr-   _r=   callbackdataexcr[   raw_pipes   f&         r4   r+   &BaseSubprocessTransport._connect_pipes   s    +	(::D::Dzz% $ 7 7=JJ!    "&A{{& $ 6 6<KK!! ! "&A{{& $ 6 6<KK!! ! "&A&&222NN4>>994@"&"5"5x/$/ #6"&D !&*:*:*<*<!!$' +=!K !! -. 	 
	* ++-$JJ$$& . "ZZdkkB'NN$ C !&*:*:*<*<$$S)) +=!
	*s   I2A	F F	AF FAF FA;F I22I2	F F F I/+I/,I*AI*-I*I*I2*I//I2c                    V P                   e   V P                   P                  W34       R # V P                  P                  ! V.VO5!   R # rE   )r   r;   r   r   )r,   cbr   s   &&*r4   _callBaseSubprocessTransport._call   s;    *&&z2JJ  +d+rC   c                r    V P                  V P                  P                  W4       V P                  4        R # rE   )r   r   pipe_connection_lost_try_finish)r,   rj   r   s   &&&r4   _pipe_connection_lost-BaseSubprocessTransport._pipe_connection_lost   s&    

4>>66@rC   c                R    V P                  V P                  P                  W4       R # rE   )r   r   pipe_data_received)r,   rj   r   s   &&&r4   _pipe_data_received+BaseSubprocessTransport._pipe_data_received   s    

4>>44b?rC   c                   Vf   Q V4       hV P                   e   Q V P                   4       hV P                  P                  4       '       d   \        P                  ! RW4       Wn         V P
                  P                  f   WP
                  n        V P                  V P                  P                  4       V P                  4        V P                   F,  pVP                  4       '       d   K  VP                  V4       K.  	  R V n        R # )Nz%r exited with return code %r)r   r   r%   r   r@   r   
returncoder   r   process_exitedr   r   doner   )r,   r   r/   s   && r4   _process_exited'BaseSubprocessTransport._process_exited   s    %1z1%'9)9)99'::!!KK7J%::  ( %/JJ!

4>>001 ((F;;==!!*- ) "rC   c                t  "   V P                   e   V P                   # V P                  P                  4       pV P                  P	                  V4        VG Rj  xL
 V P                  e   V P                  P                  V4       # #  L.  T P                  e   T P                  P                  T4       i i ; i5i)z\Wait until the process exit and return the process return code.

This method is a coroutine.N)r   r   create_futurer   adddiscard)r,   r/   s   & r4   _waitBaseSubprocessTransport._wait  s      '###))+v&	3<!!-""**62 .  !!-""**62 .s0   AB8B	 BB	 +B8B	 	,B55B8c                l   V P                   '       d   Q hV P                  f   R # \        ;QJ d4    R V P                  P	                  4        4       F  '       d   K   RM)	  RM%! R V P                  P	                  4        4       4      '       d&   RV n         V P                  V P                  R 4       R # R # )Nc              3   R   "   T F  pVR J;'       d    VP                   x  K  	  R # 5irE   )disconnected).0ps   & r4   	<genexpr>6BaseSubprocessTransport._try_finish.<locals>.<genexpr>  s*      .,1 }///,s   ''FT)r   r   allr   rT   r   _call_connection_lostrM   s   &r4   r   #BaseSubprocessTransport._try_finish  s    >>>!!#3 .**,.333 .**,. . .!DNJJt1148.rC   c                     V P                   P                  V4       R V n        R V n        R V n         R #   R T n        R T n        R T n         i ; irE   )r   connection_lostr   r   r,   r   s   &&r4   r   -BaseSubprocessTransport._call_connection_lost   sG    	"NN**3/DJDJ!DN DJDJ!DNs	   4 A)
r   r   r   r   r   r   r   r   r   r   )NN)"r:   
__module____qualname____firstlineno__r   rA   r!   rJ   rN   rQ   r"   warningswarnra   rd   rg   rk   rn   sysplatformrr   rw   rX   r+   r   r   r   r   r   r   r   __static_attributes____classdictcell____classcell__)r3   __classdict__s   @@r4   r   r      s     )<V-:""B %MM 
 ' ||w	+	#			-	-,(\,@",39" "rC   r   c                   D   a  ] tR tRt o R tR tR tR tR tR t	Rt
V tR	# )
r   i)  c                :    Wn         W n        R V n        RV n        R # )NF)r   rj   r=   r   )r,   r   rj   s   &&&r4   r   !WriteSubprocessPipeProto.__init__+  s    		!rC   c                    Wn         R # rE   )r=   )r,   	transports   &&r4   r   (WriteSubprocessPipeProto.connection_made1  s    	rC   c                l    R V P                   P                   RV P                   RV P                  : R2# )<z fd=z pipe=>)r3   r:   rj   r=   rM   s   &r4   rA   !WriteSubprocessPipeProto.__repr__4  s0    4>>**+4ytyym1MMrC   c                n    R V n         V P                  P                  V P                  V4       RV n        R# )TN)r   r   r   rj   r   s   &&r4   r   (WriteSubprocessPipeProto.connection_lost7  s)     		''5	rC   c                N    V P                   P                  P                  4        R # rE   )r   r   pause_writingrM   s   &r4   r   &WriteSubprocessPipeProto.pause_writing<  s    		))+rC   c                N    V P                   P                  P                  4        R # rE   )r   r   resume_writingrM   s   &r4   r   'WriteSubprocessPipeProto.resume_writing?  s    		**,rC   )r   rj   r=   r   N)r:   r   r   r   r   r   rA   r   r   r   r   r   r   s   @r4   r   r   )  s)     "N
,- -rC   r   c                   &   a  ] tR tRt o R tRtV tR# )r   iC  c                R    V P                   P                  V P                  V4       R # rE   )r   r   rj   )r,   r   s   &&r4   data_received%ReadSubprocessPipeProto.data_receivedF  s    		%%dggt4rC   r   N)r:   r   r   r   r   r   r   r   s   @r4   r   r   C  s     5 5rC   r   )r   r   r   r|   rt   r    r   r   logr   SubprocessTransportr   BaseProtocolr   Protocolr   r   rC   r4   <module>r      s]       	  
   Y"j<< Y"x-y55 -456'005rC   