PhIdZddlmZddlmZGddeZGddeZGdd eZ Gd d eZ Gd d eZ Gdde Z Gdde Z Gdde eZddZdadaGddeZ d ddZgdZy)z 0MQ Error classes and functions.) annotations)EINTRc$eZdZdZdfd 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 C/var/www/html/saasai/venv/lib/python3.12/site-packages/zmq/error.pyr zDraftFDWarning.__init__s q  )__name__ __module__ __qualname____doc__r __classcell__r s@r rr s rrceZdZdZy) ZMQBaseErrorz.Base exception class for 0MQ errors in Python.Nrrrrrr rrs8rrcDeZdZUdZdZded<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 | Noneerrnostrstrerrorcddlm}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" isinstanceintrr)r rr r r"s r r zZMQError.__init__-sR 4 =KE eS !DJ{ ( # { #E  # rc|jSN)r r s r __str__zZMQError.__str__Ms }}rcL|jjdt|dS)Nz(''))r rrr(s r __repr__zZMQError.__repr__Ps$..))*"SYKr::r)NN)rrr z str | None)returnr) rrrrr__annotations__r r)r,rrr rrs( E:M$@;rrceZdZdZy) ZMQBindErrorznAn error for ``Socket.bind_to_random_port()``. See Also -------- .Socket.bind_to_random_port Nrrrr r0r0Trr0ceZdZdZy)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 Nrrrr r3r3]r1rr3c$eZdZdZdfd ZxZS)ContextTerminatedz6Wrapper for zmq.ETERM .. versionadded:: 13.0 c0ddlm}t| |y)Nr)ETERM)zmqr7rr )r rr r7r s r r zContextTerminated.__init__ls rignoredr:rrs@r r5r5fs   rr5c$eZdZdZdfd ZxZS)Againz7Wrapper for zmq.EAGAIN .. versionadded:: 13.0 c0ddlm}t| |y)Nr)EAGAIN)r8r>rr )r rr r>r s r r zAgain.__init__xs  rr9rrs@r r<r<rs !!rr<c>eZdZUdZeZded<dfd ZfdZxZ 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')rr r)r rr r s r r zInterruptedSystemCall.__init__s rc*t|}|dzS)NzB: This call should have been retried. Please report this to pyzmq.)rr))r sr s r r)zInterruptedSystemCall.__str__s GO WWWrr9) rrrrrrr.r r)rrs@r r@r@~s% EM XXrr@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>r7) r#r"r8r>r7rr@r<r5r)rcrerror_without_errnor"r>r7s r _check_rcrHsn  Rx = -KE A:1 % E>'. . f_,  e^#E* *5/ !!rc*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_versionr8rLr min_versionversion)r rNr rLs r r zZMQVersionError.__init__s(   '&=L&# rc dt|dS)NzZMQVersionError('r+rr(s r r,zZMQVersionError.__repr__s"3t9+R00rcR|jd|jd|jS)Nz requires libzmq >= z, have )r rNrOr(s r r)zZMQVersionError.__str__s)((/0@0@/AWWrFeature)rNrr r)rrrrrNr r,r)rrr rJrJs K$1XrrJct 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'rQ).0vs r z!_check_version..s@/?!s1v/?s)_zmq_version_infor8rVjoinrJ)min_version_infor rVrNs r _check_versionr_sF (,.++hh@/?@@ k3//,r) rrr0rr3r5r@r<rJ)NTrS)r^z3tuple[int] | tuple[int, int] | tuple[int, int, int]r r)r __future__rrrRuntimeWarningr Exceptionrrr0r3r5r<InterruptedErrorr@rHr\rMNotImplementedErrorrJr___all__rrr rfs&# ^  9993;|3;l<l     !H !XH&6X("0 X)X60I0 0( r