Edit File: forkserver.cpython-311.opt-2.pyc
� �����ff/�����������������������D����d�dl�Z�d�dlZd�dlZd�dlZd�dlZd�dlZd�dlZd�dlZd�dlZddl m Z �ddl mZ�ddlm Z �ddl mZ�ddl mZ�ddl mZ�g�d �Zd Z�ej��������d������������Z�G�d��d e������������Zdd�Zd��Zd��Zd��Z�e��������������Zej��������Zej��������Zej��������Zej��������ZdS�)�����N����)� connection)�process)� reduction)�resource_tracker)�spawn)�util)�ensure_running�get_inherited_fds�connect_to_new_process�set_forkserver_preload�����qc��������������������8�����e�Zd�Zd��Zd��Zd��Zd��Zd��Zd��Zd��Z dS�) � ForkServerc������������������~�����d�|�_���������d�|�_��������d�|�_��������d�|�_��������t ����������j����������������������|�_��������dg|�_��������d�S�)N�__main__)�_forkserver_address�_forkserver_alive_fd�_forkserver_pid�_inherited_fds� threading�Lock�_lock�_preload_modules��selfs��� �A/opt/alt/python311/lib64/python3.11/multiprocessing/forkserver.py�__init__zForkServer.__init__"���sA������#'�� �$(��!�#���"����^�%�%�� �!+����������c������������������n�����|�j���������5��|�������������������������������������d�d�d��������������d�S�#�1�swxY�w�Y���d�S��N)r����_stop_unlockedr���s��� r����_stopzForkServer._stop*���s������� �Z�� "�� "����!�!�!� "�� "�� "�� "�� "�� "�� "�� "�� "�� "�� "�� "����� "�� "�� "�� "�� "�� "s����*�.�.c����������������������|�j����������d�S�t����������j��������|�j���������������������d�|�_��������t����������j��������|�j���������d�������������d�|�_���������t����������j��������|�j��������������������st����������j��������|�j���������������������d�|�_��������d�S�)Nr���) r����os�closer����waitpidr ����is_abstract_socket_namespacer����unlinkr���s��� r���r#���zForkServer._stop_unlocked/���s���������'��F�� ���*�+�+�+�$(��!� � �4�'��+�+�+�#����0��1I�J�J�� 0��I�d�.�/�/�/�#'�� � � r ���c������������������f����� �t����������d��|D���������������������������st����������d�������������||�_��������d�S�)Nc��������������3����B���K����|�]}t����������|������������t����������u�V����d�S�r"���)�type�str)�.0�mods��� r���� <genexpr>z4ForkServer.set_forkserver_preload.<locals>.<genexpr>@���s-����������=�=��4��9�9��#�=�=�=�=�=�=r ���z&module_names must be a list of strings)�all� TypeErrorr���)r���� modules_namess��� r���r ���z!ForkServer.set_forkserver_preload>���sB������L��=�=�}�=�=�=�=�=�� F��D�E�E�E� -����r ���c����������������������� �|�j���������S�r"���)r���r���s��� r���r���zForkServer.get_inherited_fdsD���s������ � ��"�"r ���c���������������������� �|��������������������������������������t����������|������������dz���t����������k����rt����������d�������������t ����������j��������t����������j��������������������5�}|���������������������|�j���������������������t����������j ����������������������\��}}t����������j ����������������������\��}}|||�j ��������t����������j����������������������g}||z ��} �t����������j��������||�������������||ft����������j��������|�������������t����������j��������|�������������cd�d�d��������������S�#��t����������j��������|�������������t����������j��������|���������������xY�w#�t����������j��������|�������������t����������j��������|�������������w�xY�w#�1�swxY�w�Y���d�S�)N����ztoo many fds)r ����len�MAXFDS_TO_SEND� ValueError�socket�AF_UNIX�connectr���r&����piper���r����getfdr����sendfdsr'���)r����fds�client�parent_r�child_w�child_r�parent_w�allfdss��� r���r���z!ForkServer.connect_to_new_processL���s������ �� �������s�8�8�a�<�>�)�)��^�,�,�,� �]�6�>� *� *�� "�f��N�N�4�3�4�4�4� "�� � ��H�g� "�� � ��G�X��w��(A�&�,�.�.�0�F��c�M�F� "��!�&�&�1�1�1���)�����!�!�!����!�!�!�! "�� "�� "�� "�� "�� "�� "�� "�� ����"�"�"����"�"�"���������!�!�!����!�!�!�!����! "�� "�� "�� "����� "�� "�� "�� "�� "�� "s7����A(E/�D�(E/�+D?�?E�*E,�,E/�/E3�6E3c������������������������ �|�j���������5��t����������j�����������������������|�j���������et ����������j��������|�j��������t����������j��������������������\��}}|s �d�d�d��������������d�S�t ����������j��������|�j���������������������d�|�_ ��������d�|�_��������d�|�_��������d}|�j ��������r9ddh�t����������j��������d������������}�fd�|� ����������������������������������D���������������}ni�}t����������j��������t����������j��������������������5�}t!����������j��������d������������}|���������������������|�������������t'����������j��������|������������st ����������j��������|d�������������|������������������������������������t ����������j����������������������\��}} �|�����������������������������������|g} ||�����������������������������������||�j ��������|fz��}t����������j����������������������} | gt'����������j����������������������z���}|d|gz ��}t'����������j��������| || ������������}n#��t ����������j��������|���������������xY�w �t ����������j��������|�������������n#�t ����������j��������|�������������w�xY�w||�_ ��������||�_��������||�_��������d�d�d��������������n#�1�swxY�w�Y���d�d�d��������������d�S�#�1�swxY�w�Y���d�S�) NzCfrom multiprocessing.forkserver import main; main(%d, %d, %r, **%r)� main_path�sys_path�ignorec������������������$������i�|�]\��}}|�v�� ||�� S���rM���)r/����x�y�desired_keyss��� �r���� <dictcomp>z-ForkServer.ensure_running.<locals>.<dictcomp>����s)�������K�K�K���A��l�9J�9J��1�9J�9J�9Jr ���r<���i���z-c)r���r���r ���r���r&���r(����WNOHANGr'���r���r���r���r����get_preparation_data�itemsr;���r<���r����arbitrary_address�bindr ���r)����chmod�listenr>����fileno�get_executable�_args_from_interpreter_flags�spawnv_passfds) r����pid�status�cmd�data�listener�address�alive_r�alive_w�fds_to_pass�exe�argsrP���s ��� @r���r ���zForkServer.ensure_runningi���s������ ���Z��1 +��1 +��+�-�-�-��#�/� �j��)=�r�z�J�J���V�����1 +��1 +��1 +��1 +��1 +��1 +��1 +��1 +�����2�3�3�3�+/��(�,0��)�'+��$�,�C���$�� � +�Z�8���1�(�;�;��K�K�K�K������K�K�K�������v�~�.�.�� +�(�$�6�y�A�A��� � �g�&�&�&��8��A�A��-��H�W�e�,�,�,����!�!�!��$&�7�9�9� ���&�#+�?�?�#4�#4�g�">�K��H�O�O�-�-�w��8M� �"��"�C��.�0�0�C��5�4�#D�#F�#F�F�D��T�3�K�'�D��-�c�4��E�E�C�C����H�W�%�%�%������� ��H�W�%�%�%�%��B�H�W�%�%�%�%����+2��(�,3��)�'*��$�3 +�� +�� +�� +�� +�� +�� +�� +�� +�� +�� +����� +�� +�� +�� +�11 +��1 +��1 +��1 +��1 +��1 +��1 +��1 +��1 +��1 +��1 +��1 +�����1 +��1 +��1 +��1 +��1 +��1 +si����AI*�BI*�,A=I�*A=G(�'H�(G?�?H�I�H.�.I�I*�I �I*�I �I*�*I.�1I.N) �__name__� __module__�__qualname__r���r$���r#���r ���r���r���r ���rM���r ���r���r���r��� ���s}��������������-��-��-�"��"��"� (�� (�� (�.��.��.�#��#��#�"��"��"�:8+��8+��8+��8+��8+r ���r���c����������� ������� ���� �|r�d|v�r[|�Ydt����������j����������������������_�������� �t����������j��������|�������������t����������j����������������������`n#�t����������j����������������������`w�xY�w|D�]"} �t����������|��������������#�t����������$�r�Y��w�xY�wt����������j�����������������������t����������j ����������������������\��}}t����������j��������|d�������������t����������j��������|d�������������d��}t����������j ��������|t����������j��������t����������j��������i} d��| �����������������������������������D���������������} t����������j��������|�������������i�}t%����������j��������t$����������j��������|��������������5�}t)����������j����������������������5�} |�����������������������������������t.����������_��������| ���������������������|t(����������j���������������������| ���������������������|t(����������j���������������������| ���������������������|t(����������j��������������������� � � �d��| �����������������������������������D���������������}|rn�"||v�rt8�����������||v�r�t����������j��������|d������������� � �t����������j��������d t����������j��������������������\��}}n#�t@����������$�r�Y�n�w�xY�w|d k����rn{|�!��������������������|d�������������}|�Kt����������j"��������|������������} �tG����������||�������������n#�tH����������$�r�Y�nw�xY�wt����������j%��������|�������������ntM����������j'��������d|z�����������������||v��r|�(����������������������������������d ���������5�}tS����������j*��������|tV����������dz���������������}tY����������|������������tV����������k����r/t[����������d �.��������������������tY����������|�������������������������������������|^}}}|�%�����������������������������������t����������j/����������������������}|d k����r�d} �|�%�����������������������������������| �%�����������������������������������||||g}|�0��������������������|�1�����������������������������������������������te����������|||| ������������}nM#�tf����������$�r@�ti����������j5��������ti����������j6�������������������������th����������j7���������8�����������������������������������Y�nw�xY�wt����������j9��������|�������������nm#�t����������j9��������|�������������w�xY�w �tG����������||�������������n#�tH����������$�r�Y�nw�xY�w|||<���t����������j%��������|�������������|D�]}t����������j%��������|��������������d�d�d��������������n#�1�swxY�w�Y���n-#�tt����������$�r }|j;��������tv����������j<��������k����r��Y�d�}~nd�}~ww�xY�w��6#�1�swxY�w�Y���d�d�d��������������d�S�#�1�swxY�w�Y���d�S�)Nr���TFc������������������������d�S�r"���rM���)�_unuseds��� r����sigchld_handlerzmain.<locals>.sigchld_handler����s�������r ���c������������������@�����i�|�]\��}}|t����������j���������||��������������S�rM���)�signal)r/����sig�vals��� r���rQ���zmain.<locals>.<dictcomp>����s:�������8��8��8�"��c�����s�C�0�0��8��8��8r ���)rY���c������������������"�����g�|�]\��}}|j����������� S�rM���)�fileobj)r/����key�eventss��� r���� <listcomp>zmain.<locals>.<listcomp>����s������O�O�O�M�S�&�C�K�O�O�Or ���i������r���z.forkserver: waitpid returned unexpected pid %dr���zToo many ({0:n}) fds to send)=r����current_process�_inheritingr����import_main_path� __import__�ImportErrorr ����_close_stdinr&���r>����set_blockingrp����SIGCHLD�SIGINT�SIG_IGNrT���� set_wakeup_fdr;���r<���� selectors�DefaultSelector�getsockname�_forkserverr����register� EVENT_READ�select� SystemExit�readr(���rR����ChildProcessError�pop�waitstatus_to_exitcode�write_signed�BrokenPipeErrorr'����warnings�warn�acceptr����recvfdsr9���r8����RuntimeError�format�fork�extend�values� _serve_one� Exception�sys� excepthook�exc_info�stderr�flush�_exit�OSError�errno�ECONNABORTED)�listener_fdrc����preloadrI���rJ����modname�sig_r�sig_wrn����handlers�old_handlers� pid_to_fdra����selector�rfdsr]����stsrD���� returncode�srA���rE����code� unused_fds�fd�es��� r����mainr��������s������������ � �Y�%:�48�G�#�%�%�1� :��&�y�1�1�1��+�-�-�9�9��G�+�-�-�9�9�9�9�9��� �� �G� ��7�#�#�#�#���� �� �� ��� ����� ������7�9�9�L�E�5��O�E�5�!�!�!��O�E�5�!�!�!� �� �� �� ���� �v�~� �H�8��8�&.�n�n�&6�&6�8��8��8�L����������I� ��v�~�k� :� :� :��Y�h� � "� $� $�Y�(0�*2�*>�*>�*@�*@��'����(�I�$8�9�9�9����'�9�#7�8�8�8����%��!5�6�6�6�Q �P ��O�O�X�_�_�=N�=N�O�O�O�D������ ��d�?�?��%�$��D�=�=��G�E�5�)�)�)�E�"�')�z�"�b�j�'A�'A�H�C����0��"��"��"�!�E�"�����!�8�8�!�"+�-�-��T�":�":��"�.�)+�)B�3�)G�)G�J�%� ,�W�j� A� A� A� A��#2��%��%��%� $��%������H�W�-�-�-�-��%�M��+>�@C�+D��E��E��E�+E�0��t�#�#�!���*�*�1�-��$-��'�/��>�A�3E�F�F���s�8�8�n�4�4�".� >� E� E�$'��H�H�!.��!.�#/��#/��/��25�.���3���� � � � �g�i�i���!�8�8�#$�D�/� (��� 0� 0� 0� (��� 0� 0� 0�.5�w��u�-M� � *� 1� 1�)�2B�2B�2D�2D� E� E� E�'1�'�3�2<�2>�(@��(@�����$-��3��3��3� #������ ?� ?� #� � 0� 0� 2� 2� 2� 2� 2�3�����!#������������������%� ,�W�c� :� :� :� :��#2��%��%��%� $��%�����.5�I�c�N��H�W�-�-�-�&)��-��-�� "�������I$-��$-��$-��$-��$-��$-��$-��$-��$-��$-��$-�����$-��$-��$-��$-���L��� �� �� ��7�e�0�0�0���1�0�0�0�0����� ����_Q �Y��Y��Y��Y�����Y��Y��Y��Y��Y��Y��Y��Y��Y��Y��Y��Y��Y��Y��Y��Y�����Y��Y��Y��Y��Y��YsC���A��A �(A8�8 B�B�T8�*B�T �+AS1�4"I�S1� I$�!S1�#I$�$6S1�J,�+S1�, J9�6S1�8J9�9AS1�BS%�"A'P � Q,� AQ �Q,�Q �Q,�S%�,R �S%�R�S%� R$ �!S%�#R$ �$5S%�S1�%S)�)S1�,S)�-S1�0T �1 T�;T�T �T�T � T$ �$T8�'T$ �(T8�8T<�?T<c������������������`����t����������j��������d�������������|�����������������������������������D�]\��}}t����������j���������||��������������|D�]}t����������j��������|��������������|^t ����������_��������t����������j��������_ ��������t ����������_ ��������t����������j��������|�������������}t����������j ��������|�|������������}|S�)Nrx���)rp���r����rT���r&���r'���r����r���r����_resource_tracker�_fdr����dupr����_main) rE���rA���r����r����rq���rr���r�����parent_sentinelr����s ��� r���r����r����+��s������� �������N�N�$�$�� �� ���S�� �c�3����������� ��������%(�"�[�%��'�+�� ���f�W�o�o�O��;�w��0�0�D��Kr ���c������������������ ����d}t�����������j��������}t����������|������������|k�����rNt����������j��������|�|t����������|������������z ��������������}|st����������d�������������||z ��}t����������|������������|k������Nt��������������������������������|������������d���������S�)Nr ���zunexpected EOFr���)� SIGNED_STRUCT�sizer8���r&���r�����EOFError�unpack)r����r`����lengthr����s��� r����read_signedr����B��s��������D� � �F� �d�)�)�f� � ��G�B���T���*�+�+���� -��+�,�,�,��� �� ��d�)�)�f� � � �����%�%�a�(�(r ���c�����������������������t��������������������������������|������������}|r8t����������j��������|�|������������}|dk����rt ����������d�������������||d�����������}|�6d�S�d�S�)Nr���zshould not get here)r�����packr&����writer����)r�����n�msg�nbytess��� r���r����r����L��sq������ � � �Q� � �C� �����"�c�"�"���Q�;�;��4�5�5�5��&�'�'�l�� �����������r ���)NN) r����r&���r����rp���r;����structr����r���r������r���r����contextr���r���r���r ����__all__r9����Structr�����objectr���r����r����r����r����r����r ���r���r���r ���rM���r ���r����<module>r�������s����������� � � � ���������� � � � �� � � � �� � � � �� � � � ��������������������������������������������������������������������������������������%��%��%������� �c�"�"� �A+��A+��A+��A+��A+���A+��A+��A+�NA��A��A��A�H�����.)��)��)��������j�l�l���+���1���$�;���$�;������r ���