add-determinism 0.7.3

RPM buildroot helper to strip nondeterministic bits in files
Documentation
�

��Vc�"cs��ddlZddlZddlZddlmZddlmZddlmZGd�dej��Z	Gd�d	ej
��ZGd
�deej��Z
dS)�N�)�	protocols)�
transports)�loggercs���eZdZ	d�fd�	Zd�Zd�Zd�Zd�Zd�Zd�Z	e
jfd	�Zd
�Z
d�Zd�Zd
�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Z�xZS)�BaseSubprocessTransportNc
sD��t���|
��d|_||_||_d|_d|_d|_g|_tj
��|_i|_d|_
|tjkr
d|jd<|tjkr
d|jd<|tjkr
d|jd<	|jd||||||d�|��n#|����xYw|jj|_|j|jd<|j���rBt+|t,t.f��r|}n|d}t1jd||j��|j�|�|	����dS)	NFrr�)�args�shell�stdin�stdout�stderr�bufsize�
subprocesszprocess %r created: pid %s�)Zsuper�__init__�_closed�	_protocol�_loop�_proc�_pid�_returncode�
_exit_waiters�collectionsZdeque�_pending_calls�_pipes�	_finishedr
ZPIPE�_start�closeZpidZ_extra�	get_debugZ
isinstanceZbytesZstrrZdebugZcreate_task�_connect_pipes)�self�loop�protocolrrr	r
rr�waiterZextra�kwargsZprogram�	__class__s             ��0/usr/lib64/python3.11/asyncio/base_subprocess.pyrz 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�C5cs8�|jjg}|jr|�d��|j�|�d|j����|j�|�d|j����n2|j�|�d��n|�d��|j�d��}|�|�d|j����|j�d��}|j�d	��}|�"||ur|�d
|j����n>|�|�d|j����|�|�d|j����d
�	d�
|����S)NZclosedzpid=zreturncode=Zrunningznot startedrzstdin=rrzstdout=stderr=zstdout=zstderr=z<{}>z )r$�__name__r�appendrrrZget�pipeZformatZjoin)r�infor	r
rs     r%�__repr__z BaseSubprocessTransport.__repr__7s�����'�(���<�	"��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�-���-�-�.�.�.������#�#�������#�#���	5�&�F�"2�	5��K�K�6���6�6�7�7�7�7��
5����3�f�k�3�3�4�4�4��
5����3�f�k�3�3�4�4�4��}�}�S�X�X�d�^�^�,�,�,�cs�t��N)ZNotImplementedError)rrrr	r
rrr#s        r%rzBaseSubprocessTransport._startTs��!�!r+c��||_dSr,�r)rr!�  r%�set_protocolz$BaseSubprocessTransport.set_protocolWs
��!����r+c��|jSr,r.�r� r%�get_protocolz$BaseSubprocessTransport.get_protocolZs
���~�r+cr1r,)rr2r3r%�
is_closingz"BaseSubprocessTransport.is_closing]s
���|�r+cs��|jrdSd|_|j���D]}|��|j����|j�{|j�v|j����_|j�	��rtjd|��	|j���dS#t$rYdSwxYwdSdSdS)NTz$Close running child process: kill %r)rr�valuesr(rrrZpollrrrZwarning�kill�ProcessLookupError)rZprotor/r%rzBaseSubprocessTransport.close`s���<�	��F�����[�'�'�)�)�	�	�E��
���J��������J�
	�� �
	�
�
���!�!�
	��z�#�#�%�%�
M���E�t�L�L�L�
��
���!�!�!�!�!��%�
�
�
����
����
	�
	�
	�
	�
	�
	s�B:�:
C�Ccsl�|js,|d|��t|���|���dSdS)Nzunclosed transport )Zsource)rZResourceWarningr)rZ_warnr/r%�__del__zBaseSubprocessTransport.__del__{sG���|�	��E�0��0�0�/�$�O�O�O�O��J�J�L�L�L�L�L�	�	r+cr1r,)rr2r3r%�get_pidzBaseSubprocessTransport.get_pid�s
���y�r+cr1r,)rr2r3r%�get_returncodez&BaseSubprocessTransport.get_returncode�s����r+cs<�||jvr|j|jSdSr,)rr()r�fdr/r%�get_pipe_transportz*BaseSubprocessTransport.get_pipe_transport�s%��
����	��;�r�?�'�'��4r+cs0�|j�t���dSr,)rr8r2r3r%�_check_procz#BaseSubprocessTransport._check_proc�s"���:�	'�$�&�&�&�	'�	'r+csb�|���|j�|��dSr,)r>r�send_signal)rZsignalr/r%r?z#BaseSubprocessTransport.send_signal�s0���������
���v�&�&�&�&�&r+c�`�|���|j���dSr,)r>r�	terminater2r3r%rAz!BaseSubprocessTransport.terminate�s.���������
�������r+cr@r,)r>rr7r2r3r%r7zBaseSubprocessTransport.kill�s,���������
�������r+c�s�K�	�j}�j}|j�1|��fd�|j���d{V��\}}|�jd<|j�1|��fd�|j���d{V��\}}|�jd<|j�1|��fd�|j���d{V��\}}|�jd<|��j	j
����jD]\}}|j|g|�R��d�_|�+|���s|�
d��dSdSdS#ttf$r�t $rB}|�/|���s!|�|��Yd}~dSYd}~dSYd}~dSd}~wwxYw)Nc�$��t�d��S)Nr)�WriteSubprocessPipeProtor2��r%�<lambda>�8BaseSubprocessTransport._connect_pipes.<locals>.<lambda>�s���4�T�1�=�=�r+rcrB)Nr��ReadSubprocessPipeProtor2rDr%rErF�����3�D�!�<�<�r+rcrB)NrrGr2rDr%rErF�rIr+r)rrr	Zconnect_write_piperr
Zconnect_read_piper�	call_soonr�connection_mader�	cancelled�
set_resultZ
SystemExitZKeyboardInterruptZ
BaseExceptionZ
set_exception)	rr"�procr Z_r(Zcallback�data�excs	`        r%rz&BaseSubprocessTransport._connect_pipes�s������#	(��:�D��:�D��z�
&� $� 7� 7�=�=�=�=��J�! �! � � � � � � ���4�"&���A���{�
&� $� 6� 6�<�<�<�<��K�!!�!!�!�!�!�!�!�!���4�"&���A���{�
&� $� 6� 6�<�<�<�<��K�!!�!!�!�!�!�!�!�!���4�"&���A��
�N�N�4�>�9�4�@�@�@�"&�"5�
0�
0���$����x�/�$�/�/�/�/�/�"&�D���
(�&�*:�*:�*<�*<�
(��!�!�$�'�'�'�'�'�
(�
(�
(�
(��
�-�.�	�	�	���	*�	*�	*��
*�&�*:�*:�*<�*<�
*��$�$�S�)�)�)�)�)�)�)�)�)�
*�
*�
*�
*�
*�
*�
*�
*�
*�
*�
*�
*�����	*���s�C8D.�.F�	+F�Fcsv�|j�|j�||f��dS|jj|g|�R�dSr,)rr'rrJ)rZcbrO�   r%�_callzBaseSubprocessTransport._call�sQ����	,���&�&��D�z�2�2�2�2�2� �D�J� ��+�d�+�+�+�+�+�+r+csp�|�|jj||��|���dSr,)rRrZpipe_connection_lost�_try_finish)rr<rPrQr%�_pipe_connection_lostz-BaseSubprocessTransport._pipe_connection_lost�s5���
�
�4�>�6��C�@�@�@��������r+csH�|�|jj||��dSr,)rRrZpipe_data_received)rr<rOrQr%�_pipe_data_receivedz+BaseSubprocessTransport._pipe_data_received�s#���
�
�4�>�4�b�$�?�?�?�?�?r+cs|�|j���rtjd||��||_|jj�||j_|�|jj	��|�
��|jD]+}|���s|�
|���,d|_dS)Nz%r exited with return code %r)rrrr)rr�
returncoderRrZprocess_exitedrSrrLrM)rrVr"rQr%�_process_exitedz'BaseSubprocessTransport._process_exited�s����:���!�!�	K��K�7��z�J�J�J�%����:� �	/�%/�D�J�!��
�
�4�>�0�1�1�1��������(�	.�	.�F��#�#�%�%�
.��!�!�*�-�-�-��!����r+c�s�K�	|j�|jS|j���}|j�|��|�d{V��Sr,)rrZ
create_futurerr')rr"r/r%�_waitzBaseSubprocessTransport._wait�s]����	'���	$��#�#���)�)�+�+����!�!�&�)�)�)��|�|�|�|�|�|�r+cs��|j�dStd�|j���D����r$d|_|�|jd��dSdS)Nc3s,K�|]}|duo|jV��dSr,)�disconnected)Z.0Zpr/r%z	<genexpr>z6BaseSubprocessTransport._try_finish.<locals>.<genexpr>�sA����.�.����}�/���.�.�.�.�.�.r+T)rZallrr6rrR�_call_connection_lostr2r3r%rSz#BaseSubprocessTransport._try_finish�s|����	��F��.�.���*�*�,�,�.�.�.�.�.�	9�!�D�N��J�J�t�1�4�8�8�8�8�8�	9�	9r+cs��	|j�|��d|_d|_d|_dS#d|_d|_d|_wxYwr,)r�connection_lostrr�rrPr/r%rZz-BaseSubprocessTransport._call_connection_lost�sZ��	"��N�*�*�3�/�/�/��D�J��D�J�!�D�N�N�N���D�J��D�J�!�D�N�!�!�!�!s	�3�A
)NN)r&�
__module__�__qualname__rr*rr0r4r5r�warningsZwarnr9r:r;r=r>r?rAr7rrRrTrUrWrXrSrZZ
__classcell__)r$s@r%rr
s��������%)�)<�)<�)<�)<�)<�)<�V-�-�-�:"�"�"�"�"�"����������6%�M�����
��� � � ����'�'�'�'�'�'�������$(�$(�$(�L,�,�,����@�@�@�"�"�"�&	�	�	�9�9�9�"�"�"�"�"�"�"r+rcs2�eZdZd�Zd�Zd�Zd�Zd�Zd�ZdS)rCcs>�||_||_d|_d|_dS)NF)rNr<r(rY)rrNr<rQr%rz!WriteSubprocessPipeProto.__init__s%����	������	�!����r+cr-r,)r()rZ	transportr/r%rKz(WriteSubprocessPipeProto.connection_mades
����	�	�	r+csB�d|jj�d|j�d|j�d�S)Nz<z fd=z pipe=z>)r$r&r<r(r2r3r%r*z!WriteSubprocessPipeProto.__repr__
s,��M�4�>�*�M�M���M�M�t�y�M�M�M�Mr+csb�d|_|j�|j|��d|_dS)NT)rYrNrTr<r\r/r%r[z(WriteSubprocessPipeProto.connection_lost
s/�� ����	�'�'����5�5�5���	�	�	r+c�B�|jj���dSr,)rNr�
pause_writingr2r3r%raz&WriteSubprocessPipeProto.pause_writings���	��)�)�+�+�+�+�+r+cr`r,)rNr�resume_writingr2r3r%rbz'WriteSubprocessPipeProto.resume_writings���	��*�*�,�,�,�,�,r+N)	r&r]r^rrKr*r[rarbrr+r%rCrC�sq������"�"�"����N�N�N����
,�,�,�-�-�-�-�-r+rCcs�eZdZd�ZdS)rHcsF�|j�|j|��dSr,)rNrUr<)rrOr/r%�
data_receivedz%ReadSubprocessPipeProto.data_receiveds"���	�%�%�d�g�t�4�4�4�4�4r+N)r&r]r^rcrr+r%rHrHs#������5�5�5�5�5r+rH)rr
r_ZrrZlogrZSubprocessTransportrZBaseProtocolrCZProtocolrHrr+r%�<module>rds���������������������������������r"�r"�r"�r"�r"�j�<�r"�r"�r"�j-�-�-�-�-�y�5�-�-�-�45�5�5�5�5�6�'�0�5�5�5�5�5r+