HEX
Server: Apache
System: Linux server2.voipitup.com.au 4.18.0-553.109.1.lve.el8.x86_64 #1 SMP Thu Mar 5 20:23:46 UTC 2026 x86_64
User: posscale (1027)
PHP: 8.2.30
Disabled: exec,passthru,shell_exec,system
Upload Files
File: //opt/saltstack/salt/lib/python3.10/site-packages/zmq/auth/__pycache__/asyncio.cpython-310.pyc
o

�N�g��@s^dZddlZddlZddlmZmZddlZddlmZddl	m
Z
Gdd�de
�ZdgZdS)	zOZAP Authenticator integrated with the asyncio IO loop.

.. versionadded:: 15.2
�N)�Any�Optional)�Poller�)�
AuthenticatorcsteZdZUdZeeed<eed<ded<ddedd	ef�fd
d�
Zdd
d�Z	d�fdd�Z
d�fdd�Z�ZS)�AsyncioAuthenticatorz1ZAP authentication for use in the asyncio IO loop�_AsyncioAuthenticator__poller�_AsyncioAuthenticator__taskzzmq.asyncio.Socket�
zap_socketN�contextzzmq.Context�loopcs8t��|�|durt�|jj�d��d|_d|_dS)Nz (loop) is deprecated and ignored)�super�__init__�warnings�warn�	__class__�__name__rr	)�selfrr�r��D/opt/saltstack/salt/lib/python3.10/site-packages/zmq/auth/asyncio.pyrs

zAsyncioAuthenticator.__init__�returnc�sL�	|jdur	dS|j��IdH}|jt|�vr%|j��IdH}|�|�q)N)r�pollr
�dictZrecv_multipartZhandle_zap_message)r�events�msgrrrZ__handle_zap!s�

�z!AsyncioAuthenticator.__handle_zapcs8t���t�|_|j�|jtj�t�	|�
��|_dS)zStart ZAP authenticationN)r
�startrr�registerr
�zmq�POLLIN�asyncioZ
ensure_future�!_AsyncioAuthenticator__handle_zapr	�rrrrr*s
zAsyncioAuthenticator.startcs8|jr|j��|jr|j�|j�d|_t���dS)zStop ZAP authenticationN)r	�cancelr�
unregisterr
r
�stopr"rrrr%1s
zAsyncioAuthenticator.stop)NN)rN)
r�
__module__�__qualname__�__doc__rr�__annotations__rrr!rr%�
__classcell__rrrrrs

	r)
r(r r�typingrrrZzmq.asyncior�baserr�__all__rrrr�<module>s
(