File: //opt/saltstack/salt/lib/python3.10/site-packages/zmq/__pycache__/error.cpython-310.pyc
o
�N�g � @ s� d Z ddlmZ ddlmZmZmZ G dd� de�ZG dd� de�Z G dd � d e�Z
G d
d � d e�Z G d d
� d
e �Z G dd� de �Z
G dd� de e�Zd dd�ZdadaG dd� de�Z d deee eeef eeeef f defdd �Zg d �ZdS ) z 0MQ Error classes and functions.� )�EINTR)�Optional�Tuple�Unionc @ � e Zd ZdZdS )� ZMQBaseErrorz.Base exception class for 0MQ errors in Python.N��__name__�
__module__� __qualname__�__doc__� r
r
�=/opt/saltstack/salt/lib/python3.10/site-packages/zmq/error.pyr
� r c @ sZ e Zd ZU dZdZee ed< d dee dee fdd�Z defdd �Z
defd
d �Z dS )
�ZMQErrorz�Wrap an errno style error.
Parameters
----------
errno : int
The ZMQ errno or None. If None, then ``zmq_errno()`` is called and
used.
msg : string
Description of the error or None.
N�errno�msgc C sn ddl m}m} |du r|� }t|t�r'|| _|du r"||�| _dS || _dS |du r2t|�| _dS || _dS )a Wrap an errno style error.
Parameters
----------
errno : int
The ZMQ errno or None. If None, then ``zmq_errno()`` is called and
used.
msg : string
Description of the error or None.
r )�strerror� zmq_errnoN)� zmq.backendr r �
isinstance�intr �str)�selfr r r r r
r
r �__init__ s
zZMQError.__init__�returnc C s | j S �N)r �r r
r
r �__str__< s zZMQError.__str__c C s | j j� dt| �� d�S )Nz('z'))� __class__r r r r
r
r �__repr__? s zZMQError.__repr__)NN) r r
r r r r r �__annotations__r r r r r
r
r
r r s
r c @ r )� ZMQBindErrorznAn error for ``Socket.bind_to_random_port()``.
See Also
--------
.Socket.bind_to_random_port
Nr r
r
r
r r" C r r" c @ r )�NotDonez�Raised when timeout is reached while waiting for 0MQ to finish with a Message
See Also
--------
.MessageTracker.wait : object for tracking when ZeroMQ is done
Nr r
r
r
r r# L r r# c �" e Zd ZdZd� fdd� Z� ZS )�ContextTerminatedz6Wrapper for zmq.ETERM
.. versionadded:: 13.0
�ignoredc � ddl m} t� �|� d S )Nr )�ETERM)�zmqr( �superr )r r r r( �r r
r r [ � zContextTerminated.__init__�r& r& �r r
r r r �
__classcell__r
r
r+ r r% U � r% c r$ )�Againz7Wrapper for zmq.EAGAIN
.. versionadded:: 13.0
r& c r' )Nr )�EAGAIN)r) r2 r* r )r r r r2 r+ r
r r g r, zAgain.__init__r- r. r
r
r+ r r1 a r0 r1 c s2 e Zd ZdZeZd� fdd� Z� fdd�Z� ZS )�InterruptedSystemCallz�Wrapper for EINTR
This exception should be caught internally in pyzmq
to retry system calls, and not propagate to the user.
.. versionadded:: 14.7
r& c s t � �t� d S r )r* r r )r r r r+ r
r r x s z InterruptedSystemCall.__init__c s t � �� }|d S )NzB: This call should have been retried. Please report this to pyzmq.)r* r )r �sr+ r
r r { s
z InterruptedSystemCall.__str__r- ) r r
r r r r r r r/ r
r
r+ r r3 m s
r3 NTc C s~ | dkr=|du rddl m} |� }|dkr|sdS ddlm}m} |tkr)t|��||kr1t|��||kr9t|��t |��dS )zhinternal utility for checking zmq return condition
and raising the appropriate Exception class
���Nr )r )r2 r( )
r r r) r2 r( r r3 r1 r% r )�rcr Zerror_without_errnor r2 r( r
r
r � _check_rc� s �r7 c @ s8 e Zd ZdZdZd dedefdd�Zdd � Zd
d � ZdS )
�ZMQVersionErrorzgRaised when a feature is not provided by the linked version of libzmq.
.. versionadded:: 14.2
N�Feature� min_versionr c C s0 t d u r
ddlm} |� a || _|| _t | _d S )Nr )� zmq_version)� _zmq_versionr) r; r r: �version)r r: r r; r
r
r r � s
zZMQVersionError.__init__c C s dt | � S )NzZMQVersionError('%s')�r r r
r
r r � s zZMQVersionError.__repr__c C s d� | j| j| j�S )Nz!{} requires libzmq >= {}, have {})�formatr r: r= r r
r
r r � s
�zZMQVersionError.__str__�r9 ) r r
r r r: r r r r r
r
r
r r8 � s
r8 r9 �min_version_infor c C sD t du r
ddlm} |� a t | k r d�dd� | D ��}t||��dS )z�Check for libzmq
raises ZMQVersionError if current zmq version is not at least min_version
min_version_info is a tuple of integers, and will be compared against zmq.zmq_version_info().
Nr )�zmq_version_info�.c s s � | ]}t |�V qd S r r> )�.0�vr
r
r � <genexpr>� s � z!_check_version.<locals>.<genexpr>)�_zmq_version_infor) rB �joinr8 )rA r rB r: r
r
r �_check_version� s
�rI )r r" r r# r% r3 r1 r8 )NTr@ )r r r �typingr r r � Exceptionr r r" r# r% r1 �InterruptedErrorr3 r7 rG r< �NotImplementedErrorr8 r r rI �__all__r
r
r
r �<module> s* 5
�"�
�