+
    ic(  c                   s    ^ 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                   s
  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  < \         SV `  V
4       R V n        W n        Wn        RV n        RV n        RV n        . V n        \        P                  ! 4       V n        / V n        R 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 )Zsuper__init___closed	_protocol_loop_proc_pid_returncode_exit_waiterscollectionsZdeque_pending_calls_pipes	_finished_pipes_connectedr   ZPIPE_startclosepidZ_extra	get_debugZ
isinstanceZbytesZstrr   ZdebugZcreate_task_connect_pipes)selfloopprotocolr   r   r   r   r	   r
   waiterZextrakwargsZprogram	__class__s   &&&&&&&&&&&, 0/usr/lib64/python3.14/asyncio/base_subprocess.pyr   Z BaseSubprocessTransport.__init__   s    	!

	)//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                s   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      # )Zclosedzpid=zreturncode=Zrunningznot startedzstdin=zstdout=stderr=zstdout=zstderr=z<{}>Z )r$   __name__r   appendr   r   r   ZgetpipeZformatZjoin)r   infor   r   r	   s   &    r%   __repr__Z 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                s    \         hN)ZNotImplementedError)r   r   r   r   r   r	   r
   r#   s   &&&&&&&,r%   r   ZBaseSubprocessTransport._startX   s    !!r+   c                    Wn         R # r,   r   )r   r!      &&r%   set_protocolZ$BaseSubprocessTransport.set_protocol[   s    !r+   c                    V P                   # r,   r.   r      &r%   get_protocolZ$BaseSubprocessTransport.get_protocol^   s    ~~r+   c                r1   r,   )r   r2   r3   r%   
is_closingZ"BaseSubprocessTransport.is_closinga   s    ||r+   c                sz   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   Z	is_closedr(   r   r   r   Zpollr   r   ZwarningkillProcessLookupErrorZPermissionError)r   Zproto   & r%   r   ZBaseSubprocessTransport.closed   s    <<<[['')E}
 zzz$**"6"6"8"8

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

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

! * ) # '8 s   D% %D:9D:c                st    V P                   '       g&   V! R V : 2\        V R7       V P                  4        R# R# )zunclosed transport )ZsourceN)r   ZResourceWarningr   )r   Z_warnr/   r%   __del__ZBaseSubprocessTransport.__del__   s-    |||'x0/$OJJL r+   c                r1   r,   )r   r2   r3   r%   get_pidZBaseSubprocessTransport.get_pid   s    yyr+   c                r1   r,   )r   r2   r3   r%   get_returncodeZ&BaseSubprocessTransport.get_returncode   s    r+   c                s`    WP                   9   d   V P                   V,          P                  # R # r,   )r   r(   )r   fdr/   r%   get_pipe_transportZ*BaseSubprocessTransport.get_pipe_transport   s#    ;;r?'''r+   c                s6    V P                   f   \        4       hR # r,   )r   r8   r2   r3   r%   _check_procZ#BaseSubprocessTransport._check_proc   s    ::$&& r+   Zwin32c                s\    V P                  4        V P                  P                  V4       R # r,   )r?   r   send_signalr   signalr/   r%   r@   #BaseSubprocessTransport.send_signal   s     JJ""6*r+   c                Z    V P                  4        V P                  P                  4        R # r,   )r?   r   	terminater2   r3   r%   rE   !BaseSubprocessTransport.terminate   s    JJ  "r+   c                rD   r,   )r?   r   r7   r2   r3   r%   r7   BaseSubprocessTransport.kill   s    JJOOr+   c                s    V P                  4         \        P                  ! V P                  P                  V4       R #   \
         d     R # i ; ir,   )r?   osr7   r   r   r8   rA   r/   r%   r@   rC      s;    

/% s   +? AAc                D    V P                  \        P                  4       R # r,   )r@   rB   ZSIGTERMr2   r3   r%   rE   rF          V^^,r+   c                rI   r,   )r@   rB   ZSIGKILLr2   r3   r%   r7   rG      rJ   r+   c                s  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                  ^&   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S n        R #  EL. L L  \        \         3 d    h \"         dC   p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   < \        S ^ 4      # )r    )WriteSubprocessPipeProtor2      r%   <lambda>8BaseSubprocessTransport._connect_pipes.<locals>.<lambda>   s    4T1=r+   c                  s   < \        S ^4      # )i   ReadSubprocessPipeProtor2   rL   r%   rM   rN          3D!<r+   c                  s   < \        S ^4      # )i   rO   r2   rL   r%   rM   rN      rQ   r+   T)r   r   r   Zconnect_write_piper   r   Zconnect_read_piper	   	call_soonr   connection_mader   	cancelled
set_resultr   Z
SystemExitZKeyboardInterruptZBaseExceptionZset_exception)	r   r"   procr    Z_r(   Zcallbackdataexcs	   f&       r%   r   Z&BaseSubprocessTransport._connect_pipes   s    $	)::D::Dzz% $ 7 7=JJ!    "&A{{& $ 6 6<KK!! ! "&A{{& $ 6 6<KK!! ! "&A NN4>>994@"&"5"5x/$/ #6"&D !&*:*:*<*<!!$'$(D!? !! -. 	 	*!&*:*:*<*<$$S)) +=!	*sz   G$A	F E<AF E?AF FA+F G$"G$<F ?F F G!G!G9G
G$G!!G$c                s    V P                   e   V P                   P                  W34       R # V P                  P                  ! V.VO5!   R # r,   )r   r'   r   rR   )r   ZcbrW   s   &&*r%   _callZBaseSubprocessTransport._call   s;    *&&z2JJ  +d+r+   c                sr    V P                  V P                  P                  W4       V P                  4        R # r,   )rY   r   Zpipe_connection_lost_try_finish)r   r=   rX      &&&r%   _pipe_connection_lostZ-BaseSubprocessTransport._pipe_connection_lost   s&    

4>>66@r+   c                sR    V P                  V P                  P                  W4       R # r,   )rY   r   Zpipe_data_received)r   r=   rW   r[   r%   _pipe_data_receivedZ+BaseSubprocessTransport._pipe_data_received   s    

4>>44b?r+   c                s:   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        R# )z%r exited with return code %rN)r   r   r   r)   r   r   
returncoderY   r   Zprocess_exitedrZ   )r   r^   r/   r%   _process_exitedZ'BaseSubprocessTransport._process_exited   sj     ::!!KK7J%::  ( %/JJ!

4>>001r+   c                s   "   V P                   e   V P                   # V P                  P                  4       pV P                  P	                  V4       VG Rj  xL
 #  L5i)z\Wait until the process exit and return the process return code.

This method is a coroutine.N)r   r   Zcreate_futurer   r'   r   r"   r9   r%   _waitZBaseSubprocessTransport._wait   sO      '###))+!!&)||s   AAAAc                s   V P                   f   R # V P                  '       gG   V P                   F6  pVP                  4       '       d   K  VP	                  V P                   4       K8  	  \
        ;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   sR   "   T F  pVR J;'       d    VP                   x  K  	  R # 5ir,   )disconnected)Z.0Zpr9   r%   Z	<genexpr>Z6BaseSubprocessTransport._try_finish.<locals>.<genexpr>  s*      .,1 }///,s   ''FT)r   r   r   rT   rU   Zallr   r6   r   rY   _call_connection_lostr`   r9   r%   rZ   Z#BaseSubprocessTransport._try_finish  s    #$$$ ,,''))%%d&6&67 - 3 .**,.333 .**,. . .!DNJJt1148.r+   c                s    V P                   P                  V4       V P                   F6  pVP                  4       '       d   K  VP	                  V P
                  4       K8  	  R V n        R V n        R V n        R V n         R #   T P                   F6  pTP                  4       '       d   K  TP	                  T P
                  4       K8  	  R T n        R T n        R T n        R T n         i ; ir,   )r   connection_lostr   rT   rU   r   r   r   )r   rX   r"   s   && r%   rc   Z-BaseSubprocessTransport._call_connection_lost  s    
	"NN**3/ ,,''))%%d&6&67 - "&DDJDJ!DN ,,''))%%d&6&67 - "&DDJDJ!DNs   B #C%)<C%)r   r   r   r   r   r   r   r   r   r   r   )NN)"r&   
__module____qualname____firstlineno__r   r*   r   r0   r4   r5   r   warningsZwarnr:   r;   r<   r>   r?   sysZplatformr@   rE   r7   r   rY   r\   r]   r_   ra   rZ   rc   __static_attributes____classdictcell__Z__classcell__)r$   __classdict__s   @@r%   r   r      s     *<X-:""B %MM 
 ' ||w	+	#			-	-%)N,@	9$" "r+   r   c                   sD   a  ] tR tRt o R tR tR tR tR tR t	Rt
V tR	# )
rK   i!  c                s:    Wn         W n        R V n        RV n        R # )NF)rV   r=   r(   rb   )r   rV   r=   r[   r%   r   Z!WriteSubprocessPipeProto.__init__#  s    		!r+   c                r-   r,   )r(   )r   Z	transportr/   r%   rS   Z(WriteSubprocessPipeProto.connection_made)  s    	r+   c                sl    R V P                   P                   RV P                   RV P                  : R2# )Z<z fd=z pipe=Z>)r$   r&   r=   r(   r2   r3   r%   r*   Z!WriteSubprocessPipeProto.__repr__,  s0    4>>**+4ytyym1MMr+   c                sn    R V n         V P                  P                  V P                  V4       RV n        R# )TN)rb   rV   r\   r=   )r   rX   r/   r%   rd   Z(WriteSubprocessPipeProto.connection_lost/  s)     		''5	r+   c                N    V P                   P                  P                  4        R # r,   )rV   r   pause_writingr2   r3   r%   rn   Z&WriteSubprocessPipeProto.pause_writing4  s    		))+r+   c                rm   r,   )rV   r   resume_writingr2   r3   r%   ro   Z'WriteSubprocessPipeProto.resume_writing7  s    		**,r+   )rb   r=   r(   rV   N)r&   re   rf   rg   r   rS   r*   rd   rn   ro   rj   rk   rl      @r%   rK   rK   !  s)     "N
,- -r+   rK   c                   s&   a  ] tR tRt o R tRtV tR# )rP   i;  c                sR    V P                   P                  V P                  V4       R # r,   )rV   r]   r=   )r   rW   r/   r%   data_receivedZ%ReadSubprocessPipeProto.data_received>  s    		%%dggt4r+   r   N)r&   re   rf   rg   rr   rj   rk   rp   rq   r%   rP   rP   ;  s     5 5r+   rP   )r   r   rh   rH   rB   ri   Z r   r   Zlogr   ZSubprocessTransportr   ZBaseProtocolrK   ZProtocolrP   r   r+   r%   <module>rs      s]       	  
   Q"j<< Q"h-y55 -456'005r+   