Edit File: base_subprocess.cpython-311.pyc
� �����f�"����������������������������d�dl�Z�d�dlZd�dlZddlmZ�ddlmZ�ddlmZ��G�d��dej��������������������Z �G�d��d ej ��������������������Z�G�d ��deej��������������������Z dS�)�����N����)� protocols)� transports)�loggerc���������������������������e�Zd�Z �d��fd� Zd��Zd��Zd��Zd��Zd��Zd��Z e j��������fd �Zd ��Z d��Zd��Zd ��Zd��Zd��Zd��Zd��Zd��Zd��Zd��Zd��Zd��Zd��Zd��Z��xZS�)�BaseSubprocessTransportNc����������� �������D�����t���������������������������������������������| �������������d|�_��������||�_��������||�_��������d�|�_��������d�|�_��������d�|�_��������g�|�_��������t����������j ����������������������|�_��������i�|�_��������d|�_ ��������|t����������j��������k����r d�|�j��������d<���|t����������j��������k����r d�|�j��������d<���|t����������j��������k����r d�|�j��������d<��� ��|�j��������d||||||d�|���n#��|���������������������������������������xY�w|�j��������j��������|�_��������|�j��������|�j��������d<���|�j�������������������������������������������rBt+����������|t,����������t.����������f������������r|}n|d���������}t1����������j��������d||�j���������������������|�j�����������������������������|����������������������| �������������������������d�S�) NFr���r�������)�args�shell�stdin�stdout�stderr�bufsize� subprocesszprocess %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��� ��>/opt/alt/python311/lib64/python3.11/asyncio/base_subprocess.pyr���z BaseSubprocessTransport.__init__���s�������� ������������!����� ��� ��� �������)�/�1�1����������J�O�#�#�!�D�K��N��Z�_�$�$�!�D�K��N��Z�_�$�$�!�D�K��N� ��D�K�� B�T��e�F�%�w� B�� B�:@� B�� B�� B�� B�� ��J�J�L�L�L������J�N�� �$(�J���L�!��:���!�!�� -��$����-�-�� "�����q�'���L�5� �$�)� -�� -�� -�� � ���t�2�2�6�:�:�;�;�;�;�;s���� C��C5c������������������8����|�j���������j��������g}|�j��������r|���������������������d�������������|�j���������|���������������������d|�j������������������������|�j���������|���������������������d|�j������������������������n2|�j���������|���������������������d�������������n|���������������������d�������������|�j�����������������������������d������������}|�|���������������������d|j������������������������|�j�����������������������������d������������}|�j�����������������������������d ������������}|�"||u�r|���������������������d |j������������������������n>|�|���������������������d|j������������������������|�|���������������������d|j������������������������d � ��������������������d� ��������������������|������������������������S�)N�closedzpid=zreturncode=�runningznot startedr���zstdin=r���r ���zstdout=stderr=zstdout=zstderr=z<{}>� )r4����__name__r����appendr���r���r����get�pipe�format�join)r-����infor ���r���r���s��� r5����__repr__z BaseSubprocessTransport.__repr__7���s��������'�(���<�� "��K�K��!�!�!��9� ��K�K�*�t�y�*�*�+�+�+���'��K�K�8�d�&6�8�8�9�9�9�9� �Y� "��K�K� �"�"�"�"��K�K� �&�&�&������"�"�����K�K�-���-�-�.�.�.������#�#�������#�#����&�F�"2�"2��K�K�6���6�6�7�7�7�7��!����3�f�k�3�3�4�4�4��!����3�f�k�3�3�4�4�4��}�}�S�X�X�d�^�^�,�,�,�����c�����������������������t�������������N)�NotImplementedError)r-���r���r���r ���r���r���r���r2���s��� r5���r"���zBaseSubprocessTransport._startT���s������!�!rB���c�����������������������||�_���������d�S�rD����r���)r-���r/���s��� r5����set_protocolz$BaseSubprocessTransport.set_protocolW���s ������!����rB���c�����������������������|�j���������S�rD���rG����r-���s��� r5����get_protocolz$BaseSubprocessTransport.get_protocolZ���s �������~�rB���c�����������������������|�j���������S�rD���)r���rJ���s��� r5���� is_closingz"BaseSubprocessTransport.is_closing]���s �������|�rB���c����������������������|�j���������rd�S�d|�_���������|�j�������������������������������������������D�]}|��|j���������������������������������������������|�j���������{|�j���������v|�j��������������������������������������������_|�j��������� ����������������������������������rt����������j��������d|�������������� �|�j��������������������������������������������d�S�#�t����������$�r�Y�d�S�w�xY�wd�S�d�S�d�S�)NTz$Close running child process: kill %r)r���r����valuesr=���r#���r���r����pollr���r&���r����warning�kill�ProcessLookupError)r-����protos��� r5���r#���zBaseSubprocessTransport.close`���s��������<�� ��F�����[�'�'�)�)�� �� �E��}���J��������J�"�� �(��� ���!�!�)��z�#�#�%�%�� M���E�t�L�L�L� �� ���!�!�!�!�!��%�� �� �� ���� ����� #�"�(�(��*�)s����B:��: C�Cc������������������l�����|�j���������s,�|d|���t����������|���������������|�������������������������������������d�S�d�S�)Nzunclosed transport )�source)r����ResourceWarningr#���)r-����_warns��� r5����__del__zBaseSubprocessTransport.__del__{���sG�������|�� ��E�0��0�0�/�$�O�O�O�O��J�J�L�L�L�L�L� �� rB���c�����������������������|�j���������S�rD���)r���rJ���s��� r5����get_pidzBaseSubprocessTransport.get_pid����s �������y�rB���c�����������������������|�j���������S�rD���)r���rJ���s��� r5����get_returncodez&BaseSubprocessTransport.get_returncode����s��������rB���c������������������<�����||�j���������v�r|�j���������|���������j��������S�d�S�rD���)r���r=���)r-����fds��� r5����get_pipe_transportz*BaseSubprocessTransport.get_pipe_transport����s#������ ������;�r�?�'�'��4rB���c������������������0�����|�j����������t�������������������������d�S�rD���)r���rS���rJ���s��� r5����_check_procz#BaseSubprocessTransport._check_proc����s�������:��$�&�&�&���rB���c������������������b�����|��������������������������������������|�j�����������������������������|�������������d�S�rD���)rb���r����send_signal)r-����signals��� r5���rd���z#BaseSubprocessTransport.send_signal����s0������������� ���v�&�&�&�&�&rB���c������������������`�����|��������������������������������������|�j��������������������������������������������d�S�rD���)rb���r���� terminaterJ���s��� r5���rg���z!BaseSubprocessTransport.terminate����s.������������� �������rB���c������������������`�����|��������������������������������������|�j��������������������������������������������d�S�rD���)rb���r���rR���rJ���s��� r5���rR���zBaseSubprocessTransport.kill����s,������������� �������rB���c�������������������.����K���� ���j���������}��j��������}|j���������1|�����������������������fd�|j����������������������d�{V���\��}}|��j��������d<���|j���������1|�����������������������fd�|j����������������������d�{V���\��}}|��j��������d<���|j���������1|�����������������������fd�|j����������������������d�{V���\��}}|��j��������d<�����j���������J��|� ����������������������j ��������j�������������������������j��������D�]\��}}�|j ��������|g|�R�����d���_��������|�+|�����������������������������������s|� ��������������������d��������������d�S�d�S�d�S�#�t����������t����������f$�r���t ����������$�rB}|�/|�����������������������������������s!|���������������������|�������������Y�d�}~d�S�Y�d�}~d�S�Y�d�}~d�S�d�}~ww�xY�w)Nc�������������������$������t������������d������������S�)Nr���)�WriteSubprocessPipeProtorJ���s����r5����<lambda>z8BaseSubprocessTransport._connect_pipes.<locals>.<lambda>����s�������4�T�1�=�=��rB���r���c�������������������$������t������������d������������S�)Nr�����ReadSubprocessPipeProtorJ���s����r5���rl���z8BaseSubprocessTransport._connect_pipes.<locals>.<lambda>������������3�D�!�<�<��rB���r���c�������������������$������t������������d������������S�)Nr ���rn���rJ���s����r5���rl���z8BaseSubprocessTransport._connect_pipes.<locals>.<lambda>����rp���rB���r ���)r���r���r ����connect_write_piper���r����connect_read_piper���r���� call_soonr����connection_made� cancelled� set_result� SystemExit�KeyboardInterrupt� BaseException� set_exception) r-���r0����procr.����_r=����callback�data�excs ���` r5���r,���z&BaseSubprocessTransport._connect_pipes����st����������# (��:�D��:�D��z�%� $� 7� 7�=�=�=�=��J�! ��! �� �� �� �� �� �� ���4��"&���A���{�&� $� 6� 6�<�<�<�<��K�!!��!!��!��!��!��!��!��!���4��"&���A���{�&� $� 6� 6�<�<�<�<��K�!!��!!��!��!��!��!��!��!���4��"&���A���&�2�2�2��N�N�4�>�9�4�@�@�@�"&�"5�� 0�� 0���$����x�/�$�/�/�/�/�/�"&�D����!�&�*:�*:�*<�*<�!��!�!�$�'�'�'�'�'��"�!�!�!�� ��-�.�� �� �� ���� *�� *�� *��!�&�*:�*:�*<�*<�!��$�$�S�)�)�)�)�)�)�)�)�)��"�!�!�!�!�!�!�!�!�!�!�!����� *���s����DD7��7F�+F�Fc������������������v�����|�j����������|�j������������������������������||f�������������d�S��|�j��������j��������|g|�R����d�S�rD���)r���r;���r���rt���)r-����cbr���s��� r5����_callzBaseSubprocessTransport._call����sO��������*���&�&��D�z�2�2�2�2�2� �D�J� ��+�d�+�+�+�+�+�+rB���c������������������p�����|�����������������������|�j��������j��������||�������������|�������������������������������������d�S�rD���)r����r����pipe_connection_lost�_try_finish)r-���r_���r����s��� r5����_pipe_connection_lostz-BaseSubprocessTransport._pipe_connection_lost����s5������� � �4�>�6��C�@�@�@��������rB���c������������������H�����|�����������������������|�j��������j��������||�������������d�S�rD���)r����r����pipe_data_received)r-���r_���r���s��� r5����_pipe_data_receivedz+BaseSubprocessTransport._pipe_data_received����s#������� � �4�>�4�b�$�?�?�?�?�?rB���c������������������L����|� J�|���������������|�j����������J�|�j������������������������|�j�������������������������������������������rt����������j��������d|�|�������������||�_���������|�j��������j���������||�j��������_��������|����������������������|�j��������j ���������������������|�� �����������������������������������d�S�)Nz%r exited with return code %r)r���r���r&���r���r@���r���� returncoder����r����process_exitedr����)r-���r����s��� r5����_process_exitedz'BaseSubprocessTransport._process_exited����s��������%�%�z�%�%�%���'�'��)9�'�'�'��:���!�!�� K��K�7��z�J�J�J�%����:� �(��%/�D�J�!�� � �4�>�0�1�1�1��������rB���c����������������������K����|�j����������|�j���������S�|�j�������������������������������������������}|�j�����������������������������|�������������|��d{V���S�)zdWait until the process exit and return the process return code. This method is a coroutine.N)r���r���� create_futurer���r;���)r-���r0���s��� r5����_waitzBaseSubprocessTransport._wait����sV�������������'��#�#���)�)�+�+����!�!�&�)�)�)��|�|�|�|�|�|�rB���c������������������������|�j���������rJ��|�j���������d�S�t����������d��|�j�������������������������������������������D���������������������������r$d|�_���������|����������������������|�j��������d��������������d�S�d�S�)Nc��������������3����,���K����|�]}|d�uo|j���������V����d�S�rD���)�disconnected)�.0�ps��� r5���� <genexpr>z6BaseSubprocessTransport._try_finish.<locals>.<genexpr>����sA�����������.��.�����}�/����.��.��.��.��.��.rB���T)r ���r����allr���rO���r�����_call_connection_lostrJ���s��� r5���r����z#BaseSubprocessTransport._try_finish����s��������>�!�!�!���#��F���.��.���*�*�,�,�.��.��.��.��.�� 9�!�D�N��J�J�t�1�4�8�8�8�8�8� 9�� 9rB���c���������������������� �|�j������������������������������|�������������|�j��������D�]0}|�����������������������������������s|���������������������|�j����������������������1d�|�_��������d�|�_��������d�|�_��������d�|�_���������d�S�#�|�j��������D�]0}|�����������������������������������s|���������������������|�j����������������������1d�|�_��������d�|�_��������d�|�_��������d�|�_���������w�xY�wrD���)r����connection_lostr���rv���rw���r���r���r���)r-���r����r0���s��� r5���r����z-BaseSubprocessTransport._call_connection_lost����s������� "��N�*�*�3�/�/�/���,�� 8�� 8���'�'�)�)��8��%�%�d�&6�7�7�7��!%�D���D�J��D�J�!�D�N�N�N�� ��,�� 8�� 8���'�'�)�)��8��%�%�d�&6�7�7�7��!%�D���D�J��D�J�!�D�N�!�!�!�!s����A2��2AC)NN)r:���� __module__�__qualname__r���rA���r"���rH���rK���rM���r#����warnings�warnrY���r[���r]���r`���rb���rd���rg���rR���r,���r����r����r����r����r����r����r����� __classcell__)r4���s���@r5���r���r��� ���s����������������%)�)<��)<��)<��)<��)<��)<�V-��-��-�:"��"��"�"��"��"����������������6�%�M��������� ����� �� �� ������'��'��'�'��'��'�����������$(��$(��$(�L,��,��,������@��@��@������ �� �� �9��9��9�"��"��"��"��"��"��"rB���r���c��������������������2�����e�Zd�Zd��Zd��Zd��Zd��Zd��Zd��ZdS�)rk���c������������������>�����||�_���������||�_��������d�|�_��������d|�_��������d�S�)NF)r|���r_���r=���r����)r-���r|���r_���s��� r5���r���z!WriteSubprocessPipeProto.__init__��s%�������� ������ �!����rB���c�����������������������||�_���������d�S�rD���)r=���)r-���� transports��� r5���ru���z(WriteSubprocessPipeProto.connection_made��s �������� � � rB���c������������������B�����d|�j���������j����������d|�j����������d|�j���������d�S�)N�<z fd=z pipe=�>)r4���r:���r_���r=���rJ���s��� r5���rA���z!WriteSubprocessPipeProto.__repr__ ��s,������M�4�>�*�M�M���M�M�t�y�M�M�M�MrB���c������������������b�����d|�_���������|�j�����������������������������|�j��������|�������������d�|�_��������d�S�)NT)r����r|���r����r_���)r-���r����s��� r5���r����z(WriteSubprocessPipeProto.connection_lost ��s/������ ���� �'�'����5�5�5��� � � rB���c������������������B�����|�j���������j��������������������������������������������d�S�rD���)r|���r���� pause_writingrJ���s��� r5���r����z&WriteSubprocessPipeProto.pause_writing��s������� ��)�)�+�+�+�+�+rB���c������������������B�����|�j���������j��������������������������������������������d�S�rD���)r|���r����resume_writingrJ���s��� r5���r����z'WriteSubprocessPipeProto.resume_writing��s������� ��*�*�,�,�,�,�,rB���N) r:���r����r����r���ru���rA���r����r����r����r���rB���r5���rk���rk�������sq��������������"��"��"������N��N��N������ ,��,��,�-��-��-��-��-rB���rk���c�������������������������e�Zd�Zd��ZdS�)ro���c������������������F�����|�j������������������������������|�j��������|�������������d�S�rD���)r|���r����r_���)r-���r���s��� r5���� data_receivedz%ReadSubprocessPipeProto.data_received��s"������� �%�%�d�g�t�4�4�4�4�4rB���N)r:���r����r����r����r���rB���r5���ro���ro�����s#��������������5��5��5��5��5rB���ro���)r���r���r������r���r����logr����SubprocessTransportr����BaseProtocolrk����Protocolro���r���rB���r5����<module>r�������s���������������������������������������������������������������r"��r"��r"��r"��r"�j�<��r"��r"��r"�j-��-��-��-��-�y�5��-��-��-�45��5��5��5��5�6�'�0�5��5��5��5��5rB���