Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes14kdownloads
subprocess.cpython-314.pyc56 linesDownload Raw Back to __pycache__
1+
2��i9��>�Rt^RIt^RIHt^RIHt^RIHt^RIHt^RIHt]Pt	]Pt3]Pt!RR]P]P4t!R	R44tRRR]P 3RltRRR
RRRR]P /RltR#)�create_subprocess_execN)�events)�	protocols)�streams)�tasks)�loggerc�`aa�]tRt^toRtV3RltRtRtRtRt	Rt5RtR	tR6t
VtV;t#)�SubprocessStreamProtocolz0Like StreamReaderProtocol, but for a subprocess.c��<�\SV`VR7WnR;Vn;VnVnRVnRVn.VnVPP4VnR#))�loopNF)�super�__init__�_limit�stdin�stdout�stderr�7_transport�_process_exited�	_pipe_fds�_loop�
create_future�
_stdin_closed)�self�limitr�	__class__s&&&��Lib\asyncio\subprocess.pyr
�!SubprocessStreamProtocol.__init__sX���
���d��#���15�5��8�5�T�[�4�;����$������!�Z�Z�5�5�7���c�~�VPP.pVPe VPRVP:24VPe VPRVP:24VP9e VPRVP10:24RP
RPV44#)Nzstdin=zstdout=zstderr=z<{}>� )r�__name__r�appendrr�format�join)r�infos& r�__repr__�!SubprocessStreamProtocol.__repr__s������'�'�(���:�:�!��K�K�&�����/�0��;�;�"��K�K�'�$�+�+��1�2��;�;�"��K�K�'�$�+�+��1�2��}�}�S�X�X�d�^�,�,rc��WnVP^4pVeh\P!VPVP11R7VnVPPV4VPP^4VP^4pVeh\P!VPVP12R7Vn13VPPV4VPP^4VP^4pVe,\P!VVRVP14R7VnR#R#)�N�rr)�protocol�readerr)
r�get_pipe_transportr�StreamReaderrrr�
set_transportrr!r�StreamWriterr)r�	transport�stdout_transport�stderr_transport�stdin_transports&&   r�connection_made�(SubprocessStreamProtocol.connection_made(s���#��$�7�7��:���'�!�.�.�T�[�[�48�J�J�@�D�K��K�K�%�%�&6�7��N�N�!�!�!�$�$�7�7��:���'�!�.�.�T�[�[�48�J�J�@�D�K��K�K�%�%�&6�7��N�N�!�!�!�$�#�6�6�q�9���&� �-�-�o�7;�59�37�:�:�?�D�J�'rc��V^8XdVPpMV^8XdVPpMRpVeVPV4R#R#)r(N)rr�	feed_data)r�fd�datar+s&&& r�pipe_data_received�+SubprocessStreamProtocol.pipe_data_received@s@��
��7��[�[�F�
�1�W��[�[�F��F������T�"�rc�2�V^8Xd�VPpVeVP4VPV4VfVPP	R4R#VPPV4RVPnR#V^8XdVPpMV^8XdVPpMRpVe'VfVP4MVPV4WP9dVPPV4VP4R#)�NF)
r�close�connection_lostr�15set_result�
set_exception�_log_tracebackrr�feed_eofr�remove�_maybe_close_transport)rr8�exc�piper+s&&&  r�pipe_connection_lost�-SubprocessStreamProtocol.pipe_connection_lostJs���
��7��:�:�D����16�17��� � ��%��{��"�"�-�-�d�3�
�	�"�"�0�0��5�5:��"�"�1��
��7��[�[�F�
�1�W��[�[�F��F����{����!��$�$�S�)�
�����N�N�!�!�"�%��#�#�%rc�4�RVnVP4R#)TN)rrE�rs&r�process_exited�'SubprocessStreamProtocol.process_exitedhs��#����#�#�%rc��\VP4^8Xd8VP'd$VPP	4RVnR#R#R#)r=N)�lenrrrr>rKs&rrE�/SubprocessStreamProtocol._maybe_close_transportls=���t�~�~��!�#��(<�(<�(<��O�O�!�!�#�"�D�O�)=�#rc�<�WPJd
VP#R#�N)rr)r�streams&&r�_get_close_waiter�*SubprocessStreamProtocol._get_close_waiterqs���Z�Z���%�%�%� r)rrrrrrrr)r �18__module__�__qualname__�__firstlineno__�__doc__r
r%r4r:rHrLrErT�__static_attributes__�__classdictcell__�
__classcell__)r�
__classdict__s@@rr	r	s5����:�8�-�?�0#�&�<&�#�19&�&rr	c�pa�]tRt^vtoRtRt]R4tRtRt	Rt20RtRtR	t
R21tRRltR
tVtR#)�Processc��WnW nW0nVPVnVPVnVP22VnVP
4VnR#rR)r�	_protocolrrrr�get_pid�pid)rr0r*rs&&&&rr
�Process.__init__wsB��#��!���23��^�^��24��o�o����o�o����$�$�&��rc�P�RVPPRVPR2#)�<r�>)rr rcrKs&rr%�Process.__repr__�s&���4�>�>�*�*�+�1�T�X�X�J�a�8�8rc�6�VPP4#rR)r�get_returncoderKs&r�25returncode�Process.returncode�s�����-�-�/�/rc��R"�VPP4GRjx�L26#L5i)z?Wait until the process exit and return the process return code.N)r�_waitrKs&r�wait�Process.wait�s����_�_�*�*�,�,�,�,�s�'�%�'c�<�VPPV4R#rR)r�send_signal)r�signals&&rrr�Process.send_signal�s�����#�#�F�+rc�:�VPP4R#rR)r�	terminaterKs&rrv�Process.terminate�s�����!�!�#rc�:�VPP4R#rR)r�killrKs&rry�Process.kill�s�������rc��"�VPP4pVeEVPPV4V'd"\P27!RV\
V44VPP4GRjx�L28V'd\P29!RV4VPP4R#L? \\3d*pT'd\P30!RY4Rp?LrRp?ii;i5i)Nz%%r communicate: feed stdin (%s bytes)z%r communicate: stdin got %rz%r communicate: close stdin)r�	get_debugr�writer�debugrO�drain�BrokenPipeError�ConnectionResetErrorr>)r�inputr~rFs&&  r�_feed_stdin�Process._feed_stdin�s�����31�32�$�$�&��	H�� ��33�34� � ��'���L�L�?��s�5�z�S��*�*�"�"�$�$�$���L�L�6��=��35�36����
%���!5�6�	H�����;�T�G���		H�sL�D�&C�>C�C�C�D�3D�C�C?�C:�5D�:C?�?Dc��"�R#5irR�rKs&r�_noop�
Process._noop�s����s�c���"�VPPV4pV^8XdVPpMV^8XgQhVPpVPP4'd#V^8XdRMRp\P!RW4VP4GRjx�L37pVPP4'd#V^8XdRMRp\P!RW4VP4V#LX5i)�rrz%r communicate: read %sNz%r communicate: close %s)38rr,rrrr|rr~�readr>)rr8r0rS�name�outputs&&    r�_read_stream�Process._read_stream�s�����O�O�6�6�r�:�	�
��7��[�[�F���7�N�7��[�[�F��:�:���!�!�!�Q�w�8�H�D��L�L�2�D�?��{�{�}�$���:�:���!�!�!�Q�w�8�H�D��L�L�3�T�@������
�%�s�A$C7�'5C7�C5�#C7�5C7Nc��"�VPeVPV4pMVP4pVPeVP	^4pMVP4pVP39eVP	^4pMVP4p\P!W#V4GRjx�L40wr#pVP4GRjx�L41W43#L"L	5irR)	rr�r�rr�rr�gatherro)rr�rrrs&&   r�communicate�Process.communicate�s�����:�:�!��$�$�U�+�E��J�J�L�E��;�;�"��&�&�q�)�F��Z�Z�\�F��;�;�"��&�&�q�)�F��Z�Z�\�F�&+�l�l�5�&�&I� I���v��i�i�k������!J��s$�B+C�-C�.C�C�	C�C)rrarrcrrrrR)r rVrWrXr
r%�propertyrkrorrrvryr�r�r�r�rZr[)r]s@rr_r_vsP����'�9��0��0�-�,�$���(��" � rr_c	��aa	"�\P!4o	VV	3RlpS	P!VV3RVRVRV/VBGRjx�L42wrx\WxS	4#L5i)c�<�\SSR7#�r)�r	r)s��r�<lambda>�)create_subprocess_shell.<locals>.<lambda>�����7�e�=A� CrrrrN)r�get_running_loop�subprocess_shellr_)43�cmdrrrr�kwds�protocol_factoryr0r*rs44&&&&f,   @r�create_subprocess_shellr��ss�����"�"�$�D�C�� $� 5� 5���!��!�!'�!��!��!���I��9��-�-�	�s�:A�A�Arrrrc	��aa45"�\P!4o46VV473RlpS48P!VV.VO5RVRVRV/VBGRjx�L49wr�\W�S504#L5i)c�<�\SSR7#r�r�r)s��rr��(create_subprocess_exec.<locals>.<lambda>�r�rrrrN)rr��subprocess_execr_)�programrrrr�argsr�r�r0r*rs&$$$d*,   @rrr�s������"�"�$�D�C�� $� 4� 4���!��!��!�#�!��	!��	!���I�51�9��-�-��s�=A�A�A)rr�)�__all__�52subprocess�rrrr�logr�PIPE�STDOUT�DEVNULL�FlowControlMixin�SubprocessProtocolr	r_�_DEFAULT_LIMITr�rr�rr�<module>r�s���53=������������	�	�	��54�55�56��b&�w�7�7�(�;�;�b&�JU �U �p.2�$�t�(/�(>�(>�	.�.�t�.�D�.�(,�.�4;�4J�4J�.r
codekingpro/portable-devtools · Team Ai