Ef .dZddlmZddlmZmZmZGddeZGddeZ Gdd eZ Gd d eZ Gd d e Z Gdde Z Gdde eZddZdadaGddeZ ddeeeeeefeeeeffdefdZgdZy)z 0MQ Error classes and functions.)EINTR)OptionalTupleUnionceZdZdZy) ZMQBaseErrorz.Base exception class for 0MQ errors in Python.N__name__ __module__ __qualname____doc__+/usr/lib/python3/dist-packages/zmq/error.pyrr s8rrc\eZdZUdZdZeeed<d deedeefdZ defdZ defdZ y) ZMQErrorzWrap 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. Nerrnomsgcddlm}m}||}t|tr||_||||_y||_y|t ||_y||_y)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 isinstanceintrstr)selfrrrrs r__init__zZMQError.__init__sR 4 =KE eS !DJ{ ( # { #E  # rreturnc|jSN)rrs r__str__zZMQError.__str__<s }}rcL|jjdt|dS)Nz('z')) __class__r rr!s r__repr__zZMQError.__repr__?s$..))*"SYKr::r)NN) r r r r rrr__annotations__rrr"r%rrrrrsK  E8C=$hsm$#$@;#;rrceZdZdZy) ZMQBindErrorznAn error for ``Socket.bind_to_random_port()``. See Also -------- .Socket.bind_to_random_port Nr rrrr(r(Crr(ceZdZdZy)NotDonezRaised 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 rrrr+r+Lr)rr+c$eZdZdZdfd ZxZS)ContextTerminatedz6Wrapper for zmq.ETERM .. versionadded:: 13.0 c0ddlm}t| |y)Nr)ETERM)zmqr/superr)rrrr/r$s rrzContextTerminated.__init__[s rignoredr3r r r r r __classcell__r$s@rr-r-Us   rr-c$eZdZdZdfd ZxZS)Againz7Wrapper for zmq.EAGAIN .. versionadded:: 13.0 c0ddlm}t| |y)Nr)EAGAIN)r0r:r1r)rrrr:r$s rrzAgain.__init__gs  rr2r4r6s@rr8r8as !!rr8c2eZdZdZeZdfd ZfdZxZS)InterruptedSystemCallzWrapper for EINTR This exception should be caught internally in pyzmq to retry system calls, and not propagate to the user. .. versionadded:: 14.7 c,t|tyr )r1rr)rrrr$s rrzInterruptedSystemCall.__init__xs rc*t|}|dzS)NzB: This call should have been retried. Please report this to pyzmq.)r1r")rsr$s rr"zInterruptedSystemCall.__str__{s GO WWWrr2) r r r r rrrr"r5r6s@rr<r<ms  E XXrr<Nc|dk(r^| ddlm}|}|dk(r|syddlm}m}|t k(r t |||k(r t|||k(r t|t|y)zhinternal utility for checking zmq return condition and raising the appropriate Exception class Nr)r)r:r/) rrr0r:r/rr<r8r-r)rcrerror_without_errnorr:r/s r _check_rcrDsn  Rx = -KE A:1 % E>'. . f_,  e^#E* *5/ !!rc2eZdZdZdZddedefdZdZdZy) ZMQVersionErrorzgRaised when a feature is not provided by the linked version of libzmq. .. versionadded:: 14.2 N min_versionrc\t ddlm}|a||_||_t|_y)Nr) zmq_version) _zmq_versionr0rIrrGversion)rrGrrIs rrzZMQVersionError.__init__s(   '&=L&# rcdt|zS)NzZMQVersionError('%s')rr!s rr%zZMQVersionError.__repr__s&T22rcddj|j|j|jS)Nz!{} requires libzmq >= {}, have {})formatrrGrKr!s rr"zZMQVersionError.__str__s,299 HH    LL  rFeature) r r r r rGrrr%r"rrrrFrFs+ K$C$c$3 rrFmin_version_inforct ddlm}|at|kr$djd|D}t ||y)zCheck 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.c32K|]}t|ywr rM).0vs r z!_check_version..s@!s1v@s)_zmq_version_infor0rTjoinrF)rRrrTrGs r_check_versionr\sF (,.++hh@/?@@ k3//,r)rr(rr+r-r<r8rF)NTrP)r rrtypingrrr Exceptionrrr(r+r-r8InterruptedErrorr<rDrZrJNotImplementedErrorrFrrr\__all__rrrrbs& ))9992;|2;j<l     !H !XH&6X&"0  ) >0E#Jc3hsC}9MMN0 0( r