U lu fã@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 ú-/tmp/pip-unpacked-wheel-h6ekxre8/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__rrrr r r Ú__repr__?szZMQError.__repr__)NN) rr r r rrrÚ__annotations__rrrrr r r r rs   rc@seZdZdZdS)Ú ZMQBindErrorznAn error for ``Socket.bind_to_random_port()``. See Also -------- .Socket.bind_to_random_port Nrr r r r r Csr c@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 Nrr r r r r!Lsr!cs"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#©rr r r rÚ __classcell__r r r'r r"Usr"cs"eZdZdZd‡fdd„ Z‡ZS)ÚAgainz7Wrapper for zmq.EAGAIN .. versionadded:: 13.0 r#csddlm}tƒ |¡dS)Nr)ÚEAGAIN)r%r+r&r)rrrr+r'r r rgs zAgain.__init__)r#r#r(r r r'r 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¡dSr)r&rr)rrrr'r r rxszInterruptedSystemCall.__init__cstƒ ¡}|dS)NzB: This call should have been retried. Please report this to pyzmq.)r&r)rÚsr'r r r{s zInterruptedSystemCall.__str__)r#r#) rr r r rrrrr)r r r'r 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*r"r)ÚrcrZerror_without_errnorr+r$r r r Ú _check_rc€s     r0c@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%r4rr3Úversion)rr3rr4r r r r¤s  zZMQVersionError.__init__cCs dt|ƒS)NzZMQVersionError('%s')©rrr r r r®szZMQVersionError.__repr__cCsd |j|j|j¡S)Nz!{} requires libzmq >= {}, have {})Úformatrr3r6rr r r r±s ýzZMQVersionError.__str__)r2) rr r r r3rrrrr r r r r1œs  r1r2)Ú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|ƒVqdSrr7)Ú.0Úvr r r Ú Ész!_check_version..)Ú_zmq_version_infor%r:Újoinr1)r9rr:r3r r r Ú_check_version¹s  rA)NT)r2)r rrÚtypingrrrÚ Exceptionrrr r!r"r*ÚInterruptedErrorr,r0r?r5ÚNotImplementedErrorr1rrrAÚ__all__r r r r Ús6 5     þ"þ ø