Zd xdZddlmZddlmZmZmZGddeZGddeZ Gdd eZ Gd d eZ Gd d e Z Gdde Z Gdde eZddZdadaGddeZ ddeeeeeefeeeeffdefdZgdZdS)z 0MQ Error classes and functions.)EINTR)OptionalTupleUnionceZdZdZdS) ZMQBaseErrorz.Base exception class for 0MQ errors in Python.N__name__ __module__ __qualname____doc__)lib/python3.11/site-packages/zmq/error.pyrr s8888rrcpeZdZUdZdZeeed<d deedeefdZ defdZ defdZ dS) 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$||_||||_dS||_dS|t ||_dS||_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 isinstanceintrstr)selfrrrrs r__init__zZMQError.__init__s 43333333 =IKKE eS ! ! $DJ{ ( # { #E  # rreturnc|jSN)rrs r__str__zZMQError.__str__<s }rc@|jjdt|dS)Nz('z')) __class__r rr!s r__repr__zZMQError.__repr__?s$.)::SYY::::r)NN) r r r r rrr__annotations__rrr"r%rrrrrs   E8C=$$hsm$#$$$$@;#;;;;;;rrceZdZdZdS) ZMQBindErrorznAn error for ``Socket.bind_to_random_port()``. See Also -------- .Socket.bind_to_random_port Nr rrrr(r(Crr(ceZdZdZdS)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 ignoredcVddlm}t|dS)Nr)ETERM)zmqr0superr)rrrr0r$s rrzContextTerminated.__init__[s3 rr.r.r r r r r __classcell__r$s@rr-r-UsG           rr-c$eZdZdZdfd ZxZS)Againz7Wrapper for zmq.EAGAIN .. versionadded:: 13.0 r.cVddlm}t|dS)Nr)EAGAIN)r1r:r2r)rrrr:r$s rrzAgain.__init__gs3      rr3r4r6s@rr8r8asG !!!!!!!!!!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 r.cTttdSr )r2rr)rrrr$s rrzInterruptedSystemCall.__init__xs! rcNt}|dzS)NzB: This call should have been retried. Please report this to pyzmq.)r2r")rsr$s rr"zInterruptedSystemCall.__str__{s" GGOO  WWWrr3) r r r r rrrr"r5r6s@rr<r<msp E      XXXXXXXXXrr<NTc|dkrw|ddlm}|}|dkr|sdSddlm}m}|t krt |||krt|||krt|t|dS)zhinternal utility for checking zmq return condition and raising the appropriate Exception class Nr)r)r:r0) rrr1r:r0rr<r8r-r)rcrerror_without_errnorr:r0s r _check_rcrDs  Rxx = - - - - - -IKKE A::1: F%%%%%%%% E>>'.. . f__,,  e^^#E** *5// !!xrc4eZdZdZdZd dedefdZdZdZdS) ZMQVersionErrorzgRaised when a feature is not provided by the linked version of libzmq. .. versionadded:: 14.2 NFeature min_versionrchtddlm}|a||_||_t|_dS)Nr) zmq_version) _zmq_versionr1rJrrHversion)rrHrrJs rrzZMQVersionError.__init__s?   ' ' ' ' ' '&;==L&# rc&dt|zS)NzZMQVersionError('%s')rr!s rr%zZMQVersionError.__repr__s&T22rcNd|j|j|jS)Nz!{} requires libzmq >= {}, have {})formatrrHrLr!s rr"zZMQVersionError.__str__s*299 H   L   rrG) r r r r rHrrr%r"rrrrFrFsj K$$C$c$$$$333     rrFrGmin_version_inforctddlm}|at|kr/dd|D}t ||dS)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.c34K|]}t|VdSr rN).0vs r z!_check_version..s(@@!s1vv@@@@@@r)_zmq_version_infor1rTjoinrF)rRrrTrHs r_check_versionr\sp ((((((,,..+++hh@@/?@@@@@ k3///,+r)rr(rr+r-r<r8rF)NTrQ)r rrtypingrrr Exceptionrrr(r+r-r8InterruptedErrorr<rDrZrKNotImplementedErrorrFrrr\__all__rrrrbs!&& ))))))))))9999999992;2;2;2;2;|2;2;2;j<l           ! ! ! ! !H ! ! !XXXXXH&6XXX&""""0      )   >00E#Jc3hsC}9MMN0 0000(   r