← Back
Editing: thread.cpython-311.pyc
� mc�c � �� � d Z ddlZddlmZ ddlmZmZ ddlmZm Z m Z mZmZm Z ddlZddlmZmZ ddlmZ dd lmZ G d � de� � Z ede� � � Zdedefd�Ze G d� d� � � � ZdgZdS )z>ZAP Authenticator in a Python Thread. .. versionadded:: 14.1 � N)�chain)�Event�Thread)�Any�Dict�List�Optional�TypeVar�cast)�NOBLOCK�POLLIN)�jsonapi� )� Authenticatorc �| � � e Zd ZdZ ddddededed ee d df� fd� Zdd�Z dd �Z dee d e fd�Z� xZS )�AuthenticationThreadziA Thread for running a zmq Authenticator This is run in the background by ThreadedAuthenticator �utf-8N�context�zmq.Context�endpoint�encoding�log� authenticator�returnc �� �� t � � � � � |pt j � � � | _ || _ |pt j d� � x| _ }t � � | _ |pt |||�� � | _ |� t j � � | _ d| j _ | j � |� � d S )Nzzmq.auth�r r r )�super�__init__�zmq�Context�instancer r �logging� getLoggerr r �startedr r �socket�PAIR�pipe�linger�connect)�selfr r r r r � __class__s ��1/usr/lib/python3/dist-packages/zmq/auth/thread.pyr zAuthenticationThread.__init__ s� �� � ���������8�#�+�"6�"6�"8�"8��� �� ��=�� 1�*� =� =�=���3��w�w���,9� - �]��h�C�> � > � > ��� �N�N�3�8�,�,�� ��� ��� ���(�#�#�#�#�#� c �B � | j � � � | j � � � | j j }t j � � }|� | j t j � � |� |t j � � t |� � � � � }n# t j $ r Y n�w xY w| j |v rj|| j t k rT | j � t �� � }n# t j $ r Y nw xY w| � |� � }|rn�P|rn*||v r%|| t k r| � � � ��| j � � � | j � � � dS )z*Start the Authentication Agent thread taskT)�flagsN)r �startr$ �set� zap_socketr �Poller�registerr'