o i @sdZddlmZddlmZmZmZGdddeZGdddeZ Gdd d eZ Gd d d eZ Gd d d e Z Gddde Z Gddde eZdddZdadaGdddeZ ddeeeeeefeeeeffdefddZgdZdS) z 0MQ Error classes and functions.)EINTR)OptionalTupleUnionc@eZdZdZdS) ZMQBaseErrorz.Base exception class for 0MQ errors in Python.N__name__ __module__ __qualname____doc__r r D/var/www/edux/Edux_v2/venv/lib/python3.10/site-packages/zmq/error.pyr rc@sZeZdZUdZdZeeed<d deedeefddZ defdd Z defd d Z 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. NerrnomsgcCsnddlm}m}|dur|}t|tr'||_|dur"|||_dS||_dS|dur2t||_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)selfrrrrr r r__init__s    zZMQError.__init__returncCs|jSN)rrr r r__str__<szZMQError.__str__cCs|jjdt|dS)Nz('z')) __class__r rrr r r__repr__?szZMQError.__repr__)NN) r r r r rrr__annotations__rrrr r r r rrs   rc@r) ZMQBindErrorznAn error for ``Socket.bind_to_random_port()``. See Also -------- .Socket.bind_to_random_port Nrr r r rr"Crr"c@r)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 Nrr r r rr#Lrr#c"eZdZdZdfdd ZZS)ContextTerminatedz6Wrapper for zmq.ETERM .. versionadded:: 13.0 ignoredcddlm}t|dS)Nr)ETERM)zmqr(superr)rrrr(rr rr[ zContextTerminated.__init__r&r&r r r r r __classcell__r r r+rr%Ur%cr$)Againz7Wrapper for zmq.EAGAIN .. versionadded:: 13.0 r&cr')Nr)EAGAIN)r)r2r*r)rrrr2r+r rrgr,zAgain.__init__r-r.r r r+rr1ar0r1cs2eZdZdZeZdfdd ZfddZZS)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&csttdSr)r*rr)rrrr+r rrxszInterruptedSystemCall.__init__cst}|dS)NzB: This call should have been retried. Please report this to pyzmq.)r*r)rsr+r rr{s zInterruptedSystemCall.__str__r-) r r r r rrrrr/r r r+rr3ms r3NTcCs~|dkr=|durddlm}|}|dkr|sdSddlm}m}|tkr)t|||kr1t|||kr9t|t |dS)zhinternal utility for checking zmq return condition and raising the appropriate Exception class Nr)r)r2r() rrr)r2r(rr3r1r%r)rcrerror_without_errnorr2r(r r r _check_rcs  r8c@s8eZdZdZdZd dedefddZdd Zd d ZdS) ZMQVersionErrorzgRaised when a feature is not provided by the linked version of libzmq. .. versionadded:: 14.2 NFeature min_versionrcCs0tdur ddlm}|a||_||_t|_dS)Nr) zmq_version) _zmq_versionr)r<rr;version)rr;rr<r r rrs   zZMQVersionError.__init__cCs dt|S)NzZMQVersionError('%s')rrr r rr s zZMQVersionError.__repr__cCsd|j|j|jS)Nz!{} requires libzmq >= {}, have {})formatrr;r>rr r rrs zZMQVersionError.__str__r:) r r r r r;rrr rr r r rr9s  r9r:min_version_inforcCsDtdur ddlm}|at|kr ddd|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.css|]}t|VqdSrr?).0vr r r sz!_check_version..)_zmq_version_infor)rCjoinr9)rBrrCr;r r r_check_versions  rJ)rr"rr#r%r3r1r9)NTrA)r rrtypingrrr Exceptionrrr"r#r%r1InterruptedErrorr3r8rHr=NotImplementedErrorr9rrrJ__all__r r r rs* 5    "