Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/auth/__pycache__/thread.cpython-39.pyc
Ðазад
a a�h� � @ s� d Z ddlZddlZddlmZmZ ddlZddlmZ ddl m Z m Z m Z m Z ddlZddlmZ G dd � d e�Zd d � ZeG d d � d e��Zd gZdS )z>ZAP Authenticator in a Python Thread. .. versionadded:: 14.1 � N)�Thread�Event)�jsonapi)�bytes�unicode�b�u� )� Authenticatorc s: e Zd ZdZd � fdd� Zdd� Zdd � Zd d � Z� ZS ) �AuthenticationThreadzmA Thread for running a zmq Authenticator This is run in the background by ThreadedAuthenticator �utf-8Nc sz t t| ��� |ptj�� | _|| _|p0t� d� | _ }t � | _ |pPt |||d�| _|�tj�| _d| j_| j�|� d S )Nzzmq.auth��encoding�logr )�superr �__init__�zmq�Context�instance�contextr �logging� getLoggerr r �startedr � authenticator�socket�PAIR�pipe�linger�connect)�selfr Zendpointr r r �� __class__� �/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/zmq/auth/thread.pyr s z AuthenticationThread.__init__c C s | j �� | j�� | j j}t�� }|�| jtj � |�|tj � zt |� � �}W n tj yj Y q�Y n0 | j|v r�|| j tj kr�z| jj tjd�}W n tjy� Y q�Y n0 | �|�}|r�q�q�|r�q�||v rB|| tj krB| �� qB| j�� | j �� dS )z*Start the Authentication Agent thread task)�flagsN)r �startr �set� zap_socketr ZPoller�registerr �POLLIN�dict�pollZZMQError�recv_multipartZNOBLOCKZAgain� _handle_pipe� _handle_zap�close�stop)r �zapZpoller�socks�msg� terminater" r" r# �run' s0 zAuthenticationThread.runc C s$ | j j�� }|sdS | j �|� dS )z7 Handle a message from the ZAP socket. N)r r' r, Zhandle_zap_message)r r3 r" r" r# r. J s z AuthenticationThread._handle_zapc s� d}|du rd}|S |d }� j �d|� |dkr�� fdd�|d d� D �}z� jj|� W n2 ty� } z� j �d |� W Y d}~n d}~0 0 n�|d kr�� fd d�|d d� D �}z� jj|� W n2 ty� } z� j �d |� W Y d}~n d}~0 0 n�|dk�r2t|d � j�}|d }� j� |t � |�� nX|dk�rlt|d � j�}t|d � j�}� j� ||� n |dk�r|d}n� j � d|� |S )z6 Handle a message from front-end API. FNTr z auth received API command %r� ALLOWc s g | ]}t |� j��qS r" �r r ��.0�m�r r" r# � <listcomp>` � z5AuthenticationThread._handle_pipe.<locals>.<listcomp>r zFailed to allow %s� DENYc s g | ]}t |� j��qS r" r7 r8 r; r" r# r< g r= zFailed to deny %s� PLAIN� � CURVE� TERMINATEz!Invalid auth command from API: %r)r �debugr �allow� Exception� exception�denyr r �configure_plainr �loads�configure_curve�error) r r3 r4 �command� addresses�e�domainZjson_passwords�locationr" r; r# r- R s< && z!AuthenticationThread._handle_pipe)r NN) �__name__� __module__� __qualname__�__doc__r r5 r. r- � __classcell__r" r" r r# r s #r c C sF | j �� D ]6\}}|�d�s t|�s&q tt|d�}|js |j|_q | S )zAinherit docstrings from Authenticator, so we don't duplicate them�_N)�__dict__�items� startswith�callable�getattrr rT )�cls�name�methodZupstream_methodr" r" r# �_inherit_docstrings� s r_ c @ s� e Zd ZdZdZdZdZdZdZdZ dZ d dd�Z dd� Z d d � Z d d � Zd d� Zd dd�Zd dd�Zd!dd�Zdd� Zdd� Zdd� Zd d � ZdS )"�ThreadAuthenticatorz-Run ZAP authentication in a background threadN� r c C s< |p t j�� | _|| _|| _d | _d�t| ��| _ d | _ d S )Nzinproc://{0}.inproc) r r r r r r r �format�id� pipe_endpoint�thread)r r r r r" r" r# r � s z ThreadAuthenticator.__init__c C sH | g| j �� D ]"}||jv rt�| ||� d S qt| jj||� d S �N)r! �mrorW �object� __setattr__�setattrre r )r �key�value�objr" r" r# ri � s z ThreadAuthenticator.__setattr__c C s6 zt �| |� W n ty0 t| jj|� Y S 0 d S rf )rh � __getattr__�AttributeErrorr[ re r )r rk r" r" r# rn � s z ThreadAuthenticator.__getattr__c s$ � j �dg� fdd�|D � � d S )Nr6 c s g | ]}t |� j��qS r" �r r �r9 �ar; r" r# r< � r= z-ThreadAuthenticator.allow.<locals>.<listcomp>�r �send_multipart�r rM r" r; r# rD � s zThreadAuthenticator.allowc s$ � j �dg� fdd�|D � � d S )Nr> c s g | ]}t |� j��qS r" rp rq r; r" r# r< � r= z,ThreadAuthenticator.deny.<locals>.<listcomp>rs ru r" r; r# rG � s zThreadAuthenticator.deny�*c C s( | j �dt|| j�t�|p i �g� d S )Nr? )r rt r r r �dumps)r rO � passwordsr" r" r# rH � s z#ThreadAuthenticator.configure_plainc C s. t || j�}t || j�}| j�d||g� d S )NrA )r r r rt )r rO rP r" r" r# rJ � s z#ThreadAuthenticator.configure_curvec C s | j jj||d� d S )N)�credentials_provider)re r �configure_curve_callback)r rO ry r" r" r# rz � s z,ThreadAuthenticator.configure_curve_callbackc C s� | j �tj�| _d| j_| j�| j� t| j | j| j | j d�| _ | j � � t jdk rf| j jjdd� n| j jjdd�s~td��dS )z Start the authentication threadr r )r@ � � )�timeoutz$Authenticator thread failed to startN)r r r r r r �bindrd r r r re r% �sys� version_infor �wait� RuntimeErrorr; r" r" r# r% � s zThreadAuthenticator.startc C s> | j r:| j �d� | �� r$| j�� d| _| j �� d| _ dS )z Stop the authentication threadrB N)r �send�is_alivere �joinr/ r; r" r" r# r0 � s zThreadAuthenticator.stopc C s | j r| j �� rdS dS )z$Is the ZAP thread currently running?TF)re r� r; r" r" r# r� � s z ThreadAuthenticator.is_alivec C s | � � d S rf )r0 r; r" r" r# �__del__� s zThreadAuthenticator.__del__)Nr N)rv N)rv ra )rv N)rQ rR rS rT r r r r rd re �authr ri rn rD rG rH rJ rz r% r0 r� r� r" r" r" r# r` � s( r` )rT �timer � threadingr r r Z zmq.utilsr Zzmq.utils.strtypesr r r r r �baser r r_ rh r` �__all__r" r" r" r# �<module> s o T
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка