B b ,cã@sdZddlmZddlmZmZmZGdd„deƒZGdd„deƒZ Gdd „d eƒZ Gd d „d eƒZ Gd d „d e ƒZ Gdd„de ƒZ Gdd„de eƒZddd„ZdadaGdd„deƒZdeeeeeefeeeeffedœdd„Zdd dd d dddgZdS)z 0MQ Error classes and functions.é)ÚEINTR)ÚOptionalÚTupleÚUnionc@seZdZdZdS)Ú ZMQBaseErrorz.Base exception class for 0MQ errors in Python.N)Ú__name__Ú __module__Ú __qualname__Ú__doc__©r r ú(lib/python3.7/site-packages/zmq/error.pyr src@sXeZdZUdZdZeeed<d eeeedœdd„Z edœdd „Z edœd 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)rÚmsgcCshddlm}m}|dkr|ƒ}t|tƒrJ||_|dkrB||ƒ|_qd||_n|dkr^t|ƒ|_n||_dS)aWrap 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ÚintrÚstr)Úselfrrrrr r r Ú__init__s    zZMQError.__init__)ÚreturncCs|jS)N)r)rr r r Ú__str__<szZMQError.__str__cCs|jj›dt|ƒ›dS)Nz('z'))Ú __class__rr)rr r r Ú__repr__?szZMQError.__repr__)NN) rrr r rrrÚ__annotations__rrrrr r r r r s  r c@seZdZdZdS)Ú ZMQBindErrorznAn error for ``Socket.bind_to_random_port()``. See Also -------- .Socket.bind_to_random_port N)rrr r r r r r rCsrc@seZdZdZdS)Ú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)rrr r r r r r rLsrcs"eZdZdZd‡fdd„ Z‡ZS)ÚContextTerminatedz6Wrapper for zmq.ETERM .. versionadded:: 13.0 Úignoredcsddlm}tƒ |¡dS)Nr)ÚETERM)Úzmqr!Úsuperr)rrrr!)rr r r[s zContextTerminated.__init__)r r )rrr r rÚ __classcell__r r )rr rUsrcs"eZdZdZd‡fdd„ Z‡ZS)ÚAgainz7Wrapper for zmq.EAGAIN .. versionadded:: 13.0 r csddlm}tƒ |¡dS)Nr)ÚEAGAIN)r"r&r#r)rrrr&)rr r rgs zAgain.__init__)r r )rrr r rr$r r )rr r%asr%cs2eZdZdZeZd‡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 cstƒ t¡dS)N)r#rr)rrr)rr r rxszInterruptedSystemCall.__init__cstƒ ¡}|dS)NzB: This call should have been retried. Please report this to pyzmq.)r#r)rÚs)rr r r{s zInterruptedSystemCall.__str__)r r ) rrr r rrrrr$r r )rr r'msr'NTcCs„|dkr€|dkr"ddlm}|ƒ}|dkr2|s2dSddlm}m}|tkrTt|ƒ‚n,||krft|ƒ‚n||krxt|ƒ‚nt |ƒ‚dS)zhinternal utility for checking zmq return condition and raising the appropriate Exception class éÿÿÿÿNr)r)r&r!) rrr"r&r!rr'r%rr )ZrcrZerror_without_errnorr&r!r r r Ú _check_rc€s     r*c@s6eZdZdZdZd eedœdd„Zdd„Zd d „ZdS) ÚZMQVersionErrorzgRaised when a feature is not provided by the linked version of libzmq. .. versionadded:: 14.2 NÚFeature)Ú min_versionrcCs0tdkrddlm}|ƒa||_||_t|_dS)Nr)Ú zmq_version)Ú _zmq_versionr"r.rr-Úversion)rr-rr.r r r r¤s  zZMQVersionError.__init__cCs dt|ƒS)NzZMQVersionError('%s'))r)rr r r r®szZMQVersionError.__repr__cCsd |j|j|j¡S)Nz!{} requires libzmq >= {}, have {})Úformatrr-r0)rr r r r±szZMQVersionError.__str__)r,) rrr r r-rrrrr r r r r+œs  r+r,)Úmin_version_inforcCsDtdkrddlm}|ƒat|kr@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Ú.css|]}t|ƒVqdS)N)r)Ú.0Úvr r r ú Ész!_check_version..)Ú_zmq_version_infor"r3Újoinr+)r2rr3r-r r r Ú_check_version¹s  r:)NT)r,)r rrÚtypingrrrÚ Exceptionrr rrrr%ÚInterruptedErrorr'r*r8r/ÚNotImplementedErrorr+rrr:Ú__all__r r r r Ús, 5     2