Server IP : 85.214.239.14 / Your IP : 216.73.216.130 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/2/cwd/proc/2/root/lib/python3.11/asyncio/__pycache__/ |
Upload File : |
� ��h����dZddlZddlmZddlmZddlmZddlmZddlmZej Z ej Z ejZGd �d ejej ��ZGd�d��Zdddejfd �Zdddejd�d�ZdS))�create_subprocess_exec�create_subprocess_shell�N�)�events)� protocols)�streams)�tasks)�loggerc�L��eZdZdZ�fd�Zd�Zd�Zd�Zd�Zd�Z d�Z d �Z�xZS) �SubprocessStreamProtocolz0Like StreamReaderProtocol, but for a subprocess.c����t���|���||_dx|_x|_|_d|_d|_g|_|j � ��|_dS)N)�loopF)�super�__init__�_limit�stdin�stdout�stderr� _transport�_process_exited� _pipe_fds�_loop� create_future� _stdin_closed)�self�limitr� __class__s ��)/usr/lib/python3.11/asyncio/subprocess.pyrz!SubprocessStreamProtocol.__init__sl��� �����d��#�#�#����15�5�� �5�T�[�4�;����$������!�Z�5�5�7�7�����c�D�|jjg}|j�|�d|j����|j�|�d|j����|j�|�d|j����d�d�|����S)Nzstdin=zstdout=zstderr=z<{}>� )r�__name__r�appendrr�format�join)r�infos r�__repr__z!SubprocessStreamProtocol.__repr__s�����'�(���:�!��K�K�/���/�/�0�0�0��;�"��K�K�1�$�+�1�1�2�2�2��;�"��K�K�1�$�+�1�1�2�2�2��}�}�S�X�X�d�^�^�,�,�,rc�J�||_|�d��}|�Ytj|j|j���|_|j�|��|j� d��|�d��}|�Ytj|j|j���|_ |j �|��|j� d��|�d��}|�$tj||d|j���|_dSdS)Nr�rr�r)�protocol�readerr) r�get_pipe_transportr�StreamReaderrrr� set_transportrr#r�StreamWriterr)r� transport�stdout_transport�stderr_transport�stdin_transports r�connection_madez(SubprocessStreamProtocol.connection_made(s,��#���$�7�7��:�:���'�!�.�T�[�48�J�@�@�@�D�K��K�%�%�&6�7�7�7��N�!�!�!�$�$�$�$�7�7��:�:���'�!�.�T�[�48�J�@�@�@�D�K��K�%�%�&6�7�7�7��N�!�!�!�$�$�$�#�6�6�q�9�9���&� �-�o�7;�59�37�:�?�?�?�D�J�J�J�'�&rc�t�|dkr|j}n|dkr|j}nd}|�|�|��dSdS�Nrr*)rr� feed_data)r�fd�datar,s r�pipe_data_receivedz+SubprocessStreamProtocol.pipe_data_received@sS�� ��7�7��[�F�F� �1�W�W��[�F�F��F������T�"�"�"�"�"��rc���|dkrk|j}|�|���|�|��|�|j�d��n|j�|��dS|dkr|j}n|dkr|j}nd}|�,|�|���n|�|��||j vr|j � |��|���dS)Nrrr*)r�close�connection_lostr� set_result� set_exceptionrr�feed_eofr�remove�_maybe_close_transport)rr9�exc�piper,s r�pipe_connection_lostz-SubprocessStreamProtocol.pipe_connection_lostJs �� ��7�7��:�D���� � ����� � ��%�%�%��{��"�-�-�d�3�3�3�3��"�0�0��5�5�5��F� ��7�7��[�F�F� �1�W�W��[�F�F��F����{����!�!�!�!��$�$�S�)�)�)� ������N�!�!�"�%�%�%��#�#�%�%�%�%�%rc�<�d|_|���dS)NT)rrC�rs r�process_exitedz'SubprocessStreamProtocol.process_exitedes"��#����#�#�%�%�%�%�%rc��t|j��dkr)|jr$|j���d|_dSdSdS)Nr)�lenrrrr=rHs rrCz/SubprocessStreamProtocol._maybe_close_transportisL���t�~���!�#�#��(<�#��O�!�!�#�#�#�"�D�O�O�O�$�#�#�#rc�&�||jur|jSdS�N)rr)r�streams r�_get_close_waiterz*SubprocessStreamProtocol._get_close_waiterns ���T�Z����%�%� �r) r"� __module__�__qualname__�__doc__rr'r5r;rFrIrCrO� __classcell__)rs@rrrs��������:�:�8�8�8�8�8�-�-�-�?�?�?�0#�#�#�&�&�&�6&�&�&�#�#�#� &�&�&�&�&�&�&rrc�b�eZdZd�Zd�Zed���Zd�Zd�Zd�Z d�Z d�Zd �Zd �Z d d�ZdS)�Processc��||_||_||_|j|_|j|_|j|_|���|_dSrM)r� _protocolrrrr�get_pid�pid)rr1r+rs rrzProcess.__init__tsI��#���!����� ��^�� ��o����o����$�$�&�&����rc�2�d|jj�d|j�d�S)N�<r!�>)rr"rYrHs rr'zProcess.__repr__}s"��8�4�>�*�8�8�T�X�8�8�8�8rc�4�|j���SrM)r�get_returncoderHs r� returncodezProcess.returncode�s����-�-�/�/�/rc��DK�|j����d{V��S)z?Wait until the process exit and return the process return code.N)r�_waitrHs r�waitzProcess.wait�s,�����_�*�*�,�,�,�,�,�,�,�,�,rc�:�|j�|��dSrM)r�send_signal)r�signals rrdzProcess.send_signal�s����#�#�F�+�+�+�+�+rc�8�|j���dSrM)r� terminaterHs rrgzProcess.terminate�s����!�!�#�#�#�#�#rc�8�|j���dSrM)r�killrHs rrizProcess.kill�s����������rc���K�|j���}|j�|��|r#t jd|t |���� |j����d{V��n6#ttf$r"}|rt jd||��Yd}~nd}~wwxYw|rt jd|��|j� ��dS)Nz%%r communicate: feed stdin (%s bytes)z%r communicate: stdin got %rz%r communicate: close stdin)r� get_debugr�writer �debugrK�drain�BrokenPipeError�ConnectionResetErrorr=)r�inputrmrDs r�_feed_stdinzProcess._feed_stdin�s����� �$�$�&�&��� �������� K��L�7��s�5�z�z� K� K� K� H��*�"�"�$�$�$�$�$�$�$�$�$�$���!5�6� H� H� H�� H���;�T�3�G�G�G���������� H���� � >��L�6��=�=�=�� �������s�A<�<B/� B*�*B/c�� K�dSrM�rHs r�_noopz Process._noop�s�����trc��K�|j�|��}|dkr|j}n|dksJ�|j}|j���r |dkrdnd}t jd||��|����d{V��}|j���r |dkrdnd}t jd||��|� ��|S)Nr*rrrz%r communicate: read %sz%r communicate: close %s) rr-rrrrkr rm�readr=)rr9r1rN�name�outputs r�_read_streamzProcess._read_stream�s������O�6�6�r�:�:� � ��7�7��[�F�F���7�7�7�7��[�F��:���!�!� @�!�Q�w�w�8�8�H�D��L�2�D�$�?�?�?��{�{�}�}�$�$�$�$�$�$���:���!�!� A�!�Q�w�w�8�8�H�D��L�3�T�4�@�@�@�������� rNc��K�|�|�|��}n|���}|j�|�d��}n|���}|j�|�d��}n|���}tj|||���d{V��\}}}|����d{V��||fSr7)rrrurrzrr �gatherrb)rrqrrrs r�communicatezProcess.communicate�s��������$�$�U�+�+�E�E��J�J�L�L�E��;�"��&�&�q�)�)�F�F��Z�Z�\�\�F��;�"��&�&�q�)�)�F�F��Z�Z�\�\�F�&+�l�5�&�&�&I�&I� I� I� I� I� I� I���v�v��i�i�k�k�����������rrM)r"rPrQrr'�propertyr_rbrdrgrirrrurzr}rtrrrUrUss�������'�'�'�9�9�9��0�0��X�0�-�-�-�,�,�,�$�$�$�������"������" � � � � � rrUc���� K�tj��� �� fd�}� j||f|||d�|���d{V��\}}t||� ��S)Nc�&��t�����S�Nr)�rr)s��r�<lambda>z)create_subprocess_shell.<locals>.<lambda>�����7�e�=A� C� C� C�r�rrr)r�get_running_loop�subprocess_shellrU) �cmdrrrr�kwds�protocol_factoryr1r+rs ` @rrr�s��������"�$�$�D�C�C�C�C�C�� 5�� 5���!����!�!��!�!��������I�x��9�h��-�-�-r)rrrrc���� K�tj��� �� fd�}� j||g|�R|||d�|���d{V��\}} t|| � ��S)Nc�&��t�����Sr�r�r)s��rr�z(create_subprocess_exec.<locals>.<lambda>�r�rr�)rr��subprocess_execrU)�programrrrr�argsr�r�r1r+rs ` @rrr�s��������"�$�$�D�C�C�C�C�C�� 4�� 4���!��!�!��F�� !�!�� !�!��������I�x� �9�h��-�-�-r)�__all__� subprocess�rrrr �logr �PIPE�STDOUT�DEVNULL�FlowControlMixin�SubprocessProtocolrrU�_DEFAULT_LIMITrrrtrr�<module>r�sK�� =��������������������������������������� � �� � ��_&�_&�_&�_&�_&�w�7�(�;�_&�_&�_&�DR �R �R �R �R �R �R �R �j.2�$�t�(/�(>� .� .� .� .�8<�D�(,�G�4J�.�.�.�.�.�.�.r