+
     Bi%                         ^ 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        . 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\,        \.        34      '       d   TpM	T^ ,          p\0        P2                  ! R	YP                  4       T P                  P5                  T P7                  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_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    	!

	)//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   F< <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<{}> )r2   __name__r   appendr   r   r   getpipeformatjoin)r+   infor   r   r   s   &    r3   __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   r0   s   &&&&&&&,r3   r    BaseSubprocessTransport._startW   s    !!rB   c                    Wn         R # rD   r   )r+   r-   s   &&r3   set_protocol$BaseSubprocessTransport.set_protocolZ   s    !rB   c                    V P                   # rD   rH   r+   s   &r3   get_protocol$BaseSubprocessTransport.get_protocol]   s    ~~rB   c                    V P                   # rD   )r   rL   s   &r3   
is_closing"BaseSubprocessTransport.is_closing`   s    ||rB   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   & r3   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   &&r3   __del__BaseSubprocessTransport.__del__   s-    |||'x0/$OJJL rB   c                    V P                   # rD   )r   rL   s   &r3   get_pidBaseSubprocessTransport.get_pid   s    yyrB   c                    V P                   # rD   )r   rL   s   &r3   get_returncode&BaseSubprocessTransport.get_returncode   s    rB   c                `    WP                   9   d   V P                   V,          P                  # R # rD   )r   r<   )r+   fds   &&r3   get_pipe_transport*BaseSubprocessTransport.get_pipe_transport   s#    ;;r?'''rB   c                6    V P                   f   \        4       hR # rD   )r   rX   rL   s   &r3   _check_proc#BaseSubprocessTransport._check_proc   s    ::$&& rB   win32c                \    V P                  4        V P                  P                  V4       R # rD   )rm   r   send_signalr+   signals   &&r3   rq   #BaseSubprocessTransport.send_signal   s     JJ""6*rB   c                Z    V P                  4        V P                  P                  4        R # rD   )rm   r   	terminaterL   s   &r3   rv   !BaseSubprocessTransport.terminate   s    JJ  "rB   c                Z    V P                  4        V P                  P                  4        R # rD   )rm   r   rW   rL   s   &r3   rW   BaseSubprocessTransport.kill   s    JJOOrB   c                    V P                  4         \        P                  ! V P                  P                  V4       R #   \
         d     R # i ; irD   )rm   osrW   r   r"   rX   rr   s   &&r3   rq   rt      s;    

/% s   +? AAc                D    V P                  \        P                  4       R # rD   )rq   rs   SIGTERMrL   s   &r3   rv   rw          V^^,rB   c                D    V P                  \        P                  4       R # rD   )rq   rs   SIGKILLrL   s   &r3   rW   ry      r~   rB   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                  ^&   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 \          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 ^ 4      # )r   )WriteSubprocessPipeProtorL   s   r3   <lambda>8BaseSubprocessTransport._connect_pipes.<locals>.<lambda>   s    4T1=rB   c                     < \        S ^4      # )   ReadSubprocessPipeProtorL   s   r3   r   r          3D!<rB   c                     < \        S ^4      # )   r   rL   s   r3   r   r      r   rB   )r   r   r   connect_write_piper   r   connect_read_piper   	call_soonr   connection_mader   	cancelled
set_result
SystemExitKeyboardInterruptBaseExceptionset_exception)	r+   r.   procr,   _r<   callbackdataexcs	   f&       r3   r*   &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 !&*:*:*<*<!!$' +=!; !! -. 	 	*!&*:*:*<*<$$S)) +=!	*sz   G!A	F  E9AF  E<AF  E>A+F  G!"G!9F  <F  >F   GGG6GG!GG!c                    V P                   e   V P                   P                  W34       R # V P                  P                  ! V.VO5!   R # rD   )r   r:   r   r   )r+   cbr   s   &&*r3   _callBaseSubprocessTransport._call   s;    *&&z2JJ  +d+rB   c                r    V P                  V P                  P                  W4       V P                  4        R # rD   )r   r   pipe_connection_lost_try_finish)r+   ri   r   s   &&&r3   _pipe_connection_lost-BaseSubprocessTransport._pipe_connection_lost   s&    

4>>66@rB   c                R    V P                  V P                  P                  W4       R # rD   )r   r   pipe_data_received)r+   ri   r   s   &&&r3   _pipe_data_received+BaseSubprocessTransport._pipe_data_received   s    

4>>44b?rB   c                :   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   
returncoder   r   process_exitedr   )r+   r   s   &&r3   _process_exited'BaseSubprocessTransport._process_exited   sj     ::!!KK7J%::  ( %/JJ!

4>>001rB   c                   "   V P                   e   V P                   # V P                  P                  4       pV P                  P	                  V4       VG R j  xL
 #  L5irD   )r   r   create_futurer   r:   )r+   r.   s   & r3   _waitBaseSubprocessTransport._wait   sO      '###))+!!&)||s   AAAAc                D   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rD   )disconnected).0ps   & r3   	<genexpr>6BaseSubprocessTransport._try_finish.<locals>.<genexpr>  s*      .,1 }///,s   ''FT)r   allr   rS   r   r   _call_connection_lostrL   s   &r3   r   #BaseSubprocessTransport._try_finish   sz    #3 .**,.333 .**,. . .!DNJJt1148.rB   c                    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rD   )r   connection_lostr   r   r   r   r   r   )r+   r   r.   s   && r3   r   -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   )NN)"r9   
__module____qualname____firstlineno__r   r@   r    rI   rM   rP   r!   warningswarnr`   rc   rf   rj   rm   sysplatformrq   rv   rW   r*   r   r   r   r   r   r   r   __static_attributes____classdictcell____classcell__)r2   __classdict__s   @@r3   r   r      s     )<V-:""B %MM 
 ' ||w	+	#			-	-$(L,@	9" "rB   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   ri   r<   r   )r+   r   ri   s   &&&r3   r   !WriteSubprocessPipeProto.__init__  s    		!rB   c                    Wn         R # rD   )r<   )r+   	transports   &&r3   r   (WriteSubprocessPipeProto.connection_made  s    	rB   c                l    R V P                   P                   RV P                   RV P                  : R2# )<z fd=z pipe=>)r2   r9   ri   r<   rL   s   &r3   r@   !WriteSubprocessPipeProto.__repr__!  s0    4>>**+4ytyym1MMrB   c                n    R V n         V P                  P                  V P                  V4       RV n        R# )TN)r   r   r   ri   )r+   r   s   &&r3   r   (WriteSubprocessPipeProto.connection_lost$  s)     		''5	rB   c                N    V P                   P                  P                  4        R # rD   )r   r   pause_writingrL   s   &r3   r   &WriteSubprocessPipeProto.pause_writing)  s    		))+rB   c                N    V P                   P                  P                  4        R # rD   )r   r   resume_writingrL   s   &r3   r   'WriteSubprocessPipeProto.resume_writing,  s    		**,rB   )r   ri   r<   r   N)r9   r   r   r   r   r   r@   r   r   r   r   r   r   s   @r3   r   r     s)     "N
,- -rB   r   c                   &   a  ] tR tRt o R tRtV tR# )r   i0  c                R    V P                   P                  V P                  V4       R # rD   )r   r   ri   )r+   r   s   &&r3   data_received%ReadSubprocessPipeProto.data_received3  s    		%%dggt4rB   r   N)r9   r   r   r   r   r   r   r   s   @r3   r   r   0  s     5 5rB   r   )r   r   r   r{   rs   r    r   r   logr   SubprocessTransportr   BaseProtocolr   Protocolr   r   rB   r3   <module>r      s]       	  
   F"j<< F"R-y55 -456'005rB   