MhIDdZddlmZddlmZGddeZGddeZGdd eZ Gd d eZ Gd d eZ Gdde Z Gdde Z Gdde eZd dZdadaGddeZ d!d"dZgdZdS)#z 0MQ Error classes and functions.) annotations)EINTRc$eZdZdZdfd ZxZS)DraftFDWarningzRWarning for using experimental FD on draft sockets. .. versionadded:: 27 cR|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__s I/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/zmq/error.pyr zDraftFDWarning.__init__s6 q  )r__name__ __module__ __qualname____doc__r __classcell__r s@rrr sG rrceZdZdZdS) ZMQBaseErrorz.Base exception class for 0MQ errors in Python.Nrrrrrrrrs8888rrcFeZdZUdZdZded<ded<d dd Zdd Zdd ZdS)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 | Nonecddlm}m}| |}t|tr$||_||||_dS||_dS|t ||_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.backendr r# isinstanceintrr)r rr r r#s rr zZMQError.__init__-s 43333333 =IKKE eS ! ! $DJ{ ( # { #E  # rreturnc|jSN)r r s r__str__zZMQError.__str__Ms }rc@|jjdt|dS)Nz(''))r rrr*s r__repr__zZMQError.__repr__Ps$.)::SYY::::r)NN)rrr r!)r'r) rrrrr__annotations__r r+r.rrrrrs~  EMMM$$$$$@;;;;;;rrceZdZdZdS) ZMQBindErrorznAn error for ``Socket.bind_to_random_port()``. See Also -------- .Socket.bind_to_random_port Nrrrrr1r1Trr1ceZdZdZdS)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 Nrrrrr4r4]r2rr4c$eZdZdZdfd ZxZS)ContextTerminatedz6Wrapper for zmq.ETERM .. versionadded:: 13.0 ignoredcVddlm}t|dS)Nr)ETERM)zmqr9r r )r rr r9r s rr zContextTerminated.__init__ls3 rr7r7rrs@rr6r6fsG           rr6c$eZdZdZdfd ZxZS)Againz7Wrapper for zmq.EAGAIN .. versionadded:: 13.0 r7cVddlm}t|dS)Nr)EAGAIN)r:r?r r )r rr r?r s rr zAgain.__init__xs3      rr;rrs@rr=r=rsG !!!!!!!!!!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 r7cTttdSr))r r r)r rr r s rr zInterruptedSystemCall.__init__s! rcNt}|dzS)NzB: This call should have been retried. Please report this to pyzmq.)r r+)r sr s rr+zInterruptedSystemCall.__str__s" GGOO  WWWrr;) rrrrrrr/r r+rrs@rrArA~s{ EMMM      XXXXXXXXXrrANTc|dkrw|ddlm}|}|dkr|sdSddlm}m}|t krt |||krt|||krt|t|dS)zhinternal utility for checking zmq return condition and raising the appropriate Exception class Nr)r#)r?r9) r$r#r:r?r9rrAr=r6r)rcrerror_without_errnor#r?r9s r _check_rcrIs  Rxx = - - - - - -IKKE A::1: F%%%%%%%% E>>'.. . f__,,  e^^#E** *5// !!xrc,eZdZdZdZd d dZdZd ZdS) ZMQVersionErrorzgRaised when a feature is not provided by the linked version of libzmq. .. versionadded:: 14.2 NFeature min_versionrr chtddlm}|a||_||_t|_dS)Nr) zmq_version) _zmq_versionr:rOr rMversion)r rMr rOs rr zZMQVersionError.__init__s?   ' ' ' ' ' '&;==L&# rc(dt|dS)NzZMQVersionError('r-rr*s rr.zZMQVersionError.__repr__s03t990000rc4|jd|jd|jS)Nz requires libzmq >= z, have )r rMrQr*s rr+zZMQVersionError.__str__s%(WW0@WWWWWrrL)rMrr r)rrrrrMr r.r+rrrrKrKsa K$$$$$111XXXXXrrKrLmin_version_info3tuple[int] | tuple[int, int] | tuple[int, int, int]r rctddlm}|at|kr/dd|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.c34K|]}t|VdSr)rS).0vs r z!_check_version..s(@@!s1vv@@@@@@r)_zmq_version_infor:rYjoinrK)rVr rYrMs r_check_versionrasp ((((((,,..+++hh@@/?@@@@@ k3///,+r) rrr1rr4r6rAr=rK)NTrU)rVrWr r)r __future__rrrRuntimeWarningr Exceptionrrr1r4r6r=InterruptedErrorrArIr_rPNotImplementedErrorrKra__all__rrrrhs&&#"""""     ^    9999999993;3;3;3;3;|3;3;3;l<l           ! ! ! ! !H ! ! !XXXXXH&6XXX(""""0 XXXXX)XXX600000(   r