OwlCyberSecurity - MANAGER
Edit File: resource_sharer.cpython-313.opt-2.pyc
� ���g � � � 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 rSrS rS rSrg)r � 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 sS S S 5 $ ! , ( d f g = fr )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__r r& �__static_attributes__� r r r r s � � G� /r �DupFdc � � \ rS rSrS rS rSrg)r0 �- 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 )r6 s �r r � DupFd.__init__.<locals>.close3 s �� ����� r )r9 r r r r )r �fdr r r6 s @r r �DupFd.__init__/ s, �� ��V�V�B�Z�F� 9� !�'�0�0��=�D�Hr c � � [ R U R 5 n[ R " U5 sS S S 5 $ ! , ( d f g = fr )r r" r r � recv_handle)r r s r r& � DupFd.detach7 s0 � �!�0�0����:�d� �,�,�T�2� ;�:�:�s �A � Ar( Nr) r/ r r r0 r0 - s � � >� 3r c �L � \ rS rSrS rS r\S 5 rS S jrS r S r S r S r g) �_ResourceSharer�= 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_forkrA � _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 4sS S S 5 $ ! , ( d f g = f)Nr )rH rJ �_startrD rE )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$ )Nr ��Client��authkey)� connectionrT r �current_processrV r r9 �getpid)�identrT �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 S 5 UR 5 U R R U5 U R R 5 ( a [ R " S5 U R R 5 S U l S U l S U l U R R! 5 H u nu pVU" 5 M U R R# 5 S S S 5 g ! , ( d f g = f)Nr rS rU z._ResourceSharer thread did not stop when asked)rW rT rH rJ r rX rV r r rK �join�is_aliver � sub_warningrI rE �items�clear)r �timeoutrT 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 ) rE rc rd rH �_at_fork_reinitrI r rJ rK )r r\ r r s r rM �_ResourceSharer._afterforko st � �"&�+�+�"3�"3�"5� �C� �$� �G� #6� � � ���� � � �"�"�$� �>�>� %� �N�N� � � "� ��� �� ��� r c �: � SSK Jn [ R " S5 U" [ R " 5 R SS9U l U R R U l [ R " U R S9nSUl UR 5 X l g )Nr )�Listenerz0starting listener and thread for sending handles� )rV �backlog)�targetT)rW rk r �debugr rX rV rI r[ rJ rF �Thread�_serve�daemon�startrK )r rk �ts r rP �_ResourceSharer._startz sj � �(� � � �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�signalrw � SIG_BLOCK� valid_signalsrI �accept�recvrE �popr � is_exiting�sys� excepthook�exc_info)r r �msgr\ �destination_pidr r s r rq �_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%)rJ rE rD rI rH rK r ) r* r+ r, r- r r � staticmethodr" r rM rP rq r. r/ r r rA rA = s5 � �C�.� �� ��$�* � �4r rA )r9 ry r$ r� rF � r �contextr r �__all__�platform�objectr r0 rA r r r/ r r �<module>r� s� �� � � � � � � � � �(�� �<�<�7�� � �}� �G� /�F� /� ��y��G� 3�� 3� Y4�f� Y4�x #�$� �� � �r