ZIP olu?turuldu: wp-log/parcalar.zip
ZIP olu?turuldu: wp-log/parcalar.zip
ZIP olu?turuldu: wp-log/parcalar.zip
ZIP olu?turuldu: wp-log/parcalar.zip
ZIP olu?turuldu: wp-log/parcalar.zip
ZIP olu?turuldu: wp-log/parcalar.zip
ZIP olu?turuldu: wp-log/parcalar.zip
ZIP olu?turuldu: wp-log/parcalar.zip
a
i @ s d Z ddlZddlZddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ej
Z
ej Z ej Z G d d
d
ej
ejZG d d d Zddddejfd
dZddddejdddZdS ))create_subprocess_execcreate_subprocess_shell N )events) protocols)streams)tasks)loggerc sT e Zd Z fddZdd Zdd Zdd Zd d
Zd d Zd
d Z dd Z
Z S )SubprocessStreamProtocolc sH t j|d || _d | _ | _| _d | _d| _g | _| j
| _ d S )NloopF) super__init___limitstdinstdoutstderr
_transport_process_exited _pipe_fds_loopZ
create_future
_stdin_closed)selflimitr __class__ */usr/lib64/python3.9/asyncio/subprocess.pyr s z!SubprocessStreamProtocol.__init__c C sn | j jg}| jd ur&|d| j | jd urB|d| j | jd ur^|d| j dd|S )Nzstdin=zstdout=zstderr=z<{}> )r __name__r appendr r formatjoin)r infor r r __repr__ s
z!SubprocessStreamProtocol.__repr__c C s || _ |d}|d urDtj| j| jd| _| j| | j d |d}|d urtj| j| jd| _
| j
| | j d |d}|d urtj || d | jd| _ d S )Nr r r r )protocolreaderr )
r get_pipe_transportr StreamReaderr r r Z
set_transportr r r StreamWriterr )r transportZstdout_transportZstderr_transportZstdin_transportr r r connection_made) s,
z(SubprocessStreamProtocol.connection_madec C s: |dkr| j }n|dkr | j}nd }|d ur6|| d S )Nr r& )r r Z feed_data)r fddatar( r r r pipe_data_receivedA s z+SubprocessStreamProtocol.pipe_data_receivedc C s |dkrN| j }|d ur | | | |d u r>| jd n | j| d S |dkr^| j}n|dkrn| j}nd }|d ur|d u r| n
|| || j v r| j
| | d S )Nr r r& ) r closeZconnection_lostr
set_result
set_exceptionr r Zfeed_eofr remove_maybe_close_transport)r r. excpiper( r r r pipe_connection_lostK s*
z-SubprocessStreamProtocol.pipe_connection_lostc C s d| _ | d S )NT)r r5 r r r r process_exitedf s z'SubprocessStreamProtocol.process_exitedc C s( t | jdkr$| jr$| j d | _d S )Nr )lenr r r r1 r9 r r r r5 j s
z/SubprocessStreamProtocol._maybe_close_transportc C s || j u r| jS d S N)r r )r streamr r r _get_close_waitero s
z*SubprocessStreamProtocol._get_close_waiter) r
__module__ __qualname__r r$ r- r0 r8 r: r5 r>
__classcell__r r r r r
s
r
c @ sj e Zd Zdd Zdd Zedd Zdd Zd d
Zd d Z d
d Z
dd Z dd Z dd Z
dddZdS )Processc C s8 || _ || _|| _|j| _|j| _|j| _| | _d S r< )r Z _protocolr r r r Zget_pidpid)r r, r' r r r r r u s zProcess.__init__c C s d| j j d| j dS )N)r r rC r9 r r r r$ ~ s zProcess.__repr__c C s
| j S r< )r Zget_returncoder9 r r r
returncode s zProcess.returncodec s | j I d H S r< )r _waitr9 r r r wait s z Process.waitc C s | j | d S r< )r send_signal)r signalr r r rI s zProcess.send_signalc C s | j d S r< )r terminater9 r r r rK s zProcess.terminatec C s | j d S r< )r killr9 r r r rL s z Process.killc
s | j }| j| |r,td| t| z| j I d H W n: tt fyz } z |rftd| | W Y d }~n
d }~0 0 |rtd| | j
d S )Nz%%r communicate: feed stdin (%s bytes)z %r communicate: stdin got %rz%r communicate: close stdin) r get_debugr writer debugr; ZdrainBrokenPipeErrorConnectionResetErrorr1 )r inputrO r6 r r r _feed_stdin s
$ zProcess._feed_stdinc s d S r< r r9 r r r _noop s z
Process._noopc s | j |}|dkr | j}n| j}| j rJ|dkr8dnd}td| | | I d H }| j r|dkrndnd}td| | | |S )Nr& r r r z%r communicate: read %sz%r communicate: close %s)
r r) r r r rM r rO readr1 )r r. r, r= nameoutputr r r _read_stream s
zProcess._read_streamNc s |d ur| |}n| }| jd ur2| d}n| }| jd urP| d}n| }tj|||| jdI d H \}}}| I d H ||fS )Nr r& r ) rS rT r rX r r Z_gatherr rH )r rR r r r r r r communicate s
zProcess.communicate)N)r r? r@ r r$ propertyrF rH rI rK rL rS rT rX rY r r r r rB t s
rB c
sb d u rt ntjdtdd fdd}j|| f|||d|I d H \}} t|| S )NZThe loop argument is deprecated since Python 3.8 and scheduled for removal in Python 3.10.r&
stacklevelc s t dS Nr% r
r r% r r s z)create_subprocess_shell..r r r )r get_event_loopwarningswarnDeprecationWarningZsubprocess_shellrB )
cmdr r r r r kwdsprotocol_factoryr, r' r r% r r s"
r )r r r r r c sh d u rt ntjdtdd fdd}j|| g|R |||d|I d H \} }
t| |
S )Nr[ r& r\ c s t dS r^ r_ r r% r r r` s z(create_subprocess_exec..ra )r rb rc rd re Zsubprocess_execrB ) Zprogramr r r r r argsrg rh r, r' r r% r r s&
r )__all__
subprocessrc r r r r logr PIPESTDOUTDEVNULLZFlowControlMixinZSubprocessProtocolr
rB Z_DEFAULT_LIMITr r r r r r s* bV