← Back
Editing: forkedfunc.cpython-311.pyc
� ��al � �f � d Z ddlZddlZddlZddlZd� Z G d� d� � Z G d� de� � ZdS )z� ForkedFunc provides a way to run a function in a forked process and get at its return value, stdout and stderr output as well as signals and exitstatusus. � Nc �� �� t t |� � d� � �| �� � � k r't j �� � � | � � G �fd�d� � } |� � S )N�wc �$ �� e Zd Z� fd�Z� fd�ZdS )�$get_unbuffered_io.<locals>.AutoFlushc �Z �� �� |� � �� � � d S �N)�write�flush)�self�data�fs ��8/usr/lib/python3/dist-packages/py/_process/forkedfunc.pyr z*get_unbuffered_io.<locals>.AutoFlush.write s# �� � �G�G�D�M�M�M� �G�G�I�I�I�I�I� c �$ �� t �|� � S r )�getattr)r �namer s �r � __getattr__z0get_unbuffered_io.<locals>.AutoFlush.__getattr__ s �� ��1�d�#�#� #r N)�__name__� __module__� __qualname__r r )r s �r � AutoFlushr sG �� � � � � � � � � � � $� $� $� $� $� $� $r r )�open�str�fileno�os�dup2)�fd�filenamer r s @r �get_unbuffered_ior s� �� � �S��]�]�C� � �A� �Q�X�X�Z�Z��� ����� � �B� � � �$� $� $� $� $� $� $� $� $� $� �9�;�;�r c �D � e Zd ZdZ d d�Zd� Zej fd�Zd� Z d� Z dS ) � ForkedFunc� Nr c � � |�g }|�i }|| _ || _ || _ t j j � � � x| _ }|� d� � | _ |� d� � | _ |� d� � | _ t j � � }|r || _ d S d | _ | � |||� � d S )N�retval�stdout�stderr)�fun�args�kwargs�py�path�local�mkdtemp�tempdir�ensure�RETVAL�STDOUT�STDERRr �fork�pid�_child) r r' r( r) � nice_level�child_on_start� child_on_exitr. r4 s r �__init__zForkedFunc.__init__ s� � � �<��D� �>��F������ � �� �!#�� �!6�!6�!8�!8�8�� �w� �n�n�X�.�.�� � �n�n�X�.�.�� � �n�n�X�.�.�� ��g�i�i�� � C��D�H�H�H��D�H� �K�K� �N�M� B� B� B� B� Br c �� � t d| j � � xt _ }t d| j � � xt _ }| j � d� � }d} |rt j |� � |� |� � | j | j i | j ��}|� t j |� � � � |� |� � n`# t j � � � } |� t' | � � � � � � � | j }Y nxY w|� � � |� � � |� � � nA# |� � � |� � � |� � � w xY wt j d� � t j d� � t j |� � d S )N� � �wbr )r r1 �sysr% r2 r& r0 r r �nicer' r( r) r �marshal�dumpsr* �code� ExceptionInfor � _getreprcrash�EXITSTATUS_EXCEPTION�close�_exit) r r6 r7 r8 r% r& �retvalf� EXITSTATUSr$ �excinfos r r5 zForkedFunc._child4 s� � � 0��4�;� ?� ?�?�� �V� /��4�;� ?� ?�?�� �V��+�"�"�4�(�(��� � �� $��� �#�#�#� 7�!�-�"�N�$�$�$�!���4�9�<�� �<�<��� � �g�m�F� 3� 3�4�4�4� �,�!�M�O�O�O��� 7� �'�/�/�1�1��� � �S��!6�!6�!8�!8� 9� 9�:�:�:� !� 6� � � ���� �L�L�N�N�N� �L�L�N�N�N� �M�M�O�O�O�O�� �L�L�N�N�N� �L�L�N�N�N� �M�M�O�O�O�O���� ��� � � � ��� � � � ��� � � � � s& � E+ �7AC � E+ �AD+�)E+ �+>F)c �` � || j d� � \ }}|rAt j |� � rt j |� � dz }nt j |� � }nd}|dz }|st|sr| j � d� � } |� � � }|� � � n# |� � � w xY wt j |� � }nd }| j � � � }| j � � � } | � � � t ||||| � � S )Nr � � �rb)r4 r � WIFSIGNALED�WTERMSIG� WEXITSTATUSr0 r �readrF r@ �loadsr1 r2 � _removetemp�Result) r �waiterr4 � systemstatus� exitstatus�signalr$ � retval_datar% r& s r � waitfinishzForkedFunc.waitfinishQ s% � � "�F�4�8�Q� /� /���\� � ��~�l�+�+� :� �[� � 6� 6�� <� � � �^�L� 9� 9� � ��J� ��$��� �&� ��[�%�%�d�+�+�F� � $�k�k�m�m� �� � ������� � �������� �]�;�/�/�F�F��F���!�!�#�#����!�!�#�#�� �������j�&�&�&�&�A�A�As �>B' �'B=c �n � | j � � � r| j � � � d S d S r )r. �check�remove�r s r rT zForkedFunc._removetempi s< � � �<� � � � � "� �L� � � !� !� !� !� !� "� "r c �@ � | j �| � � � d S d S r )r4 rT r_ s r �__del__zForkedFunc.__del__m s* � � �8� � � � � � � � � � � r )NNr NN) r r r rE r9 r5 r �waitpidr[ rT ra � r r r! r! s� � � � � � � �� @A�48�C� C� C� C�* � � �: !#� � B� B� B� B�0"� "� "� � � � � r r! c � � e Zd Zd� ZdS )rU c �L � || _ || _ || _ || _ || _ d S r )rX rY r$ �out�err)r rX rY r$ r% r& s r r9 zResult.__init__s s) � �$��� �� � �� ��������r N)r r r r9 rc r r rU rU r s# � � � � � �� � � � r rU ) �__doc__r* r r> r@ r r! �objectrU rc r r �<module>rj s� ��� � � � � � � � � � � � � � ���� � � �T � T � T � T � T � T � T � T �n� � � � �V� � � � � r
Save File
Cancel