:vj$dZddlmZddlmZddlmZGddeZGdde Z Gd d e Z Gd d e Z Gd de Z Gdde ZGdde ZGdde eZdddZdadaGddeZ d ddZgdZy)z 0MQ Error classes and functions.) annotations)EINTR)Literalc&eZdZdZddfd ZxZS)DraftFDWarningzRWarning for using experimental FD on draft sockets. .. versionadded:: 27 c,|sd}t||y)Na!pyzmq's back-fill socket.FD support on thread-safe sockets is experimental, and may be removed. This warning will go away automatically if/when libzmq implements socket.FD on thread-safe sockets. You can suppress this warning with `warnings.simplefilter('ignore', zmq.error.DraftFDWarning))super__init__)selfmsg __class__s Z/workspace/moltex-experiments/.pixi/envs/default/lib/python3.12/site-packages/zmq/error.pyr zDraftFDWarning.__init__s q  ))r strreturnNone__name__ __module__ __qualname____doc__r __classcell__r s@rrr s rrceZdZdZy) ZMQBaseErrorz.Base exception class for 0MQ errors in Python.Nrrrrrrrrs8rrcDeZdZUdZdZded<ded<d d dZd dZd d Zy) ZMQErrorzWrap an errno style error. Parameters ---------- errno : int The ZMQ errno or None. If None, then ``zmq_errno()`` is called and used. msg : str Description of the error or None. N int | Noneerrnorstrerrorcddlm}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)r# zmq_errnoN) zmq.backendr#r% isinstanceintr"r)r r"r r#r%s rr zZMQError.__init__.sR 4 =KE eS !DJ{ ( # { #E  # rc|jSN)r#r s r__str__zZMQError.__str__Ns }}rcL|jjdt|dS)Nz(''))r rrr+s r__repr__zZMQError.__repr__Qs$..))*"SYKr::r)NN)r"r!r z str | Nonerr) rrrrr"__annotations__r r,r/rrrr r s( E:M$@;rr ceZdZdZy) ZMQBindErrorznAn error for ``Socket.bind_to_random_port()``. See Also -------- .Socket.bind_to_random_port Nrrrrr3r3Urr3ceZdZdZy)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 Nrrrrr6r6^r4rr6c4eZdZdZ d dfd ZxZS)ContextTerminatedz6Wrapper for zmq.ETERM .. versionadded:: 13.0 c0ddlm}t| |y)Nr)ETERM)zmqr:r r )r r"r r:r s rr zContextTerminated.__init__ms  rignoredr=r"zint | Literal['ignored']r rrrrrs@rr8r8gs6+4 '      rr8c4eZdZdZ d dfd ZxZS)Againz7Wrapper for zmq.EAGAIN .. versionadded:: 13.0 c0ddlm}t| |y)Nr)EAGAIN)r;rBr r )r r"r rBr s rr zAgain.__init__}s   rr<r>rrs@rr@r@ws6+4!'!!  !!rr@cPeZdZUdZeZded< d dfd Zdfd ZxZ S) InterruptedSystemCallzWrapper for EINTR This exception should be caught internally in pyzmq to retry system calls, and not propagate to the user. .. versionadded:: 14.7 rr#c,t|tyr*)r r r)r r"r r s rr zInterruptedSystemCall.__init__s rc*t|}|dzS)NzB: This call should have been retried. Please report this to pyzmq.)r r,)r sr s rr,zInterruptedSystemCall.__str__s GO WWWrr<r>r0) rrrrrr"r1r r,rrs@rrDrDsI EM+4 '     XXrrDNc|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%)rBr:) r&r%r;rBr:rrDr@r8r )rcr"error_without_errnor%rBr:s r _check_rcrLsn  Rx = -KE A:1 % E>'. . f_,  e^#E* *5/ !!rcFeZdZUdZded<ded<ded<d d dZdZdZy ) ZMQVersionErrorzgRaised when a feature is not provided by the linked version of libzmq. .. versionadded:: 14.2 rr min_versionversionc\t ddlm}|a||_||_t|_y)Nr) zmq_version) _zmq_versionr;rRr rOrP)r rOr rRs rr zZMQVersionError.__init__s(   '&=L&# rc dt|dS)NzZMQVersionError('r.rr+s rr/zZMQVersionError.__repr__s"3t9+R00rcR|jd|jd|jS)Nz requires libzmq >= z, have )r rOrPr+s rr,zZMQVersionError.__str__s)((/0@0@/AWWrNFeature)rOrr rrr)rrrrr1r r/r,rrrrNrNs) H L$1XrrNct 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*rU).0vs r z!_check_version..s@/?!s1v/?s)_zmq_version_infor;rZjoinrN)min_version_infor rZrOs r_check_versionrcsF (,.++hh@/?@@ k3//,r) rrr3r r6r8rDr@rN)NT)r"r!rKboolrrrW)rbz3tuple[int] | tuple[int, int] | tuple[int, int, int]r rrr)r __future__rr"rtypingrRuntimeWarningr Exceptionrr r3r6r8r@InterruptedErrorrDrLr`rSNotImplementedErrorrNrc__all__rrrrls&# ^  9993;|3;l<l    !H ! XH&6X0"0 X)X:0I0 0 0( r