Server: appserver-7f0f8755-nginx-15961cad18524ec5a9db05f2a6a7e440
Current directory: /usr/lib/python3.11/multiprocessing/__pycache__
Software: nginx/1.27.5
Shell Command
Create a new file
Upload file
File: managers.cpython-311.pyc
� ��hC� � �t � g d �Z ddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl mZ ddlm Z ddlmZmZmZ ddlmZ dd lmZ dd lmZ ddlmZ ddlmZ d Ze � d� � n # e$ r dZY nw xY wd� Z ej ej e� � d� dD � � Zd� ZeD ]Z ej ee� � �[[ G d� de� � Z di fd�Z!d� Z" G d� de#� � Z$d� Z%d� Z& G d� de� � Z' G d� d e� � Z(e j) e j* fe j+ e j, fd!�Z- G d"� d#e� � Z. G d$� d%e/� � Z0 G d&� d'e� � Z1d(� Z2i fd)�Z3 dcd*�Z4 G d+� d,e� � Z5 G d-� d.e� � Z6ddd/�Z7 G d0� d1e1� � Z8 G d2� d3e1� � Z9 G d4� d5e9� � Z: G d6� d7e1� � Z; G d8� d9e1� � Z< G d:� d;e1� � Z= G d<� d=e1� � Z> e3d>d?� � Z? G d@� dAe?� � Z@ e3dBdC� � ZAdDdEieA_B e3dFdG� � ZC e3dHdI� � ZDdJdJdJdEdEdK�eD_B G dL� dHeD� � ZE G dM� dNe.� � ZFeF� dOejG � � eF� dPejG � � eF� dQejH e;� � eF� dRejI e9� � eF� dSejJ e9� � eF� dTejK e9� � eF� dUejL e9� � eF� dVejM e:� � eF� dWejN e<� � eF� dXejO eE� � eF� dYePe@� � eF� dZeQeA� � eF� d.e6e>� � eF� d[e7eC� � eF� d,e5e=� � eF� dEe8d�\� � eF� dJd�]� � er+ G d^� d_� � ZR G d`� dae'� � ZS G db� de.� � ZTdS dS )e)�BaseManager�SyncManager� BaseProxy�Token� N)�getpid)� format_exc� )� connection)� reduction�get_spawning_popen�ProcessError)�pool)�process)�util)�get_context)� shared_memoryT�SharedMemoryManagerFc �P � t j | j | � � � ffS �N)�array�typecode�tobytes)�as �//usr/lib/python3.11/multiprocessing/managers.py�reduce_arrayr / s � ��;���Q�Y�Y�[�[�1�1�1� c �X � g | ]'}t t i |� � � � � � ��(S � )�type�getattr��.0�names r �
r$ 3 s3 � � N� N� N�D�d�$�7�2�t�$�$�&�&�'�'� N� N� Nr )�items�keys�valuesc �0 � t t | � � ffS r )�list��objs r �rebuild_as_listr, 4 s � ��$�s�)�)���r c �. � e Zd ZdZdZd� Zd� Zd� Zd� ZdS )r z3 Type to uniquely identify a shared object ��typeid�address�idc �2 � |||c| _ | _ | _ d S r r. )�selfr/ r0 r1 s r �__init__zToken.__init__D s � �06���,���d�l�D�G�G�Gr c �* � | j | j | j fS r r. �r3 s r �__getstate__zToken.__getstate__G s � ���T�\�4�7�3�3r c �0 � |\ | _ | _ | _ d S r r. �r3 �states r �__setstate__zToken.__setstate__J s � �/4�,���d�l�D�G�G�Gr c �P � | j j �d| j �d| j �d| j �d�S )Nz(typeid=z , address=z, id=�))� __class__�__name__r/ r0 r1 r6 s r �__repr__zToken.__repr__M s4 � ���'�'�'�����d�l�l�l�D�G�G�G�M� Mr N) r? � __module__�__qualname__�__doc__� __slots__r4 r7 r; r@ r r r r r > si � � � � � �� � ,�I�E� E� E�4� 4� 4�5� 5� 5�M� M� M� M� Mr r r c � � | � ||||f� � | � � � \ }}|dk r|S t ||� � �)zL Send a message to manager using connection `c` and return response �#RETURN)�send�recv�convert_to_error)�cr1 � methodname�args�kwds�kind�results r �dispatchrP U sP � � �F�F�B� �D�$�'�(�(�(��6�6�8�8�L�D�&��y���� � �4�� (� (�(r c �8 � | dk r|S | dv rmt |t � � s1t d� || t |� � � � � � �| dk rt d|z � � S t |� � S t d� | � � � � S )N�#ERROR)� #TRACEBACK�#UNSERIALIZABLEz.Result {0!r} (kind '{1}') type is {2}, not strrT zUnserializable message: %s zUnrecognized message type {!r})� isinstance�str� TypeError�formatr �RemoteError� ValueError)rN rO s r rI rI _ s� � ��x���� � �2� 2� 2��&�#�&�&� 1��@�G�G��D�$�v�,�,�0� 0�1� 1� 1� �$�$�$��=��F�G�G�G��v�&�&�&��:�A�A�$�G�G�H�H�Hr c � � e Zd Zd� ZdS )rY c �B � dt | j d � � z dz S )NzM --------------------------------------------------------------------------- r zK---------------------------------------------------------------------------)rV rL r6 s r �__str__zRemoteError.__str__o s � �$�s�4�9�Q�<�'8�'8�8�6�A�Br N)r? rA rB r] r r r rY rY n s( � � � � � �C� C� C� C� Cr rY c � � g }t | � � D ]6}t | |� � }t |� � r|� |� � �7|S )z4 Return a list of names of methods of `obj` )�dirr �callable�append)r+ �tempr# �funcs r �all_methodsrd v sS � � �D��C��� � ���s�D�!�!���D�>�>� ��K�K�������Kr c �4 � d� t | � � D � � S )zP Return a list of names of methods of `obj` which do not start with '_' c �* � g | ]}|d dk �|��S )r �_r r! s r r$ z"public_methods.
.
� s! � �@�@�@�T��a��C���D���r )rd r* s r �public_methodsrh � s! � � A�@�[��-�-�@�@�@�@r c � � e Zd ZdZg d�Zd� Zd� Zd� Zd� Zd� Z d� Z d � Zd � Zd� Z ee ed�Zd � Zd� Zd� Zd� Zd� Zd� Zd� Zd� Zd� ZdS )�ServerzM Server class which runs in a process controlled by a manager object ) �shutdown�create�accept_connection�get_methods� debug_info�number_of_objects�dummy�incref�decrefc � � t |t � � s0t d� |t |� � � � � � �|| _ t j |� � | _ t | \ }} ||d�� � | _ | j j | _ ddi| _ i | _ i | _ t j � � | _ d S )Nz&Authkey {0!r} is type {1!s}, not bytes� )r0 �backlog�0�Nr )rU �bytesrW rX r �registryr �AuthenticationString�authkey�listener_client�listenerr0 � id_to_obj�id_to_refcount�id_to_local_proxy_obj� threading�Lock�mutex)r3 rz r0 r| � serializer�Listener�Clients r r4 zServer.__init__� s� � ��'�5�)�)� -��8�?�?��T�'�]�]�,� ,�-� -� -� !�� ��3�G�<�<���*�:�6���&� !���"�=�=�=�� ��}�,����z�*��� ���%'��"��^�%�%�� � � r c �^ � t j � � | _ | t j � � _ t j | j �� � }d|_ |� � � | j � � � s3| j � d� � | j � � � �3n# t t f$ r Y nw xY wt j t j k r@t# j d� � t j t _ t j t _ t j d� � dS # t j t j k r@t# j d� � t j t _ t j t _ t j d� � w xY w)z( Run the server forever )�targetTr zresetting stdout, stderrr N)r� �Event� stop_eventr �current_process�_manager_server�Thread�accepter�daemon�start�is_set�wait�KeyboardInterrupt� SystemExit�sys�stdout� __stdout__r �debug� __stderr__�stderr�exit)r3 r� s r � serve_foreverzServer.serve_forever� sP � � $�/�+�+���48���!�!�1� � �'�t�}�=�=�=�H�"�H�O��N�N���� ��/�0�0�2�2� ,��O�(�(��+�+�+� �/�0�0�2�2� ,���%�z�2� � � ��� ���� �z�S�^�+�+�� �5�6�6�6� �^�� � �^�� ��H�Q�K�K�K�K�K�� �z�S�^�+�+�� �5�6�6�6� �^�� � �^�� ��H�Q�K�K�K�K���s1 �5D<