| Server IP : 85.214.239.14 / Your IP : 216.73.216.27 Web Server : Apache/2.4.65 (Debian) System : Linux h2886529.stratoserver.net 4.9.0 #1 SMP Mon Sep 30 15:36:27 MSK 2024 x86_64 User : www-data ( 33) PHP Version : 8.2.29 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : OFF Directory : /proc/2/cwd/proc/self/root/usr/lib/python3.5/asyncio/__pycache__/ |
Upload File : |
F��a �
@ s d d g Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d
l m
Z
e j Z e j Z e j
Z
Gd d � d e j e j � Z Gd
d � d � Z e d d d d e j d d � � Z e d d d d d d d d d e j d d � � Z d S)�create_subprocess_exec�create_subprocess_shell� N� )�events)� protocols)�streams)�tasks)� coroutine)�loggerc sd e Z d Z d Z � f d d � Z d d � Z d d � Z d d � Z d
d � Z d d
� Z � S)�SubprocessStreamProtocolz0Like StreamReaderProtocol, but for a subprocess.c s@ t � j d | � | | _ d | _ | _ | _ d | _ d S)N�loop)�super�__init__�_limit�stdin�stdout�stderr�
_transport)�self�limitr )� __class__� �(/usr/lib/python3.5/asyncio/subprocess.pyr s z!SubprocessStreamProtocol.__init__c C s� | j j g } | j d k r2 | j d | j � | j d k rU | j d | j � | j d k rx | j d | j � d d j | � S)Nzstdin=%rz stdout=%rz stderr=%rz<%s>� )r �__name__r �appendr r �join)r �infor r r �__repr__ s z!SubprocessStreamProtocol.__repr__c C s� | | _ | j d � } | d k rU t j d | j d | j � | _ | j j | � | j d � } | d k r� t j d | j d | j � | _ | j j | � | j d � } | d k r� t j | d | d d d | j �| _
d S)Nr r r � r �protocol�reader) r �get_pipe_transportr � StreamReaderr �_loopr Z
set_transportr � StreamWriterr )r � transportZstdout_transportZstderr_transportZstdin_transportr r r �connection_made& s" z(SubprocessStreamProtocol.connection_madec C sS | d k r | j } n | d k r0 | j } n d } | d k rO | j | � d S)Nr r )r r Z feed_data)r �fd�datar! r r r �pipe_data_received< s z+SubprocessStreamProtocol.pipe_data_receivedc C s� | d k r< | j } | d k r+ | j � | j | � d S| d k rT | j } n | d k rl | j } n d } | d k r� | d k r� | j � n
| j | � d S)Nr r r )r �closeZconnection_lostr r Zfeed_eofZ
set_exception)r r( �exc�piper! r r r �pipe_connection_lostF s
z-SubprocessStreamProtocol.pipe_connection_lostc C s | j j � d | _ d S)N)r r+ )r r r r �process_exitedY s
z'SubprocessStreamProtocol.process_exited)
r �
__module__� __qualname__�__doc__r r r' r* r. r/ r r )r r r s
r c @ s� e Z d Z d d � Z d d � Z e d d � � Z e d d � � Z d d
� Z d d � Z
d
d � Z e d d � � Z e d d � � Z
e d d � � Z e d d d � � Z d S)�Processc C sR | | _ | | _ | | _ | j | _ | j | _ | j | _ | j � | _ d S)N)r Z _protocolr$ r r r Zget_pid�pid)r r& r r r r r r _ s zProcess.__init__c C s d | j j | j f S)Nz<%s %s>)r r r4 )r r r r r h s zProcess.__repr__c C s
| j j � S)N)r Zget_returncode)r r r r �
returncodek s zProcess.returncodec c s | j j � Ed HS)zdWait until the process exit and return the process return code.
This method is a coroutine.N)r Z_wait)r r r r �waito s z Process.waitc C s | j j | � d S)N)r � send_signal)r �signalr r r r7 v s zProcess.send_signalc C s | j j � d S)N)r � terminate)r r r r r9 y s zProcess.terminatec C s | j j � d S)N)r �kill)r r r r r: | s z Process.killc c s� | j j � } | j j | � | r> t j d | t | � � y | j j � Ed HWnD t t f k
r� } z | r� t j d | | � WYd d } ~ Xn X| r� t j d | � | j j
� d S)Nz%%r communicate: feed stdin (%s bytes)z %r communicate: stdin got %rz%r communicate: close stdin) r$ � get_debugr �writer
�debug�lenZdrain�BrokenPipeError�ConnectionResetErrorr+ )r �inputr= r, r r r � _feed_stdin s &zProcess._feed_stdinc C s d S)Nr )r r r r �_noop� s z
Process._noopc c s� | j j | � } | d k r* | j } n | d k s< t � | j } | j j � r | d k rf d n d } t j d | | � | j � Ed H} | j j � r� | d k r� d n d } t j d | | � | j
� | S)Nr r r r z%r communicate: read %sz%r communicate: close %s) r r" r �AssertionErrorr r$ r; r
r= �readr+ )r r( r& �stream�name�outputr r r � _read_stream� s
zProcess._read_streamNc c s� | d k r | j | � } n | j � } | j d k rK | j d � } n | j � } | j d k rx | j d � } n | j � } t j | | | d | j �Ed H\ } } } | j � Ed H| | f S)Nr r r ) rB rC r rI r r Zgatherr$ r6 )r rA r r r r r r � communicate� s zProcess.communicate)r r0 r1 r r �propertyr5 r r6 r7 r9 r: rB rC rI rJ r r r r r3 ^ s r3 c
+ so � d k r t j � � � � f d d � } � j | | d | d | d | | �Ed H\ } } t | | � � S)Nc s t d � d � � S)Nr r )r r )r r r r �<lambda>� s z)create_subprocess_shell.<locals>.<lambda>r r r )r �get_event_loopZsubprocess_shellr3 )
�cmdr r r r r �kwds�protocol_factoryr& r r )r r r r � s r r r r r c / sr � d k r t j � � � � f d d � } � j | | | d | d | d | | �Ed H\ } }
t | |
� � S)Nc s t d � d � � S)Nr r )r r )r r r r rL � s z(create_subprocess_exec.<locals>.<lambda>r r r )r rM Zsubprocess_execr3 ) Zprogramr r r r r �argsrO rP r& r r )r r r r � s )�__all__�
subprocess� r r r r Z
coroutinesr �logr
�PIPEZSTDOUTZDEVNULLZFlowControlMixinZSubprocessProtocolr r3 Z_DEFAULT_LIMITr r r r r r �<module> s( K]