| Server IP : 198.38.94.13 / Your IP : 216.73.217.33 Web Server : Apache System : Linux d4744.dxb1.stableserver.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : revivere ( 1140) PHP Version : 8.2.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /opt/saltstack/salt/lib/python3.10/site-packages/zmq/__pycache__/ |
Upload File : |
o
;jI � @ s� d Z ddlmZ ddlmZ G dd� de�ZG dd� de�ZG dd � d e�Z G d
d � d e�Z
G d d
� d
e�Z G dd� de �Z G dd� de �Z
G dd� de e�Zd"dd�ZdadaG dd� de�Z d#d$d d �Zg d!�ZdS )%z 0MQ Error classes and functions.� )� annotations)�EINTRc �" e Zd ZdZd� fdd� Z� ZS )�DraftFDWarningzRWarning for using experimental FD on draft sockets.
.. versionadded:: 27
� c s |sd}t � �|� d S )Na! pyzmq's back-fill socket.FD support on thread-safe sockets is experimental, and may be removed. This warning will go away automatically if/when libzmq implements socket.FD on thread-safe sockets. You can suppress this warning with `warnings.simplefilter('ignore', zmq.error.DraftFDWarning))�super�__init__)�self�msg�� __class__� �=/opt/saltstack/salt/lib/python3.10/site-packages/zmq/error.pyr s �zDraftFDWarning.__init__)r ��__name__�
__module__� __qualname__�__doc__r �
__classcell__r
r
r r r
� r c @ � e Zd ZdZdS )� ZMQBaseErrorz.Base exception class for 0MQ errors in Python.N�r r r r r
r
r
r r � r c @ sF e Zd ZU dZdZded< ded< ddd d
�Zdd d
�Zddd�ZdS )�ZMQErrorz�Wrap an errno style error.
Parameters
----------
errno : int
The ZMQ errno or None. If None, then ``zmq_errno()`` is called and
used.
msg : str
Description of the error or None.
N�
int | None�errno�str�strerrorr
�
str | Nonec 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 )r � zmq_errnoN)� zmq.backendr r �
isinstance�intr r )r r r
r r r
r
r r - s
zZMQError.__init__�returnc C s | j S �N)r �r r
r
r �__str__M s zZMQError.__str__c C s | j j� dt| �� d�S )Nz('�'))r r r r& r
r
r �__repr__P s zZMQError.__repr__)NN)r r r
r )r$ r ) r r r r r �__annotations__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+ T 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, ] r r, c r )�ContextTerminatedz6Wrapper for zmq.ETERM
.. versionadded:: 13.0
�ignoredc � ddl m} t� �|� d S )Nr )�ETERM)�zmqr0 r r )r r r
r0 r r
r r l � zContextTerminated.__init__�r. r. r r
r
r r r- f r r- c r )�Againz7Wrapper for zmq.EAGAIN
.. versionadded:: 13.0
r. c r/ )Nr )�EAGAIN)r1 r5 r r )r r r
r5 r r
r r x r2 zAgain.__init__r3 r r
r
r r r4 r r r4 c s< e Zd ZU dZeZded< d � fdd� Z� fdd�Z� Z S )
�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 r r. c s t � �t� d S r% )r r r )r r r
r r
r r � � 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__r3 )
r r r r r r r* r r' r r
r
r r r6 ~ s
r6 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 )r5 r0 )
r! r r1 r5 r0 r r6 r4 r- r )�rcr Zerror_without_errnor r5 r0 r
r
r � _check_rc� s �r; c @ s0 e Zd ZdZdZd
ddd�Zd d
� Zd d � ZdS )�ZMQVersionErrorzgRaised when a feature is not provided by the linked version of libzmq.
.. versionadded:: 14.2
N�Feature� min_versionr r
c C s0 t d u r
ddlm} |� a || _|| _t | _d S )Nr )� zmq_version)� _zmq_versionr1 r? r
r> �version)r r> r
r? r
r
r r � s
zZMQVersionError.__init__c C s dt | �� d�S )NzZMQVersionError('r( �r r& r
r
r r) � r7 zZMQVersionError.__repr__c C s | j � d| j� d| j� �S )Nz requires libzmq >= z, have )r
r> rA r& r
r
r r' � s zZMQVersionError.__str__�r= )r> r r
r )r r r r r> r r) r' r
r
r
r r< � s
r< r= �min_version_info�3tuple[int] | tuple[int, int] | tuple[int, int, int]r
r 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% rB )�.0�vr
r
r � <genexpr>� s � z!_check_version.<locals>.<genexpr>)�_zmq_version_infor1 rF �joinr< )rD r
rF r> r
r
r �_check_version� s
�rM ) r r r+ r r, r- r6 r4 r< )NTrC )rD rE r
r )r �
__future__r r r �RuntimeWarningr � Exceptionr r r+ r, r- r4 �InterruptedErrorr6 r; rK r@ �NotImplementedErrorr< rM �__all__r
r
r
r �<module> s$ 6
�