o ڷiI@sdZddlmZddlmZGdddeZGdddeZGdd d eZ Gd d d eZ Gd d d eZ Gddde Z Gddde Z Gddde eZd"ddZdadaGdddeZ d#d$dd Zgd!ZdS)%z 0MQ Error classes and functions.) annotations)EINTRc"eZdZdZdfdd ZZS)DraftFDWarningzRWarning for using experimental FD on draft sockets. .. versionadded:: 27 cs|sd}t|dS)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__?/home/ubuntu/vllm_env/lib/python3.10/site-packages/zmq/error.pyrszDraftFDWarning.__init__)r__name__ __module__ __qualname____doc__r __classcell__r r r rr rc@eZdZdZdS) ZMQBaseErrorz.Base exception class for 0MQ errors in Python.Nrrrrr r r rrrc@sFeZdZUdZdZded<ded<ddd d Zdd d ZdddZdS)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 | Noneerrnostrstrerrorr str | NonecCsnddlm}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)r zmq_errnoN) zmq.backendrr isinstanceintrr)r rr rr r r rr-s    zZMQError.__init__returncCs|jSN)rr r r r__str__MszZMQError.__str__cCs|jjdt|dS)Nz(''))r rrr&r r r__repr__PszZMQError.__repr__)NN)rrr r)r$r) rrrrr__annotations__rr'r)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+Trr+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,]rr,cr)ContextTerminatedz6Wrapper for zmq.ETERM .. versionadded:: 13.0 ignoredcddlm}t|dS)Nr)ETERM)zmqr0rr)r rr r0r r rrl zContextTerminated.__init__r.r.rr r r rr-frr-cr)Againz7Wrapper for zmq.EAGAIN .. versionadded:: 13.0 r.cr/)Nr)EAGAIN)r1r5rr)r rr r5r r rrxr2zAgain.__init__r3rr r r rr4rrr4cs<eZdZUdZeZded<d fdd ZfddZZ 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 rrr.csttdSr%)rrr)r rr r r rrzInterruptedSystemCall.__init__cst}|dS)NzB: This call should have been retried. Please report this to pyzmq.)rr')r sr r rr's zInterruptedSystemCall.__str__r3) rrrrrrr*rr'rr r r rr6~s r6NTcCs~|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 )r5r0) r!r r1r5r0rr6r4r-r)rcrerror_without_errnor r5r0r r r _check_rcs  r<c@s0eZdZdZdZd dddZd d Zd d ZdS)ZMQVersionErrorzgRaised when a feature is not provided by the linked version of libzmq. .. versionadded:: 14.2 NFeature min_versionrr cCs0tdur ddlm}|a||_||_t|_dS)Nr) zmq_version) _zmq_versionr1r@r r?version)r r?r r@r r rrs   zZMQVersionError.__init__cCsdt|dS)NzZMQVersionError('r(rr&r r rr)r7zZMQVersionError.__repr__cCs|jd|jd|jS)Nz requires libzmq >= z, have )r r?rBr&r r rr'szZMQVersionError.__str__r>)r?rr r)rrrrr?rr)r'r r r rr=s   r=r>min_version_info3tuple[int] | tuple[int, int] | tuple[int, int, int]r rcCsDtdur 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|VqdSr%rC).0vr r r sz!_check_version..)_zmq_version_infor1rGjoinr=)rEr rGr?r r r_check_versions  rN) rrr+rr,r-r6r4r=)NTrD)rErFr r)r __future__rrrRuntimeWarningr Exceptionrrr+r,r-r4InterruptedErrorr6r<rLrANotImplementedErrorr=rN__all__r r r rs$  6