Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/billiard/__pycache__/managers.cpython-39.pyc
Ðазад
a i�h�� � @ s� d dl Z d dlZd dlZd dlmZ ddlmZ ddlmZ ddlmZ ddlm Z ddlm Z dd lm Z dd lm Z d d l mZ d d lmZ g d �Ze jd dkZer�dd� Zndd� Ze �eje� dd� dD �Zed eu�rdd� ZeD ]Ze �ee� q�G dd� d�Zdi fdd�Zd d � Z G d d � d e �Z d d!� Z d"d#� Z G d$d%� d%�Z!G d&d'� d'�Z"ej#ej$fej%ej&fd(�Z'G d)d*� d*�Z(G d+d,� d,e)�Z*G d-d.� d.�Z+d/d0� Z,i fd1d2�Z-dkd4d5�Z.G d6d7� d7�Z/G d8d9� d9�Z0dld:d;�Z1G d<d=� d=e+�Z2G d>d?� d?e+�Z3G d@dA� dAe3�Z4G dBdC� dCe+�Z5G dDdE� dEe+�Z6G dFdG� dGe+�Z7G dHdI� dIe+�Z8dJZ9e�spe9dK7 Z9e-dLe9�Z:G dMdN� dNe:�Z;e-dOdP�Z<dQZ=e�s�e=dR7 Z=e-dSe=�Z>e-dTdU�Z?dVdVdVdWdWdX�e?_@G dYdT� dTe?�ZAG dZd[� d[e(�ZBeB�d\e� eB�d]e� eB�d^ejCe5� eB�d_ejDe3� eB�d`ejEe3� eB�daejFe3� eB�dbejGe3� eB�dcejHe4� eIedd��r�eB�ddejJe6� eB�deejKeA� eB�dfee;� eB�dgeLe<� eB�d9e0e8� eB�d;e1e>� eB�d7e/e7� eBjdWe2dhdi� eBjdVdhdj� dS )m� N)� format_exc� )� connection)�context)�pool)�process)� reduction)�util)� get_context)�Queue)� monotonic)� BaseManager� SyncManager� BaseProxy�Token� c C s t j | j| �� ffS �N)�array�typecode�tobytes��a� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/billiard/managers.py� reduce_array* s r c C s t j | j| �� ffS r )r r Ztostringr r r r r - s c C s g | ]}t ti |�� ��qS r )�type�getattr��.0�namer r r � <listcomp>1 s �r )�items�keys�valuesc C s t t | �ffS r )�list��objr r r �rebuild_as_list5 s r' c @ s4 e Zd ZdZdZdd� Zdd� Zdd� Zd d � Zd S ) r z3 Type to uniquely identify a shared object ��typeid�address�idc C s ||| | _ | _| _d S r r( )�selfr) r* r+ r r r �__init__E s zToken.__init__c C s | j | j| jfS r r( �r, r r r � __getstate__H s zToken.__getstate__c C s |\| _ | _| _d S r r( )r, �stater r r � __setstate__K s zToken.__setstate__c C s d| j j| j| j| jf S )Nz %s(typeid=%r, address=%r, id=%r))� __class__�__name__r) r* r+ r. r r r �__repr__N s �zToken.__repr__N) r3 � __module__� __qualname__�__doc__� __slots__r- r/ r1 r4 r r r r r ? s r r c C s8 | � ||||f� | �� \}}|dkr*|S t||��dS )zL Send a message to manager using connection `c` and return response �#RETURNN)�send�recv�convert_to_error)�cr+ � methodname�args�kwds�kind�resultr r r �dispatchW s rC c C s\ | dkr |S | dkr,t |�tu s$J �t|�S | dkrPt |�tu sDJ �td| �S td�S d S )N�#ERROR� #TRACEBACK�#UNSERIALIZABLEzUnserializable message: %s zUnrecognized message type)r �str� RemoteError� ValueError)rA rB r r r r< b s r< c @ s e Zd Zdd� ZdS )rH c C s dt | jd � d S )NzM --------------------------------------------------------------------------- r zK---------------------------------------------------------------------------)rG r? r. r r r �__str__q s zRemoteError.__str__N)r3 r5 r6 rJ r r r r rH o s rH c C s2 g }t | �D ] }t| |�}t|�r |�|� q |S )z4 Return a list of names of methods of `obj` )�dirr �callable�append)r& �tempr �funcr r r � all_methodsy s rP c C s dd� t | �D �S )zP Return a list of names of methods of `obj` which do not start with '_' c S s g | ]}|d dkr|�qS )r �_r r r r r r � � z"public_methods.<locals>.<listcomp>)rP r% r r r �public_methods� s rS c @ s� e Zd ZdZg d�Zdd� Zdd� Zdd� Zd d � Zd d � Z d d� Z dd� Z dd� Z e e e d�Z dd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&S )'�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 C sb t |t�sJ �|| _t�|�| _t| \}}||dd�| _| jj| _ddi| _ i | _ t � � | _ d S )N� )r* �backlog�0�Nr )� isinstance�bytes�registryr �AuthenticationString�authkey�listener_client�listenerr* � id_to_obj�id_to_refcount� threading�RLock�mutex)r, rd r* rf � serializer�Listener�Clientr r r r- � s zServer.__init__c C s� t �� | _| t�� _z�t j| jd�}d|_|� � z | j� � sL| j� d� q4W n t t fyd Y n0 W tjtjkr�t�d� tjt_tjt_t�d� n2tjtjkr�t�d� tjt_tjt_t�d� 0 dS )z( Run the server forever )�targetTr zresetting stdout, stderrr N)rk �Event� stop_eventr �current_process�_manager_server�Thread�accepter�daemon�start�is_set�wait�KeyboardInterrupt� SystemExit�sys�stdout� __stdout__r �debug� __stderr__�stderr�exit)r, rw r r r � serve_forever� s* � zServer.serve_foreverc C sL z| j �� }W n ty$ Y q Y n0 tj| j|fd�}d|_|�� q d S )N�rq r? T)rh �accept�OSErrorrk rv �handle_requestrx ry )r, r= �tr r r rw � s zServer.accepterc C sN d } }}zTt �|| j� t �|| j� |�� }|\}}}}|| jv sTJ d| ��t| |�}W n ty| dt� f} Y nB0 z||g|�R i |��}W n ty� dt� f} Y n 0 d|f} z|� | � W nt t�y@ } zZz|� dt� f� W n t�y Y n0 t � d| � t � d|� t � d| � W Y d} ~ n d} ~ 0 0 |� � dS )z) Handle a new connection Nz%r unrecognizedrE r9 zFailure to send message: %rz ... request was %r� ... exception was %r) r Zdeliver_challengerf Zanswer_challenger; �publicr � Exceptionr r: r �info�close) r, r= �funcnamerB �request�ignorer? r@ rO �msg�excr r r r� � s4 "zServer.handle_requestc C sx t �dt�� j� |j}|j}| j}| j� � �stz�d }}|� }|\}}} } || \}} } || vrxt d|t |�| f ��t ||�} z| | i | ��}W n, t y� } zd|f}W Y d}~nVd}~0 0 | o�| �|d�}|�r| �|||�\}}t|| j|�}d||ff}nd|f}W n� t �y� |du �r6dt� f}nRz2| j| }|| |||g| �R i | ��}d|f}W n t �y� dt� f}Y n0 Y nL t�y� t �dt�� j� t�d � Y n t �y� dt� f}Y n0 z6z ||� W n$ t �y |d t|�f� Y n0 W q$ t �yp } zHt �d t�� j� t �d |� t �d |� |�� t�d� W Y d}~q$d}~0 0 q$dS )zQ Handle requests from the proxies in a particular process/thread z$starting server thread to service %rNz+method %r of %r object is not in exposed=%rrD �#PROXYr9 rE z$got EOF -- exiting thread serving %rr rF z exception in thread serving %rz ... message was %rr� r )r r� rk �current_threadr r; r: ri rs rz �AttributeErrorr r r� �getrV r r* r �fallback_mapping�EOFErrorr~ r� �reprr� r� )r, �connr; r: ri r> r& r� �identr? r@ �exposedZ gettypeid�function�resr� r� r) ZridentZrexposed�tokenZ fallback_funcrB r r r � serve_client� s� � �� ��� � � zServer.serve_clientc C s |S r r �r, r� r� r& r r r �fallback_getvalue1 s zServer.fallback_getvaluec C s t |�S r �rG r� r r r � fallback_str4 s zServer.fallback_strc C s t |�S r )r� r� r r r � fallback_repr7 s zServer.fallback_repr)rJ r4 � #GETVALUEc C s d S r r �r, r= r r r r[ @ s z Server.dummyc C s� | j �v g }t| j�� �}|�� |D ]<}|dkr&|�d|| j| t| j| d �dd� f � q&d�|�W d � S 1 s�0 Y dS )zO Return some info --- useful to spot problems with refcounting r` z %s: refcount=%s %sr N�K � ) rm r$ ri r" �sortrM rj rG �join)r, r= rB r" r� r r r rY C s ��zServer.debug_infoc C s t | j�d S )z* Number of shared objects r )�lenri r� r r r rZ R s zServer.number_of_objectsc C sV zDzt �d� |�d� W n ddl}|�� Y n0 W | j�� n | j�� 0 dS )z' Shutdown this process z!Manager received shutdown message�r9 Nr N)r r� r: � traceback� print_excrs �set)r, r= r� r r r rU X s zServer.shutdownc O s | j �� | j| \}}}}|du r@t|�dkr2|r6J �|d } n||i |��} |du r^t| �}|dur�t|�tu svJ �t|�t|� }dt| � } t� d|| � | t |�|f| j | < | | j vr�d| j | < | � || � | t|�fW d � S 1 � s�0 Y dS )z> Create a new shared object and return its id Nr r z%xz&%r callable returned object with id %r)rm rd r� rS r �dictr$ r+ r r� r� ri rj r\ �tuple) r, r= r) r? r@ rL r� �method_to_typeid� proxytyper& r� r r r rV e s& � z Server.createc C s t | j|j d �S )zL Return the methods of the shared object indicated by token r )r� ri r+ )r, r= r� r r r rX � s zServer.get_methodsc C s" |t �� _|�d� | �|� dS )z= Spawn a new thread to serve this connection r� N)rk r� r r: r� )r, r= r r r r rW � s zServer.accept_connectionc C s< | j �" | j| d7 < W d � n1 s.0 Y d S )Nr )rm rj �r, r= r� r r r r\ � s z Server.increfc C sx | j �^ | j| dksJ �| j| d8 < | j| dkrV| j|= | j|= t�d|� W d � n1 sj0 Y d S )Nr r zdisposing of obj with id %r)rm rj ri r r� r� r r r r] � s z Server.decrefN)r3 r5 r6 r7 r� r- r� rw r� r� r� r� r� r� r[ rY rZ rU rV rX rW r\ r] r r r r rT � s. "J� #rT c @ s e Zd ZdgZdZdZdZdS )�State�valuer r � N)r3 r5 r6 r8 �INITIAL�STARTED�SHUTDOWNr r r r r� � s r� )�pickle� xmlrpclibc @ s� e Zd ZdZi ZeZd$dd�Zdd� Zdd � Z d d � Z d%d d�Z e d&dd��Z dd� Zd'dd�Zdd� Zdd� Zdd� Zdd � Zed d � �Zed d � �Ze d(d"d#��ZdS ))r z! Base class for managers Nr� c C s\ |d u rt �� j}|| _t �|�| _t� | _tj| j_ || _ t | \| _ | _ |pTt� | _d S r )r rt rf �_addressre �_authkeyr� �_stater� r� � _serializerrg Z _Listener�_Clientr �_ctx)r, r* rf rn �ctxr r r r- � s zBaseManager.__init__c C s t | �j| j| j| jffS r )r Z from_addressr� r� r� r. r r r � __reduce__� s �zBaseManager.__reduce__c C s( | j jtjksJ �t| j| j| j| j�S )zX Return server object with serve_forever() method and address attribute ) r� r� r� r� rT � _registryr� r� r� r. r r r � get_server� s �zBaseManager.get_serverc C s8 t | j \}}|| j| jd�}t|dd� tj| j_dS )z> Connect manager object to the server process �rf Nr[ ) rg r� r� r� rC r� r� r� r� )r, ro rp r� r r r �connect� s zBaseManager.connectr c C s� | j jtjksJ �|dur*t|�s*td��tjdd�\}}| jj t | �j | j | j | j| j|||fd�| _d�dd� | jjD ��}t | �jd | | j_| j�� |�� |�� | _ |�� tj| j _tj| t | �j| j| j | j| j | j fd d �| _ dS ) z@ Spawn a server process for this manager object Nz initializer must be a callableF)Zduplexr� �:c s s | ]}t |�V qd S r r� )r �ir r r � <genexpr>� rR z$BaseManager.start.<locals>.<genexpr>�-r �r? Z exitpriority) r� r� r� r� rL � TypeErrorr ZPiper� �Processr � _run_serverr� r� r� r� �_processr� Z _identityr3 r ry r� r; r� r �Finalize�_finalize_managerr� rU )r, � initializer�initargs�reader�writerr� r r r ry � s0 �� ��zBaseManager.startc C sN |dur||� | � ||||�}|�|j� |�� t�d|j� |�� dS )z@ Create a server, report its address and run it Nzmanager serving at %r)�_Serverr: r* r� r r� r� ) �clsrd r* rf rn r� r� r� �serverr r r r� s zBaseManager._run_serverc O sl | j jtjksJ d��| j| j| jd�}z&t|dd|f| |�\}}W |�� n |�� 0 t || j|�|fS )zP Create a new shared object; return the token and exposed tuple zserver not yet startedr� NrV ) r� r� r� r� r� r� r� rC r� r )r, r) r? r@ r� r+ r� r r r �_create s � zBaseManager._createc C s* | j dur&| j �|� | j �� s&d| _ dS )zC Join the manager process (if it has been spawned) N)r� r� �is_alive�r, �timeoutr r r r� ( s zBaseManager.joinc C s8 | j | j| jd�}zt|dd�W |�� S |�� 0 dS )zS Return some info about the servers shared objects and connections r� NrY �r� r� r� rC r� �r, r� r r r � _debug_info1 s �zBaseManager._debug_infoc C s8 | j | j| jd�}zt|dd�W |�� S |�� 0 dS )z5 Return the number of shared objects r� NrZ r� r� r r r �_number_of_objects; s �z BaseManager._number_of_objectsc C s, | j jtjkr| �� | j jtjks(J �| S r )r� r� r� r� ry r� r. r r r � __enter__E s zBaseManager.__enter__c C s | � � d S r )rU �r, �exc_type�exc_val�exc_tbr r r �__exit__K s zBaseManager.__exit__c C s� | � � r�t�d� z4|||d�}zt|dd� W |�� n |�� 0 W n tyX Y n0 | jdd� | � � r�t�d� t| d�r�t�d � | �� | jd d� | � � r�t�d � t j |_ z t j |= W n ty� Y n0 dS ) zQ Shutdown the manager process; will be registered as a finalizer z#sending shutdown message to managerr� NrU g �?)r� zmanager still alive� terminatez'trying to `terminate()` manager processg�������?z#manager still alive after terminate)r� r r� rC r� r� r� �hasattrr� r� r� r� r �_address_to_local�KeyError)r r* rf r0 r� r� r r r r� N s. z BaseManager._finalize_managerc C s | j S r )r� r. r r r �<lambda>n rR zBaseManager.<lambda>Tc s� d| j vr| j�� | _� du r"t� |p0t� dd�}|p@t� dd�}|r�|�� D ]8\}}t|�tu snJ d| ��t|�tu sNJ d| ��qN|||� f| j�< |r�� �fdd�} �| _t | �| � dS )z9 Register a typeid with the manager type r� N� _exposed_�_method_to_typeid_z%r is not a stringc sf t �d�� | j�g|�R i |��\}}� || j| | j|d�}| j|j| jd�}t|d d|jf� |S )Nz)requesting creation of a shared %r object��managerrf r� r� r] ) r r� r� r� r� r� r* rC r+ )r, r? r@ r� �exp�proxyr� �r� r) r r rN � s �z"BaseManager.register.<locals>.temp) �__dict__r� �copy� AutoProxyr r! r rG r3 �setattr) r� r) rL r� r� r� � create_method�keyr� rN r r� r �registerp s$ �� zBaseManager.register)NNr� N)Nr )Nr )N)NNNNT)r3 r5 r6 r7 r� rT r� r- r� r� r� ry � classmethodr� r� r� r� r� r� r� � staticmethodr� �propertyr* r� r r r r r � s4 � $ � �r c @ s e Zd Zdd� Zdd� ZdS )�ProcessLocalSetc C s t �| dd� � d S )Nc S s | � � S r )�clearr% r r r r� � rR z*ProcessLocalSet.__init__.<locals>.<lambda>)r �register_after_forkr. r r r r- � s zProcessLocalSet.__init__c C s t | �dfS ra )r r. r r r r� � s zProcessLocalSet.__reduce__N)r3 r5 r6 r- r� r r r r r � s r c @ s� e Zd ZdZi Ze�� Zddd�Zdd� Z di fd d �Z d d � Z d d� Z e dd� �Zdd� Zdd� Zdd� Zdd� Zdd� ZdS ) r z. A base for proxies of shared objects NTc C s� t j�B t j�|jd �}|d u r:t�� t� f}|t j|j< W d � n1 sN0 Y |d | _|d | _ || _ | j j | _ || _ || _t| d | _|d ur�t�|�| _n"| j d ur�| j j| _n t�� j| _|r�| �� t�| t j� d S )Nr r )r �_mutexr� r� r* r ZForkAwareLocalr �_tls�_idset�_tokenr+ �_id�_managerr� rg r� r re r� rt rf �_increfr � _after_fork)r, r� rn r� rf r� r\ Z tls_idsetr r r r- � s( * zBaseProxy.__init__c C sd t �d� t�� j}t�� jdkr4|dt�� j 7 }| j| jj | j d�}t |d d|f� || j _ d S )Nz making connection to manager� MainThread�|r� rW )r r� r rt r rk r� r� r r* r� rC r r )r, r r� r r r �_connect� s zBaseProxy._connectr c C s� z | j j}W n4 ty@ t�dt�� j� | �� | j j}Y n0 |� | j |||f� |� � \}}|dkrn|S |dkr�|\}}| j j |j d } | jj|_| || j| j | j|d�} | j|j| jd�}t|dd|jf� | S t||��dS ) zW Try to call a method of the referrent and return a copy of the result z#thread %r does not own a connectionr9 r� ���r� r� Nr] )r r r� r r� rk r� r r r: r r; r r� r) r r* r� r� r� rC r+ r< ) r, r> r? r@ r� rA rB r� r� r� r� r r r � _callmethod� s0 � �zBaseProxy._callmethodc C s | � d�S )z9 Get a copy of the value of the referent r� �r r. r r r � _getvalue� s zBaseProxy._getvaluec C s� | j | jj| jd�}t|d d| jf� t�d| jj� | j � | j� | j oP| j j }tj | tj| j| j|| j| j | j fdd�| _d S )Nr� r\ z INCREF %r� r� )r� r r* r� rC r r r� r+ r �addr r� r� r �_decrefr �_close)r, r� r0 r r r r s ��zBaseProxy._increfc C s� |� | j� |d u s |jtjkr�z2t�d| j� || j|d�}t|d d| jf� W q� t y� } zt�d|� W Y d }~q�d }~0 0 nt�d| j� |s�t |d�r�t�dt � � j � |j�� |`d S )Nz DECREF %rr� r] z... decref failed %sz%DECREF %r -- manager already shutdownr z-thread %r has no more proxies so closing conn)�discardr+ r� r� r� r r� r* rC r� r� rk r� r r r� )r� rf r0 �tlsZidsetr� r� r� r r r r s $� zBaseProxy._decrefc C sH d | _ z | �� W n0 tyB } zt�d|� W Y d }~n d }~0 0 d S )Nzincref failed: %s)r r r� r r� )r, r� r r r r , s zBaseProxy._after_forkc C s` i }t �� d ur| j|d< t| dd�rD| j|d< tt| j| j|ffS tt | �| j| j|ffS d S )Nrf �_isautoFr� ) r Zget_spawning_popenr� r r� � RebuildProxyr� r r� r �r, r@ r r r r� 4 s ��zBaseProxy.__reduce__c C s | � � S r )r )r, �memor r r � __deepcopy__A s zBaseProxy.__deepcopy__c C s dt | �j| jjt| �f S )Nz <%s object, typeid %r at %#x>)r r3 r r) r+ r. r r r r4 D s �zBaseProxy.__repr__c C s8 z | � d�W S ty2 t| �dd� d Y S 0 dS )zV Return representation of the referent (or a fall-back if that fails) r4 Nr z; '__str__()' failed>)r r� r� r. r r r rJ H s zBaseProxy.__str__)NNNT)r3 r5 r6 r7 r� r ZForkAwareThreadLockr r- r r r r r r r r� r r4 rJ r r r r r � s" � # r c C sh t t�� dd�}|r0|j|jkr0|j|j d S |�dd�oLt t�� dd� }| ||fd|i|��S dS )z� Function used for unpickling proxy objects. If possible the shared object is returned, or otherwise a proxy for it. ru Nr r\ TZ _inheritingF)r r rt r* ri r+ �pop)rO r� rn r@ r� r\ r r r r V s �r c C sn t |�}z|| |f W S ty( Y n0 i }|D ]}td||f |� q2t| tf|�}||_||| |f< |S )zC Return an proxy type whose methods are given by `exposed` zLdef %s(self, *args, **kwds): return self._callmethod(%r, args, kwds))r� r� �execr r r� )r r� �_cacheZdic�meth� ProxyTyper r r � MakeProxyTypel s �� r$ Tc C s� t | d }|du rJ|| j|d�}z t|dd| f�}W |�� n |�� 0 |du r`|dur`|j}|du rrt�� j}td| j |�}|| ||||d�} d| _ | S )z* Return an auto-proxy for `token` r Nr� rX z AutoProxy[%s])r� rf r\ T) rg r* rC r� r� r rt rf r$ r) r ) r� rn r� rf r� r\ r� r� r# r� r r r r� � s �r� c @ s e Zd Zdd� Zdd� ZdS )� Namespacec K s | j �|� d S r )r� �updater r r r r- � s zNamespace.__init__c C sZ t | j�� �}g }|D ]$\}}|�d�s|�d||f � q|�� d| jjd�|�f S )NrQ z%s=%rz%s(%s)z, ) r$ r� r! � startswithrM r� r2 r3 r� )r, Z_itemsrN r r� r r r r4 � s zNamespace.__repr__N)r3 r5 r6 r- r4 r r r r r% � s r% c @ s8 e Zd Zd dd�Zdd� Zdd� Zdd � Zeee�Zd S ) �ValueTc C s || _ || _d S r )� _typecode�_value)r, r r� �lockr r r r- � s zValue.__init__c C s | j S r �r* r. r r r r� � s z Value.getc C s || _ d S r r, �r, r� r r r r� � s z Value.setc C s dt | �j| j| jf S )Nz %s(%r, %r))r r3 r) r* r. r r r r4 � s �zValue.__repr__N)T) r3 r5 r6 r- r� r� r4 r r� r r r r r( � s r( c C s t � | |�S r )r )r �sequencer+ r r r �Array� s r/ c @ sT e Zd Zejd dkr dZn dZdd� Zdd� Zd d � Z d d � Z d d� Z dd� Z dS )� IteratorProxyr r )�__next__r: �throwr� )r1 �nextr: r2 r� c G s | � d|�S )Nr3 r �r, r? r r r r3 � s zIteratorProxy.nextc C s | S r r r. r r r �__iter__� s zIteratorProxy.__iter__c G s | � d|�S )Nr1 r r4 r r r r1 � s zIteratorProxy.__next__c G s | � d|�S )Nr: r r4 r r r r: � s zIteratorProxy.sendc G s | � d|�S )Nr2 r r4 r r r r2 � s zIteratorProxy.throwc G s | � d|�S )Nr� r r4 r r r r� � s zIteratorProxy.closeN) r3 r5 r6 r~ � version_infoZ_exposedr� r3 r5 r1 r: r2 r� r r r r r0 � s r0 c @ s2 e Zd ZdZd dd�Zdd� Zdd � Zd d � ZdS ) � AcquirerProxy)�acquire�releaseTNc C s" |d u r|fn||f}| � d|�S �Nr8 r )r, �blockingr� r? r r r r8 � s zAcquirerProxy.acquirec C s | � d�S �Nr9 r r. r r r r9 � s zAcquirerProxy.releasec C s | � d�S r: r r. r r r r� � s zAcquirerProxy.__enter__c C s | � d�S r< r r� r r r r� � s zAcquirerProxy.__exit__)TN)r3 r5 r6 r� r8 r9 r� r� r r r r r7 � s r7 c @ s4 e Zd ZdZd dd�Zdd� Zdd� Zd d d �ZdS ) �ConditionProxy)r8 r9 r{ �notify� notify_allNc C s | � d|f�S �Nr{ r r� r r r r{ � s zConditionProxy.waitc C s | � d�S )Nr> r r. r r r r> � s zConditionProxy.notifyc C s | � d�S )Nr? r r. r r r r? � s zConditionProxy.notify_allc C s` |� }|r|S |d ur"t � | }nd }d }|s\|d urJ|t � }|dkrJq\| �|� |� }q*|S )Nr )r r{ )r, � predicater� rB �endtime�waittimer r r �wait_for� s zConditionProxy.wait_for)N)N)r3 r5 r6 r� r{ r> r? rD r r r r r= � s r= c @ s2 e Zd ZdZdd� Zdd� Zdd� Zd d d �ZdS ) � EventProxy)rz r� r r{ c C s | � d�S )Nrz r r. r r r rz s zEventProxy.is_setc C s | � d�S �Nr� r r. r r r r� s zEventProxy.setc C s | � d�S )Nr r r. r r r r s zEventProxy.clearNc C s | � d|f�S r@ r r� r r r r{ s zEventProxy.wait)N)r3 r5 r6 r� rz r� r r{ r r r r rE s rE c @ sN e Zd ZdZddd�Zdd� Zdd� Zed d � �Zed d � �Z ed d� �Z dS )� BarrierProxy)�__getattribute__r{ �abort�resetNc C s | � d|f�S r@ r r� r r r r{ % s zBarrierProxy.waitc C s | � d�S )NrI r r. r r r rI ( s zBarrierProxy.abortc C s | � d�S )NrJ r r. r r r rJ + s zBarrierProxy.resetc C s | � dd�S )NrH )�partiesr r. r r r rK . s zBarrierProxy.partiesc C s | � dd�S )NrH )� n_waitingr r. r r r rL 2 s zBarrierProxy.n_waitingc C s | � dd�S )NrH )�brokenr r. r r r rM 6 s zBarrierProxy.broken)N) r3 r5 r6 r� r{ rI rJ r rK rL rM r r r r rG " s rG c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �NamespaceProxy)rH � __setattr__� __delattr__c C s0 |d dkrt �| |�S t �| d�}|d|f�S )Nr rQ r rH )�objectrH �r, r� � callmethodr r r � __getattr__> s zNamespaceProxy.__getattr__c C s4 |d dkrt �| ||�S t �| d�}|d||f�S )Nr rQ r rO )rQ rO rH )r, r� r� rS r r r rO D s zNamespaceProxy.__setattr__c C s0 |d dkrt �| |�S t �| d�}|d|f�S )Nr rQ r rP )rQ rP rH rR r r r rP J s zNamespaceProxy.__delattr__N)r3 r5 r6 r� rT rO rP r r r r rN ; s rN c @ s* e Zd ZdZdd� Zdd� Zeee�ZdS )� ValueProxy)r� r� c C s | � d�S )Nr� r r. r r r r� T s zValueProxy.getc C s | � d|f�S rF r r- r r r r� W s zValueProxy.setN)r3 r5 r6 r� r� r� r r� r r r r rU Q s rU )�__add__� __contains__� __delitem__� __getitem__�__len__�__mul__� __reversed__�__rmul__� __setitem__rM �count�extend�index�insertr �remove�reverser� �__imul__)� __getslice__� __setslice__Z __delslice__� BaseListProxyc @ s e Zd Zdd� Zdd� ZdS )� ListProxyc C s | � d|f� | S )Nr` r r- r r r �__iadd__i s zListProxy.__iadd__c C s | � d|f� | S )Nre r r- r r r re m s zListProxy.__imul__N)r3 r5 r6 rj re r r r r ri g s ri � DictProxy)rW rX rY rZ r^ r r� r� Zhas_keyr! r" r �popitem� setdefaultr& r# )rZ rY r^ )rf rg � ArrayProxy� PoolProxy) �apply� apply_asyncr� �imap�imap_unorderedr� �map� map_async�starmap� starmap_asyncr� Z AsyncResult�Iterator)rq ru rw rr rs c @ s e Zd Zdd� Zdd� ZdS )ro c C s | S r r r. r r r r� � s zPoolProxy.__enter__c G s | � � d S r )r� )r, �exc_infor r r r� � s zPoolProxy.__exit__N)r3 r5 r6 r� r� r r r r ro � s c @ s e Zd ZdZdS )r a! Subclass of `BaseManager` which supports a number of shared object types. The types registered are those intended for the synchronization of threads, plus `dict`, `list` and `Namespace`. The `billiard.Manager()` function creates started instances of this class. N)r3 r5 r6 r7 r r r r r � s r r Z JoinableQueuerr �Lockrl � Semaphore�BoundedSemaphore� Condition�Barrier�Poolr$ r� F)r� r� )r� )NNNT)T)Mr~ rk r r� r � r r r r r r r �queuer �timer �__all__r6 �PY3r r� Z view_typesr$ r' Z view_typer rC r< r� rH rP rS rT r� ro rp Z XmlListenerZ XmlClientrg r r� r r r r$ r� r% r( r/ r0 r7 r= rE rG rN rU Z_ListProxy_Attributesrh ri rk Z_ArrayProxy_Attributesrn Z BasePoolProxyr� ro r rr rz rl r{ r| r} r� r~ r r� r r r r �<module> s� � � e + � � �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка