fdZddlmZddlmZGddeZGddeZGdd eZGd d eZ Gd d eZ GddeZ Gddee Z ddZdadaGddeZ d ddZgdZy)z 0MQ Error classes and functions.) annotations)EINTRceZdZdZy) ZMQBaseErrorz.Base exception class for 0MQ errors in Python.N__name__ __module__ __qualname____doc__D/var/www/cvtools/html/venv/lib/python3.12/site-packages/zmq/error.pyrr s8r rc:eZdZUdZdZded<dd dZd dZd dZy) 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 | Noneerrnocddlm}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)selfrmsgrrs r__init__zZMQError.__init__sR 4 =KE eS !DJ{ ( # { #E  # r c|jSN)rrs r__str__zZMQError.__str__<s }}r cL|jjdt|dS)Nz('')) __class__rrrs r__repr__zZMQError.__repr__?s$..))*"SYKr::r )NN)rrrz str | None)returnr) rr r r r__annotations__rr r$r r rrrs# E:$@;r rceZdZdZy) ZMQBindErrorznAn error for ``Socket.bind_to_random_port()``. See Also -------- .Socket.bind_to_random_port Nrr r rr(r(Cr r(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 Nrr r rr+r+Lr)r r+c$eZdZdZdfd ZxZS)ContextTerminatedz6Wrapper for zmq.ETERM .. versionadded:: 13.0 c0ddlm}t| |y)Nr)ETERM)zmqr/superr)rrrr/r#s rrzContextTerminated.__init__[s r ignoredr3rr r r r __classcell__r#s@rr-r-Us   r r-c$eZdZdZdfd ZxZS)Againz7Wrapper for zmq.EAGAIN .. versionadded:: 13.0 c0ddlm}t| |y)Nr)EAGAIN)r0r:r1r)rrrr:r#s rrzAgain.__init__gs  r r2r4r6s@rr8r8as !!r r8c2eZdZdZeZdfd 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 r c*t|}|dzS)NzB: This call should have been retried. Please report this to pyzmq.)r1r )rsr#s rr zInterruptedSystemCall.__str__{s GO WWWr r2) rr r r rrrr r5r6s@rr<r<ms  E XXr r<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/ !!r c*eZdZdZdZdddZdZdZy)ZMQVersionErrorzgRaised when a feature is not provided by the linked version of libzmq. .. versionadded:: 14.2 Nc\t ddlm}|a||_||_t|_y)Nr) zmq_version) _zmq_versionr0rHr min_versionversion)rrJrrHs rrzZMQVersionError.__init__s(   '&=L&# r c dt|dS)NzZMQVersionError('r"rrs rr$zZMQVersionError.__repr__s"3t9+R00r cR|jd|jd|jS)Nz requires libzmq >= z, have )rrJrKrs rr zZMQVersionError.__str__s)((/0@0@/AWWr Feature)rJrrr)rr r r rJrr$r r r rrFrFs K$1Xr rFct 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|ywrrM).0vs r z!_check_version..s@!s1v@s)_zmq_version_infor0rRjoinrF)min_version_inforrRrJs r_check_versionr[sF (,.++hh@/?@@ k3//,r )rr(rr+r-r<r8rF)NTrO)rZz3tuple[int] | tuple[int, int] | tuple[int, int, int]rr)r __future__rrr Exceptionrrr(r+r-r8InterruptedErrorr<rDrXrINotImplementedErrorrFr[__all__r r rras&#9992;|2;j<l     !H !XH&6X&"0 X)X60I0 0( r