← Back
Editing: resource_sharer.cpython-313.pyc
� :��i � � � S SK r S SKrS SKrS SKrS SKrSSKJr SSKJr SSKJ r S/r \R S:X a \ S/- r " S S\ 5 r O\ S /- r " S S \ 5 r " S S \ 5 r\" 5 r\R" rg)� N� )�process)� reduction)�util�stop�win32� DupSocketc �$ � \ rS rSrSrS rS rSrg)r � z Picklable wrapper for a socket.c �| ^� UR 5 mU4S jn[ R UTR 5 U l g )Nc �J >� TR U5 nU R U5 g �N)�share� send_bytes)�conn�pidr �new_socks ��F/opt/alt/python313/lib64/python3.13/multiprocessing/resource_sharer.py�send� DupSocket.__init__.<locals>.send s �� � ���s�+������&� )�dup�_resource_sharer�register�close�_id)�self�sockr r s @r �__init__�DupSocket.__init__ s- �� ��x�x�z�H� '� (�0�0��x�~�~�F�D�Hr c �� � [ R U R 5 nUR 5 n[ R " U5 sSSS5 $ ! , ( d f g= f)z1Get the socket. This should only be called once.N)r �get_connectionr � recv_bytes�socket� fromshare)r r r s r �detach�DupSocket.detach$ s< � �!�0�0����:�d� ���)�� �'�'��.� ;�:�:�s �&A� A �r N��__name__� __module__� __qualname__�__firstlineno__�__doc__r r& �__static_attributes__� r r r r s � �-� G� /r �DupFdc �$ � \ rS rSrSrS rS rSrg)r1 �- z-Wrapper for fd which can be used at any time.c �~ ^� [ R " U5 mU4S jnU4S jn[ R X#5 U l g )Nc �6 >� [ R " U TU5 g r )r � send_handle)r r �new_fds �r r � DupFd.__init__.<locals>.send1 s �� ��%�%�d�F�C�8r c �2 >� [ R " T 5 g r )�osr )r7 s �r r � DupFd.__init__.<locals>.close3 s �� ����� r )r: r r r r )r �fdr r r7 s @r r �DupFd.__init__/ s, �� ��V�V�B�Z�F� 9� !�'�0�0��=�D�Hr c � � [ R U R 5 n[ R " U5 sSSS5 $ ! , ( d f g= f)z-Get the fd. This should only be called once.N)r r" r r � recv_handle)r r s r r& � DupFd.detach7 s0 � �!�0�0����:�d� �,�,�T�2� ;�:�:�s �A � Ar( Nr) r0 r r r1 r1 - s � �;� >� 3r c �P � \ rS rSrSrS rS r\S 5 rS S jr S r S r S r S r g) �_ResourceSharer�= z.Manager for resources using background thread.c �� � SU l 0 U l [ R " 5 U l S U l S U l S U l [ R " U [ R 5 g )Nr ) �_key�_cache� threading�Lock�_lock� _listener�_address�_threadr �register_after_forkrB � _afterfork)r s r r �_ResourceSharer.__init__? sI � ��� ��� � �^�^�%�� � ��� �� ��� � � � ���'A�'A�Br c � � U R U R c U R 5 U =R S- sl X4U R U R ' U R U R 4sSSS5 $ ! , ( d f g= f)z+Register resource, returning an identifier.Nr )rI rK �_startrE rF )r r r s r r �_ResourceSharer.registerH sW � � �Z�Z��}�}�$�� � � � �I�I��N�I�&*�]�D�K�K�� � � "��M�M�4�9�9�-� �Z�Z�s �A$A;�; B c � � SSK Jn U u p#U" U[ R " 5 R S9nUR U[ R " 5 45 U$ )z<Return connection from which to receive identified resource.r ��Client��authkey)� connectionrU r �current_processrW r r: �getpid)�identrU �address�key�cs r r" � _ResourceSharer.get_connectionQ sE � � '� � �� �7�G�$;�$;�$=�$E�$E� F�� ����R�Y�Y�[�!�"��r Nc � � SSK Jn U R U R Gb U" U R [ R " 5 R S9nUR S5 UR 5 U R R U5 U R R 5 ( a [ R " S5 U R R 5 SU l SU l SU l U R R! 5 H u nu pVU" 5 M U R R# 5 SSS5 g! , ( d f g= f)z:Stop the background thread and clear registered resources.r rT NrV z._ResourceSharer thread did not stop when asked)rX rU rI rK r rY rW r r rL �join�is_aliver � sub_warningrJ rF �items�clear)r �timeoutrU r^ r] r r s r r �_ResourceSharer.stopZ s� � �&� �Z�Z��}�}�(��4�=�=�#*�#:�#:�#<�#D�#D�F�����t� ���� �� � �!�!�'�*��<�<�(�(�*�*��$�$� &;� <����$�$�&� #�� � $�� �!%���*.�+�+�*;�*;�*=�&�C� �$��G� +>�� � �!�!�#�! �Z�Z�s �D$E � Ec �> � U R R 5 H u nu p#U" 5 M U R R 5 U R R 5 U R b U R R 5 S U l S U l S U l g r ) rF rd re rI �_at_fork_reinitrJ r rK rL )r r] r r s r rN �_ResourceSharer._afterforko st � �"&�+�+�"3�"3�"5� �C� �$� �G� #6� � � ���� � � �"�"�$� �>�>� %� �N�N� � � "� ��� �� ��� r c �b � SSK Jn U R b S5 e[ R " S5 U" [ R " 5 R SS9U l U R R U l [ R " U R S9nSUl UR 5 X l g ) Nr )�ListenerzAlready have Listenerz0starting listener and thread for sending handles� )rW �backlog)�targetT)rX rl rJ r �debugr rY rW r\ rK rG �Thread�_serve�daemon�startrL )r rl �ts r rQ �_ResourceSharer._startz s� � �(��~�~�%�>�'>�>�%� � � �E�F�!�'�*A�*A�*C�*K�*K�UX�Y��� ���.�.�� � � � �D�K�K� 0����� ��� �� r c �P � [ [ S5 ( a8 [ R " [ R [ R " 5 5 U R R 5 nUR 5 nUc S S S 5 g Uu p4U R R U5 u pV U" X5 U" 5 S S S 5 Mu ! U" 5 f = f! , ( d f N = f! [ R " 5 ( d& [ R " [ R " 5 6 Nc= f)N�pthread_sigmask)�hasattr�signalrx � SIG_BLOCK� valid_signalsrJ �accept�recvrF �popr � is_exiting�sys� excepthook�exc_info)r r �msgr] �destination_pidr r s r rr �_ResourceSharer._serve� s� � � �6�,� -� -� � "� "�6�#3�#3�V�5I�5I�5K� L�� 4��^�^�*�*�,�� �)�)�+�C��{� � -�,� ,/�(�C�"&�+�+�/�/�#�"6�K�D� � �T�3� �� -� �� ��� -�,�� 4����(�(��N�N�C�L�L�N�3�sO �C! �*C�?C! �!C�*C�2C�:C! � C � C� C �C! � C! �!AD%)rK rF rE rJ rI rL r )r* r+ r, r- r. r r � staticmethodr" r rN rQ rr r/ r0 r r rB rB = s8 � �8�C�.� �� ��$�* � �4r rB )r: rz r$ r� rG � r �contextr r �__all__�platform�objectr r1 rB r r r0 r r �<module>r� s� �� � � � � � � � � �(�� �<�<�7�� � �}� �G� /�F� /� ��y��G� 3�� 3� Y4�f� Y4�x #�$� �� � �r
Save File
Cancel