3

VS�_��@s�dZd
dl
mZ
Gdd�de�ZGdd�de�ZGdd�de�ZGd	d
�d
e�ZGdd�de�ZGd
d�de�Z	ye

Wnek
r�


eZ
YnXGdd�dee
�Z
ddd�
ZdadaGdd�de�Zddd�
Zdddd
ddddgZdS)z 0MQ Error classes and functions.�)
�EINTRc
@seZ
dZd
ZdS)�ZMQBaseErrorz.Base exception class for 0MQ errors in Python.N)�__name__�
__module__�__qualname__�__doc__�rr�/usr/lib64/python3.6/error.pyr	s

rc@s.eZ
dZd
ZdZd	dd�
Zdd�Zdd�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 : string
        Description of the error or None.
    NcCshd
dlm
}m}
|
dkr|�}
t|
t�rJ|
|_|dkrB||
�
|_
qd||_
n|dkr^t|
�
|_
n||_
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.backendrr�
isinstance�int�errno�str)�selfr�msgrrrrr	�__init__s







zZMQError.__init__c


Cs|jS)
N)
r)
rrrr	�__str__9s
zZMQError.__str__c

Csd
|jj
t|�
fS)Nz%s('%s'))�	__class__rr)
rrrr	�__repr__<s
zZMQError.__repr__)NN)rrrrrrrrrrrr	r

s



r
c
@seZ
dZd
ZdS)�ZMQBindErrorzrAn error for ``Socket.bind_to_random_port()``.
    
    See Also
    --------
    .Socket.bind_to_random_port
    N)rrrrrrrr	r@s
rc
@seZ
dZd
ZdS)�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
    N)rrrrrrrr	rJs
rcs"eZ
dZd
Zd�f
dd�	Z�ZS)�ContextTerminatedz:Wrapper for zmq.ETERM
    
    .. versionadded:: 13.0
    �ignoredcs d
dlm
}
tt|�j|�

dS)Nr
)
�ETERM)�zmqr�superrr)rrrr)
rrr	rYs

zContextTerminated.__init__)rr)rrrrr�
__classcell__rr)
rr	rTs
rcs"eZ
dZd
Zd�f
dd�	Z�ZS)�Againz;Wrapper for zmq.EAGAIN
    
    .. versionadded:: 13.0
    rcs d
dlm
}
tt|�j|�

dS)Nr
)
�EAGAIN)rr!rr r)rrrr!)
rrr	rds

zAgain.__init__)rr)rrrrrrrr)
rr	r ^sr cs.eZ
dZd
Zd�f
dd�	Z�f
dd�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
    rcstt
|�jt�

dS)
N)rr"rr)rrr)
rrr	rws
zInterruptedSystemCall.__init__c
stt
|�j�}
|
d
S)NzB: This call should have been retried. Please report this to pyzmq.)rr"r)r�
s)
rrr	rzs

zInterruptedSystemCall.__str__)rr)rrrrrrrrr)
rr	r"nsr"NTcCs�|dkr�|
dkr"ddlm
}
|�}
|
dkr4|r4dSddlm}m}
|
tkrVt|
�
�
n,|
|krht|
�
�
n|
|krzt|
�
�
nt	|
�
�
dS)zlinternal utility for checking zmq return condition
    
    and raising the appropriate Exception class
    �
Nr
)
r)r!r���)
r
rrr!rrr"r rr
)ZrcrZerror_without_errnorr!rrrr	�	_check_rcs














r&c@s.eZ
dZd
ZdZd
dd�
Zdd�Zdd	�ZdS)�ZMQVersionErrorzkRaised when a feature is not provided by the linked version of libzmq.
    
    .. versionadded:: 14.2
    N�FeaturecCs0tdkrd
dl
m}
|�a||_|
|_t|_dS)Nr
)
�zmq_version)�_zmq_versionrr)r�min_version�version)rr+rr)rrr	r�s




zZMQVersionError.__init__c

Csd
t|�
S)NzZMQVersionError('%s'))
r)
rrrr	r�s
zZMQVersionError.__repr__c

Csd
|j|j
|jfS)Nz!%s requires libzmq >= %s, have %s)rr+r,)
rrrr	r�s
zZMQVersionError.__str__)
r()rrrrr+rrrrrrr	r'�s



	r'r(cCsDtd
krddl
m}
|�at|kr@djdd�|D�
�
}t||
��
d
S)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
ss|]}
t|
�
V
qdS)
N)
r)�.0�
vrrr	�	<genexpr>�sz!_check_version.<locals>.<genexpr>)�_zmq_version_inforr-�joinr')Zmin_version_inforr-r+rrr	�_check_version�s




r4)NT)
r()rrr�	Exceptionrr
rrrr �InterruptedError�	NameError�OSErrorr"r&r2r*�NotImplementedErrorr'r4�__all__rrrr	�<module>
s23